From 16722180b6c6daa1052546ed6997f0261d39c3c0 Mon Sep 17 00:00:00 2001 From: mik Date: Mon, 20 Feb 2017 10:33:09 +0100 Subject: [PATCH 1/2] new base topic --- software/config.lua | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/software/config.lua b/software/config.lua index 0795b12..1faa60b 100644 --- a/software/config.lua +++ b/software/config.lua @@ -8,7 +8,7 @@ module.mqtt = { host = "mqtt.devlol.org", port = 1883, id = "supermariocount" .. node.chipid(), - endpoint = 'supermariocount/', + endpoint = 'devlol/h19/mainroom/supermariocount/', user = nil, password = nil, secure = true From 6471fb13d562a3c2b7acfa019f870aa373656680 Mon Sep 17 00:00:00 2001 From: mik Date: Mon, 20 Feb 2017 10:48:00 +0100 Subject: [PATCH 2/2] add lwt for status subtopic, add reconnect --- software/mqtt-client.lua | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/software/mqtt-client.lua b/software/mqtt-client.lua index 43f0525..c830827 100644 --- a/software/mqtt-client.lua +++ b/software/mqtt-client.lua @@ -13,7 +13,9 @@ function module.setup(opts, connected) module.options = opts client = mqtt.Client(module.options.id, 120, module.options.user, module.options.password) - client:on("connect", connected) + client:lwt((module.options.endpoint .. "status", "offline", 0, 1) + client:on("connect", function (client) client:publish(module.options.endpoint .. "status", "online", 0, 1)) + client:on("offline", function (client) module.connect(module.options, connected)) module.connect(module.options, connected) return module end