From a896e81519c7011ee0cfa990513759ea0a5d152a Mon Sep 17 00:00:00 2001 From: Laurent Date: Fri, 2 Jan 2026 19:42:36 +0100 Subject: [PATCH] add broker subscription --- api-customer/app.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/api-customer/app.py b/api-customer/app.py index 4fd624f5..a1e160fa 100644 --- a/api-customer/app.py +++ b/api-customer/app.py @@ -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") 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): client_id = data.get_client_id() @@ -46,10 +50,14 @@ def start_mqtt(data : AuthData): password="hepl", ) + api_broker.subscribe(f"/chat/{client_id}/message", handle_message_received) + forwarder = MQTTForwarder(client_id, local_broker, api_broker) forwarder.start(f"/customer/telemetry/#", f"/board-mate/{client_id}/telemetry") + + if __name__ == '__main__': auth_controller.set_on_login(start_mqtt)