From 4c5a12610ea6ed08796ecf93daf6b581114e70bc Mon Sep 17 00:00:00 2001
From: crazybuster <crazybuster@gmail.com>
Date: Wed, 15 Aug 2018 21:14:43 -0700
Subject: [PATCH] reconnect to the server if it can't connect. (#343)

* reconnect to the server if it can't connect.

* Format
---
 src/resources/messaging.js | 17 +++++++++++++++++
 1 file changed, 17 insertions(+)

diff --git a/src/resources/messaging.js b/src/resources/messaging.js
index a2d08e58..21ba9c95 100644
--- a/src/resources/messaging.js
+++ b/src/resources/messaging.js
@@ -205,6 +205,22 @@ class Messaging extends ResourceBase {
         this.last_peers = peer_ids
         console.log('New peers:', this.last_peers)
       }
+      //let's do a 15 second reconnect policy
+      if (
+        this.ipfs.__reconnect_peers &&
+        Date.now() - this.last_connect_time > 20000 &&
+        this.last_peers
+      ) {
+        this.last_connect_time = Date.now()
+        //every 20 seconds either connect or ping
+        for (const peer of Object.keys(this.ipfs.__reconnect_peers)) {
+          if (!this.last_peers.includes(peer)) {
+            const peer_address = this.ipfs.__reconnect_peers[peer]
+            console.log('Reconnecting:', peer_address)
+            this.ipfs.swarm.connect(peer_address)
+          }
+        }
+      }
     })
   }
 
@@ -247,6 +263,7 @@ class Messaging extends ResourceBase {
             clearInterval(this.refreshIntervalId)
           }
 
+          this.last_connect_time = Date.now()
           this.refreshIntervalId = setInterval(
             this.refreshPeerList.bind(this),
             5000