249 lines
7.9 KiB
Lua
249 lines
7.9 KiB
Lua
-- Global variable
|
|
local m=nil
|
|
local mqttConnected = false
|
|
-- Temp:
|
|
local t=nil
|
|
local tw=nil
|
|
local tcol=nil
|
|
|
|
function handleSingleCommand(client, topic, data)
|
|
if (data == "ON") then
|
|
briPer=100
|
|
m:publish(mqttPrefix .. "/clock", "ON", 0, 0)
|
|
elseif (data == "OFF") then
|
|
briPer=0
|
|
m:publish(mqttPrefix .. "/clock", "OFF", 0, 0)
|
|
elseif ((data:sub(1,1) == "#" and data:len() == 7) or (string.match(data, "%d+,%d+,%d+"))) then
|
|
local red=0
|
|
local green=0
|
|
local blue=0
|
|
if (data:sub(1,1) == "#") then
|
|
red = tonumber(data:sub(2,3), 16)
|
|
green = tonumber(data:sub(4,5), 16)
|
|
blue = tonumber(data:sub(6,7), 16)
|
|
else
|
|
red, green, blue = string.match(data, "(%d+),(%d+),(%d+)")
|
|
end
|
|
colorBg=string.char(green * briPer / 100, red * briPer / 100, blue * briPer / 100)
|
|
print("Updated BG: " .. tostring(red) .. "," .. tostring(green) .. "," .. tostring(blue) )
|
|
m:publish(mqttPrefix .. "/background", tostring(red) .. "," .. tostring(green) .. "," .. tostring(blue), 0, 0)
|
|
else
|
|
if (tonumber(data) >= 0 and tonumber(data) <= 100) then
|
|
briPer=tonumber(data)
|
|
m:publish(mqttPrefix .. "/clock", tostring(data), 0, 0)
|
|
else
|
|
print "Unknown MQTT command"
|
|
end
|
|
end
|
|
|
|
end
|
|
|
|
-- Parse MQTT data and extract color
|
|
-- @param data MQTT information
|
|
-- @param row string of the row e.g. "row1" used to publish current state
|
|
-- @param per percent the color should be dimmed
|
|
function parseBgColor(data, row, per)
|
|
local red=nil
|
|
local green=nil
|
|
local blue=nil
|
|
if (data:sub(1,1) == "#") then
|
|
red = tonumber(data:sub(2,3), 16)
|
|
green = tonumber(data:sub(4,5), 16)
|
|
blue = tonumber(data:sub(6,7), 16)
|
|
else
|
|
red, green, blue = string.match(data, "(%d+),(%d+),(%d+)")
|
|
end
|
|
if ((red ~= nil) and (green ~= nil) and (blue ~= nil) ) then
|
|
m:publish(mqttPrefix .. "/"..row, tostring(red) .. "," .. tostring(green) .. "," .. tostring(blue), 0, 0)
|
|
if (per ~= nil) then
|
|
return string.char(green * per / 100, red * per / 100, blue * per / 100)
|
|
else
|
|
return string.char(green , red , blue )
|
|
end
|
|
else
|
|
return nil
|
|
end
|
|
end
|
|
|
|
function readTemp(ds18b20)
|
|
if (ds18b20 ~= nil) then
|
|
addrs=ds18b20.addrs()
|
|
-- Total DS18B20 numbers
|
|
sensors=table.getn(addrs)
|
|
local temp1=0
|
|
if (sensors >= 1) then
|
|
temp1=ds18b20.read(addrs[0])
|
|
else
|
|
print("No sensor DS18B20 found")
|
|
end
|
|
return temp1
|
|
else
|
|
print("No DS18B20 lib")
|
|
return nil
|
|
end
|
|
end
|
|
|
|
-- Connect or reconnect to mqtt server
|
|
function reConnectMqtt()
|
|
if (not mqttConnected) then
|
|
m:connect(mqttServer, 1883, false, function(c)
|
|
print("MQTT is connected")
|
|
mqttConnected = true
|
|
-- subscribe topic with qos = 0
|
|
m:subscribe(mqttPrefix .. "/cmd/#", 0)
|
|
local tmr1 = tmr.create()
|
|
tmr1:register(1000, tmr.ALARM_SINGLE, function (dummyTemp)
|
|
-- publish a message with data = hello, QoS = 0, retain = 0
|
|
m:publish(mqttPrefix .. "/ip", tostring(wifi.sta.getip()), 0, 0)
|
|
local red = string.byte(colorBg,2)
|
|
local green = string.byte(colorBg,1)
|
|
local blue = string.byte(colorBg,3)
|
|
m:publish(mqttPrefix .. "/background", tostring(red) .. "," .. tostring(green) .. "," .. tostring(blue), 0, 0)
|
|
tmr1:unregister()
|
|
end)
|
|
tmr1:start()
|
|
end,
|
|
function(client, reason)
|
|
print("failed reason: " .. reason)
|
|
mqttConnected = false
|
|
end)
|
|
end
|
|
end
|
|
|
|
-- MQTT extension
|
|
function registerMqtt()
|
|
m = mqtt.Client("wordclock", 120)
|
|
-- on publish message receive event
|
|
m:on("message", function(client, topic, data)
|
|
print("MQTT " .. topic .. ":" )
|
|
if data ~= nil then
|
|
print(data)
|
|
if (topic == (mqttPrefix .. "/cmd/single")) then
|
|
handleSingleCommand(client, topic, data)
|
|
elseif (topic == (mqttPrefix .. "/cmd/temp")) then
|
|
if (( data == "" ) or (data == nil)) then
|
|
tw=nil
|
|
tcol=nil
|
|
print("MQTT | wordclock failed")
|
|
else
|
|
-- generate the temperatur to display, once as it will not change
|
|
local dispTemp = tonumber(data)
|
|
collectgarbage()
|
|
mydofile("wordclock")
|
|
if (wc ~= nil) then
|
|
tw, tcol = wc.temp(dw, rgbBuffer, invertRows)
|
|
wc = nil
|
|
print("MQTT | generated words for: " + tostring(dispTemp))
|
|
else
|
|
print("MQTT | wordclock failed")
|
|
end
|
|
end
|
|
else
|
|
-- Handle here the /cmd/# sublevel
|
|
if (string.match(topic, "telnet$")) then
|
|
client:publish(mqttPrefix .. "/telnet", tostring(wifi.sta.getip()), 0, 0)
|
|
ws2812.write(string.char(0,0,0):rep(114))
|
|
print("Stop Mqtt and Temp")
|
|
m=nil
|
|
t=nil
|
|
mqttConnected = false
|
|
if (mlt ~= nil) then
|
|
mlt:unregister()
|
|
else
|
|
print("main loop unstoppable")
|
|
end
|
|
collectgarbage()
|
|
mydofile("telnet")
|
|
if (startTelnetServer ~= nil) then
|
|
startTelnetServer()
|
|
else
|
|
print("Cannost start Telnet Server!")
|
|
end
|
|
elseif (string.match(topic, "color$")) then
|
|
color = parseBgColor(data, "color")
|
|
print("Updated color" )
|
|
elseif (string.match(topic, "color1$")) then
|
|
color1 = parseBgColor(data, "color1")
|
|
print("Updated color1" )
|
|
elseif (string.match(topic, "color2$")) then
|
|
color2 = parseBgColor(data, "color2")
|
|
print("Updated color2" )
|
|
elseif (string.match(topic, "color3$")) then
|
|
color3 = parseBgColor(data, "color3")
|
|
print("Updated color3" )
|
|
elseif (string.match(topic, "color4$")) then
|
|
color4 = parseBgColor(data, "color4")
|
|
print("Updated color4" )
|
|
else
|
|
for i=1,10,1 do
|
|
if (string.match(topic, "row".. tostring(i) .."$")) then
|
|
rowbgColor[i] = parseBgColor(data, "row" .. tostring(i), briPer)
|
|
print("Updated row" .. tostring(i) )
|
|
return
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end)
|
|
m:on("offline", function(client)
|
|
print("MQTT Disconnected")
|
|
mqttConnected = false
|
|
end
|
|
)
|
|
reConnectMqtt()
|
|
end
|
|
|
|
function connectedMqtt()
|
|
return mqttConnected
|
|
end
|
|
|
|
function startMqttClient()
|
|
if (mqttServer ~= nil and mqttPrefix ~= nil) then
|
|
registerMqtt()
|
|
print "Started MQTT client"
|
|
local dstimer = tmr.create()
|
|
dstimer:register(123, tmr.ALARM_SINGLE, function (kTemp)
|
|
if (file.open("ds18b20_diet.lc")) then
|
|
t=true
|
|
print "Setup temperatur"
|
|
end
|
|
end)
|
|
dstimer:start()
|
|
local oldBrightness=0
|
|
oldTemp=0
|
|
local mqtttimer = tmr.create()
|
|
mqtttimer:register(6001, tmr.ALARM_AUTO, function (kTemp)
|
|
if (mqttConnected) then
|
|
local heapusage = node.heap()
|
|
local temperatur = nil
|
|
if (oldBrightness ~= briPer) then
|
|
m:publish(mqttPrefix .. "/brightness", tostring(briPer), 0, 0)
|
|
oldBrightness = briPer
|
|
else
|
|
if ((t ~= nil) and (heapusage > 12000)) then
|
|
local ds18b20=require("ds18b20_diet")
|
|
ds18b20.setup(2) -- GPIO4
|
|
readTemp(ds18b20) -- read once, to setup chip
|
|
temperatur=readTemp(ds18b20)
|
|
if (temperatur == 8500) then
|
|
temperatur=nil
|
|
end
|
|
ds18b20=nil
|
|
else
|
|
collectgarbage()
|
|
end
|
|
if (temperatur ~= nil and temperatur ~= oldTemp) then
|
|
oldTemp = temperatur
|
|
m:publish(mqttPrefix .. "/temp", tostring(temperatur/100)..".".. tostring(temperatur%100), 0, 0)
|
|
else
|
|
m:publish(mqttPrefix .. "/heap", tostring(heapusage), 0, 0)
|
|
end
|
|
end
|
|
end
|
|
end)
|
|
mqtttimer:start()
|
|
end
|
|
end
|
|
|