Update main.py

main.py

@@ -11,7 +11,7 @@ async def websocket_endpoint(websocket: WebSocket):
     await websocket.accept()
     client_ws = websocket
     while True:
-        data = await websocket.receive_text()
+        data = await websocket.receive_json()
         if type(worker_ws) is WebSocket:
             await worker_ws.send_json(data)
         else: