summaryrefslogtreecommitdiffstats
path: root/ttun_server/websockets.py
diff options
context:
space:
mode:
Diffstat (limited to 'ttun_server/websockets.py')
-rw-r--r--ttun_server/websockets.py6
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))