solr/client.go - Code Metrics - Inspection of "Integração com apis de configurações" - adrianolaselva/solr-client-go - Measure and Improve Code Quality continuously with Scrutinizer

Test Setup Failed

Pull Request — master (#2)

by Adriano

created 2020-05-08 16:25 UTC

solr/client.go A

↳ Parent: Project

Size/Duplication

Total Lines	170
Duplicated Lines	0 %

Importance

Changes

Metric	Value
cc	28
eloc	106
dl	0
loc	170
rs	10
c	0
b	0
f	0

9 Methods

Rating	Name	Size	Complexity
A	solr.*Client.OnRequestCompleted	2	1
A	solr.*Client.SetBasicAuth	5	1
C	solr.*Client.NewRequest	36	9
B	solr.*Client.Do	24	6
A	solr.*Client.Initialize	7	1
A	solr.*Client.SetHttpClient	4	1
A	solr.*Client.SetBaseURL	4	1
B	solr.*Client.NewRequestUpload	30	7
A	solr.NewClient	13	1

package solr

import (
	"bytes"
	"context"
	"encoding/json"
	"github.com/google/go-querystring/query"
	"net/http"
	"net/url"
)

const (
	DefaultHost = "http://127.0.0.1:8983"

	DefaultContentType = "application/json"
)

type Client struct {

	client 				*http.Client
	baseURL 			*url.URL
	Document 			DocumentAPI
	Collection 			CollectionAPI
	Config 				ConfigAPI
	onRequestCompleted 	RequestCompletionCallback
	username			string
	password			string
}

type RequestCompletionCallback func(*http.Request, *http.Response)


func NewClient() Client {


	httpClient := http.DefaultClient
	baseURL, _ := url.Parse(DefaultHost)
	
	client := Client{
		client:             httpClient,
		baseURL:            baseURL,
	}

	client.Initialize()

	return client
}

func (c *Client) Initialize() {

	document := DocumentAPI{client: c}
	c.Document = document
	collection := CollectionAPI{client: c}
	c.Collection = collection
	config := ConfigAPI{client: c}
	c.Config = config
}

func (c *Client) SetHttpClient(httpClient *http.Client) *Client {

	c.client = httpClient
	c.Initialize()
	return c
}

func (c *Client) SetBasicAuth(username string, password string) *Client {

	c.username = username
	c.password = password
	c.Initialize()
	return c
}

func (c *Client) SetBaseURL(baseURL string) *Client{

	c.baseURL, _ = url.Parse(baseURL)
	c.Initialize()
	return c
}

func (c *Client) NewRequest(ctx context.Context, method, urlStr string, body interface{}, queryStrings interface{}, headers *map[string]string) (*http.Request, error) {

	u, err := c.baseURL.Parse(urlStr)
	if err != nil {
		return nil, err
	}

	buf := new(bytes.Buffer)
	if body != nil {
		err = json.NewEncoder(buf).Encode(body)
		if err != nil {
			return nil, err
		}
	}

	params, _ := query.Values(queryStrings)
	u.RawQuery = params.Encode()

	req, err := http.NewRequest(method, u.String(), buf)
	if err != nil {
		return nil, err
	}

	req.Header.Add("Content-Type", DefaultContentType)
	req.Header.Add("Accept", DefaultContentType)

	if headers != nil {
		for key, value := range *headers {
			req.Header.Set(key, value)
		}
	}

	if c.username != "" && c.password != "" {
		req.SetBasicAuth(c.username, c.password)
	}

	return req, nil
}

func (c *Client) NewRequestUpload(ctx context.Context, method, urlStr string, body interface{}, queryStrings interface{}) (*http.Request, error) {

	u, err := c.baseURL.Parse(urlStr)
	if err != nil {
		return nil, err
	}

	buf := new(bytes.Buffer)
	if body != nil {
		err = json.NewEncoder(buf).Encode(body)
		if err != nil {
			return nil, err
		}
	}

	params, _ := query.Values(queryStrings)
	u.RawQuery = params.Encode()

	req, err := http.NewRequest(method, u.String(), buf)
	if err != nil {
		return nil, err
	}

	req.Header.Add("Content-Type", DefaultContentType)
	req.Header.Add("Accept", DefaultContentType)

	if c.username != "" && c.password != "" {
		req.SetBasicAuth(c.username, c.password)
	}

	return req, nil
}

func (c *Client) Do(ctx context.Context, req *http.Request) (*Response, error) {

	req = req.WithContext(ctx)
	resp, err := c.client.Do(req)
	if err != nil {
		return nil, err
	}
	if c.onRequestCompleted != nil {
		c.onRequestCompleted(req, resp)
	}

	defer func() {
		if rerr := resp.Body.Close(); err == nil {
			err = rerr
		}
	}()

	response := Response{HttpResponse: resp}

	err = json.NewDecoder(resp.Body).Decode(&response)
	if err != nil {
		return nil, err
	}

	return &response, nil
}

func (c *Client) OnRequestCompleted(rc RequestCompletionCallback) {

	c.onRequestCompleted = rc
}

1			package solr
2
3			import (
4			"bytes"
5			"context"
6			"encoding/json"
7			"github.com/google/go-querystring/query"
8			"net/http"
9			"net/url"
10			)
11
12			const (
13			DefaultHost = "http://127.0.0.1:8983"
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported const DefaultHost should have comment (or a comment on this block) or be unexported Loading history...
14			DefaultContentType = "application/json"
15			)
16
17			type Client struct {
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported type Client should have comment or be unexported Loading history...
18			client *http.Client
19			baseURL *url.URL
20			Document DocumentAPI
21			Collection CollectionAPI
22			Config ConfigAPI
23			onRequestCompleted RequestCompletionCallback
24			username string
25			password string
26			}
27
28			type RequestCompletionCallback func(http.Request, http.Response)
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported type RequestCompletionCallback should have comment or be unexported Loading history...
29
30			func NewClient() Client {
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported function NewClient should have comment or be unexported Loading history...
31
32			httpClient := http.DefaultClient
33			baseURL, _ := url.Parse(DefaultHost)
34
35			client := Client{
36			client: httpClient,
37			baseURL: baseURL,
38			}
39
40			client.Initialize()
41
42			return client
43			}
44
45			func (c *Client) Initialize() {
			1 ignored issue – show introduced 2020-05-02 13:24 UTC by Report Bug Copy Issue Report exported method Client.Initialize should have comment or be unexported Loading history...
46			document := DocumentAPI{client: c}
47			c.Document = document
48			collection := CollectionAPI{client: c}
49			c.Collection = collection
50			config := ConfigAPI{client: c}
51			c.Config = config
52			}
53
54			func (c Client) SetHttpClient(httpClient http.Client) *Client {
			2 ignored issues – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported method Client.SetHttpClient should have comment or be unexported Loading history... introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report method SetHttpClient should be SetHTTPClient Loading history...
55			c.client = httpClient
56			c.Initialize()
57			return c
58			}
59
60			func (c Client) SetBasicAuth(username string, password string) Client {
			1 ignored issue – show introduced 2020-05-02 13:24 UTC by Report Bug Copy Issue Report exported method Client.SetBasicAuth should have comment or be unexported Loading history...
61			c.username = username
62			c.password = password
63			c.Initialize()
64			return c
65			}
66
67			func (c Client) SetBaseURL(baseURL string) Client{
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported method Client.SetBaseURL should have comment or be unexported Loading history...
68			c.baseURL, _ = url.Parse(baseURL)
69			c.Initialize()
70			return c
71			}
72
73			func (c Client) NewRequest(ctx context.Context, method, urlStr string, body interface{}, queryStrings interface{}, headers map[string]string) (*http.Request, error) {
			1 ignored issue – show introduced 2020-05-08 16:27 UTC by Report Bug Copy Issue Report exported method Client.NewRequest should have comment or be unexported Loading history...
74			u, err := c.baseURL.Parse(urlStr)
75			if err != nil {
76			return nil, err
77			}
78
79			buf := new(bytes.Buffer)
80			if body != nil {
81			err = json.NewEncoder(buf).Encode(body)
82			if err != nil {
83			return nil, err
84			}
85			}
86
87			params, _ := query.Values(queryStrings)
88			u.RawQuery = params.Encode()
89
90			req, err := http.NewRequest(method, u.String(), buf)
91			if err != nil {
92			return nil, err
93			}
94
95			req.Header.Add("Content-Type", DefaultContentType)
96			req.Header.Add("Accept", DefaultContentType)
97
98			if headers != nil {
99			for key, value := range *headers {
100			req.Header.Set(key, value)
101			}
102			}
103
104			if c.username != "" && c.password != "" {
105			req.SetBasicAuth(c.username, c.password)
106			}
107
108			return req, nil
109			}
110
111			func (c Client) NewRequestUpload(ctx context.Context, method, urlStr string, body interface{}, queryStrings interface{}) (http.Request, error) {
			1 ignored issue – show introduced 2020-05-08 16:27 UTC by Report Bug Copy Issue Report exported method Client.NewRequestUpload should have comment or be unexported Loading history...
112			u, err := c.baseURL.Parse(urlStr)
113			if err != nil {
114			return nil, err
115			}
116
117			buf := new(bytes.Buffer)
118			if body != nil {
119			err = json.NewEncoder(buf).Encode(body)
120			if err != nil {
121			return nil, err
122			}
123			}
124
125			params, _ := query.Values(queryStrings)
126			u.RawQuery = params.Encode()
127
128			req, err := http.NewRequest(method, u.String(), buf)
129			if err != nil {
130			return nil, err
131			}
132
133			req.Header.Add("Content-Type", DefaultContentType)
134			req.Header.Add("Accept", DefaultContentType)
135
136			if c.username != "" && c.password != "" {
137			req.SetBasicAuth(c.username, c.password)
138			}
139
140			return req, nil
141			}
142
143			func (c Client) Do(ctx context.Context, req http.Request) (*Response, error) {
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported method Client.Do should have comment or be unexported Loading history...
144			req = req.WithContext(ctx)
145			resp, err := c.client.Do(req)
146			if err != nil {
147			return nil, err
148			}
149			if c.onRequestCompleted != nil {
150			c.onRequestCompleted(req, resp)
151			}
152
153			defer func() {
154			if rerr := resp.Body.Close(); err == nil {
155			err = rerr
156			}
157			}()
158
159			response := Response{HttpResponse: resp}
160
161			err = json.NewDecoder(resp.Body).Decode(&response)
162			if err != nil {
163			return nil, err
164			}
165
166			return &response, nil
167			}
168
169			func (c *Client) OnRequestCompleted(rc RequestCompletionCallback) {
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported method Client.OnRequestCompleted should have comment or be unexported Loading history...
170			c.onRequestCompleted = rc
171			}

adrianolaselva / solr-client-go

Pull Request — master (#2)

solr/client.go A

Size/Duplication

Importance

9 Methods

Duplication Side-by-Side

Filter issues like