kucoin: implement query tickers

examples/kucoin/tickers.go

@@ -22,13 +22,20 @@ var tickersCmd = &cobra.Command{
 			return nil
 		}
 
-
 		ticker, err := client.MarketDataService.GetTicker(args[0])
 		if err != nil {
 			return err
 		}
 
 		logrus.Infof("ticker: %+v", ticker)
+
+
+		tickerStats, err := client.MarketDataService.GetTicker24HStat(args[0])
+		if err != nil {
+			return err
+		}
+
+		logrus.Infof("ticker 24h stats: %+v", tickerStats)
 		return nil
 	},
 }

pkg/exchange/kucoin/exchange.go

@@ -104,11 +104,39 @@ func (e *Exchange) QueryMarkets(ctx context.Context) (types.MarketMap, error) {
 }
 
 func (e *Exchange) QueryTicker(ctx context.Context, symbol string) (*types.Ticker, error) {
-	panic("implement me")
+	s, err := e.client.MarketDataService.GetTicker24HStat(symbol)
+	if err != nil {
+		return nil, err
+	}
+
+	return &types.Ticker{
+		Time:   s.Time.Time(),
+		Volume: s.Volume.Float64(),
+		Last:   s.Last.Float64(),
+		Open:   s.Last.Float64() - s.ChangePrice.Float64(),
+		High:   s.High.Float64(),
+		Low:    s.Low.Float64(),
+		Buy:    s.Buy.Float64(),
+		Sell:   s.Sell.Float64(),
+	}, nil
 }
 
-func (e *Exchange) QueryTickers(ctx context.Context, symbol ...string) (map[string]types.Ticker, error) {
+func (e *Exchange) QueryTickers(ctx context.Context, symbols ...string) (map[string]types.Ticker, error) {
-	panic("implement me")
+	tickers := map[string]types.Ticker{}
+	if len(symbols) > 0 {
+		for _, s := range symbols {
+			t, err := e.QueryTicker(ctx, s)
+			if err != nil {
+				return nil, err
+			}
+
+			tickers[s] = *t
+		}
+
+		return tickers, nil
+	}
+
+	return tickers, nil
 }
 
 func (e *Exchange) QueryKLines(ctx context.Context, symbol string, interval types.Interval, options types.KLineQueryOptions) ([]types.KLine, error) {

pkg/exchange/kucoin/kucoinapi/marketdata.go

@@ -120,7 +120,7 @@ func (s *MarketDataService) GetTicker(symbol string) (*Ticker, error) {
     "ticker":[
         {
             "symbol": "BTC-USDT",   // symbol
-            "symbolName":"BTC-USDT", // Name of trading pairs, it would change after renaming
+            "symbolName":"BTC-USDT", // SymbolName of trading pairs, it would change after renaming
             "buy": "11328.9",   // bestAsk
             "sell": "11329",    // bestBid
             "changeRate": "-0.0055",    // 24h change rate
@@ -142,7 +142,7 @@ func (s *MarketDataService) GetTicker(symbol string) (*Ticker, error) {
 
 type Ticker24H struct {
 	Symbol       string           `json:"symbol"`
-	Name         string           `json:"symbolName"`
+	SymbolName   string           `json:"symbolName"`
 	Buy          fixedpoint.Value `json:"buy"`
 	Sell         fixedpoint.Value `json:"sell"`
 	ChangeRate   fixedpoint.Value `json:"changeRate"`
@@ -159,6 +159,8 @@ type Ticker24H struct {
 
 	TakerCoefficient fixedpoint.Value `json:"takerCoefficient"`
 	MakerCoefficient fixedpoint.Value `json:"makerCoefficient"`
+
+	Time types.MillisecondTimestamp `json:"time"`
 }
 
 type AllTickers struct {
@@ -190,6 +192,33 @@ func (s *MarketDataService) ListTickers() (*AllTickers, error) {
 	return apiResponse.Data, nil
 }
 
+func (s *MarketDataService) GetTicker24HStat(symbol string) (*Ticker24H, error) {
+	var params = url.Values{}
+	params.Add("symbol", symbol)
+
+	req, err := s.client.newRequest("GET", "/api/v1/market/stats", params, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	response, err := s.client.sendRequest(req)
+	if err != nil {
+		return nil, err
+	}
+
+	var apiResponse struct {
+		Code    string     `json:"code"`
+		Message string     `json:"msg"`
+		Data    *Ticker24H `json:"data"`
+	}
+
+	if err := response.DecodeJSON(&apiResponse); err != nil {
+		return nil, err
+	}
+
+	return apiResponse.Data, nil
+}
+
 /*
 {
     "sequence": "3262786978",