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

add broker subscription

Browse Source
This commit is contained in:
Laurent
2026-01-02 19:42:36 +01:00
parent cd0e5f15ed
commit a896e81519
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
api-customer/app.py
View File

@@ -27,6 +27,10 @@ auth_controller = AuthController(app, auth_data, "https://192.168.15.120:8000")
client_controller = ClientController(app, auth_data, "https://192.168.15.120:8000") client_controller = ClientController(app, auth_data, "https://192.168.15.120:8000")
message_controller = MessageController(app, auth_data, "https://192.168.15.120:8000") message_controller = MessageController(app, auth_data, "https://192.168.15.120:8000")
def handle_message_received(topic:str, payload:str):
pass
def start_mqtt(data : AuthData): def start_mqtt(data : AuthData):
client_id = data.get_client_id() client_id = data.get_client_id()
@@ -46,10 +50,14 @@ def start_mqtt(data : AuthData):
password="hepl", password="hepl",
) )
api_broker.subscribe(f"/chat/{client_id}/message", handle_message_received)
forwarder = MQTTForwarder(client_id, local_broker, api_broker) forwarder = MQTTForwarder(client_id, local_broker, api_broker)
forwarder.start(f"/customer/telemetry/#", f"/board-mate/{client_id}/telemetry") forwarder.start(f"/customer/telemetry/#", f"/board-mate/{client_id}/telemetry")
if __name__ == '__main__': if __name__ == '__main__':
auth_controller.set_on_login(start_mqtt) auth_controller.set_on_login(start_mqtt)