feat: support binance non global

able to change api endpoint

Author: panapol-p

v2/client.go

@@ -103,9 +103,9 @@ type RateLimitInterval string
 type AccountType string
 
 // Endpoints
-const (
-	baseAPIMainURL    = "https://api.binance.com"
-	baseAPITestnetURL = "https://testnet.binance.vision"
+var (
+	BaseAPIMainURL    = "https://api.binance.com"
+	BaseAPITestnetURL = "https://testnet.binance.vision"
 )
 
 // UseTestnet switch all the API endpoints from production to the testnet
@@ -261,9 +261,9 @@ func newJSON(data []byte) (j *simplejson.Json, err error) {
 // getAPIEndpoint return the base endpoint of the Rest API according the UseTestnet flag
 func getAPIEndpoint() string {
 	if UseTestnet {
-		return baseAPITestnetURL
+		return BaseAPITestnetURL
 	}
-	return baseAPIMainURL
+	return BaseAPIMainURL
 }
 
 // NewClient initialize an API client instance with API key and secret key.

v2/websocket_service.go

@@ -1,22 +1,19 @@
 package binance
 
 import (
+	stdjson "encoding/json"
 	"fmt"
 	"strings"
 	"time"
-
-	stdjson "encoding/json"
-)
-
-// Endpoints
-const (
-	baseWsMainURL          = "wss://stream.binance.com:9443/ws"
-	baseWsTestnetURL       = "wss://testnet.binance.vision/ws"
-	baseCombinedMainURL    = "wss://stream.binance.com:9443/stream?streams="
-	baseCombinedTestnetURL = "wss://testnet.binance.vision/stream?streams="
 )
 
 var (
+	// Endpoints
+	BaseWsMainURL          = "wss://stream.binance.com:9443/ws"
+	BaseWsTestnetURL       = "wss://testnet.binance.vision/ws"
+	BaseCombinedMainURL    = "wss://stream.binance.com:9443/stream?streams="
+	BaseCombinedTestnetURL = "wss://testnet.binance.vision/stream?streams="
+
 	// WebsocketTimeout is an interval for sending ping/pong messages if WebsocketKeepalive is enabled
 	WebsocketTimeout = time.Second * 60
 	// WebsocketKeepalive enables sending ping/pong messages to check the connection stability
@@ -26,17 +23,17 @@ var (
 // getWsEndpoint return the base endpoint of the WS according the UseTestnet flag
 func getWsEndpoint() string {
 	if UseTestnet {
-		return baseWsTestnetURL
+		return BaseWsTestnetURL
 	}
-	return baseWsMainURL
+	return BaseWsMainURL
 }
 
 // getCombinedEndpoint return the base endpoint of the combined stream according the UseTestnet flag
 func getCombinedEndpoint() string {
 	if UseTestnet {
-		return baseCombinedTestnetURL
+		return BaseCombinedTestnetURL
 	}
-	return baseCombinedMainURL
+	return BaseCombinedMainURL
 }
 
 // WsPartialDepthEvent define websocket partial depth book event
@@ -797,7 +794,7 @@ func WsBookTickerServe(symbol string, handler WsBookTickerHandler, errHandler Er
 
 // WsCombinedBookTickerServe is similar to WsBookTickerServe, but it is for multiple symbols
 func WsCombinedBookTickerServe(symbols []string, handler WsBookTickerHandler, errHandler ErrHandler) (doneC, stopC chan struct{}, err error) {
-	endpoint := baseCombinedMainURL
+	endpoint := getCombinedEndpoint()
 	for _, s := range symbols {
 		endpoint += fmt.Sprintf("%s@bookTicker", strings.ToLower(s)) + "/"
 	}