From 478a69d834904f62cc4fb5ff52d5ed345e6859af Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sun, 1 Nov 2015 16:13:45 +0100
Subject: web: o Publishing messages when the name/description is changed from
 the web.

---
 diller-mqtt.js | 18 ++++++++++++++++--
 1 file changed, 16 insertions(+), 2 deletions(-)

(limited to 'diller-mqtt.js')

diff --git a/diller-mqtt.js b/diller-mqtt.js
index db6fc2b..e528bb4 100644
--- a/diller-mqtt.js
+++ b/diller-mqtt.js
@@ -4,5 +4,19 @@ var injector = new di.Injector();
 var config = injector.get(require('./src/DillerConfig'));
 config.configureLogging('mqtt');
 
-var dillerMqtt = injector.get(require('./src/mqtt/DillerMqtt'));
-dillerMqtt.run();
+/**
+ * @type {function(function(PgTx, DillerDao, Diller))} tx
+ */
+var tx = injector.get(require('./src/DillerTx'));
+
+/**
+ * @type DillerMqttClient
+ */
+var dillerMqttClient = injector.get(require('./src/mqtt/DillerMqttClient'));
+dillerMqttClient.run('mqtt');
+
+dillerMqttClient.on('message', function (topic, message, payload) {
+  tx(function (pg, dao, diller) {
+    return diller.onMessage(topic, message, payload);
+  });
+});
-- 
cgit v1.2.3