solr.*Client.Initialize - Code Metrics - Inspection of "adição de autenticação por modo basic authenticati..." - adrianolaselva/solr-client-go - Measure and Improve Code Quality continuously with Scrutinizer

Test Setup Failed

Push — master ( 18d1be...9c409f )

by Adriano

created 2020-05-02 13:22 UTC

solr.*Client.Initialize A

↳ Parent: solr/client.go

Complexity

Conditions

Size

Total Lines	5
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	5
nop	0
dl	0
loc	5
rs	10
c	0
b	0
f	0

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
	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
}

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{}) (*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			onRequestCompleted RequestCompletionCallback
23			username string
24			password string
25			}
26
27			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...
28
29			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...
30
31			httpClient := http.DefaultClient
32			baseURL, _ := url.Parse(DefaultHost)
33
34			client := Client{
35			client: httpClient,
36			baseURL: baseURL,
37			}
38
39			client.Initialize()
40
41			return client
42			}
43
44			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...
45			document := DocumentAPI{client: c}
46			c.Document = document
47			collection := CollectionAPI{client: c}
48			c.Collection = collection
49			}
50
51			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...
52			c.client = httpClient
53			c.Initialize()
54			return c
55			}
56
57			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...
58			c.username = username
59			c.password = password
60			c.Initialize()
61			return c
62			}
63
64			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...
65			c.baseURL, _ = url.Parse(baseURL)
66			c.Initialize()
67			return c
68			}
69
70			func (c Client) NewRequest(ctx context.Context, method, urlStr string, body interface{}, queryStrings interface{}) (http.Request, error) {
			1 ignored issue – show introduced 2020-05-01 14:27 UTC by Report Bug Copy Issue Report exported method Client.NewRequest should have comment or be unexported Loading history...
71			u, err := c.baseURL.Parse(urlStr)
72			if err != nil {
73			return nil, err
74			}
75
76			buf := new(bytes.Buffer)
77			if body != nil {
78			err = json.NewEncoder(buf).Encode(body)
79			if err != nil {
80			return nil, err
81			}
82			}
83
84			params, _ := query.Values(queryStrings)
85			u.RawQuery = params.Encode()
86
87			req, err := http.NewRequest(method, u.String(), buf)
88			if err != nil {
89			return nil, err
90			}
91
92			req.Header.Add("Content-Type", DefaultContentType)
93			req.Header.Add("Accept", DefaultContentType)
94
95			if c.username != "" && c.password != "" {
96			req.SetBasicAuth(c.username, c.password)
97			}
98
99			return req, nil
100			}
101
102			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...
103			req = req.WithContext(ctx)
104			resp, err := c.client.Do(req)
105			if err != nil {
106			return nil, err
107			}
108			if c.onRequestCompleted != nil {
109			c.onRequestCompleted(req, resp)
110			}
111
112			defer func() {
113			if rerr := resp.Body.Close(); err == nil {
114			err = rerr
115			}
116			}()
117
118			response := Response{HttpResponse: resp}
119
120			err = json.NewDecoder(resp.Body).Decode(&response)
121			if err != nil {
122			return nil, err
123			}
124
125			return &response, nil
126			}
127
128			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...
129			c.onRequestCompleted = rc
130			}

adrianolaselva / solr-client-go

Push — master ( 18d1be...9c409f )

solr.*Client.Initialize A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like