monster/broadlink-mqtt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

up

Browse Source
This commit is contained in:
monster
2018-10-31 22:31:18 +03:00
parent e3fc991b05
commit 7409866c65
3 changed files with 33 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Dockerfile
+1 -1
View File
@@ -1,4 +1,4 @@
FROM jfloff/alpine-python:3.4
FROM python:3.7.1-stretch
ENV LIBRARY_PATH=/lib:/usr/lib
src/main.py
+16 -7
View File
@@ -13,10 +13,12 @@ QUERY_TIME = os.getenv('QUERY_TIME', 5)
PREFIX = os.getenv('PREFIX', 'home')
ips = dict({
'192.168.1.103':{'name':'kitchen-right', 'mac':bytearray(b'vr\xcb\rC\xb4'), 'type':'plug'},
'192.168.1.183':{'name':'balcony-heater', 'mac':bytearray(b'\xc1j\xcb\rC\xb4'), 'type':'plug'},
'192.168.1.188':{'name':'kitchen-kettle', 'mac':bytearray(b'9V\xcb\rC\xb4'), 'type':'plug'},
'192.168.1.49':{'name':'rm2', 'mac':bytearray(b'U"\xcc\rC\xb4'), 'type':'remote'}
'192.168.1.49':{'name':'rm2', 'mac':'B4430DCC2255', 'type':'remote'},
# '192.168.1.62':{'name':'main-humidifier', 'mac':'B4430DCB6AC1', 'type':'plug'},
'192.168.1.63':{'name':'kitchen-mini-light', 'mac':'B4430DCB6C07', 'type':'plug'},
# '192.168.1.64':{'name':'balcony-heater', 'mac':'B4430DCB7276', 'type':'plug'},
# '192.168.1.65':{'name':'kitchen-kettle', 'mac':'B4430DCB5639', 'type':'plug'},
# '192.168.1.66':{'name':'balcony-lights', 'mac':'B4430DCB6F18', 'type':'plug'},
})
plugs=[]
@@ -40,9 +42,13 @@ def push_data(client, model, sid, data):
prop=key)
client.publish(path, payload=value, qos=0, retain=True)
def reverse_hex(s):
return "".join(map(str.__add__, s[-2::-2] ,s[-1::-2]))
def init_plugs():
plugs=[]
for ip in ips:
for i in range(1,3):
try:
props = ips[ip]
name = props['name']
@@ -51,13 +57,15 @@ def init_plugs():
typeId = 0x2720 #SP2 by default
if (typeName == "remote"):
typeId = 0x2712
broadObj = broadlink.gendevice(typeId, (ip, 80) , mac)
macBytes = bytes.fromhex(reverse_hex(mac))
broadObj = broadlink.gendevice(typeId, (ip, 80) , macBytes)
broadObj.auth()
plug = PlugState(ip, typeName, name, broadObj)
plug.update_properties()
plugs.append(plug)
break
except Exception as e:
print('Connection to ', str(ip) , ' error:', str(e))
print('['+str(i) + '] Connection to ', str(ip) , ' error:', str(e))
return plugs
def refresh_plug_states(data_callback):
@@ -98,7 +106,7 @@ def on_mqtt_message(client, userdata, msg):
plug.process_command(param, value)
processNow=True
def on_connect(client, userdata, rc):
def on_connect(client, userdata, rc, kwargs):
client.subscribe(PREFIX + "/plug/+/+/set")
client.subscribe(PREFIX + "/remote/+/+/learn")
client.subscribe(PREFIX + "/remote/+/+/set")
@@ -130,3 +138,4 @@ if __name__ == "__main__":
# and process mqtt messages in this thread
client.loop_forever()
src/plugstate.py
+1 -1
View File
@@ -63,7 +63,7 @@ class PlugState:
print("No ir packets recieved")
return
self.learn_temp = binascii.hexlify(ir_packet)
print("Learned code:", self.learn_temp)
print("Learned code:", ir_packet)
if (param == 'code' and self.type == 'remote'):
if (value == None or value == ""):
print("No ir packets in value")