init

kucoinCollector.js

 const BaseCollector = require('./baseCollector');
-const baseCurrencies = ["BIX","ETH","BTC","USDT"];
-const restCurrencies = ["USDT","BTC","ETH", "NEO", "KCS"];
+const baseCurrencies = ["ETH","BTC","USDT", "NEO", "KCS"];
+const restCurrencies = ["USDT","BTC","ETH", "NEO", "KCS", ];
 // const machine = process.env['MACHINE'];
 const machine = 'K'
 const biboxApi = require('./api_kucoin');
@@ -30,8 +30,10 @@ class BiboxCollector extends BaseCollector{
         const symbolDetails = data.data;
         const symbolMap = {};
         for(let detail of symbolDetails){
+          if(detail.change >= 0){
             symbolMap[detail.symbol] = detail;
           }
+        }
         callback(null,symbolMap);
       }
     })
@@ -59,13 +61,13 @@ class BiboxCollector extends BaseCollector{
     // })
   }
   _fetchDepthByRest(symbols,depth,callback){
-    const restSymbols = [];
-    for(let symbol of symbols){
-      const midCurrency = symbol.split("-")[0];
-      if(restCurrencies.includes(midCurrency)){
-        restSymbols.push(symbol);
-      }
-    }
+    const restSymbols = symbols;
+    // for(let symbol of symbols){
+    //   const midCurrency = symbol.split("-")[0];
+    //   if(restCurrencies.includes(midCurrency)){
+    //     restSymbols.push(symbol);
+    //   }
+    // }
     const perInterval = 500;
     const totalInterval = perInterval * restSymbols.length+50;
     setInterval(()=>{