fix

app.py

@@ -11,8 +11,6 @@ import threading
 import logging
 from queue import Queue
 import json
-import yaml
-import os
 
 lock = threading.Lock()
 app = FastAPI()
@@ -432,7 +430,6 @@ async def websocket_endpoint(websocket: WebSocket):
                     if item == user_id:
                         queue.queue.remove(item)
                         print(f"User {user_id} disconnected.")
-                        break
     except WebSocketDisconnect:
         print("WebSocket connection closed.")
 
@@ -448,6 +445,7 @@ def form_get(request: Request):
 def form_post(request: Request,topic: str = Form(...), user_id: str = Form(...), state: str = Form(...)):
     global reply_count
     global current_user
+    print("current queue length",len(queue.queue))
     start_time = time.time()
     client_ip = request.client.host
     if user_id == "":