Draft: Resolve "Implement websockets client"

Closes #2

dist/adapter.esm.js

     this.protocol = protocol;
     this.config = config;
     this.axios = axios;
-    console.error(this.getMode());
-    if (this.getMode() === 'socket') this.openSocket();
+    this.pollTimer = null;
+  }
+
+  /**
+   * Start listening for inbound messages 
+   */
+  start() {
+    switch (this.getMode()) {
+      case 'socket': this.openSocket(); break;
+      case 'http': {
+        const interval = ('pollInterval' in this.config) ? this.config.pollInterval : 5;
+        this.pollEveryXSeconds(interval);
+      } break;
+    }
   }
 
   /**
       });
   }
 
+  pollEveryXSeconds(interval) {
+    this.poll()
+    .then(() => {
+      if (this.pollTimer) clearTimeout(this.pollTimer);
+      this.pollTimer = setTimeout(this.poll(), interval*1000);
+    });
+  }
+
   /**
    * Call the GET /receive endpoint and process the messages with decode
    * 
   }
 
   socket_publish(topic, body) {
-    this.socket.send(JSON.stringify({ topic, message: body }));
+    if (this.socket) {
+      this.socket.send(JSON.stringify({ topic, message: body }));
+    } else {
+      this.openSocket().then((socket) => {
+        socket.send(JSON.stringify({ topic, message: body }));
+      });
+    }
   }
 
   /**
   }
 
   socket_broadcast(body) {
-    this.socket.send(JSON.stringify({ message: body }));
+    if (this.socket) {
+      this.socket.send(JSON.stringify({ message: body }));
+    } else {
+      this.openSocket().then((socket) => {
+        socket.send(JSON.stringify({ message: body }));
+      });
+    }
   }
 }
 

dist/adapter.js

     this.protocol = protocol;
     this.config = config;
     this.axios = axios;
-    console.error(this.getMode());
-    if (this.getMode() === 'socket') this.openSocket();
+    this.pollTimer = null;
+  }
+
+  /**
+   * Start listening for inbound messages 
+   */
+  start() {
+    switch (this.getMode()) {
+      case 'socket': this.openSocket(); break;
+      case 'http': {
+        const interval = ('pollInterval' in this.config) ? this.config.pollInterval : 5;
+        this.pollEveryXSeconds(interval);
+      } break;
+    }
   }
 
   /**
       });
   }
 
+  pollEveryXSeconds(interval) {
+    this.poll()
+    .then(() => {
+      if (this.pollTimer) clearTimeout(this.pollTimer);
+      this.pollTimer = setTimeout(this.poll(), interval*1000);
+    });
+  }
+
   /**
    * Call the GET /receive endpoint and process the messages with decode
    * 
   }
 
   socket_publish(topic, body) {
-    this.socket.send(JSON.stringify({ topic, message: body }));
+    if (this.socket) {
+      this.socket.send(JSON.stringify({ topic, message: body }));
+    } else {
+      this.openSocket().then((socket) => {
+        socket.send(JSON.stringify({ topic, message: body }));
+      });
+    }
   }
 
   /**
   }
 
   socket_broadcast(body) {
-    this.socket.send(JSON.stringify({ message: body }));
+    if (this.socket) {
+      this.socket.send(JSON.stringify({ message: body }));
+    } else {
+      this.openSocket().then((socket) => {
+        socket.send(JSON.stringify({ message: body }));
+      });
+    }
   }
 }
 

src/adapter/index.js

     this.protocol = protocol;
     this.config = config;
     this.axios = axios;
-    if (this.getMode() === 'socket') this.openSocket();
+    this.pollTimer = null;
+  }
+
+  /**
+   * Start listening for inbound messages 
+   */
+  start() {
+    switch (this.getMode()) {
+      case 'socket': this.openSocket(); break;
+      case 'http': {
+        const interval = ('pollInterval' in this.config) ? this.config.pollInterval : 5;
+        this.pollEveryXSeconds(interval);
+      } break;
+    }
   }
 
   /**
       });
   }
 
+  pollEveryXSeconds(interval) {
+    this.poll()
+    .then(() => {
+      if (this.pollTimer) clearTimeout(this.pollTimer);
+      this.pollTimer = setTimeout(this.poll(), interval*1000);
+    });
+  }
+
   /**
    * Call the GET /receive endpoint and process the messages with decode
    *