kucoin: implement QueryClosedOrders

pkg/exchange/kucoin/convert.go

@@ -134,8 +134,9 @@ func toGlobalOrderStatus(o kucoinapi.Order) types.OrderStatus {
 	var status types.OrderStatus
 	if o.IsActive {
 		status = types.OrderStatusNew
-	} else if o.DealSize > 0 {
+		if o.DealSize > 0 {
-		status = types.OrderStatusPartiallyFilled
+			status = types.OrderStatusPartiallyFilled
+		}
 	} else if o.CancelExist {
 		status = types.OrderStatusCanceled
 	} else {

pkg/exchange/kucoin/exchange.go

@@ -27,6 +27,7 @@ type Exchange struct {
 	client                  *kucoinapi.RestClient
 }
 
+
 func New(key, secret, passphrase string) *Exchange {
 	client := kucoinapi.NewClient()
 
@@ -225,6 +226,32 @@ func (e *Exchange) QueryOpenOrders(ctx context.Context, symbol string) (orders [
 	return orders, err
 }
 
+func (e *Exchange) QueryClosedOrders(ctx context.Context, symbol string, since, until time.Time, lastOrderID uint64) (orders []types.Order, err error) {
+	req := e.client.TradeService.NewListOrdersRequest()
+	req.Symbol(toLocalSymbol(symbol))
+	req.Status("done")
+	req.EndAt(until)
+	req.StartAt(since)
+
+	orderList, err := req.Do(ctx)
+	if err != nil {
+		return orders, err
+	}
+
+	// TODO: support pagination (right now we can only get 50 items from the first page)
+	for _, o := range orderList.Items {
+		order := toGlobalOrder(o)
+		orders = append(orders, order)
+	}
+
+	return orders, err
+}
+
+func (e *Exchange) QueryTrades(ctx context.Context, symbol string, options *types.TradeQueryOptions) ([]types.Trade, error) {
+	panic("implement me")
+}
+
+
 func (e *Exchange) CancelOrders(ctx context.Context, orders ...types.Order) (errs error) {
 	for _, o := range orders {
 		req := e.client.TradeService.NewCancelOrderRequest()