Method connect

src/core/web_socket/ws_manager.py:19–28

(self, user_id: str, websocket: WebSocket)

        self.log = log

    async def connect(self, user_id: str, websocket: WebSocket) -> None:
        if len(self._connections) >= self.MAX_CONNECTIONS:
            await websocket.close(code=status.WS_1008_POLICY_VIOLATION)  # Connection limit exceeded
            self.log.error(f"🥕 WebSocket connect: user {user_id}, connection limit exceeded")
            return
        await websocket.accept()
        async with self._lock:
            lock = asyncio.Lock()
            self._connections.setdefault(user_id, []).append((websocket, lock))
        self.log.info(f"🍏 WebSocket connected: {user_id} (total {len(self._connections.get(user_id, []))})")

    async def disconnect(self, user_id: str, websocket: WebSocket) -> None:
        async with self._lock: