Domoticz

Code: Select all

[{"id":"53864ab3.6d5304","type":"tab","label":"Temperature2Domoticz","disabled":false,"info":""},{"id":"5490d5ff.8a5774","type":"inject","z":"53864ab3.6d5304","name":"Inject 5 Minutes","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"300","crontab":"","once":true,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":570,"y":160,"wires":[["eaf2f3b6.01dd48"]]},{"id":"eaf2f3b6.01dd48","type":"http request","z":"53864ab3.6d5304","name":"Get Temperature","method":"GET","ret":"obj","paytoqs":"ignore","url":"http://www.temperatur.nu/termo/abro/temp.txt","tls":"","persist":false,"proxy":"","authType":"","x":810,"y":160,"wires":[["66d5458.1a526bc","4fbd99e.7a945e8"]]},{"id":"66d5458.1a526bc","type":"debug","z":"53864ab3.6d5304","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":1030,"y":220,"wires":[]},{"id":"4fbd99e.7a945e8","type":"function","z":"53864ab3.6d5304","name":"Prepare for Domoticz","func":"msg.payload = {\"command\":\"udevice\",\"idx\":11,\"nvalue\":0,\"svalue\":msg.payload.toString()};\nreturn msg;","outputs":1,"noerr":0,"initialize":"","finalize":"","libs":[],"x":1060,"y":160,"wires":[["1ccce439.04623c","844c19c8.4eba3"]]},{"id":"1ccce439.04623c","type":"debug","z":"53864ab3.6d5304","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"false","statusVal":"","statusType":"auto","x":1290,"y":220,"wires":[]},{"id":"844c19c8.4eba3","type":"mqtt out","z":"53864ab3.6d5304","name":"","topic":"domoticz/in","qos":"","retain":"","respTopic":"","contentType":"","userProps":"","correl":"","expiry":"","broker":"f9f13036.e28b58","x":1290,"y":160,"wires":[]},{"id":"f9f13036.e28b58","type":"mqtt-broker","name":"localhost","broker":"127.0.0.1","port":"1883","clientid":"","usetls":false,"compatmode":true,"keepalive":"60","cleansession":true,"birthTopic":"","birthQos":"0","birthRetain":"false","birthPayload":"","closeTopic":"","closeQos":"0","closePayload":"","willTopic":"","willQos":"0","willPayload":""}]

Code: Select all

utils = require("Utils") 

function os.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
 

return {
	on = {
		timer = {
			'every 15 minutes' -- just an example to trigger the request
		},
		httpResponses = {
			'trigger' -- must match with the callback passed to the openURL command
		}
	},
	logging = {
		level = domoticz.LOG_INFO,
		marker = 'ECorridor',
	},
	execute = function(dz, item)
        local temperatureHumidityDevice = dz.devices('Ecco2 Corridor')
        local batteryDevice = dz.devices('Ecco2 Battery')
        local signalDevice = dz.devices('Ecco2 Signal')        
        local dataUrl = 'https://live.ecco2.ch/data?devId=10CE45FFFE0006DC'
        local moreUrl = 'https://live.ecco2.ch/more?devId=10CE45FFFE0006DC'

        local function humidityStatus(temperature, humidity) -- as used indz source
            if humidity <= 30 then return dz.HUM_DRY
            elseif humidity >= 70 then return dz.HUM_WET
            elseif  humidity >= 35 and humidity <= 65 and temperature >= 22 and temperature <= 26 then return dz.HUM_COMFORTABLE end
            return dz.HUM_NORMAL
        end
		
		if (item.isTimer) then
			dz.openURL({
				url = dataUrl,
				method = 'GET',
				callback = 'trigger', -- see httpResponses above.
			})
		end

		if (item.isHTTPResponse) then

			if (item.ok) then
			    --dz.log(item['data'], dz.LOG_INFO)
			    local strTemp =  [[ echo "]] .. item['data'] .. [[" | grep  "&#176" - | sed 's/.*>\(.*\)<.*/\1/' - | awk '{print $1}' - ]]
                local strHygro = [[ echo "]] .. item['data'] .. [[" | grep  "%</span>" - | sed 's/.*>\(.*\)<.*/\1/' - | awk '{print $1}' - ]]
                local t = tonumber(os.capture(strTemp, false));
                local h = tonumber(os.capture(strHygro, false));
                dz.log(t, h,  dz.LOG_INFO)
                temperatureHumidityDevice.updateTempHum( t, h, humidityStatus( t, h ) )
			else
				dz.log('There was a problem handling the temperature and humidity request', dz.LOG_ERROR)
				dz.log(item, dz.LOG_ERROR)
			end
			
			local strMore = os.capture('curl '..  moreUrl, true)
			local strSig =  [[ echo "]] .. strMore .. [["| grep  "dBm</span>" - | sed 's/.*>\(.*\)<.*/\1/' - | awk '{print $1}' - ]]
			local strBat =  [[ echo "]] .. strMore .. [["| grep  "uAh</span>" - | sed 's/.*>\(.*\)<.*/\1/' - | awk '{print $1}' - ]]
			

			local battery = tonumber(os.capture(strBat, false));
            local signal = tonumber(os.capture(strSig, false));
            
            
            dz.log('Battery =' .. battery .. ' uAh', dz.LOG_INFO)
            dz.log('Signal =' .. signal .. ' dBm', dz.LOG_INFO)
            
            signalDevice.updateCustomSensor(signal)
            batteryDevice.updateCustomSensor(battery)
        end

	end

Code: Select all

def DomoticzAPI(APICall):
    resultJson = None
    url = "{}{}".format(config.domoticz_url,  parse.quote(APICall, safe="&="))
    print("Calling domoticz API: {}".format(url))
    resultJson = None
    try:
        req = request.Request(url)
        if config.user != "":
            credentials = ('%s:%s' % (config.user, config.pw))
            encoded_credentials = base64.b64encode(credentials.encode('ascii'))
            req.add_header('Authorization', 'Basic %s' % encoded_credentials.decode("ascii"))

        response = request.urlopen(req)
        if response.status == 200:
            resultJson = json.loads(response.read().decode('utf-8'))
            if resultJson["status"] != "OK":
                status ="Domoticz API returned an error: status = {}".format(resultJson["status"])
                resultJson = None
            else:
                status ="Domoticz API returned {}".format(resultJson["status"])
        else:
            status="Domoticz API: http error = {}".format(response.status)
    except:
        status="Error '{}'".format(url)
    
    print (status)
    return resultJson