From a165f187d89d21b949756db78137e355f254dd8f Mon Sep 17 00:00:00 2001 From: Laurent Date: Fri, 2 Jan 2026 19:45:26 +0100 Subject: [PATCH] Forward received message to nodered --- api-customer/app.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/api-customer/app.py b/api-customer/app.py index a1e160fa..6beb6221 100644 --- a/api-customer/app.py +++ b/api-customer/app.py @@ -1,6 +1,7 @@ import os import threading +import requests from dotenv import load_dotenv from flask import Flask @@ -29,7 +30,11 @@ message_controller = MessageController(app, auth_data, "https://192.168.15.120:8 def handle_message_received(topic:str, payload:str): - pass + try : + url = "https://127.0.0.1:1880/message/receive" + requests.post(url, json=payload, verify=False) + except Exception as e: + print(e) def start_mqtt(data : AuthData): client_id = data.get_client_id()