Method process_message

src/app/ws/service/ws_service.py:57–58

(self, user_id: str, message: dict[str, Any], websocket: WebSocket)

        for service in self.services:
            await service.add_connection(user_id=user_id, websocket=websocket)
    async def process_message(self, user_id: str, message: dict[str, Any], websocket: WebSocket) -> None:
        await self._queue.put((user_id, message, websocket))

    async def _handle_message(self, user_id: str, message: dict[str, Any], websocket: WebSocket) -> None:
        tp = message.get("type", WSType.UNKNOWN.value)