eswyft/homekit
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqtt receivers: call parent on_message function for debugging purposes

Browse Source
This commit is contained in:
Evgeny Zinoviev 2023-04-26 14:30:28 +03:00
parent 2f5191bb6f
commit 9e3be40a44
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/inverter_mqtt_receiver.py
View File

@ -20,6 +20,7 @@ class MQTTReceiver(MQTTBase):
client.subscribe('hk/#', qos=1) client.subscribe('hk/#', qos=1)
def on_message(self, client: mqtt.Client, userdata, msg): def on_message(self, client: mqtt.Client, userdata, msg):
super().on_message(client, userdata, msg)
try: try:
match = re.match(r'(?:home|hk)/(\d+)/(status|gen)', msg.topic) match = re.match(r'(?:home|hk)/(\d+)/(status|gen)', msg.topic)
if not match: if not match:

1
src/sensors_mqtt_receiver.py
View File

@ -27,6 +27,7 @@ class MQTTServer(MQTTBase):
client.subscribe('hk/#', qos=1) client.subscribe('hk/#', qos=1)
def on_message(self, client: mqtt.Client, userdata, msg): def on_message(self, client: mqtt.Client, userdata, msg):
super().on_message(client, userdata, msg)
try: try:
variants = '|'.join([s.name.lower() for s in TemperatureSensorLocation]) variants = '|'.join([s.name.lower() for s in TemperatureSensorLocation])
match = re.match(rf'hk/(\d+)/si7021/({variants})', msg.topic) match = re.match(rf'hk/(\d+)/si7021/({variants})', msg.topic)