|
|
@@ -48,11 +48,10 @@ def get_current_user(token: str = Depends(oauth2_scheme)):
|
|
|
|
|
|
|
|
|
async def get_current_user_websocket(websocket: WebSocket):
|
|
|
- auth_header = websocket.headers.get('Authorization')
|
|
|
- if auth_header is None or not auth_header.startswith('Bearer '):
|
|
|
+ token = websocket.query_params.get('token')
|
|
|
+ if token is None:
|
|
|
await websocket.close(code=1008)
|
|
|
raise WebSocketDisconnect(code=status.WS_1008_POLICY_VIOLATION)
|
|
|
- token = auth_header[len('Bearer '):]
|
|
|
try:
|
|
|
payload = jwt.decode(token, SECRET_KEY, algorithms=[ALGORITHM])
|
|
|
username: str = payload.get("sub")
|
|
|
@@ -67,4 +66,4 @@ async def get_current_user_websocket(websocket: WebSocket):
|
|
|
except jwt.PyJWTError as e:
|
|
|
print(e)
|
|
|
await websocket.close(code=1008)
|
|
|
- raise WebSocketDisconnect(code=status.WS_1008_POLICY_VIOLATION)
|
|
|
+ raise WebSocketDisconnect(code=status.WS_1008_POLICY_VIOLATION)
|