bug

api_kucoin.js

@@ -86,7 +86,7 @@ class biboxApi {
             for(const symbol of symbols){
               this._subscribeSymbol(wss, id, symbol, depth)
             }
-          }else if(response.type === 'subscribe'){
+          }else if(response.topic.startsWith('/trade')){
             const timeStamp = response.data.time;
             const symbol = response.data.topic.replace('/trade/','').replace('_TRADE','');
             let asks = totalOrderbook[symbol].asks || [];

kucoinCollector.js

@@ -134,29 +134,29 @@ class BiboxCollector extends BaseCollector{
 
   _subscribeSymbols(symbols,callback,subscribeDepth){
     // this._fetchDepthByRest(symbols,subscribeDepth,callback);
-    this.api.subscribeSymbolsAndTicker(symbols,(error,result)=>{
-      if(error){
-        console.log(error);
-      }else{
-        //{"data":{"volume":0.03502337,"price":0.03367632,"count":1.04,"action":"ADD","time":1538538428679,"type":"BUY"},"topic":"/trade/ETH-BTC_TRADE","type":"message","seq":32748778883081}
-
-        const timeStamp = result.data.time;
-        const symbol = result.data.topic.replace('/trade/','').replace('_TRADE','');
-        const updateData = [[result.data.price,result.data.count]];
-        let asks = totalOrderbook[symbol].asks|| [];
-        let bids = totalOrderbook[symbol].bids|| [];
-        if(result.data.type === 'BUY'){
-          asks = mergeDepthAsk(asks,updateData);
-        }else if(result.data.type === 'SELL'){
-          bids = mergeDepthBid(bids,updateData);
-        }
-        if(symbol === 'NEO-BTC'){
-          console.log("") //todo 这里输出日志，与网页对比
-        }
-        callback(asks.slice(0,subscribeDepth), bids.slice(0,subscribeDepth), symbol, timeStamp);
-      }
-    })
-
+    // this.api.subscribeSymbolsAndTicker(symbols,(error,result)=>{
+    //   if(error){
+    //     console.log(error);
+    //   }else{
+    //     //{"data":{"volume":0.03502337,"price":0.03367632,"count":1.04,"action":"ADD","time":1538538428679,"type":"BUY"},"topic":"/trade/ETH-BTC_TRADE","type":"message","seq":32748778883081}
+    //
+    //     const timeStamp = result.data.time;
+    //     const symbol = result.data.topic.replace('/trade/','').replace('_TRADE','');
+    //     const updateData = [[result.data.price,result.data.count]];
+    //     let asks = totalOrderbook[symbol].asks|| [];
+    //     let bids = totalOrderbook[symbol].bids|| [];
+    //     if(result.data.type === 'BUY'){
+    //       asks = mergeDepthAsk(asks,updateData);
+    //     }else if(result.data.type === 'SELL'){
+    //       bids = mergeDepthBid(bids,updateData);
+    //     }
+    //     if(symbol === 'NEO-BTC'){
+    //       console.log("") //todo 这里输出日志，与网页对比
+    //     }
+    //     callback(asks.slice(0,subscribeDepth), bids.slice(0,subscribeDepth), symbol, timeStamp);
+    //   }
+    // })
+    this._fetchDepthByWebsocket(symbols,subscribeDepth,callback)
 
   }
   _fetchDepthByRest(symbols,depth,callback){
@@ -194,6 +194,23 @@ class BiboxCollector extends BaseCollector{
     },totalInterval);
   }
 
+
+  _fetchDepthByWebsocket(symbols, depth, callback){
+    this.api.subscribeSymbols(symbols, depth, (error, result)=>{
+      if(error){
+        console.error("subscribe error");
+        console.error(error);
+      }else{
+        console.log("subscribe success");
+        return;
+        const data = result.data;
+        const timeStamp = result.timestamp;
+        const symbol = result.symbol;
+        callback(data.SELL.slice(0, depth).map((item)=>[item[0], item[1]]), data.BUY.slice(0, depth).map((item)=>[item[0], item[1]]), symbol, timeStamp);
+      }
+    })
+  }
+
   _runMonitor(callback){
     let balanceMap = {};
     let need = 1;