debug mqtt

mqtt_manager.py

@@ -66,7 +66,7 @@ def mqtt_publisher_loop(tl_id):
 
     last_state = None
     while True:
-        current_state = state.request[tl_id]['State'] 
+        current_state = state.singlas_state[tl_id] 
         '''
         if current_state != last_state:
             topic = topic_msg(tl_id)

state.py

@@ -9,7 +9,7 @@ singlas_state = {
     "1698478721" :status_free,
     "6082411793":status_free } 
 
-request = {
+request = { # only store info of current request ,not as updated as singlas_state
     "1698478721":{
         'State' : status_free,
         'time' : None,

traffic_utils.py

@@ -37,13 +37,13 @@ def get_rectangle_container(coordinates):
 async def wait_check_conection(tl_id,check_time):
     start = time.time()
     while time.time() - start < check_time:
-        if state.request[tl_id]['State'] != state.status_chk:
+        if state.singlas_state[tl_id] != state.status_chk:
             break
         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"
+    if (state.singlas_state[tl_id] != state.status_free): #exist old request
+        request_type = "Accident to stop road " if (state.singlas_state[tl_id] == state.status_acc) else "Exist Emergency request"
         return "Request Refused , Exist old request : \n"+ request_type
     
     check_time = 4
@@ -59,10 +59,11 @@ async def open_signal(tl_id,state_,duration,delay):
 
     if  (state.request[tl_id]['accepted']== True):
         state.singlas_state[tl_id] = state_
-        state.set_request(tl_id,state_,duration)
+        state.set_request(tl_id,state_,duration) 
 
         return "Request Accepted"
     else:
+
         state.delete_last_request(tl_id)
         return "Request Refused , No Internet Connection or Very High Queue Length"