Ensure we continue processin commands when reconnected

flowbased · Mar 21, 2018 · ef49248 · ef49248
1 parent 8826d80
commit ef49248
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/lib/adapter/0_6.js b/lib/adapter/0_6.js
@@ -6,6 +6,7 @@ class Adapter {
     this.commands = [];
     this.listener = null;
     this.subscribe();
+    this.tick();
   }
 
   subscribe() {
@@ -22,6 +23,12 @@ class Adapter {
         }, err => this.client.protocolError(err));
     };
     this.client.transport.on('message', onMessage);
+    this.client.transport.on('status', ({ online }) => {
+      if (!online) {
+        return;
+      }
+      this.tick();
+    });
   }
 
   send(protocol, command, payload) {

diff --git a/lib/client.js b/lib/client.js
@@ -110,14 +110,12 @@ class FbpClient extends EventEmitter {
 
   prepareAdapter(version) {
     if (this.adapter) {
-      this.adapter.tick();
       return;
     }
     // TODO: Semver comparison?
     const versionNumber = Number.parseFloat(version);
     if (versionNumber <= 0.6) {
       this.adapter = adapter06(this);
-      this.adapter.tick();
       return;
     }
     throw new Error(`Unsupported FBP protocol version ${version}`);