| | |
| | | from fastapi import Depends, APIRouter |
| | | from sqlalchemy.orm import Session |
| | | from starlette.responses import StreamingResponse |
| | | from app.api import get_current_user |
| | | from app.models import UserModel |
| | | from app.models.base_model import get_db |
| | | from app.models.v2.session_model import ChatDialogData |
| | | from app.service.v2.chat import service_chat_dialog |
| | | |
| | | chat1_router = APIRouter() |
| | | |
| | | |
| | | @chat1_router.get("/chat_dialog") |
| | | async def api_chat_dialog(dialog: ChatDialogData, db: Session = Depends(get_db), current_user: UserModel = Depends(get_current_user)): |
| | | return StreamingResponse(await service_chat_dialog(dialog.question, dialog.sessionId), media_type="text/event-stream") |