Format code

cmd/isolatedmarginclientexample/isolatedmarginclientexample.go

@@ -68,8 +68,8 @@ func marginOrders() {
 	client := new(client.IsolatedMarginClient).Init(config.AccessKey, config.SecretKey, config.Host)
 	request := postrequest.IsolatedMarginOrdersRequest{
 		Currency: "eos",
-		Amount: "0.001",
-		Symbol: "eosht",
+		Amount:   "0.001",
+		Symbol:   "eosht",
 	}
 	resp, err := client.Apply(request)
 	if err != nil {

cmd/main.go

@@ -34,7 +34,6 @@ func runAll() {
 	orderwebsocketclientexample.RunAllExamples()
 }
 
-
 // Run performance test
 func perfTest() {
 	logging.EnablePerformanceLog(true)
@@ -47,4 +46,4 @@ func perfTest() {
 	crossmarginclientexample.RunAllExamples()
 	walletclientexample.RunAllExamples()
 	etfclientexample.RunAllExamples()
-}
+}

cmd/marketwebsocketclientexample/marketwebsocketclientexample.go

@@ -106,14 +106,14 @@ func reqAndSubscribeDepth() {
 					if depthResponse.Tick != nil {
 						if depthResponse.Tick.Asks != nil {
 							a := depthResponse.Tick.Asks
-							for i := len(a)-1; i >= 0; i-- {
+							for i := len(a) - 1; i >= 0; i-- {
 								fmt.Printf("%v - %v\n", a[i][0], a[i][1])
 							}
 						}
 						fmt.Println("---ask-bid-update--")
 						if depthResponse.Tick.Bids != nil {
 							b := depthResponse.Tick.Bids
-							for i:= 0; i < len(b); i++ {
+							for i := 0; i < len(b); i++ {
 								fmt.Printf("%v - %v\n", b[i][0], b[i][1])
 							}
 						}
@@ -123,14 +123,14 @@ func reqAndSubscribeDepth() {
 					if depthResponse.Data != nil {
 						if depthResponse.Data.Asks != nil {
 							a := depthResponse.Data.Asks
-							for i := len(a)-1; i >= 0; i-- {
+							for i := len(a) - 1; i >= 0; i-- {
 								fmt.Printf("%v - %v\n", a[i][0], a[i][1])
 							}
 						}
 						fmt.Println("---ask-bid-data--")
 						if depthResponse.Data.Bids != nil {
 							b := depthResponse.Data.Bids
-							for i:= 0; i < len(b); i++ {
+							for i := 0; i < len(b); i++ {
 								fmt.Printf("%v - %v\n", b[i][0], b[i][1])
 							}
 						}
@@ -189,13 +189,13 @@ func reqAndSubscribeMarketByPrice() {
 						t := depthResponse.Tick
 						fmt.Printf("MBP prevSeqNum: %d, seqNum: %d\n", t.PrevSeqNum, t.SeqNum)
 						if t.Asks != nil {
-							for i := len(t.Asks)-1; i >= 0; i-- {
+							for i := len(t.Asks) - 1; i >= 0; i-- {
 								fmt.Printf("%v - %v\n", t.Asks[i][0], t.Asks[i][1])
 							}
 						}
 						fmt.Println("---MBP-update--")
 						if t.Bids != nil {
-							for i:= 0; i < len(t.Bids); i++ {
+							for i := 0; i < len(t.Bids); i++ {
 								fmt.Printf("%v - %v\n", t.Bids[i][0], t.Bids[i][1])
 							}
 						}
@@ -207,14 +207,14 @@ func reqAndSubscribeMarketByPrice() {
 						fmt.Printf("MBP prevSeqNum: %d, seqNum: %d\n", d.PrevSeqNum, d.SeqNum)
 						if d.Asks != nil {
 							a := d.Asks
-							for i := len(a)-1; i >= 0; i-- {
+							for i := len(a) - 1; i >= 0; i-- {
 								fmt.Printf("%v - %v\n", a[i][0], a[i][1])
 							}
 						}
 						fmt.Println("---MBP-data--")
 						if depthResponse.Data.Bids != nil {
 							b := depthResponse.Data.Bids
-							for i:= 0; i < len(b); i++ {
+							for i := 0; i < len(b); i++ {
 								fmt.Printf("%v - %v\n", b[i][0], b[i][1])
 							}
 						}
@@ -381,13 +381,13 @@ func reqAndSubscribeLast24hCandlestick() {
 
 					if candlestickResponse.Data != nil {
 						t := candlestickResponse.Data
-							fmt.Printf("Candlestick data, id: %d, count: %v, volume: %v [%v-%v-%v-%v]\n",
-								t.Id, t.Count, t.Vol, t.Open, t.Close, t.Low, t.High)
-						}
+						fmt.Printf("Candlestick data, id: %d, count: %v, volume: %v [%v-%v-%v-%v]\n",
+							t.Id, t.Count, t.Vol, t.Open, t.Close, t.Low, t.High)
 					}
-				} else {
-					fmt.Printf("Unknown response: %v\n", resp)
 				}
+			} else {
+				fmt.Printf("Unknown response: %v\n", resp)
+			}
 
 		})
 

cmd/orderclientexample/orderclientexample.go

@@ -298,7 +298,6 @@ func getLast48hOrders() {
 	}
 }
 
-
 func getMatchResultByCriteria() {
 	client := new(client.OrderClient).Init(config.AccessKey, config.SecretKey, config.Host)
 	request := new(getrequest.GetRequest).Init()
@@ -342,4 +341,4 @@ func getTransactFeeRate() {
 			fmt.Printf("Get fee error: %s\n", resp.Message)
 		}
 	}
-}
+}

cmd/orderwebsocketclientexample/orderwebsocketclientexample.go

@@ -65,9 +65,9 @@ func reqOrdersV1() {
 		func(resp *model.WebSocketV1AuthenticationResponse) {
 			if resp.ErrorCode == 0 {
 				req := getrequest.RequestOrdersRequest{
-					AccountId:11136102,
-					Symbol:"btcusdt",
-					States:"submitted, created, canceled",
+					AccountId: 11136102,
+					Symbol:    "btcusdt",
+					States:    "submitted, created, canceled",
 				}
 				err := client.Request(req)
 				if err != nil {

internal/gzip/gzipdecompresser.go

@@ -42,4 +42,4 @@ func GZipCompress(input string) ([]byte, error) {
 	}
 
 	return buf.Bytes(), nil
-}
+}

internal/gzip/gzipdecompresser_test.go

@@ -11,4 +11,4 @@ func Test_Decompress_Success(t *testing.T) {
 	if result != expected {
 		t.Errorf("expected: %s, actual: %s", expected, result)
 	}
-}
+}

internal/httprequest.go

@@ -37,4 +37,4 @@ func HttpPost(url string, body string) (string, error) {
 	logger.StopAndLog("POST", url)
 
 	return string(result), err
-}
+}

internal/model/pingmessage.go

@@ -14,4 +14,4 @@ func ParsePingMessage(message string) *PingMessage {
 	}
 
 	return &result
-}
+}

internal/model/websocketv1authenticationresponse.go

@@ -3,10 +3,10 @@ package model
 import "encoding/json"
 
 type WebSocketV1AuthenticationResponse struct {
-	Op string `json:"op"`
-	Timestamp int64 `json:"ts"`
-	ErrorCode int `json:"err-code"`
-	Data *struct {
+	Op        string `json:"op"`
+	Timestamp int64  `json:"ts"`
+	ErrorCode int    `json:"err-code"`
+	Data      *struct {
 		UserId int `json:"user-id"`
 	}
 }
@@ -23,4 +23,4 @@ func ParseWSV1AuthResp(message string) *WebSocketV1AuthenticationResponse {
 	}
 
 	return result
-}
+}

internal/model/websocketv2authenticationresponse.go

@@ -4,9 +4,9 @@ import "encoding/json"
 
 type WebSocketV2AuthenticationResponse struct {
 	Action string `json:"action"`
-	Ch string `json:"ch"`
-	Code int `json:"code"`
-	Data interface{}
+	Ch     string `json:"ch"`
+	Code   int    `json:"code"`
+	Data   interface{}
 }
 
 func (p *WebSocketV2AuthenticationResponse) IsAuth() bool {
@@ -21,4 +21,4 @@ func ParseWSV2AuthResp(message string) *WebSocketV2AuthenticationResponse {
 	}
 
 	return result
-}
+}

internal/requestbuilder/privateurlbuilder.go

@@ -8,14 +8,14 @@ import (
 )
 
 type PrivateUrlBuilder struct {
-	host string
-	akKey string
+	host    string
+	akKey   string
 	akValue string
-	smKey string
+	smKey   string
 	smValue string
-	svKey string
+	svKey   string
 	svValue string
-	tKey string
+	tKey    string
 
 	signer *Signer
 }
@@ -54,7 +54,7 @@ func (p *PrivateUrlBuilder) BuildWithTime(method string, path string, utcDate ti
 
 	signature := p.signer.Sign(method, p.host, path, parameters)
 
-	url := fmt.Sprintf("https://%s%s?%s&Signature=%s",p.host, path, parameters, url.QueryEscape(signature))
+	url := fmt.Sprintf("https://%s%s?%s&Signature=%s", p.host, path, parameters, url.QueryEscape(signature))
 
 	return url
-}
+}

internal/requestbuilder/privateurlbuilder_test.go

@@ -8,8 +8,8 @@ import (
 )
 
 func TestPrivateUrlBuilder_Build_NoRequestParameter_Success(t *testing.T) {
-	builder := new(PrivateUrlBuilder).Init("access","secret", "api.huobi.pro")
-	utcDate := time.Date(2019,11,21,10,0,0, 0, time.UTC)
+	builder := new(PrivateUrlBuilder).Init("access", "secret", "api.huobi.pro")
+	utcDate := time.Date(2019, 11, 21, 10, 0, 0, 0, time.UTC)
 
 	result := builder.BuildWithTime("GET", "/v1/account/accounts", utcDate, nil)
 
@@ -20,8 +20,8 @@ func TestPrivateUrlBuilder_Build_NoRequestParameter_Success(t *testing.T) {
 }
 
 func TestPrivateUrlBuilder_Build_HasRequestParameter_Success(t *testing.T) {
-	builder := new(PrivateUrlBuilder).Init("access","secret", "api.huobi.pro")
-	utcDate := time.Date(2019,11,21,10,0,0, 0, time.UTC)
+	builder := new(PrivateUrlBuilder).Init("access", "secret", "api.huobi.pro")
+	utcDate := time.Date(2019, 11, 21, 10, 0, 0, 0, time.UTC)
 	reqParams := new(getrequest.GetRequest).Init()
 	reqParams.AddParam("account-id", "123")
 	reqParams.AddParam("currency", "btc")

internal/requestbuilder/publicurlbuilder.go

@@ -22,4 +22,4 @@ func (p *PublicUrlBuilder) Build(path string, request *getrequest.GetRequest) st
 		result := fmt.Sprintf("https://%s%s", p.host, path)
 		return result
 	}
-}
+}

internal/requestbuilder/signer.go

@@ -17,7 +17,6 @@ func (p *Signer) Init(key string) *Signer {
 	return p
 }
 
-
 func (p *Signer) Sign(method string, host string, path string, parameters string) string {
 	if method == "" || host == "" || path == "" || parameters == "" {
 		return ""
@@ -36,7 +35,7 @@ func (p *Signer) Sign(method string, host string, path string, parameters string
 }
 
 func (p *Signer) sign(payload string) string {
-	p.hash.Write([]byte (payload))
+	p.hash.Write([]byte(payload))
 	result := base64.StdEncoding.EncodeToString(p.hash.Sum(nil))
 	return result
-}
+}

internal/requestbuilder/signer_test.go

@@ -24,4 +24,4 @@ func TestSigner_Sign_OneEmptyString_Success(t *testing.T) {
 	if result != expected {
 		t.Errorf("expected: %s, actual: %s", expected, result)
 	}
-}
+}

logging/performancelogger.go

@@ -78,4 +78,4 @@ func (p *PerformanceLogger) StopAndLog(method string, url string) {
 
 		p.index++
 	}
-}
+}

pkg/client/accountwebsocketclient/requestaccountwebsocketv1client.go

@@ -37,4 +37,4 @@ func (p *RequestAccountWebSocketV1Client) handleMessage(msg string) (interface{}
 	result := account.RequestAccountV1Response{}
 	err := json.Unmarshal([]byte(msg), &result)
 	return result, err
-}
+}

pkg/client/accountwebsocketclient/subscribeaccountwebsocketv1client.go

@@ -44,4 +44,4 @@ func (p *SubscribeAccountWebSocketV1Client) handleMessage(msg string) (interface
 	result := account.SubscribeAccountV1Response{}
 	err := json.Unmarshal([]byte(msg), &result)
 	return result, err
-}
+}

pkg/client/marketwebsocketclient/marketbypricewebsocketclient.go

@@ -47,4 +47,4 @@ func (p *MarketByPriceWebSocketClient) handleMessage(msg string) (interface{}, e
 	result := market.SubscribeMarketByPriceResponse{}
 	err := json.Unmarshal([]byte(msg), &result)
 	return result, err
-}
+}

pkg/client/orderwebsocketclient/subscribeorderwebsocketv2client.go

@@ -42,4 +42,4 @@ func (p *SubscribeOrderWebSocketV2Client) handleMessage(msg string) (interface{}
 	result := &order.SubscribeOrderV2Response{}
 	err := json.Unmarshal([]byte(msg), result)
 	return result, err
-}
+}

pkg/client/websocketclientbase/websocketv2clientbase.go

@@ -20,17 +20,17 @@ type AuthenticationV2ResponseHandler func(resp *model.WebSocketV2AuthenticationR
 
 // The base class that responsible to get data from websocket authentication v2
 type WebSocketV2ClientBase struct {
-	host                     string
-	conn                     *websocket.Conn
+	host string
+	conn *websocket.Conn
 
 	authenticationResponseHandler AuthenticationV2ResponseHandler
 	messageHandler                MessageHandler
 	responseHandler               ResponseHandler
 
-	stopReadChannel          chan int
-	stopTickerChannel        chan int
-	ticker                   *time.Ticker
-	lastReceivedTime         time.Time
+	stopReadChannel   chan int
+	stopTickerChannel chan int
+	ticker            *time.Ticker
+	lastReceivedTime  time.Time
 
 	requestBuilder *requestbuilder.WebSocketV2RequestBuilder
 }

pkg/getrequest/getrequest.go

@@ -36,4 +36,4 @@ func (p *GetRequest) AddParam(property string, value string) *GetRequest {
 // Concat the property and value pair
 func (p *GetRequest) BuildParams() string {
 	return p.urls.Encode()
-}
+}

pkg/getrequest/getrequest_test.go

@@ -28,7 +28,6 @@ func TestAddParam_ValueEmpty_ReturnEmpty(t *testing.T) {
 	}
 }
 
-
 func TestBuildParam_NullParam_ReturnEmpty(t *testing.T) {
 	request := new(GetRequest).Init()
 
@@ -76,4 +75,4 @@ func TestBuildParam_TwoParams_ReturnOrderedTwoPairs(t *testing.T) {
 	if result != expected {
 		t.Errorf("expected: %s, actual: %s", expected, result)
 	}
-}
+}