fix(mqtt): error handling and expose mqtt data handler

Author: hugocortes

lib/Core.js

@@ -4,6 +4,7 @@ const classes = {
   Executor: require('./Services/executor'),
   Hermes: require('./Services/hermes'),
   Prometheus: require('./Services/prometheus'),
+  Starbase: require('./Services/starbase'),
   Streaming: require('./Services/streaming'),
   Timekeeper: require('./Services/timekeeper')
 };

lib/Services/starbase.js

@@ -21,7 +21,7 @@ class Starbase {
    * @param {string}   payload[].unit
    */
   publishJSON(clientId, clientSecret, hardwareId, payload) {
-    const mqttClient = new MQTT({
+    let mqttClient = new MQTT({
       username: clientId,
       password: clientSecret,
       clientId: hardwareId,
@@ -32,15 +32,30 @@ class Starbase {
       try {
         mqttClient.connect(async (err, client) => {
           if (err) {
+            client.end();
             return reject(err);
           }
 
           mqttClient.rawWrite('json', JSON.stringify(payload));
           await new Promise(resolve => setTimeout(resolve, 1000));
           client.end();
+          mqttClient = null;
+          return resolve();
+        });
+
+        mqttClient.client.on('error', () => {
+          mqttClient.client.end();
+          mqttClient = null;
+          return resolve();
+        });
+        mqttClient.client.on('disconnect', () => {
+          mqttClient.client.end();
+          mqttClient = null;
           return resolve();
         });
       } catch (error) {
+        mqttClient.client.end();
+        mqttClient = null;
         return resolve();
       }
     });