From fda6a95359a3865c7c98834054adbedfb23fdcaf Mon Sep 17 00:00:00 2001 From: uwap Date: Sat, 20 Jan 2018 00:37:46 +0100 Subject: [PATCH] Only subscribe to each topic once --- config/rzl.js | 3 ++- src/connectMqtt.js | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/config/rzl.js b/config/rzl.js index cc016e9..59aef6b 100644 --- a/config/rzl.js +++ b/config/rzl.js @@ -5,7 +5,8 @@ const config : Config = { space: { name: "RZL", color: "orange", - mqtt: "ws://map.rzl:1884" + mqtt: "ws://192.168.178.90:1884" + //mqtt: "ws://map.rzl:1884" }, topics: [ { diff --git a/src/connectMqtt.js b/src/connectMqtt.js index d7b2f93..4360734 100644 --- a/src/connectMqtt.js +++ b/src/connectMqtt.js @@ -1,5 +1,6 @@ // @flow import mqtt from "mqtt"; +import _ from "lodash"; // TODO: type mqtt.js @@ -21,7 +22,7 @@ export default function connectMqtt( const client = mqtt.connect(url); client.on("connect", () => { if (settings.subscribe != null) { - client.subscribe(settings.subscribe); + client.subscribe(_.uniq(settings.subscribe)); } if (settings.onConnect != null) { settings.onConnect(client);