fix bybit liqs

Tucsky · Mar 6, 2024 · 189b0b2 · 189b0b2
1 parent 131ea04
commit 189b0b2
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 23 deletions.
diff --git a/src/exchange.js b/src/exchange.js
@@ -216,13 +216,9 @@ class Exchange extends EventEmitter {
     api._pending.push(pair)
 
     if (api.readyState === WebSocket.OPEN) {
-      this.schedule(
-        () => {
-          this.subscribePendingPairs(api)
-        },
-        'subscribe-' + api.url,
-        1000
-      )
+      setTimeout(() => {
+        this.subscribePendingPairs(api)
+      })
     }
 
     return api

diff --git a/src/exchanges/bybit.js b/src/exchanges/bybit.js
@@ -143,7 +143,7 @@ class Bybit extends Exchange {
     return {
       exchange: this.id,
       pair: liquidation.symbol,
-      timestamp: +liquidation.updateTime,
+      timestamp: +liquidation.updatedTime || +liquidation.updateTime,
       size,
       price: +liquidation.price,
       side: liquidation.side === 'Buy' ? 'sell' : 'buy',
@@ -158,20 +158,18 @@ class Bybit extends Exchange {
       return
     }
 
-    if (json.data.length) {
-      if (TRADE_TOPIC_REGEX.test(json.topic)) {
-        const isSpot = api.url === SPOT_WS
+    if (TRADE_TOPIC_REGEX.test(json.topic)) {
+      const isSpot = api.url === SPOT_WS
 
-        return this.emitTrades(
-          api.id,
-          json.data.map(trade => this.formatTrade(trade, isSpot))
-        )
-      } else {
-        return this.emitLiquidations(
-          api.id,
-          json.data.map(liquidation => this.formatLiquidation(liquidation))
-        )
-      }
+      return this.emitTrades(
+        api.id,
+        json.data.map(trade => this.formatTrade(trade, isSpot))
+      )
+    } else {
+      return this.emitLiquidations(
+        api.id,
+        [this.formatLiquidation(json.data)]
+      )
     }
   }
 

diff --git a/src/services/connections.js b/src/services/connections.js
@@ -44,8 +44,6 @@ const indexes = (module.exports.indexes = [])
       continue
     }
 
-    console.log(market, product.local, product.type)
-
     if (!cacheIndexes[product.local]) {
       cacheIndexes[product.local] = {
         id: product.local,