core:

o Adding device_status table containing the latest device status.
mqtt:
o Listening on $SYS/broker/log, parse out messages about clients connecting and disconnecting and store in database.

1 files changed, 4 insertions, 1 deletions

diff --git a/src/mqtt/DillerMqttClient.js b/src/mqtt/DillerMqttClient.js
index 62f5aef..b9cf01b 100644
--- a/src/mqtt/DillerMqttClient.js
+++ b/src/mqtt/DillerMqttClient.js
@@ -12,7 +12,7 @@ function DillerMqttClient(config, tx) {
   var mqttClient;
   var hostname = os.hostname();
 
-  function run(clientType) {
+  function run(clientType, subscribeToLog) {
     if (mqttClient) {
       throw 'Already connected';
     }
@@ -36,6 +36,9 @@ function DillerMqttClient(config, tx) {
     mqttClient.on('connect', function () {
       log.info('Connected');
       mqttClient.subscribe('/diller/#');
+      if (subscribeToLog) {
+        mqttClient.subscribe('$SYS/broker/log/#');
+      }
     });
   }