fix #16009

ccxt · Dec 25, 2022 · 4413a9d · 4413a9d
1 parent d3ce5ff
commit 4413a9d
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 2 deletions.
diff --git a/js/huobi.js b/js/huobi.js
@@ -1766,9 +1766,20 @@ module.exports = class huobi extends Exchange {
         //         askSize:  0.4156
         //     }
         //
+        // watchTikcer - bbo
+        //     {
+        //         seqId: 161499562790,
+        //         ask: 16829.51,
+        //         askSize: 0.707776,
+        //         bid: 16829.5,
+        //         bidSize: 1.685945,
+        //         quoteTime: 1671941599612,
+        //         symbol: 'btcusdt'
+        //     }
+        //
         const marketId = this.safeString2 (ticker, 'symbol', 'contract_code');
         const symbol = this.safeSymbol (marketId, market);
-        const timestamp = this.safeInteger (ticker, 'ts');
+        const timestamp = this.safeInteger2 (ticker, 'ts', 'quoteTime');
         let bid = undefined;
         let bidVolume = undefined;
         let ask = undefined;

diff --git a/js/pro/huobi.js b/js/pro/huobi.js
@@ -89,6 +89,7 @@ module.exports = class huobi extends huobiRest {
                 'ws': {
                     'gunzip': true,
                 },
+                'watchTickerTopic': 'market.{marketId}.detail', // 'market.{marketId}.bbo' or 'market.{marketId}.ticker'
             },
             'exceptions': {
                 'ws': {
@@ -123,13 +124,15 @@ module.exports = class huobi extends huobiRest {
         await this.loadMarkets ();
         const market = this.market (symbol);
         symbol = market['symbol'];
-        const messageHash = 'market.' + market['id'] + '.detail';
+        const topic = this.safeString (this.options, 'watchTickerTopic', 'market.{marketId}.detail');
+        const messageHash = this.implodeParams (topic, { 'marketId': market['id'] });
         const url = this.getUrlByMarketType (market['type'], market['linear']);
         return await this.subscribePublic (url, symbol, messageHash, undefined, params);
     }
 
     handleTicker (client, message) {
         //
+        // 'market.btcusdt.detail'
         //     {
         //         ch: 'market.btcusdt.detail',
         //         ts: 1583494163784,
@@ -145,6 +148,20 @@ module.exports = class huobi extends huobiRest {
         //             count: 265673
         //         }
         //     }
+        // 'market.btcusdt.bbo'
+        //     {
+        //         ch: 'market.btcusdt.bbo',
+        //         ts: 1671941599613,
+        //         tick: {
+        //             seqId: 161499562790,
+        //             ask: 16829.51,
+        //             askSize: 0.707776,
+        //             bid: 16829.5,
+        //             bidSize: 1.685945,
+        //             quoteTime: 1671941599612,
+        //             symbol: 'btcusdt'
+        //         }
+        //     }
         //
         const tick = this.safeValue (message, 'tick', {});
         const ch = this.safeString (message, 'ch');
@@ -1572,6 +1589,8 @@ module.exports = class huobi extends huobiRest {
                 'depth': this.handleOrderBook,
                 'mbp': this.handleOrderBook,
                 'detail': this.handleTicker,
+                'bbo': this.handleTicker,
+                'ticker': this.handleTicker,
                 'trade': this.handleTrades,
                 'kline': this.handleOHLCV,
             };