diff options
Diffstat (limited to 'ttun_server/websockets.py')
| -rw-r--r-- | ttun_server/websockets.py | 6 |
1 files changed, 2 insertions, 4 deletions
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): | |||
| 46 | else: | 46 | else: |
| 47 | yield | 47 | yield |
| 48 | except AssertionError: | 48 | except AssertionError: |
| 49 | pass | 49 | yield None |
| 50 | 50 | ||
| 51 | async def listen_for_messages(self, websocket: WebSocket): | 51 | async def listen_for_messages(self, websocket: WebSocket): |
| 52 | [subdomain, *_] = websocket.url.hostname.split('.') | 52 | [subdomain, *_] = websocket.url.hostname.split('.') |
| @@ -74,9 +74,7 @@ class WebsocketProxy(WebSocketEndpoint): | |||
| 74 | ) | 74 | ) |
| 75 | 75 | ||
| 76 | async with self.proxy(websocket, message) as m: | 76 | async with self.proxy(websocket, message) as m: |
| 77 | type = WebsocketMessageType(m['type']) | 77 | if m is not None and WebsocketMessageType(m['type']) == WebsocketMessageType.ack: |
| 78 | |||
| 79 | if type == WebsocketMessageType.ack: | ||
| 80 | await super().on_connect(websocket) | 78 | await super().on_connect(websocket) |
| 81 | 79 | ||
| 82 | self.websocket_listen_task = asyncio.create_task(self.listen_for_messages(websocket)) | 80 | self.websocket_listen_task = asyncio.create_task(self.listen_for_messages(websocket)) |
