feat: clean code

check.sh

@@ -28,11 +28,14 @@ function lint() {
     golint -set_exit_status ./...
 }
 
+# There is a bug if we define the same json tag in the struct.
+# Disable structtag temporarily.
+# see: https://github.com/golang/go/issues/40102
 function vet() {
     echo  "Running go vet ..."
     (
         cd v2
-        go vet ./...
+        go vet -structtag=false ./...
     )
 }
 

examples/config.go

@@ -13,13 +13,15 @@ type Config struct {
 	APIKey     string
 	SecretKey  string
 	UseTestnet bool
+	UseDemo    bool
 }
 
 // Global configuration instance
 var AppConfig = &Config{
 	APIKey:     getEnvOrDefault("BINANCE_API_KEY", ""),
 	SecretKey:  getEnvOrDefault("BINANCE_SECRET_KEY", ""),
 	UseTestnet: getEnvOrDefault("BINANCE_USE_TESTNET", "true") == "true",
+	UseDemo:    getEnvOrDefault("BINANCE_USE_DEMO", "true") == "true",
 }
 
 // getEnvOrDefault returns the environment variable value or a default if not set
@@ -40,6 +42,11 @@ func (c *Config) SetupTestnet() {
 	binance.UseTestnet = c.UseTestnet
 }
 
+// SetupDemo configures demo usage based on the config
+func (c *Config) SetupDemo() {
+	binance.UseDemo = c.UseDemo
+}
+
 // Validate checks if the configuration is valid
 func (c *Config) Validate() error {
 	if strings.TrimSpace(c.APIKey) == "" {

examples/main.go

@@ -14,10 +14,14 @@ func main() {
 	}
 
 	// Setup testnet
-	AppConfig.SetupTestnet()
+	// AppConfig.SetupTestnet()
+
+	// Setup demo
+	// AppConfig.SetupDemo()
 
 	fmt.Println("=== Binance API Examples ===")
 	fmt.Printf("Using testnet: %v\n", AppConfig.UseTestnet)
+	fmt.Printf("Using demo: %v\n", AppConfig.UseDemo)
 	fmt.Println()
 
 	// Run examples
@@ -27,6 +31,7 @@ func main() {
 	// FuturesOrder()
 	// DeliveryOrder()
 	// WalletBalance()
-	WatchMiniMarketsStat()
+	// WatchMiniMarketsStat()
 	// RunOrderListExamples()
+	WatchFuturesUserDataStream()
 }

examples/watcher_futures.go

@@ -0,0 +1,51 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"os"
+	"os/signal"
+
+	"github.com/adshao/go-binance/v2"
+	"github.com/adshao/go-binance/v2/futures"
+)
+
+func WatchFuturesUserDataStream() {
+	futures.UseDemo = true
+	apiKey := ""
+	secret := ""
+	client := binance.NewFuturesClient(apiKey, secret)
+
+	listenKey, err := client.NewStartUserStreamService().Do(context.Background())
+	if err != nil {
+		panic(err)
+	}
+
+	userDataHandler := func(event *futures.WsUserDataEvent) {
+		fmt.Printf("Event: %s, Time: %d\n", event.Event, event.Time)
+
+		switch event.Event {
+		case futures.UserDataEventTypeAlgoUpdate:
+			fmt.Printf("ALGO update: %+v\n", event.AlgoUpdate)
+		case futures.UserDataEventTypeTradeLite:
+			fmt.Printf("Trade lite: %+v\n", event)
+		}
+	}
+
+	errHandler := func(err error) {
+		panic(err)
+	}
+
+	doneC, stopC, err := futures.WsUserDataServe(listenKey, userDataHandler, errHandler)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	c := make(chan os.Signal, 1)
+	signal.Notify(c, os.Interrupt)
+	select {
+	case <-c:
+		stopC <- struct{}{}
+	}
+	<-doneC
+}

v2/client.go

@@ -126,6 +126,7 @@ type FuturesAlgoOrderStatusType string
 var (
 	BaseAPIMainURL    = "https://api.binance.com"
 	BaseAPITestnetURL = "https://testnet.binance.vision"
+	BaseAPIDemoURL    = "https://demo-api.binance.com"
 )
 
 // SelfTradePreventionMode define self trade prevention strategy
@@ -139,6 +140,9 @@ type MarginAccountBorrowRepayType string
 // UseTestnet switch all the API endpoints from production to the testnet
 var UseTestnet = false
 
+// UseDemo switch all the API endpoints from production to the demo
+var UseDemo = false
+
 // Global enums
 const (
 	SideTypeBuy  SideType = "BUY"
@@ -361,6 +365,9 @@ func getAPIEndpoint() string {
 	if UseTestnet {
 		return BaseAPITestnetURL
 	}
+	if UseDemo {
+		return BaseAPIDemoURL
+	}
 	return BaseAPIMainURL
 }
 
@@ -436,7 +443,7 @@ type Client struct {
 	OrderCount common.OrderCount
 }
 
-func (c *Client) debug(format string, v ...interface{}) {
+func (c *Client) debug(format string, v ...any) {
 	if c.Debug {
 		c.Logger.Printf(format, v...)
 	}

v2/common/helpers.go

@@ -34,7 +34,7 @@ func ToJSONList(v []byte) []byte {
 	return v
 }
 
-func ToInt(digit interface{}) (i int, err error) {
+func ToInt(digit any) (i int, err error) {
 	if intVal, ok := digit.(int); ok {
 		return int(intVal), nil
 	}
@@ -44,7 +44,7 @@ func ToInt(digit interface{}) (i int, err error) {
 	return 0, fmt.Errorf("unexpected digit: %v", digit)
 }
 
-func ToInt64(digit interface{}) (i int64, err error) {
+func ToInt64(digit any) (i int64, err error) {
 	if intVal, ok := digit.(int); ok {
 		return int64(intVal), nil
 	}

v2/common/websocket/client.go

@@ -58,7 +58,7 @@ type client struct {
 	reconnectCount              int64
 }
 
-func (c *client) debug(format string, v ...interface{}) {
+func (c *client) debug(format string, v ...any) {
 	if c.Debug {
 		c.logger.Println(fmt.Sprintf(format, v...))
 	}

v2/common/websocket/client_test.go

@@ -16,9 +16,9 @@ import (
 )
 
 type testApiRequest struct {
-	Id     string                 `json:"id"`
-	Method string                 `json:"method"`
-	Params map[string]interface{} `json:"params"`
+	Id     string         `json:"id"`
+	Method string         `json:"method"`
+	Params map[string]any `json:"params"`
 }
 
 func (s *clientTestSuite) SetupTest() {
@@ -81,7 +81,7 @@ func (s *clientTestSuite) TestReadWriteSync() {
 				req := testApiRequest{
 					Id:     requestID,
 					Method: "some-method",
-					Params: map[string]interface{}{},
+					Params: map[string]any{},
 				}
 				reqRaw, err := json.Marshal(req)
 				s.Require().NoError(err)
@@ -101,7 +101,7 @@ func (s *clientTestSuite) TestReadWriteSync() {
 				req := testApiRequest{
 					Id:     "some-other-request-id",
 					Method: "some-method",
-					Params: map[string]interface{}{},
+					Params: map[string]any{},
 				}
 				reqRaw, err := json.Marshal(req)
 				s.Require().NoError(err)
@@ -112,7 +112,7 @@ func (s *clientTestSuite) TestReadWriteSync() {
 				req = testApiRequest{
 					Id:     requestID,
 					Method: "some-method",
-					Params: map[string]interface{}{},
+					Params: map[string]any{},
 				}
 				reqRaw, err = json.Marshal(req)
 				s.Require().NoError(err)
@@ -132,7 +132,7 @@ func (s *clientTestSuite) TestReadWriteSync() {
 				req := testApiRequest{
 					Id:     requestID,
 					Method: "some-method",
-					Params: map[string]interface{}{
+					Params: map[string]any{
 						"timeout": "true",
 					},
 				}
@@ -154,7 +154,7 @@ func (s *clientTestSuite) TestReadWriteSync() {
 				req := testApiRequest{
 					Id:     requestID,
 					Method: "some-method",
-					Params: map[string]interface{}{},
+					Params: map[string]any{},
 				}
 				reqRaw, err := json.Marshal(req)
 				s.Require().NoError(err)

v2/common/websocket/types.go

@@ -15,9 +15,9 @@ type WsApiMethodType string
 
 // WsApiRequest define common websocket API request
 type WsApiRequest struct {
-	Id     string                 `json:"id"`
-	Method WsApiMethodType        `json:"method"`
-	Params map[string]interface{} `json:"params"`
+	Id     string          `json:"id"`
+	Method WsApiMethodType `json:"method"`
+	Params map[string]any  `json:"params"`
 }
 
 var (
@@ -112,7 +112,7 @@ type RequestData struct {
 }
 
 // CreateRequest creates signed ws request
-func CreateRequest(reqData RequestData, method WsApiMethodType, params map[string]interface{}) ([]byte, error) {
+func CreateRequest(reqData RequestData, method WsApiMethodType, params map[string]any) ([]byte, error) {
 	if reqData.requestID == "" {
 		return nil, ErrorRequestIDNotSet
 	}
@@ -153,7 +153,7 @@ func CreateRequest(reqData RequestData, method WsApiMethodType, params map[strin
 }
 
 // encode encodes the parameters to a URL encoded string
-func encodeParams(p map[string]interface{}) string {
+func encodeParams(p map[string]any) string {
 	queryValues := url.Values{}
 	for key, value := range p {
 		queryValues.Add(key, fmt.Sprintf("%v", value))

v2/delivery/client.go

@@ -67,6 +67,7 @@ type UserDataEventReasonType string
 var (
 	BaseApiMainUrl    = "https://dapi.binance.com"
 	BaseApiTestnetUrl = "https://testnet.binancefuture.com"
+	BaseApiDemoURL    = "https://demo-dapi.binance.com"
 )
 
 // Global enums
@@ -180,6 +181,9 @@ func getApiEndpoint() string {
 	if UseTestnet {
 		return BaseApiTestnetUrl
 	}
+	if UseDemo {
+		return BaseApiDemoURL
+	}
 	return BaseApiMainUrl
 }
 
@@ -239,7 +243,7 @@ type Client struct {
 	OrderCount common.OrderCount
 }
 
-func (c *Client) debug(format string, v ...interface{}) {
+func (c *Client) debug(format string, v ...any) {
 	if c.Debug {
 		c.Logger.Printf(format, v...)
 	}