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

Fixed broker forwarder

Browse Source
This commit is contained in:
Laurent
2025-12-29 13:03:30 +01:00
parent 239bd1035b
commit 4110e6823b
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
api-customer/app.py
View File

@@ -21,5 +21,6 @@ if __name__ == '__main__':
api_broker = MQTTService("192.168.15.120", 8883) api_broker = MQTTService("192.168.15.120", 8883)
forwarder = MQTTForwarder(client_id, local_broker, api_broker) forwarder = MQTTForwarder(client_id, local_broker, api_broker)
forwarder.start(f"/customer/${client_id}/#", f"/board-mate/${client_id}/telemetry")
app.run(host="0.0.0.0", port=5000, debug=False) app.run(host="0.0.0.0", port=5000, debug=False)

11
api-customer/src/controllers/mqtt_forwarder.py
View File

@@ -15,11 +15,14 @@ class MQTTForwarder:
self.local_broker = local_mqtt self.local_broker = local_mqtt
self.central_broker = central_mqtt self.central_broker = central_mqtt
def start(self): def start(self, src_topic : str, dst_topic : str) -> None:
self.local_broker.subscribe("board-mate/", self.__forward) def handler(msg:str):
self.__forward(msg, dst_topic)
def __forward(self, msg: str): self.local_broker.subscribe(src_topic, handler)
self.central_broker.publish(self.client_id, f"/board-mate/${self.client_id}/telemetry", msg)
def __forward(self, msg: str, dst_topic) -> None:
self.central_broker.publish(self.client_id, dst_topic, msg)
"""def start(self): """def start(self):
self.local.subscribe("board-mate/+/telemetry", self.handle_message) self.local.subscribe("board-mate/+/telemetry", self.handle_message)