Domoticz

Code: Select all

def UpdateDevice(self, name, val):
        if name in self.svalues:
            if "|" in str(val):
                val, val2 = val.split("|")
            else:
                val2 = val
                
            if val != self.svalues[name]:
#                print("{} {} -> {}".format(name, self.svalues[name], val2))
                data = "command&param=udevice&idx={}&svalue=" + str(val2)
                self.SendCommand(name, data)
                self.svalues[name] = str(val)
        else:
            self.SendAll("Unknown device '{}'".format(name))

Code: Select all

self.UpdateDevice(name, macip)
self.svalues[name] = macip

Code: Select all

def SendCommand(self, name, cmd):
        if name in self.indexes:
            idx = self.indexes[name]
            data = cmd.format(idx)
            threading.Thread(target=self.DomoticzData, args=(data,)).start()
        else:
            self.SendAll("No IDX for '{}'".format(name))

Code: Select all

function Utils.SendToPython(device, ddata, force)
--print("Start")
	if (otherdevices['Python helper'] == 'On' or (force and force == true)) then

		data = {}
		
		if device and ddata then
			d = {}
			d[device] = ddata
			data['changed'] = d
		elseif devicechanged then
			data['changed'] = devicechanged
		end
		
		for deviceName, deviceValue in pairs(data['changed']) do
			device = deviceName
			val = deviceValue
			print("⇒ "..device..' = '..val..' ⇒')
		end


		data['svalues']    = otherdevices
		data['indexes']    = otherdevices_idx
		data['lastupdate'] = otherdevices_lastupdate
		data['vvalues']    = uservariables
		data['vupdate']    = uservariables_lastupdate
		
		PassToPython(data)
	else
		print("-- Python offline --")
	end
end

function PassToPython(data)
	if not JSON then
		JSON = require "cjson"
	end
	
	jdata = JSON.encode(data)

	package.loadlib("core.so", "*")
	local Socket = require "socket"

	local client = Socket.connect('localhost', 8088)
	
	if not client then
		print("Python socket connect failed")
		return
	else
	
		client:settimeout(2)
		
		i, status = client:send(jdata);
	
		if not i then
			print("Python send failed - "..status)
		else
			s, status, partial = client:receive(1024)
			reply = JSON.decode(s or partial)
--				print("Status = "..reply['status'])
		end
	end

	client:close()
	return reply
end