From f4348d0e050a5be9f17122c434fb1638c0017b29 Mon Sep 17 00:00:00 2001 From: Laurent Date: Tue, 30 Dec 2025 14:14:48 +0100 Subject: [PATCH] Oopsie --- rpi/controllers/mqtt_forwarder.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/rpi/controllers/mqtt_forwarder.py b/rpi/controllers/mqtt_forwarder.py index ce9787ec..9ce69b3f 100644 --- a/rpi/controllers/mqtt_forwarder.py +++ b/rpi/controllers/mqtt_forwarder.py @@ -18,14 +18,14 @@ class MQTTForwarder: def start(self, src_topic: str, dst_topic: str): try: def forward_handler(topic: str, msg: str): - forwarded_msg = self.__wrapData(msg) + forwarded_msg = self.__wrap_data(msg) self.central_broker.publish(dst_topic, forwarded_msg) self.local_broker.subscribe(src_topic, forward_handler) except Exception as e: print(f"An error occurred while forwarding from {src_topic} to {dst_topic}: {e}") - def __wrapData(self, msg : str): + def __wrap_data(self, msg : str): result = {} data = json.loads(msg) result["timestamp"] = int(time.time()) @@ -33,4 +33,4 @@ class MQTTForwarder: result["data"] = {} for keys in data: result["data"][keys] = data[keys] - + return result \ No newline at end of file