Fix: DefaultClient to custom

Author: aopoltorzhicky

hasura/api.go

@@ -6,6 +6,7 @@ import (
 	"net/http"
 	"net/url"
 	"path"
+	"time"
 
 	jsoniter "github.com/json-iterator/go"
 
@@ -19,12 +20,20 @@ type API struct {
 	baseURL string
 	secret  string
 
-	client http.Client
+	client *http.Client
 }
 
 // New -
 func New(baseURL, secret string) *API {
-	return &API{baseURL, secret, *http.DefaultClient}
+	t := http.DefaultTransport.(*http.Transport).Clone()
+	t.MaxIdleConns = 100
+	t.MaxConnsPerHost = 100
+	t.MaxIdleConnsPerHost = 100
+
+	return &API{baseURL, secret, &http.Client{
+		Timeout:   time.Minute,
+		Transport: t,
+	}}
 }
 
 func (api *API) buildURL(endpoint string, args map[string]string) (string, error) {

node/node.go

@@ -9,6 +9,7 @@ import (
 	"net/url"
 	"path"
 	"strings"
+	"time"
 
 	jsoniter "github.com/json-iterator/go"
 	"github.com/pkg/errors"
@@ -19,12 +20,22 @@ var json = jsoniter.ConfigCompatibleWithStandardLibrary
 // NodeRPC -
 type NodeRPC struct {
 	baseURL string
+	client  *http.Client
 }
 
 // NewNodeRPC -
 func NewNodeRPC(baseURL string) *NodeRPC {
+	t := http.DefaultTransport.(*http.Transport).Clone()
+	t.MaxIdleConns = 100
+	t.MaxConnsPerHost = 100
+	t.MaxIdleConnsPerHost = 100
+
 	return &NodeRPC{
 		baseURL: strings.TrimSuffix(baseURL, "/"),
+		client: &http.Client{
+			Timeout:   time.Second * 15,
+			Transport: t,
+		},
 	}
 }
 
@@ -75,7 +86,7 @@ func (rpc *NodeRPC) makeRequest(method, uri string, queryArgs url.Values, body i
 	if err != nil {
 		return nil, errors.Errorf("makeGetRequest.NewRequest: %v", err)
 	}
-	return http.DefaultClient.Do(req)
+	return rpc.client.Do(req)
 }
 
 //nolint

tzkt/api/api.go

@@ -9,6 +9,7 @@ import (
 	"net/url"
 	"path"
 	"strconv"
+	"time"
 
 	jsoniter "github.com/json-iterator/go"
 	"github.com/pkg/errors"
@@ -24,9 +25,17 @@ type API struct {
 
 // New -
 func New(baseURL string) *API {
+	t := http.DefaultTransport.(*http.Transport).Clone()
+	t.MaxIdleConns = 100
+	t.MaxConnsPerHost = 100
+	t.MaxIdleConnsPerHost = 100
+
 	return &API{
-		url:    baseURL,
-		client: http.DefaultClient,
+		url: baseURL,
+		client: &http.Client{
+			Timeout:   time.Minute,
+			Transport: t,
+		},
 	}
 }
 

tzkt/events/signalr/transport.go

@@ -3,6 +3,7 @@ package signalr
 import (
 	"net/http"
 	"net/url"
+	"time"
 
 	"github.com/rs/zerolog/log"
 
@@ -20,13 +21,23 @@ const (
 
 // Transport -
 type Transport struct {
-	url string
+	url    string
+	client *http.Client
 }
 
 // NewTransport -
 func NewTransport(baseURL string) *Transport {
+	t := http.DefaultTransport.(*http.Transport).Clone()
+	t.MaxIdleConns = 100
+	t.MaxConnsPerHost = 100
+	t.MaxIdleConnsPerHost = 100
+
 	return &Transport{
 		url: baseURL,
+		client: &http.Client{
+			Timeout:   time.Minute,
+			Transport: t,
+		},
 	}
 }
 
@@ -48,7 +59,7 @@ func (t *Transport) Negotiate(version Version) (response NegotiateResponse, err
 		return
 	}
 
-	resp, err := http.DefaultClient.Do(req)
+	resp, err := t.client.Do(req)
 	if err != nil {
 		return
 	}