🔧 fix(coinbase): fix pagination bug for query orders.

c9s · Feb 25, 2025 · 2e2f732 · 2e2f732
1 parent 549958d
commit 2e2f732
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/pkg/exchange/coinbase/exchage.go b/pkg/exchange/coinbase/exchage.go
@@ -198,10 +198,9 @@ func (e *Exchange) queryOrdersByPagination(ctx context.Context, symbol string, s
 	}
 	sortedBy := "created_at"
 	sorting := "desc"
-	after := time.Now()
 	localSymbol := toLocalSymbol(symbol)
 	getOrdersReq := e.client.NewGetOrdersRequest()
-	getOrdersReq.ProductID(localSymbol).Status(status).SortedBy(sortedBy).Sorting(sorting).Before(after).Limit(paginationLimit)
+	getOrdersReq.ProductID(localSymbol).Status(status).SortedBy(sortedBy).Sorting(sorting).Limit(paginationLimit)
 	cbOrders, err := getOrdersReq.Do(ctx)
 	if err != nil {
 		return nil, errors.Wrap(err, "failed to get orders")
@@ -220,7 +219,7 @@ func (e *Exchange) queryOrdersByPagination(ctx context.Context, symbol string, s
 			if done {
 				break
 			}
-			after = time.Time(cbOrders[len(cbOrders)-1].CreatedAt)
+			after := time.Time(cbOrders[len(cbOrders)-1].CreatedAt)
 			getOrdersReq.After(after)
 			newOrders, err := getOrdersReq.Do(ctx)
 			if err != nil {