add clearTimeout to avoid reconnection hell (#306)

* add clearTimeout to avoid reconnection hell

* removed console.log

lib/block-listeners/cosmos-node-subscription.js

@@ -13,6 +13,8 @@ const config = require('../../config.js')
 const WAIT_FOR_BLOCK_DELAY = 5000
 const EXPECTED_MAX_BLOCK_WINDOW = 120000
 
+let reconnectionTimeout = {}
+
 // This class establishes an rpc connection to Tendermint.
 // Used for listening to events, such as new blocks.
 class CosmosNodeSubscription {
@@ -72,7 +74,12 @@ class CosmosNodeSubscription {
             scope.setExtra('rpc_url', network.rpc_url)
             Sentry.captureException(new Error(`Lost Tendermint connection`))
           })
-          setTimeout(() => this.connectTendermint(network), 3000)
+          // need to clear previous timeout to evoid connection hell
+          clearTimeout(reconnectionTimeout[network.id])
+          reconnectionTimeout[network.id] = setTimeout(
+            () => this.connectTendermint(network),
+            3000
+          )
         }
       })
       .catch(e => {
@@ -82,8 +89,12 @@ class CosmosNodeSubscription {
           Sentry.captureException(e)
         })
 
+        clearTimeout(reconnectionTimeout[network.id])
         // if can't connect, retry
-        setTimeout(() => this.connectTendermint(network), 3000)
+        reconnectionTimeout[network.id] = setTimeout(
+          () => this.connectTendermint(network),
+          3000
+        )
       })
   }
 

package.json

@@ -13,7 +13,7 @@
     "dev-docker": "docker build -t lunie-api-dev . && docker run --init -it -p 4000:4000 lunie-api-dev",
     "lint": "eslint index.js config.js lib tests",
     "lint-fix": "yarn lint --fix",
-    "start": "node index.js",
+    "start": "node index.js ",
     "test": "jest"
   },
   "husky": {