ignore websocket pongs

FIRST-South-Carolina · Feb 23, 2024 · 1cc4d6a · 1cc4d6a
1 parent 6461103
commit 1cc4d6a
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/ftc_stream_manager.py b/ftc_stream_manager.py
@@ -788,7 +788,10 @@ async def run_websocket(uri):
             while not stop.is_set():
                 try:
                     # try to get something from websocket and put it in queue for main thread (dropping events when queue is full)
-                    comm.put_nowait(json.loads(await asyncio.wait_for(websocket.recv(), 0.2)))
+                    message = await asyncio.wait_for(websocket.recv(), 0.2)
+                    if message == "pong":
+                        continue
+                    comm.put_nowait(json.loads(message))
                 except (asyncio.TimeoutError, queue.Full):
                     pass