diff options
Diffstat (limited to 'ttun_server/websockets.py')
| -rw-r--r-- | ttun_server/websockets.py | 3 |
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 | |||
| 4 | from uuid import uuid4 | 4 | from uuid import uuid4 |
| 5 | 5 | ||
| 6 | from fastapi import WebSocket, WebSocketDisconnect | 6 | from fastapi import WebSocket, WebSocketDisconnect |
| 7 | from starlette.authentication import requires | ||
| 7 | 8 | ||
| 9 | import conf | ||
| 8 | import ttun_server | 10 | import ttun_server |
| 9 | from proxy.queue import ProxyQueue | 11 | from proxy.queue import ProxyQueue |
| 10 | from ttun_server.types import ( | 12 | from 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 []) | ||
| 34 | async def tunnel(websocket: WebSocket) -> None: | 37 | async 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] = {} |
