debug mqtt

mqtt_manager.py

@@ -36,12 +36,14 @@ def mqtt_listener():
         tl_id = topic.split('/')[1]
         print(f"📥 Reply Received on {topic}: {msg}")
         if (msg == 'AVBL'):
-            client.publish(topic_msg(tl_id), 'DONE'+str(msg))
+            state.request[tl_id]['accepted'] = True
+            next_request = 'DONE' if state.request[tl_id]['State'] == state.status_acc else 'DONE QL?' # ask for queue length if to open road in emergency
+            client.publish(topic_msg(tl_id), next_request)
 
         if (msg.startswith("QL")):
             ql = msg.split()[1]
             if checked_ql(ql):
-              client.publish(topic_msg(tl_id), 'ACC'+str(msg))  
+              client.publish(topic_msg(tl_id), 'ACC')  
 
     client = mqtt.Client()
     client.connect(mqtt_broker, mqtt_port)

state.py

@@ -1,3 +1,5 @@
+import time
+
 status_free = "FREE"
 status_emr = "EMR"
 status_acc = "ACC"
@@ -23,3 +25,17 @@ request = {
     }
 
 }
+
+def set_request(tl_id,state,duration):
+    request[tl_id]['State'] = state
+    request[tl_id]['Duration'] = duration
+    request[tl_id]['time'] = time.time()
+
+def delete_last_request(tl_id):
+    request[tl_id]['State'] = status_free
+    request[tl_id]['Duration'] = None
+    request[tl_id]['time'] = None
+
+    #optional later store it in database
+
+

traffic_utils.py

@@ -42,23 +42,28 @@ async def wait_check_conection(tl_id,check_time):
         await asyncio.sleep(0.2)  
 
 async def open_signal(tl_id,state_,duration,delay):
+    if (state.request[tl_id]['State'] != state.status_free): #exist old request
+        request_type = "Accident to stop road " if (state.request[tl_id]['State'] == state.status_acc) else "Exist Emergency request"
+        return "Request Refused , Exist old request : \n"+ request_type
+    
     check_time = 4
-    print("function tlid",tl_id)
+
     await asyncio.sleep(delay)
 
-    state.request[tl_id]['State'] = state.status_chk
-    print(state.request[tl_id]['State'])
+    
+
+
+    state.singlas_state[tl_id] = state.status_chk
     await wait_check_conection(tl_id,check_time)
-    print(state.request[tl_id]['State'])
 
 
     if  (state.request[tl_id]['accepted']== True):
-        state.request[tl_id]['State'] = state_
-        state.request[tl_id]['time'] = time.time()
-        state.request[tl_id]['duration'] = duration
+        state.singlas_state[tl_id] = state_
+        state.set_request(tl_id,state_,duration)
+
         return "Request Accepted"
     else:
-        state.request[tl_id]['State'] = state.status_free 
+        state.delete_last_request(tl_id)
         return "Request Refused , No Internet Connection or Very High Queue Length"