debug

app.py

@@ -18,8 +18,9 @@ from contextlib import asynccontextmanager
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     # Starting code
-    intialize_mqtt_brokers()
-    start_mqtt_publishers()
+    #intialize_mqtt_brokers()
+    #start_mqtt_publishers()
+    start_mqtt()
     
     yield  
 

mqtt_manager.py

@@ -1,13 +1,12 @@
-
-import paho.mqtt.client as mqtt
-import time
 import threading
-from dotenv import load_dotenv
+import time
 import os
-import state
 import paho.mqtt.client as mqtt
-import time
+from dotenv import load_dotenv
+import state  # يحتوي على `singlas_state`
+
 
+# ------------------ Load .env ------------------ #
 load_dotenv(dotenv_path="keys.env")
 
 mqtt_broker = os.getenv("MQTT_BROKER")
@@ -15,46 +14,60 @@ mqtt_port = int(os.getenv("MQTT_PORT"))
 MQTT_PARTOPIC_state = os.getenv("MQTT_PARTOPIC_state")
 MQTT_SUBTOPIC_reply = os.getenv("MQTT_SUBTOPIC_reply")
 MQTT_SUBTOPIC_msg = os.getenv("MQTT_SUBTOPIC_msg")
-topic_rep = lambda x: MQTT_PARTOPIC_state+"/"+x +"/"+ MQTT_SUBTOPIC_reply
-topic_msg = lambda x:MQTT_PARTOPIC_state+"/"+x +"/"+ MQTT_SUBTOPIC_msg
 
+def topic_msg(tl_id):
+    return f"{MQTT_PARTOPIC_state}/{tl_id}/{MQTT_SUBTOPIC_msg}"
 
+def topic_rep(tl_id):
+    return f"{MQTT_PARTOPIC_state}/{tl_id}/{MQTT_SUBTOPIC_reply}"
+    
+
+# ------------------ Get state ------------------ #
+def get_State(tl_id):
+    return state.singlas_state.get(tl_id, "FREE")
 
 
-client = mqtt.Client()
+# ------------------ Listener ------------------ #
+def mqtt_listener():
+    def on_message(client, userdata, message):
+        print(f"📥 Reply Received on {message.topic}: {message.payload.decode()}")
 
-def intialize_mqtt_brokers():
+    client = mqtt.Client()
     client.connect(mqtt_broker, mqtt_port)
-    for tl_id in state.singlas_state.keys():
-        client.subscribe(topic_rep(tl_id))
 
-def start_mqtt_publishers():
+    # اشترك في كل الردود
     for tl_id in state.singlas_state.keys():
-        threading.Thread(target=mqtt_publisher_loop, args=(tl_id,), daemon=True).start()
-
-
-def get_State(tl_id):
-    if tl_id in state.singlas_state:
-        return state.singlas_state[tl_id]
-    else:
-        return "FREE"
+        client.subscribe(topic_rep(tl_id))
     
+    client.on_message = on_message
+    client.loop_forever()
+
 
+# ------------------ Publisher ------------------ #
 def mqtt_publisher_loop(tl_id):
-    client.loop_start()
+    pub_client = mqtt.Client()
+    pub_client.connect(mqtt_broker, mqtt_port)
+    pub_client.loop_start()
 
     last_state = None
     while True:
         current_state = get_State(tl_id)
         if current_state != last_state:
             topic = topic_msg(tl_id)
-            client.publish(topic, current_state)
+            pub_client.publish(topic, current_state)
             print(f"📡 Published {current_state} to {topic}")
             last_state = current_state
         time.sleep(1)
 
 
+# ------------------ Startup ------------------ #
+def start_mqtt():
+    # Start listener once
+    threading.Thread(target=mqtt_listener, daemon=True).start()
 
+    # Start one publisher per tl_id
+    for tl_id in state.singlas_state.keys():
+        threading.Thread(target=mqtt_publisher_loop, args=(tl_id,), daemon=True).start()
 
 
 '''