debug mqtt

traffic_utils.py

@@ -4,7 +4,7 @@ from dotenv import load_dotenv
 import os
 import state
 import asyncio
-
+import threading
 load_dotenv(dotenv_path="keys.env")
 
 overpass_url = os.getenv("URL_Traffic")
@@ -62,17 +62,26 @@ async def open_signal(tl_id,state_,duration,delay):
     print(state.request[tl_id])
 
     if  (state.request[tl_id]['accepted']== True):
-        
+        '''
         state.set_request(tl_id,state_,duration)
         print(state.request) 
         await asyncio.sleep(duration)
         state.delete_last_request(tl_id)
         print(state.request) 
+        '''
+        threading.Thread(target=handle_request_in_thread, args=(tl_id, state_, duration, state)).start()
         return "Request Accepted"
     else:
         state.delete_last_request(tl_id)
         return "Request Refused , No Internet Connection or Very High Queue Length"
 
+def handle_request_in_thread(tl_id, state_, duration, state):
+        state.set_request(tl_id, state_, duration)
+        print("✅ Request Set:", state.request)    
+        time.sleep(duration)
+        state.delete_last_request(tl_id)
+        print("🧹 Request Deleted:", state.request)
+        print("✅ Request Accepted")
 
 
 def check_signals(coords):