DB "canary" added - with fail/restart when connection dropped

[weathermon.git] / server / weathermon-mqtt

diff --git a/server/weathermon-mqtt b/server/weathermon-mqtt
index 025deec54de5d4e3f5773fead99f765233409cc2..d591abe30ee11dea85cf3ee4420408dab43cde6c 100755 (executable)
--- a/server/weathermon-mqtt
+++ b/server/weathermon-mqtt
@@ -1,4 +1,4 @@
-#!/usr/bin/lua
+#!/usr/bin/lua5.1

 
 local random = math.random
 local json = require "json"
 
 local random = math.random
 local json = require "json"


@@ -13,20 +13,36 @@ local function uuid()
 end
 
 function process_MSG(mid, topic, payload)
 end
 
 function process_MSG(mid, topic, payload)

-  print(topic, payload)

   pcall(function(topic,payload)
     payload = json.decode(payload)
     local time = os.date(payload['Time'])
   pcall(function(topic,payload)
     payload = json.decode(payload)
     local time = os.date(payload['Time'])

+    if not time then time = os.date(payload['time']); end 
+    local model = payload['model']
+    local id = payload['id']
+    if not model then
+      device = payload['device']
+      if device then
+        model = device['model']
+        id = device['ieeeAddr']
+      end
+    end

     for sensor_type,sensor_data in pairs(payload) do
     for sensor_type,sensor_data in pairs(payload) do

-      if sensor_type ~= "Time" and sensor_type ~= "TempUnit" then
-        for param,value in pairs(sensor_data) do
-          conn:execute(string.format("CALL meteo.submit_mqtt('%s','%s','%s','%s',NULL)", topic,sensor_type,param,value))
+      if sensor_type ~= "Time" and sensor_type ~= "TempUnit" and sensor_type ~= "model" and sensor_type ~="id" and sensor_type ~= "time" and sensor_type ~= "device" and sensor_type ~="linkquality" and sensor_type ~= "battery" and sensor_type ~= "last_seen" and sensor_type ~= "voltage" then
+        if model then
+          conn:execute(string.format("CALL meteo.submit_mqtt('%s','%s','%s','%s',NULL)", topic,model,sensor_type,sensor_data))

           conn:commit()
           conn:commit()

-          print(topic,sensor_type,param,value)
-        end
+          print(string.format("%s/%s (%s) -> %s", topic, model, sensor_type, sensor_data))
+        else 
+          for param,value in pairs(sensor_data) do
+            conn:execute(string.format("CALL meteo.submit_mqtt('%s','%s','%s','%s',NULL)", topic,sensor_type,param,value))
+            conn:commit()
+            print(string.format("%s/%s (%s) -> %s", topic, sensor_type, param, value))
+          end
+        end  

       end
     end
   end, topic, payload) 
       end
     end
   end, topic, payload) 

+  conn:execute('select 1') -- will fail if connection to DB broken

 end
 
 uci = require "uci"
 end
 
 uci = require "uci"