#!/usr/bin/lua
-function getConfig()
+require("json")
+require("socket")
+
+function startswith(String,Start)
+ if String then
+ return string.sub(String,1,string.len(Start))==Start
+ else
+ return False
+ end
+end
+
+function url_encode(str)
+ if (str) then
+ str = string.gsub (str, "\n", "\r\n")
+ str = string.gsub (str, "([^%w %-%_%.%~])",
+ function (c) return string.format ("%%%02X", string.byte(c)) end)
+ str = string.gsub (str, " ", "+")
+ end
+ return str
+end
+
+function capture(cmd, raw)
+ local f = assert(io.popen(cmd, 'r'))
+ local s = assert(f:read('*a'))
+ f:close()
+ if raw then return s end
+ s = string.gsub(s, '^%s+', '')
+ s = string.gsub(s, '%s+$', '')
+ s = string.gsub(s, '[\n\r]+', ' ')
+ return s
+end
+
+function mqtt_encode(str)
+ if (str) then
+ str = string.gsub (str, "\n", "")
+ str = string.gsub (str, "/", "-")
+ end
+ return str
+end
+
+function getConfig(configname)
local uci=require("uci")
local cur=uci.cursor()
- local config="weathermon"
+ local config
+ if configname then
+ config=configname
+ else
+ config="weathermon"
+ end
web_url = cur.get(config,"web","url")
web_user = cur.get(config,"web","user")
if serial_port then
command = "stty -F "..serial_port.." "..serial_baud
- os.execute(command)
+ capture(command)
end
end
if mqtt_host and not mqtt_topic then
- mqtt_topic = 'weathermon/'..web_devid
+ mqtt_topic = 'weathermon/{dev}/{type}/{id}/{param}'
end
if mqtt_host and not mqtt_alarm_topic then
- mqtt_alarm_topic = 'alarm/'..web_devid
+ mqtt_alarm_topic = 'alarm/{dev}/{type}/{id}'
end
end
-require "socket"
-
function sleep(sec)
socket.select(nil, nil, sec)
end
local res = {}
local idx = 1
-
while str:len()>0 do
pos = str:find(char);
if pos == nil then
end
function printLog(str)
- print(str)
if logging=="on" then
- os.execute("logger -t weathermon "..str)
+ capture("logger -t weathermon "..str)
+ else
+ print(str)
end
end
function submitValue(type,id,param,val)
- url = web_url.."?stype="..type.."&sid="..id.."¶m="..param.."&value="..val
+ url = web_url.."?stype="..url_encode(type).."&sid="..url_encode(id).."¶m="..url_encode(param).."&value="..url_encode(val)
command = "curl"
command = command.." -u "..web_user..":"..web_pass
end
- command = command.." \""..url.."\""
+ command = command.." \""..url.."\" 2>&1"
- os.execute(command)
- print()
+ result = capture(command)
+
+end
+
+function processJson(str)
+
+ msg=json.decode(str)
+
+ sensor={}
+
+ for key,value in pairs(msg) do
+ if value then
+ if key=="model" or key=="device" then
+ sensor_type=value
+ elseif key=="id" then
+ sensor_id=value
+ elseif key=='time' then
+ sensor_time=value
+ else
+ sensor[key]=value
+ end
+ end
+ end
+
+ if not (sensor_type==nil or sensor_id==nil or sensor_type=='' or sensor_id=='') then
+ if next(sensor)==nil then
+ sensor["command"]="alarm"
+ end
+ for k,v in pairs(sensor) do
+ printLog("Type = "..sensor_type..", ID = "..sensor_id..", Param = "..k..", Value = \""..v.."\"")
+ submitValue(sensor_type,sensor_id,k,v)
+ if mqtt_client then
+ mqtt_path=string.gsub(mqtt_topic,"{(.-)}",
+ function (name)
+ if name=="dev" then
+ return mqtt_encode(web_devid)
+ elseif name=="type" then
+ return mqtt_encode(sensor_type)
+ elseif name=="id" then
+ return mqtt_encode(sensor_id)
+ elseif name=="param" then
+ return k
+ else
+ return '{'..name..'}'
+ end
+ end)
+ mqtt_client:publish(mqtt_path,v)
+ end
+ end
+ else
+ printLog("Cannot parse sensor input: "..msg_body)
+ end
end
function processLine(str)
msg=splitStr(line,':')
- msg_type=msg[1] or nil
- msg_body=msg[2] or nil
+ msg_type=msg[1] or ''
+ msg_body=msg[2] or ''
if msg_type=="STATUS" then
printLog("Status: "..msg_body)
elseif msg_type=="ERROR" then
sensor_id = web_devid
for i,rec in ipairs(sens) do
recrd=splitStr(rec,'=')
- key=recrd[1] or nil
- value=recrd[2] or nil
+ key=recrd[1] or ''
+ value=recrd[2] or ''
if value then
if key=="TYPE" then
sensor_type=value
end
end
end
- mqtt_param = {}
- for k,v in pairs(sensor) do
- printLog("Type = "..sensor_type..", ID = "..sensor_id..", Param = "..k..", Value = "..v)
- submitValue(sensor_type,sensor_id,k,v)
- mqtt_param[k]=v
- end
- mqtt_msg = { type=sensor_type, id=sensor_id, data=mqtt_param }
- if mqtt_client then
- serializedString = json.encode(mqtt_msg)
- mqtt_client:publish(mqtt_topic,serializedString)
+ if not (sensor_type==nil or sensor_id==nil or sensor_type=='' or sensor_id=='') then
+ for k,v in pairs(sensor) do
+ printLog("Type = "..sensor_type..", ID = "..sensor_id..", Param = "..k..", Value = "..v)
+ submitValue(sensor_type,sensor_id,k,v)
+ if mqtt_client then
+ mqtt_path=string.gsub(mqtt_topic,"{(.-)}",
+ function (name)
+ if name=="dev" then
+ return web_devid
+ elseif name=="type" then
+ return sensor_type
+ elseif name=="id" then
+ return sensor_id
+ elseif name=="param" then
+ return k
+ else
+ return '{'..name..'}'
+ end
+ end)
+ mqtt_client:publish(mqtt_path,v)
+ end
+ end
+ else
+ printLog("Cannot parse sensor input: "..msg_body)
end
elseif msg_type=="ALARM" then
printLog("ALARM: "..msg_body)
mqtt_param = {}
for i,rec in ipairs(sens) do
recrd=splitStr(rec,'=')
- key=recrd[1] or nil
- value=recrd[2] or nil
+ key=recrd[1] or ''
+ value=recrd[2] or ''
if value then
if key=="TYPE" then
alarm_type=value
elseif key=="ID" then
alarm_id=value
- else
- mqtt_param[key]=value
end
end
end
- if mqtt_client then
- mqtt_msg = { type = alarm_type, id = alarm_id, data = mqtt_param }
- serializedString = json.encode(mqtt_msg)
- mqtt_client:publish(mqtt_alarm_topic,serializedString)
- end
- if alarm_exec then
- command=alarm_exec..
- " \""..string.gsub(alarm_type,"\"","\\\"")..
- "\" \""..string.gsub(alarm_id,"\"","\\\"")..
- "\" \""..string.gsub(msg_body,"\"","\\\"").."\""
- os.execute(command)
+ if not (alarm_type==nil or alarm_id==nil or alarm_type=='' or alarm_id=='') then
+ if mqtt_client then
+ mqtt_path=string.gsub(mqtt_alarm_topic,"{(.-)}",
+ function (name)
+ if name=="dev" then
+ return web_devid
+ elseif name=="type" then
+ return sensor_type
+ elseif name=="id" then
+ return sensor_id
+ else
+ return '{'..name..'}'
+ end
+ end)
+ mqtt_client:publish(mqtt_path,msg_body)
+ end
+ if alarm_exec then
+ command=alarm_exec..
+ " \""..string.gsub(alarm_type,"\"","\\\"")..
+ "\" \""..string.gsub(alarm_id,"\"","\\\"")..
+ "\" \""..string.gsub(msg_body,"\"","\\\"").."\""
+ capture(command)
+ end
+ else
+ printLog("Cannot parse alarm input: "..msg_body)
end
end
end
-getConfig()
+getConfig(arg[1])
if mqtt_host then
- MQTT = require "paho.mqtt"
- mqtt_client = MQTT.client.create(mqtt_host, mqtt_port)
+ MQTT = require "mosquitto"
+ mqtt_client = MQTT.new(mqtt_id)
if mqtt_user then
- mqtt_client:auth(mqtt_user, mqtt_passwd)
+ mqtt_client:login_set(mqtt_user, mqtt_passwd)
end
- mqtt_client:connect(mqtt_id)
- json = require( "json" )
+ mqtt_client:connect(mqtt_host,mqtt_port)
end
if serial_port then
end
while 1 do
line=serialin:read()
- print(line)
- processLine(line)
+ if line == nil then
+ break
+ end
+ printLog("Received: "..line);
+ if startswith(line,'{') then
+ processJson(line)
+ else
+ processLine(line)
+ end
end
projects / weathermon.git / blobdiff