aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEvgeny Zinoviev <me@ch1p.io>2023-04-26 14:30:28 +0300
committerEvgeny Zinoviev <me@ch1p.io>2023-04-26 14:30:28 +0300
commit9e3be40a444d7ee80b70b88b939decb036c21b1b (patch)
tree3ae5acb3517c75fe01902f9a773ffb2ba24ab34f
parent2f5191bb6fe61697debea1aef603a8d9b669b613 (diff)
mqtt receivers: call parent on_message function for debugging purposes
-rwxr-xr-xsrc/inverter_mqtt_receiver.py1
-rwxr-xr-xsrc/sensors_mqtt_receiver.py1
2 files changed, 2 insertions, 0 deletions
diff --git a/src/inverter_mqtt_receiver.py b/src/inverter_mqtt_receiver.py
index d138609..a7018f2 100755
--- a/src/inverter_mqtt_receiver.py
+++ b/src/inverter_mqtt_receiver.py
@@ -20,6 +20,7 @@ class MQTTReceiver(MQTTBase):
client.subscribe('hk/#', qos=1)
def on_message(self, client: mqtt.Client, userdata, msg):
+ super().on_message(client, userdata, msg)
try:
match = re.match(r'(?:home|hk)/(\d+)/(status|gen)', msg.topic)
if not match:
diff --git a/src/sensors_mqtt_receiver.py b/src/sensors_mqtt_receiver.py
index 0b4c279..9637690 100755
--- a/src/sensors_mqtt_receiver.py
+++ b/src/sensors_mqtt_receiver.py
@@ -27,6 +27,7 @@ class MQTTServer(MQTTBase):
client.subscribe('hk/#', qos=1)
def on_message(self, client: mqtt.Client, userdata, msg):
+ super().on_message(client, userdata, msg)
try:
variants = '|'.join([s.name.lower() for s in TemperatureSensorLocation])
match = re.match(rf'hk/(\d+)/si7021/({variants})', msg.topic)