From d6f59042cfbd59c322e31fe97d19b789db309f78 Mon Sep 17 00:00:00 2001 From: LKuemmel Date: Mon, 14 Apr 2025 11:44:47 +0200 Subject: [PATCH 1/3] fix --- packages/modules/devices/generic/mqtt/device.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/packages/modules/devices/generic/mqtt/device.py b/packages/modules/devices/generic/mqtt/device.py index cbf21b1124..8407d2ebff 100644 --- a/packages/modules/devices/generic/mqtt/device.py +++ b/packages/modules/devices/generic/mqtt/device.py @@ -40,10 +40,9 @@ def on_message(client, userdata, message): for component in components: component.update(received_topics) else: - for component in components: - component.fault_state.warning( - f"Keine MQTT-Daten für Gerät {device_config.id} empfangen oder es werden veraltete legacy-Topics" - " verwendet. Bitte die Doku in den Einstellungen beachten.") + raise Exception( + f"Keine MQTT-Daten für Gerät {device_config.id} empfangen oder es werden veraltete legacy-Topics" + " verwendet. Bitte die Doku in den Einstellungen beachten.") return ConfigurableDevice( device_config=device_config, From 28aa011fb076dbb9a03b87daf2994519b76a6e76 Mon Sep 17 00:00:00 2001 From: LKuemmel Date: Mon, 14 Apr 2025 12:49:50 +0200 Subject: [PATCH 2/3] fix --- packages/modules/devices/generic/mqtt/device.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/packages/modules/devices/generic/mqtt/device.py b/packages/modules/devices/generic/mqtt/device.py index 8407d2ebff..d6c5509bde 100644 --- a/packages/modules/devices/generic/mqtt/device.py +++ b/packages/modules/devices/generic/mqtt/device.py @@ -41,8 +41,9 @@ def on_message(client, userdata, message): component.update(received_topics) else: raise Exception( - f"Keine MQTT-Daten für Gerät {device_config.id} empfangen oder es werden veraltete legacy-Topics" - " verwendet. Bitte die Doku in den Einstellungen beachten.") + f"Keine MQTT-Daten für Gerät {device_config.id} empfangen oder es werden veraltete Topics" + " verwendet. Diese funktionieren mit Einschränkungen trotz dieser Fehlermeldung. Bitte die Doku in " + "den Einstellungen beachten.") return ConfigurableDevice( device_config=device_config, From 158cff5287f5eb38b10814875c95819ab19be0af Mon Sep 17 00:00:00 2001 From: LKuemmel Date: Mon, 14 Apr 2025 12:54:12 +0200 Subject: [PATCH 3/3] fix --- packages/modules/chargepoints/mqtt/chargepoint_module.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/packages/modules/chargepoints/mqtt/chargepoint_module.py b/packages/modules/chargepoints/mqtt/chargepoint_module.py index a402a4ba64..8f865b29c3 100644 --- a/packages/modules/chargepoints/mqtt/chargepoint_module.py +++ b/packages/modules/chargepoints/mqtt/chargepoint_module.py @@ -27,7 +27,7 @@ def set_current(self, current: float) -> None: def get_values(self) -> None: with SingleComponentUpdateContext(self.fault_state): def on_connect(client, userdata, flags, rc): - client.subscribe(f"openWB/mqtt/chargepoint/{self.config.id}/#") + client.subscribe(f"openWB/mqtt/chargepoint/{self.config.id}/get/#") def on_message(client, userdata, message): received_topics.update({message.topic: decode_payload(message.payload)}) @@ -62,7 +62,9 @@ def on_message(client, userdata, message): ) self.store.set(chargepoint_state) else: - raise Exception(f"Keine MQTT Daten für Gerät {self.config.id} empfangen") + raise Exception(f"Keine MQTT Daten für Ladepunkt {self.config.name} empfangen oder es werden veraltete " + "Topics verwendet. Diese funktionieren mit Einschränkungen trotz dieser Fehlermeldung. " + "Bitte die Doku in den Einstellungen beachten.") def switch_phases(self, phases_to_use: int, duration: int) -> None: Pub().pub(f"openWB/mqtt/chargepoint/{self.config.id}/set/phases_to_use", phases_to_use)