prevent wedged device if AWS IoT outage

Author: heythisisnate

src/lfs/aws_iot.lua

@@ -8,6 +8,7 @@ local topics = settings.aws.topics
 
 local sendTimer = tmr.create()
 local timeout = tmr.create()
+local mqttTimeout = tmr.create()
 local heartbeat = tmr.create()
 
 timeout:register(3000, tmr.ALARM_SEMI, function()
@@ -49,6 +50,11 @@ heartbeat:register(200, tmr.ALARM_AUTO, function(t)
   t:interval(300000) -- 5 minutes
 end)
 
+mqttTimeout:register(10000, tmr.ALARM_SEMI, function(t)
+	print("Heap:", node.heap(), 'Couldn\'t connect to AWS IoT! Restarting.')
+	node.restart()
+end)
+
 local function startLoop()
 	print("Heap:", node.heap(), 'Connecting to AWS IoT Endpoint:', settings.endpoint)
 
@@ -65,6 +71,7 @@ local function startLoop()
 		end
 	end)
 
+	mqttTimeout:start()
 	c:connect(settings.endpoint)
 end
 
@@ -101,6 +108,7 @@ c:on('message', function(_, topic, message)
 end)
 
 c:on('connect', function()
+	mqttTimeout:stop()
 	print("Heap:", node.heap(), "mqtt: connected")
 	print("Heap:", node.heap(), "Subscribing to topic:", topics.switch)
 	c:subscribe(topics.switch)

src/lfs/device.lua

@@ -2,7 +2,7 @@ local me = {
   id = "uuid:8f655392-a778-4fee-97b9-4825918" .. string.format("%x", node.chipid()),
   name = "Konnected",
   hwVersion = "2.3.0",
-  swVersion = "2.3.5",
+  swVersion = "2.3.6",
   http_port = math.floor(node.chipid()/1000) + 8000,
   urn = "urn:schemas-konnected-io:device:Security:1"
 }

src/lfs/mqtt_ws.lua

@@ -70,7 +70,10 @@ local function Client(aws_settings)
 			client:emit('message', parsed.topic, parsed.payload)
 		elseif parsed.cmd == 2 then
 			client:emit('connect')
+		else
+			print(parsed)
 		end
+
 	end)
 
 	ws:on('close', function(_, status)