Create backend/api/routes_ws.py

backend/api/routes_ws.py

@@ -0,0 +1,15 @@
+from fastapi import APIRouter, WebSocket
+
+router = APIRouter()
+
+@router.websocket("/stream/{client_id}")
+async def stream(websocket: WebSocket, client_id: str):
+    await websocket.accept()
+
+    while True:
+        data = await websocket.receive_text()
+
+        await websocket.send_json({
+            "event": "received",
+            "data": data
+        })