diff --git a/cogs/events.py b/cogs/events.py index f00665c..e3fed6f 100644 --- a/cogs/events.py +++ b/cogs/events.py @@ -385,6 +385,7 @@ class Events(commands.Cog): } # dumped = json.dumps(payload, separators=(",", ":")) self.bot.bridge_queue.put_nowait(payload) + print("Added %s to queue" % payload) if message.channel.name == "pinboard": if message.type == discord.MessageType.pins_add: diff --git a/web/server.py b/web/server.py index 0a1b25d..f257c93 100644 --- a/web/server.py +++ b/web/server.py @@ -1,3 +1,4 @@ +import asyncio import ipaddress import sys @@ -318,7 +319,12 @@ async def bridge_recv(ws: WebSocket, secret: str = Header(None)): await ws.accept() while True: - data = await app.state.bot.bridge_queue.get() + try: + data = app.state.bot.bridge_queue.get_nowait() + except asyncio.QueueEmpty: + await asyncio.sleep(0.5) + continue + try: await ws.send_json(data) except WebSocketDisconnect: