Adds mqtt support

Author: vietk

app.js

@@ -1,4 +1,4 @@
-var chaconEmitter = require('./chaconEmitter');var chaconEmitter = require('./chaconEmitter');
+var chaconEmitter = require('./chaconEmitter');
 var express = require('express');
 var path = require('path');
 
@@ -16,6 +16,10 @@ function sendOffCommand(emitterId, deviceId) {
     chaconEmitter.transmit(chaconEmitter.buildOrder(emitterId, deviceId, false));
 }
 
+function sendDimCommand(emitterId, deviceId, dimValue) {
+    chaconEmitter.transmit(chaconEmitter.buildDimOrder(emitterId, deviceId, dimValue), true);
+}
+
 app.get('/switch/:deviceId/:emitterId/:state', function (req, res) {
     var deviceId = parseInt(req.params.deviceId);
     var emitterId = parseInt(req.params.emitterId);
@@ -46,7 +50,7 @@ app.get('/switch/:deviceId/:emitterId/:state', function (req, res) {
             // console.log('dimValue:%s', dimValue);
             if (0 <= dimValue && dimValue <= 100) {
                 // console.log('dimming!');
-                chaconEmitter.transmit(chaconEmitter.buildDimOrder(emitterId, deviceId, dimValue), true);
+                sendDimCommand(emitterId, deviceId, dimValue);
             }
         }
     }

mqtt-client.js

@@ -0,0 +1,52 @@
+var mqtt = require('mqtt');
+var client  = mqtt.connect('mqtt://mosquitto');
+var chaconEmitter = require('./chaconEmitter');
+
+chaconEmitter.init();
+
+var switchTopic = 'chacon/switch';
+var dimmerTopic = 'chacon/dimmer';
+var emitterId = 12325261;
+
+client.subscribe(switchTopic);
+client.subscribe(dimmerTopic);
+
+client.on('message', function (topic, message) {
+
+    var command = JSON.parse(message.toString());
+    var deviceId = command.deviceId;
+    if (topic === switchTopic) {
+        if (command.value ===  'ON') {
+            sendOnCommand(emitterId, deviceId);
+        }
+        else if (command.value === 'OFF') {
+            sendOffCommand(emitterId, deviceId);
+        }
+    }
+    else if (topic === dimmerTopic) {
+        if (command.value === 'ON') {
+            sendOnCommand(emitterId, deviceId);
+        }
+        else if (command.value === 'OFF') {
+            sendOffCommand(emitterId, deviceId);
+        }
+        else {
+            var dimValue = parseInt(command.value);
+            if (0 <= dimValue && dimValue <= 100) {
+                sendDimCommand(emitterId, deviceId, dimValue);
+            }
+        }
+    }
+});
+
+function sendOnCommand(emitterId, deviceId) {
+    chaconEmitter.transmit(chaconEmitter.buildOrder(emitterId, deviceId, true));
+}
+
+function sendOffCommand(emitterId, deviceId) {
+    chaconEmitter.transmit(chaconEmitter.buildOrder(emitterId, deviceId, false));
+}
+
+function sendDimCommand(emitterId, deviceId, dimValue) {
+    chaconEmitter.transmit(chaconEmitter.buildDimOrder(emitterId, deviceId, dimValue), true);
+}

package.json

@@ -9,5 +9,6 @@
     "debug": "~2.6.9",
     "express": "~4.15.5",
     "wiringpi-node": "^2.4.4"
+    "mqtt": "^2.14.0"
   }
 }