feat: increase reconnect waiting time

dkontorovskyy · dkontorovskyy · commit 1aa93f55e7df · 2020-04-21T13:34:18.000+03:00
diff --git a/lib/client/socket.js b/lib/client/socket.js
@@ -27,7 +27,27 @@ module.exports = ({ url, token, filters, config, identifyingMetadata }) => {
     },
     pathname : `/primus/${token}`,
   });
-  const io = new Socket(url);
+
+  // Will exponentially back-off from 0.5 seconds to a maximum of 20 minutes
+  // Retry for a total period of around 4.5 hours
+  const io = new Socket(url, {
+    reconnect: {
+      factor: 1.5,
+      retries: 30,
+      max: 20 * 60 * 1000,
+    },
+  });
+
+  io.on('reconnect scheduled', (opts) => {
+    const attemptIn = Math.floor(opts.scheduled / 1000);
+    logger.warn(`Reconnect retry #${opts.attempt} of ${opts.retries} in about ${attemptIn}s`);
+  });
+
+  io.on('reconnect failed', () => {
+    io.end();
+    logger.error('Reconnect failed');
+    process.exit(1);
+  });
 
   logger.info({ url }, 'broker client is connecting to broker server');
 
