added async promise logic

Author: RyLee Harrison

.eslintrc.json

@@ -1,9 +1,15 @@
 {
   "env": {
+    "es6": true,
     "browser": true,
     "node": true,
     "mocha": true
   },
+
+  "parserOptions": {
+    "ecmaVersion": 2017
+  },
+
   "rules": {
     "quotes": [
       1,
@@ -21,7 +27,9 @@
     "indent": [
       2,
       2,
-      {"SwitchCase": 1}
+      {
+        "SwitchCase": 1
+      }
     ],
     "brace-style": [
       2,
@@ -46,8 +54,10 @@
       "always"
     ],
     "keyword-spacing": [
-        2,
-        {"after": true}
+      2,
+      {
+        "after": true
+      }
     ],
     "space-before-blocks": 2,
     "spaced-comment": [
@@ -59,9 +69,9 @@
         ],
         "markers": [
           "eslint",
-	  "jshint",
+          "jshint",
           "global"
-         ]
+        ]
       }
     ],
     "strict": [
@@ -72,4 +82,4 @@
     "camelcase": 0,
     "new-cap": 0
   }
-}
+}

index.js

@@ -1,104 +1,106 @@
+'use strict'
+
 const mqtt = require('mqtt');
 
 const RegularClientPrototype = mqtt.MqttClient.prototype;
 
 class AsyncClient {
-  constructor(client) {
-    this.client = client
+  constructor (client) {
+    this._client = client;
   }
 
-  set handleMessage(newHandler) {
-    this.client.handleMessage = newHandler;
+  set handleMessage (newHandler) {
+    this._client.handleMessage = newHandler;
   }
 
-  get handleMessage() {
-    return this.client.handleMessage;
+  get handleMessage () {
+    return this._client.handleMessage;
   }
 
-  publish(...args) {
-    return Promise.resolve(this.client.publish(...args))
-  }
-  
-  subscribe(...args) {
-    return Promise.resolve(this.client.subscribe(...args))
+  async publish (...args) {
+    return this._client.publish(...args);
   }
-  
-  unsubscribe(...args) {
-    return Promise.resolve(this.client.unsubscribe(...args))
+
+  async subscribe (...args) {
+    return this._client.subscribe(...args)
   }
 
-  end(...args) {
-    return Promise.resolve(this.client.end(...args))
+  async unsubscribe (...args) {
+    return this._client.unsubscribe(...args);
   }
 
-  addListener(...args) {
-    this.client.addListener(...args);
+  async end (...args) {
+    return this._client.end(...args);
   }
 
-  emit(...args) {
-    this.client.emit(...args);
+  addListener (...args) {
+    return this._client.addListener(...args);
   }
 
-  eventNames(...args) {
-    this.client.eventNames(...args);
+  emit (...args) {
+    return this._client.emit(...args);
   }
 
-  getMaxListeners(...args) {
-    this.client.getMaxListeners(...args);
+  eventNames (...args) {
+    return this._client.eventNames(...args);
   }
 
-  listenerCount(...args) {
-    this.client.listenerCount(...args);
+  getMaxListeners (...args) {
+    return this._client.getMaxListeners(...args);
   }
 
-  listeners(...args) {
-    this.client.listeners(...args);
+  listenerCount (...args) {
+    return this._client.listenerCount(...args);
   }
 
-  off(...args) {
-    this.client.off(...args);
+  listeners (...args) {
+    return this._client.listeners(...args);
   }
 
-  on(...args) {
-    this.client.on(...args);
+  off (...args) {
+    return this._client.off(...args);
   }
 
-  once(...args) {
-    this.client.once(...args);
+  on (...args) {
+    return this._client.on(...args);
   }
 
-  prependListener(...args) {
-    this.client.prependListener(...args);
+  once (...args) {
+    return this._client.once(...args);
   }
 
-  prependOnceListener(...args) {
-    this.client.prependOnceListener(...args);
+  prependListener (...args) {
+    return this._client.prependListener(...args);
   }
 
-  removeAllListeners(...args) {
-    this.client.removeAllListeners(...args);
+  prependOnceListener (...args) {
+    return this._client.prependOnceListener(...args);
   }
 
-  removeListener(...args) {
-    this.client.removeListener(...args);
+  removeAllListeners (...args) {
+    return this._client.removeAllListeners(...args);
   }
 
-  setMaxListeners(...args) {
-    this.client.setMaxListeners(...args);
+  removeListener (...args) {
+    return this._client.removeListener(...args);
   }
 
-  rawListeners(...args) {
-    this.client.rawListeners(...args);
+  setMaxListeners (...args) {
+    return this._client.setMaxListeners(...args);
   }
-};
 
-const connect = (brokerUrl, opts = {}) => {
-  const client = mqtt.connect(brokerUrl, opts);
-  const asyncClient = new AsyncClient(client);
-  return asyncClient
+  rawListeners (...args) {
+    return this._client.rawListeners(...args);
+  }
 }
 
+
 module.exports = {
-  connect,
+  connect (brokerURL, opts) {
+    const client = mqtt.connect(brokerURL, opts);
+    const asyncClient = new AsyncClient(client);
+  
+    return asyncClient;
+  },
   AsyncClient
-}
+};