bug

api_kucoin.js

@@ -115,6 +115,8 @@ class biboxApi {
                 updateData = [[response.data.price, newCount]];
               }
               asks = mergeDepth(asks, updateData, true);
+              console.log(updateData)
+              console.log(asks)
             }else if(result.data.type === 'BUY'){
               const oldD = totalOrderbook[symbol];
               let has = false;

kucoinCollector.js

@@ -204,33 +204,32 @@ class BiboxCollector extends BaseCollector{
         const data = result.data;
         const timeStamp = result.timestamp;
         const symbol = result.symbol;
-        if(symbol === 'HST-ETH'){
-          console.log(symbol, ':  subscribe ok')
-          console.log(data.SELL)
-          console.log(data.BUY)
-        }
         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);
       }
     })
   }
 
+  _getCoinsInfo(){
+    console.log('start get coin info...');
+    coinInfoMap = {}
+    this.api.coins_info((error,result)=>{
+      if(error){
+        console.error('get coins info error');
+        this._getCoinsInfo();
+      }else {
+        if(result.data){
+          for(let d of result.data){
+            coinInfoMap[d.coin] = d
+          }
+        }
+      }
+    });
+  }
   _runMonitor(callback){
     let balanceMap = {};
     let need = 1;
     if(!coinInfoMap){
-      console.log('start get coin info...');
-      coinInfoMap = {}
-      this.api.coins_info((error,result)=>{
-        if(error){
-          console.error('get coins info error')
-        }else {
-          if(result.data){
-            for(let d of result.data){
-              coinInfoMap[d.coin] = d
-            }
-          }
-        }
-      });
+      this._getCoinsInfo()
     }
     this.api.balance(20, 1, (error,result)=>{
       if(error){