From 3399b5925e1754ab829de4839200edafedc7a4f2 Mon Sep 17 00:00:00 2001 From: Laurent Date: Fri, 2 Jan 2026 15:40:17 +0100 Subject: [PATCH] Add customer api endpoint for message exchange --- .../src/controllers/message_controller.py | 30 + api/mosquitto/data/mosquitto.db | Bin 164 -> 164 bytes api/mosquitto/log/mosquitto.log | 2008 +++++++++++++++++ 3 files changed, 2038 insertions(+) create mode 100644 api-customer/src/controllers/message_controller.py diff --git a/api-customer/src/controllers/message_controller.py b/api-customer/src/controllers/message_controller.py new file mode 100644 index 00000000..ac2fdb17 --- /dev/null +++ b/api-customer/src/controllers/message_controller.py @@ -0,0 +1,30 @@ +import json + +from flask import jsonify, request + +from src.services.mqtt_service import MQTTService + + +class MessageController: + + _mqtt_service : MQTTService = None + _client_id : MQTTService = None + + def __init__(self, client_id : str, service : MQTTService): + self._mqtt_service = service + self.client_id = client_id + + def _register_routes(self, app): + app.add_url_rule("/message/send", view_func=self.send, methods=['POST']) + + def send(self): + try : + req = request.get_json() + msg = req["message"] + payload = json.dumps({"content" : msg}) + print(payload) + self._mqtt_service.publish(f"/chat/${self.client_id}/message", payload) + return jsonify({"success" : True, "message": "An error occurred"}), 500 + except Exception as e: + print(e) + return jsonify({"success" : False, "message" : "An error occurred"}), 500 \ No newline at end of file diff --git a/api/mosquitto/data/mosquitto.db b/api/mosquitto/data/mosquitto.db index 15c306ca0f476b6afe240f5d42d6b82269d1720c..2291e5223cd636e4eceeedc778db8ab60ba59028 100644 GIT binary patch delta 19 XcmZ3&xP)