backend/ws/server.py

from typing import Dict, Any

class WebSocketServerBridge:
    async def emit(self, event_name: str, payload: Dict[str, Any]):
        # Bridging into ws_manager to broadcast to all connected clients
        from backend.ws.ws_manager import ws_manager
        print(f"V15 WS Bridge: Emitting '{event_name}' -> {payload}")
        await ws_manager.broadcast(event_name, payload)

ws_server = WebSocketServerBridge()