Draft: Resolve "Implement websockets client"

Closes #2

dist/adapter.esm.js

       });
   }
 
+  /**
+   * Setup a timer to call poll every interval seconds
+   * @param {int} interval 
+   */
   pollEveryXSeconds(interval) {
     if (this.pollTimer) clearTimeout(this.pollTimer);
     this.pollTimer = setTimeout(this.pollEveryXSeconds.bind(this, interval), interval*1000);
       });
   }
 
+  /**
+   * Process a message received either from poll 
+   * or from socket.onMessage 
+   * @param {object} message 
+   */
   receive(message) {
     try {
       const parsed = JSON.parse(message.message);
     }
   }
 
+  /**
+   * Decide whether to use http or socket for comms 
+   * with the backbone 
+   * @returns string 
+   */
   getMode() {
     return ('mode' in this.config) ? this.config.mode : 'http'; 
   }
 
+  /**
+   * Create a new socket connection and send an authentication
+   * message. Websocket doesn't support headers so as soon 
+   * as the socket is open a message is sent containing 
+   * the authorisation header to authenticate the connection 
+   */
   openSocket() {
     this.getAuthorizationHeader()
     .then((headers) => {
 
       const protocols = [];
-      const options = { headers };
-
+      
       const socket = new WebSocket(
         this.config.socket, 
         protocols, 
-        options,
       );
 
       socket.addEventListener('open', () => {
     });
   }
   
+  /**
+   * If the socket connection is lost ensure that a new socket 
+   * is opened rather than continuing to send messages on this
+   * socket 
+   */
   closeSocket() {
     this.socket = null;
   }
    * Messages should be passed through encode before sending
    * @param {string} topic
    * @param {string} body
-   * @param {boolean} is_retry
    * @returns
    */
   publish(topic, body) {
     return response;
   }
 
+  /**
+   * Send via a POST to /send
+   * @param {string} topic 
+   * @param {string} body 
+   * @param {boolean} is_retry
+   * @returns Promise
+   */
   http_publish(topic, body, is_retry = false) {
     let adapterConfig = this.config;
     return this.getAuthorizationHeader()
       });
   }
 
+  /**
+   * Publish via websocket socket.send
+   * @param {string} topic 
+   * @param {string} body 
+   */
   socket_publish(topic, body) {
     if (this.socket) {
       this.socket.send(JSON.stringify({ topic, message: body }));
    *
    * Messages should be passed through encode before sending
    * @param {string} body
-   * @param {boolean} is_retry
    * @returns
    */
   broadcast(body) {
     return response;
   }
 
+  /**
+   * Broadcast via POST to /notify
+   * @param {string} body 
+   * @param {boolean} is_retry
+   * @returns Promise
+   */
   http_broadcast(body, is_retry = false) {
     let adapterConfig = this.config;
     return this.getAuthorizationHeader()
       });
   }
 
+  /**
+   * Broadcast via websocket socket.send
+   * @param {string} body 
+   */
   socket_broadcast(body) {
     if (this.socket) {
       this.socket.send(JSON.stringify({ message: body }));