fix: read WebSocket token from query_params directly, not function arg
This commit is contained in:
+2
-1
@@ -150,8 +150,9 @@ async def open_file(body: dict, user: dict = Depends(current_user)):
|
|||||||
|
|
||||||
|
|
||||||
@router.websocket("/ws")
|
@router.websocket("/ws")
|
||||||
async def websocket_endpoint(ws: WebSocket, token: str = ""):
|
async def websocket_endpoint(ws: WebSocket):
|
||||||
from auth import get_user_for_token
|
from auth import get_user_for_token
|
||||||
|
token = ws.query_params.get("token", "")
|
||||||
user = get_user_for_token(token)
|
user = get_user_for_token(token)
|
||||||
if not user:
|
if not user:
|
||||||
await ws.close(code=4001)
|
await ws.close(code=4001)
|
||||||
|
|||||||
Reference in New Issue
Block a user