Naaturel/board-mate
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

please

Browse Source
This commit is contained in:
Laurent
2025-12-30 14:52:20 +01:00
parent e6aabef60b
commit 9a425738fa
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
rpi/controllers/mqtt_forwarder.py
View File

@@ -26,7 +26,7 @@ class MQTTForwarder:
print(f"An error occurred while forwarding from {src_topic} to {dst_topic}: {e}") print(f"An error occurred while forwarding from {src_topic} to {dst_topic}: {e}")
def __wrap_data(self, msg : str): def __wrap_data(self, msg : str):
print(msg) print(repr(msg))
result = {} result = {}
data = json.loads(msg) data = json.loads(msg)
result["timestamp"] = int(time.time()) result["timestamp"] = int(time.time())
@@ -34,4 +34,4 @@ class MQTTForwarder:
result["data"] = {} result["data"] = {}
for keys in data: for keys in data:
result["data"][keys] = data[keys] result["data"][keys] = data[keys]
return result return json.dumps(result)

2
rpi/services/mqtt_service.py
View File

@@ -65,7 +65,7 @@ class MQTTService:
def publish(self, topic: str, data: str, qos: int = 0): def publish(self, topic: str, data: str, qos: int = 0):
try: try:
self.connect() self.connect()
result = self.client.publish(topic, json.dumps(data), qos=qos) result = self.client.publish(topic, data, qos=qos)
result.wait_for_publish() result.wait_for_publish()
except Exception as e: except Exception as e:
print(f"An error occurred while publishing on {topic} on {self.address} : {e}") print(f"An error occurred while publishing on {topic} on {self.address} : {e}")