fix tests by reverting the chat endpoint dependecies
This commit is contained in:
parent
ef949838e2
commit
b5b66ef077
1 changed files with 7 additions and 3 deletions
|
|
@ -2,6 +2,7 @@ from fastapi import (
|
||||||
APIRouter,
|
APIRouter,
|
||||||
Depends,
|
Depends,
|
||||||
HTTPException,
|
HTTPException,
|
||||||
|
Query,
|
||||||
WebSocket,
|
WebSocket,
|
||||||
WebSocketException,
|
WebSocketException,
|
||||||
status,
|
status,
|
||||||
|
|
@ -10,9 +11,11 @@ from fastapi.responses import StreamingResponse
|
||||||
from langflow.api.utils import build_input_keys_response
|
from langflow.api.utils import build_input_keys_response
|
||||||
from langflow.api.v1.schemas import BuildStatus, BuiltResponse, InitResponse, StreamData
|
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.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 langflow.services.cache.utils import update_build_status
|
||||||
from loguru import logger
|
from loguru import logger
|
||||||
from langflow.services.getters import get_chat_service, get_session, get_cache_service
|
from langflow.services.getters import get_chat_service, get_session, get_cache_service
|
||||||
|
|
@ -28,12 +31,13 @@ router = APIRouter(tags=["Chat"])
|
||||||
async def chat(
|
async def chat(
|
||||||
client_id: str,
|
client_id: str,
|
||||||
websocket: WebSocket,
|
websocket: WebSocket,
|
||||||
|
token: str = Query(...),
|
||||||
db: Session = Depends(get_session),
|
db: Session = Depends(get_session),
|
||||||
chat_service: "ChatService" = Depends(get_chat_service),
|
chat_service: "ChatService" = Depends(get_chat_service),
|
||||||
user: User = Depends(get_current_active_user),
|
|
||||||
):
|
):
|
||||||
"""Websocket endpoint for chat."""
|
"""Websocket endpoint for chat."""
|
||||||
try:
|
try:
|
||||||
|
user = await get_current_user_by_jwt(token, db)
|
||||||
await websocket.accept()
|
await websocket.accept()
|
||||||
if not user:
|
if not user:
|
||||||
await websocket.close(
|
await websocket.close(
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue