Added auth layer

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
 from uuid import uuid4
 
 from fastapi import WebSocket, WebSocketDisconnect
+from starlette.authentication import requires
 
+import conf
 import ttun_server
 from proxy.queue import ProxyQueue
 from ttun_server.types import (
@@ -31,6 +33,7 @@ async def assert_compatible_version(websocket: WebSocket, config: Config) -> Non
             await websocket.close(4001, 'Your client is too new')
 
 
+@requires(['authenticated', 'token'] if conf.ENABLE_AUTH else [])
 async def tunnel(websocket: WebSocket) -> None:
     request_tasks: dict[str, asyncio.Task] = {}
     proxy_queues: dict[str, ProxyQueue] = {}