add func: QueryUmFuturesAggTrades

dwdwow · Oct 16, 2024 · df7faf6 · df7faf6
1 parent fda47dd
commit df7faf6
Show file tree

Hide file tree

Showing 3 changed files with 29 additions and 0 deletions.
diff --git a/bnc/config_pub.go b/bnc/config_pub.go
@@ -456,3 +456,20 @@ var SpotAggTradesConfig = cex.ReqConfig[SpotAggTradesParams, []SpotAggTrades]{
 	HTTPStatusCodeChecker: HTTPStatusCodeChecker,
 	RespBodyUnmarshaler:   spotBodyUnmshWrapper(cex.StdBodyUnmarshaler[[]SpotAggTrades]),
 }
+
+type UmFuturesAggTradesParams SpotAggTradesParams
+
+type UmFuturesAggTrades SpotAggTrades
+
+var UmFuturesAggTradesConfig = cex.ReqConfig[UmFuturesAggTradesParams, []UmFuturesAggTrades]{
+	ReqBaseConfig: cex.ReqBaseConfig{
+		BaseUrl:          FapiBaseUrl,
+		Path:             FapiV1 + "/aggTrades",
+		Method:           http.MethodGet,
+		IsUserData:       false,
+		UserTimeInterval: 0,
+		IpTimeInterval:   0,
+	},
+	HTTPStatusCodeChecker: HTTPStatusCodeChecker,
+	RespBodyUnmarshaler:   fuBodyUnmshWrapper(cex.StdBodyUnmarshaler[[]UmFuturesAggTrades]),
+}
diff --git a/bnc/public.go b/bnc/public.go
@@ -216,3 +216,11 @@ func QuerySpotAggTrades(symbol string) ([]SpotAggTrades, error) {
 	}
 	return data, nil
 }
+
+func QueryUmFuturesAggTrades(params UmFuturesAggTradesParams) ([]UmFuturesAggTrades, error) {
+	_, data, reqErr := cex.Request(emptyUser, UmFuturesAggTradesConfig, params)
+	if reqErr.IsNotNil() {
+		return nil, reqErr.Err
+	}
+	return data, nil
+}
diff --git a/bnc/public_test.go b/bnc/public_test.go
@@ -174,3 +174,7 @@ func TestQuerySpotTrades(t *testing.T) {
 func TestQuerySpotAggTrades(t *testing.T) {
 	publicTestChecker(QuerySpotAggTrades("ETHUSDT"))
 }
+
+func TestQueryUmFuturesAggTrades(t *testing.T) {
+	publicTestChecker(QueryUmFuturesAggTrades(UmFuturesAggTradesParams{Symbol: "ETHUSDT", Limit: 1000}))
+}