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.py3
1 files changed, 3 insertions, 0 deletions
diff --git a/ttun_server/websockets.py b/ttun_server/websockets.py
index c791625..88d6cac 100644
--- a/ttun_server/websockets.py
+++ b/ttun_server/websockets.py
@@ -4,7 +4,9 @@ import os
4from uuid import uuid4 4from uuid import uuid4
5 5
6from fastapi import WebSocket, WebSocketDisconnect 6from fastapi import WebSocket, WebSocketDisconnect
7from starlette.authentication import requires
7 8
9import conf
8import ttun_server 10import ttun_server
9from proxy.queue import ProxyQueue 11from proxy.queue import ProxyQueue
10from ttun_server.types import ( 12from ttun_server.types import (
@@ -31,6 +33,7 @@ async def assert_compatible_version(websocket: WebSocket, config: Config) -> Non
31 await websocket.close(4001, 'Your client is too new') 33 await websocket.close(4001, 'Your client is too new')
32 34
33 35
36@requires(['authenticated', 'token'] if conf.ENABLE_AUTH else [])
34async def tunnel(websocket: WebSocket) -> None: 37async def tunnel(websocket: WebSocket) -> None:
35 request_tasks: dict[str, asyncio.Task] = {} 38 request_tasks: dict[str, asyncio.Task] = {}
36 proxy_queues: dict[str, ProxyQueue] = {} 39 proxy_queues: dict[str, ProxyQueue] = {}