Release v0.7.0

CHANGELOG.md

@@ -1,5 +1,22 @@
 # Change log
 
+## v0.7.0 - 2024-08-23
+
+### Added
+- SPOT `FIAT` Endpoints:
+    - `GET /sapi/v1/fiat/orders` - Get Fiat Deposit/Withdraw History
+    - `GET /sapi/v1/fiat/payments` - Get Fiat Payments History
+- Websocket Stream:
+    - `<symbol>@miniTicker` - Individual Symbol Mini Ticker Stream
+
+### Updated
+- Updated `SymbolInfo` and `SymbolFilter` types
+
+### Fixed
+- Fixed issue with `stopCh` not stopping the WebSocket connection
+- Fixed the `stop` method for `userDataStream`
+- Fixed symbols method for `NewTicker24hrService`
+
 ## v0.6.0 - 2024-06-19
 
 ### Fixed

client.go

@@ -767,3 +767,11 @@ func (c *Client) NewPingUserStream() *PingUserStream {
 func (c *Client) NewCloseUserStream() *CloseUserStream {
 	return &CloseUserStream{c: c}
 }
+
+func (c *Client) NewGetFiatDepositWithdrawHistoryService() *GetFiatDepositWithdrawHistoryService {
+	return &GetFiatDepositWithdrawHistoryService{c: c}
+}
+
+func (c *Client) NewGetFiatPaymentHistoryService() *GetFiatPaymentHistoryService {
+	return &GetFiatPaymentHistoryService{c: c}
+}

consts.go

@@ -2,4 +2,4 @@ package binance_connector
 
 const Name = "binance-connector-go"
 
-const Version = "0.6.0"
+const Version = "0.7.0"

examples/fiat/GetFiatDepositWithdrawHistory/GetFiatDepositWithdrawHistory.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"context"
+	"fmt"
+
+	binance_connector "github.com/binance/binance-connector-go"
+)
+
+func main() {
+	GetFiatDepositWithdrawHistory()
+}
+
+func GetFiatDepositWithdrawHistory() {
+	apiKey := "your api key"
+	secretKey := "your secret key"
+	baseURL := "https://api.binance.com"
+
+	client := binance_connector.NewClient(apiKey, secretKey, baseURL)
+
+	// GetFiatDepositWithdrawHistoryService - /sapi/v1/fiat/orders
+	getFiatDepositWithdrawHistory, err := client.NewGetFiatDepositWithdrawHistoryService().
+		TransactionType("0").
+		Do(context.Background())
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(binance_connector.PrettyPrint(getFiatDepositWithdrawHistory))
+}

examples/fiat/GetFiatPaymentHistory/GetFiatPaymentHistory.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"context"
+	"fmt"
+
+	binance_connector "github.com/binance/binance-connector-go"
+)
+
+func main() {
+	GetFiatPaymentHistory()
+}
+
+func GetFiatPaymentHistory() {
+	apiKey := "your api key"
+	secretKey := "your secret key"
+	baseURL := "https://api.binance.com"
+
+	client := binance_connector.NewClient(apiKey, secretKey, baseURL)
+
+	// GetFiatPaymentHistoryService - /sapi/v1/fiat/payments
+	getFiatPaymentHistory, err := client.NewGetFiatPaymentHistoryService().
+		TransactionType("0").
+		Do(context.Background())
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	fmt.Println(binance_connector.PrettyPrint(getFiatPaymentHistory))
+}

examples/websocket/AllMarketMiniTickers/AllMarketMiniTickers.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	binance_connector "github.com/binance/binance-connector-go"
 )
@@ -18,10 +19,15 @@ func WsAllMarketMiniTickers() {
 	errHandler := func(err error) {
 		fmt.Println(err)
 	}
-	doneCh, _, err := websocketStreamClient.WsAllMarketMiniTickersStatServe(wsAllMarketMiniTickersHandler, errHandler)
+	doneCh, stopCh, err := websocketStreamClient.WsAllMarketMiniTickersStatServe(wsAllMarketMiniTickersHandler, errHandler)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
 	<-doneCh
 }

examples/websocket/AllMarketTickers/AllMarketTickers.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	binance_connector "github.com/binance/binance-connector-go"
 )
@@ -18,10 +19,15 @@ func WsAllMarketTickersExample() {
 	errHandler := func(err error) {
 		fmt.Println(err)
 	}
-	doneCh, _, err := websocketStreamClient.WsAllMarketTickersStatServe(wsAllMarketTickersHandler, errHandler)
+	doneCh, stopCh, err := websocketStreamClient.WsAllMarketTickersStatServe(wsAllMarketTickersHandler, errHandler)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
 	<-doneCh
 }

examples/websocket/CombinedDepth/CombinedDepth.go

@@ -26,7 +26,7 @@ func WsCombinedDepthHandlerExample() {
 	}
 	// use stopCh to exit
 	go func() {
-		time.Sleep(5 * time.Second)
+		time.Sleep(10 * time.Second)
 		stopCh <- struct{}{}
 	}()
 	// remove this if you do not want to be blocked here

examples/websocket/MarketMiniTickers/MarketMiniTickers.go

@@ -0,0 +1,33 @@
+package main
+
+import (
+	"fmt"
+	"time"
+
+	binance_connector "github.com/binance/binance-connector-go"
+)
+
+func main() {
+	WsMarketMiniTickers()
+}
+
+func WsMarketMiniTickers() {
+	websocketStreamClient := binance_connector.NewWebsocketStreamClient(false)
+	wsMarketMiniTickersHandler := func(event binance_connector.WsMarketMiniTickerStatEvent) {
+		fmt.Println(binance_connector.PrettyPrint(event))
+	}
+	errHandler := func(err error) {
+		fmt.Println(err)
+	}
+	doneCh, stopCh, err := websocketStreamClient.WsMarketMiniTickersStatServe("BNBBTC", wsMarketMiniTickersHandler, errHandler)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
+	<-doneCh
+}

examples/websocket/aggtrades/aggtrades.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	binance_connector "github.com/binance/binance-connector-go"
 )
@@ -20,10 +21,15 @@ func AggTradesExample() {
 	errHandler := func(err error) {
 		fmt.Println(err)
 	}
-	doneCh, _, err := websocketStreamClient.WsAggTradeServe("BTCUSDT", wsAggTradeHandler, errHandler)
+	doneCh, stopCh, err := websocketStreamClient.WsAggTradeServe("BTCUSDT", wsAggTradeHandler, errHandler)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
 	<-doneCh
 }

examples/websocket/bookticker/bookticker.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	binance_connector "github.com/binance/binance-connector-go"
 )
@@ -18,10 +19,15 @@ func WsBookTickerExample() {
 	errHandler := func(err error) {
 		fmt.Println(err)
 	}
-	doneCh, _, err := websocketStreamClient.WsBookTickerServe("LTCBTC", wsBookTickerHandler, errHandler)
+	doneCh, stopCh, err := websocketStreamClient.WsBookTickerServe("LTCBTC", wsBookTickerHandler, errHandler)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
 	<-doneCh
 }

examples/websocket/depth/depth.go

@@ -26,7 +26,7 @@ func WsDepthHandlerExample() {
 	}
 	// use stopCh to exit
 	go func() {
-		time.Sleep(5 * time.Second)
+		time.Sleep(10 * time.Second)
 		stopCh <- struct{}{}
 	}()
 	// remove this if you do not want to be blocked here

examples/websocket/kline/kline.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	binance_connector "github.com/binance/binance-connector-go"
 )
@@ -18,10 +19,15 @@ func WsKlineExample() {
 	errHandler := func(err error) {
 		fmt.Println(err)
 	}
-	doneCh, _, err := websocketStreamClient.WsKlineServe("LTCBTC", "1m", wsKlineHandler, errHandler)
+	doneCh, stopCh, err := websocketStreamClient.WsKlineServe("LTCBTC", "1m", wsKlineHandler, errHandler)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
 	<-doneCh
 }

examples/websocket/trades/trades.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"fmt"
+	"time"
 
 	binance_connector "github.com/binance/binance-connector-go"
 )
@@ -18,10 +19,15 @@ func WsTradeExample() {
 	errHandler := func(err error) {
 		fmt.Println(err)
 	}
-	doneCh, _, err := websocketStreamClient.WsTradeServe("LTCBTC", wsTradeHandler, errHandler)
+	doneCh, stopCh, err := websocketStreamClient.WsTradeServe("LTCBTC", wsTradeHandler, errHandler)
 	if err != nil {
 		fmt.Println(err)
 		return
 	}
+	// use stopCh to exit
+	go func() {
+		time.Sleep(10 * time.Second)
+		stopCh <- struct{}{}
+	}()
 	<-doneCh
 }