Add new methods, property and the test.

Change handelMessage into method.
Add reconnecting property, getLastMessageId and removeOutgoingMessage methods because it is on MQTT.js API document.

Add new test using getLastMessageId.

Author: Kwon Hyungjoo

index.js

@@ -9,18 +9,14 @@ class AsyncClient {
     this._client = client;
   }
 
-  set handleMessage (newHandler) {
-    this._client.handleMessage = newHandler;
-  }
-
-  get handleMessage () {
-    return this._client.handleMessage;
-  }
-
   get connected () {
     return this._client.connected;
   }
 
+  get reconnecting () {
+    return this._client.reconnecting;
+  }
+
   publish (...args) {
     return new Promise((resolve, reject) => {
       this._client.publish(...args, (err, result) => {
@@ -69,10 +65,18 @@ class AsyncClient {
     return this._client.eventNames(...args);
   }
 
+  getLastMessageId (...args) {
+    return this._client.getLastMessageId(...args);
+  }
+
   getMaxListeners (...args) {
     return this._client.getMaxListeners(...args);
   }
 
+  handleMessage (...args) {
+    return this._client.handleMessage(...args);
+  }
+
   listenerCount (...args) {
     return this._client.listenerCount(...args);
   }
@@ -101,6 +105,10 @@ class AsyncClient {
     return this._client.prependOnceListener(...args);
   }
 
+  rawListeners (...args) {
+    return this._client.rawListeners(...args);
+  }
+
   removeAllListeners (...args) {
     return this._client.removeAllListeners(...args);
   }
@@ -109,13 +117,14 @@ class AsyncClient {
     return this._client.removeListener(...args);
   }
 
+  removeOutgoingMessage (...args) {
+    return this._client.removeOutgoingMessage(...args);
+  }
+
   setMaxListeners (...args) {
     return this._client.setMaxListeners(...args);
   }
 
-  rawListeners (...args) {
-    return this._client.rawListeners(...args);
-  }
 }
 
 

test.js

@@ -104,6 +104,19 @@ function runTests () {
       return client.end();
     });
   });
+
+  test('Calling getLastMessageId should return number after published', t => {
+    t.plan(1);
+
+    const client = AsyncMQTT.connect(SERVER_URL);
+
+    client.publish('example', 'test', {
+      qos: 1
+    }).then(() => {
+      t.ok('number' === typeof client.getLastMessageId(), 'Message id is number');
+      return client.end();
+    });
+  });
 }
 
 // Taken from MQTT.js tests