From b8d5952b83e7601c5df646efd976879f0dbd30c2 Mon Sep 17 00:00:00 2001 From: Tom van der Lee Date: Tue, 28 Apr 2026 10:45:41 +0200 Subject: Fixed issue with the redis proxy queue not working due to enqueing on the wrong queue --- ttun_server/websockets.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) (limited to 'ttun_server/websockets.py') diff --git a/ttun_server/websockets.py b/ttun_server/websockets.py index 0800cbc..f80359f 100644 --- a/ttun_server/websockets.py +++ b/ttun_server/websockets.py @@ -46,7 +46,7 @@ class WebsocketProxy(WebSocketEndpoint): else: yield except AssertionError: - pass + yield None async def listen_for_messages(self, websocket: WebSocket): [subdomain, *_] = websocket.url.hostname.split('.') @@ -74,9 +74,7 @@ class WebsocketProxy(WebSocketEndpoint): ) async with self.proxy(websocket, message) as m: - type = WebsocketMessageType(m['type']) - - if type == WebsocketMessageType.ack: + if m is not None and WebsocketMessageType(m['type']) == WebsocketMessageType.ack: await super().on_connect(websocket) self.websocket_listen_task = asyncio.create_task(self.listen_for_messages(websocket)) -- cgit v1.2.3