From b5b66ef077112687be9e2aa81c1341c6a73c368d Mon Sep 17 00:00:00 2001 From: Maryam Abdoli Date: Fri, 3 Nov 2023 18:29:51 -0400 Subject: [PATCH] fix tests by reverting the chat endpoint dependecies --- src/backend/langflow/api/v1/chat.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/src/backend/langflow/api/v1/chat.py b/src/backend/langflow/api/v1/chat.py index 0647ef71f..e1e588d8f 100644 --- a/src/backend/langflow/api/v1/chat.py +++ b/src/backend/langflow/api/v1/chat.py @@ -2,6 +2,7 @@ from fastapi import ( APIRouter, Depends, HTTPException, + Query, WebSocket, WebSocketException, status, @@ -10,9 +11,11 @@ from fastapi.responses import StreamingResponse from langflow.api.utils import build_input_keys_response from langflow.api.v1.schemas import BuildStatus, BuiltResponse, InitResponse, StreamData -from langflow.services.database.models.user.user import User from langflow.graph.graph.base import Graph -from langflow.services.auth.utils import get_current_active_user +from langflow.services.auth.utils import ( + get_current_active_user, + get_current_user_by_jwt, +) from langflow.services.cache.utils import update_build_status from loguru import logger from langflow.services.getters import get_chat_service, get_session, get_cache_service @@ -28,12 +31,13 @@ router = APIRouter(tags=["Chat"]) async def chat( client_id: str, websocket: WebSocket, + token: str = Query(...), db: Session = Depends(get_session), chat_service: "ChatService" = Depends(get_chat_service), - user: User = Depends(get_current_active_user), ): """Websocket endpoint for chat.""" try: + user = await get_current_user_by_jwt(token, db) await websocket.accept() if not user: await websocket.close(