1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
publishing_mqtt = false
publishing_http = false
watchdog = tmr.create()
chip_id = string.format("%06X", node.chipid())
device_id = "esp8266_" .. chip_id
mqtt_prefix = "uart/" .. device_id
mqttclient = mqtt.Client(device_id, 120)
dofile("config.lua")
function wdr()
watchdog:stop()
watchdog:start()
end
function wd_err()
print("Watchdog:Err")
node.restart()
end
function mqtt_err(client)
print("MQTT:Err")
end
function wifi_err()
print("WiFi:Err " .. wifi.sta.status())
end
function setup_client()
print("MQTT:Rdy " .. mqtt_prefix)
publishing_mqtt = true
mqttclient:publish(mqtt_prefix .. "/state", "online", 0, 1, function(client)
client:subscribe(mqtt_prefix .. "/in", 0)
publishing_mqtt = false
end)
end
function connect_mqtt()
print("")
print("WiFi:Rdy " .. wifi.sta.getip())
mqttclient:on("connect", setup_client)
mqttclient:on("offline", mqtt_err)
--mqttclient:on("connfail", mqtt_err)
mqttclient:on("message", print_mqtt)
mqttclient:lwt(mqtt_prefix .. "/state", "offline", 0, 1)
mqttclient:connect(mqtt_host)
end
function connect_wifi()
wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, connect_mqtt)
wifi.eventmon.register(wifi.eventmon.STA_DHCP_TIMEOUT, wifi_err)
wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, wifi_err)
wifi.setmode(wifi.STATION)
wifi.sta.config(station_cfg)
wifi.sta.connect()
end
function print_mqtt(client, topic, message)
print("RX:" .. message)
wdr()
collectgarbage()
end
function publish_mqtt(topic, payload, retain)
if publishing_mqtt then
print("MQTT:Err")
else
publishing_mqtt = true
mqttclient:publish(topic, payload, 0, retain or 0, function(client)
publishing_mqtt = false
print("MQTT:OK")
wdr()
collectgarbage()
end)
end
end
function publish_influx(payload)
if publishing_http then
print("Influx:Err")
else
publishing_http = true
http.post(influx_url, influx_header, payload, function(code, data)
publishing_http = false
print("Influx:OK")
wdr()
collectgarbage()
end)
end
end
watchdog:register(90 * 1000, tmr.ALARM_SEMI, wd_err)
watchdog:start()
connect_wifi()
|
