fix

routers/ws.py

@@ -257,10 +257,10 @@ async def session_ws(websocket: WebSocket, session_id: str):
                     await cart_incr(session_id, item_id, delta)
                     await cart_bump_version(session_id)
                     enriched = await get_enriched_cart(session_id, restaurant_id)
-                    asyncio.create_task(
+                    task = asyncio.create_task(
                         manager.broadcast(session_id, {"type": "cart_update", "cart": enriched})
                     )
-                    logger.info(f"[WS] cart_add item={item_id} session={session_id[:8]} → broadcast to {manager.count(session_id)} users")
+                    logger.info(f"[WS] cart_add item={item_id} session={session_id[:8]} → created broadcast task for {manager.count(session_id)} users")
 
                 elif msg_type == "cart_remove":
                     if not restaurant_id:
@@ -271,10 +271,10 @@ async def session_ws(websocket: WebSocket, session_id: str):
                     await cart_remove_item(session_id, item_id)
                     await cart_bump_version(session_id)
                     enriched = await get_enriched_cart(session_id, restaurant_id)
-                    asyncio.create_task(
+                    task = asyncio.create_task(
                         manager.broadcast(session_id, {"type": "cart_update", "cart": enriched})
                     )
-                    logger.info(f"[WS] cart_remove item={item_id} session={session_id[:8]} → broadcast to {manager.count(session_id)} users")
+                    logger.info(f"[WS] cart_remove item={item_id} session={session_id[:8]} → created broadcast task for {manager.count(session_id)} users")
 
                 elif msg_type == "cart_set_qty":
                     if not restaurant_id:
@@ -289,10 +289,10 @@ async def session_ws(websocket: WebSocket, session_id: str):
                         await cart_set_qty(session_id, item_id, qty)
                     await cart_bump_version(session_id)
                     enriched = await get_enriched_cart(session_id, restaurant_id)
-                    asyncio.create_task(
+                    task = asyncio.create_task(
                         manager.broadcast(session_id, {"type": "cart_update", "cart": enriched})
                     )
-                    logger.info(f"[WS] cart_set_qty item={item_id} qty={qty} session={session_id[:8]} → broadcast to {manager.count(session_id)} users")
+                    logger.info(f"[WS] cart_set_qty item={item_id} qty={qty} session={session_id[:8]} → created broadcast task for {manager.count(session_id)} users")
 
             except json.JSONDecodeError:
                 logger.warning(f"[WS] Bad JSON from {session_id[:8]}")

ws_manager.py

@@ -1,9 +1,11 @@
 """WebSocket connection manager — singleton shared across routers."""
 
 from __future__ import annotations
-import json
+import json, logging
 from fastapi import WebSocket
 
+logger = logging.getLogger(__name__)
+
 
 class ConnectionManager:
     """Tracks active WebSocket connections per session_id and broadcasts messages."""
@@ -16,25 +18,35 @@ class ConnectionManager:
         if session_id not in self.active_connections:
             self.active_connections[session_id] = []
         self.active_connections[session_id].append(websocket)
+        logger.info(f"[Manager] Connected to {session_id[:8]}, total connections: {len(self.active_connections[session_id])}")
 
     def disconnect(self, session_id: str, websocket: WebSocket):
         if session_id in self.active_connections:
             try:
                 self.active_connections[session_id].remove(websocket)
+                logger.info(f"[Manager] Disconnected from {session_id[:8]}, remaining: {len(self.active_connections[session_id])}")
             except ValueError:
                 pass
             if not self.active_connections[session_id]:
                 del self.active_connections[session_id]
+                logger.info(f"[Manager] No connections left for {session_id[:8]}, removed channel")
 
     async def broadcast(self, session_id: str, message: dict):
         if session_id not in self.active_connections:
+            logger.warning(f"[Manager] ⚠️ Cannot broadcast to {session_id[:8]} - no active connections!")
             return
+        conns = self.active_connections[session_id]
+        logger.info(f"[Manager] 📡 Broadcasting '{message.get('type')}' to {len(conns)} connection(s) in {session_id[:8]}")
         dead: list[WebSocket] = []
-        for conn in self.active_connections[session_id]:
+        success_count = 0
+        for conn in conns:
             try:
                 await conn.send_json(message)
-            except Exception:
+                success_count += 1
+            except Exception as e:
+                logger.error(f"[Manager] Failed to send to connection: {e}")
                 dead.append(conn)
+        logger.info(f"[Manager] ✅ Sent to {success_count}/{len(conns)} connections, {len(dead)} dead")
         for d in dead:
             self.disconnect(session_id, d)