Support MQTT authentication. Koenkk#2

barrygwn · Apr 11, 2018 · 0055302 · 0055302
1 parent 2cfd078
commit 0055302
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/index.js b/index.js
@@ -17,7 +17,14 @@ if (!settings.devices) {
 
 // Setup client
 console.log(`Connecting to MQTT server at ${settings.mqtt.server}`)
-const client  = mqtt.connect(settings.mqtt.server)
+
+const options = {};
+if (settings.mqtt.user && settings.mqtt.password) {
+    options.username = settings.mqtt.user;
+    options.password = settings.mqtt.password;
+}
+
+const client  = mqtt.connect(settings.mqtt.server, options)
 const shepherd = new ZShepherd(
     settings.serial.port, 
     {