|
8 | 8 |
|
9 | 9 | from apps.chat.curd.chat import list_chats, get_chat_with_records, create_chat, rename_chat, \ |
10 | 10 | delete_chat, list_records |
11 | | -from apps.chat.models.chat_model import CreateChat, ChatRecord, RenameChat, Chat, ChatQuestion, ChatToken |
| 11 | +from apps.chat.models.chat_model import CreateChat, ChatRecord, RenameChat, Chat, ChatQuestion, ChatMcp |
12 | 12 | from apps.chat.task.llm import LLMService |
13 | 13 | from apps.datasource.crud.datasource import get_table_schema |
14 | 14 | from apps.datasource.models.datasource import CoreDatasource |
@@ -58,13 +58,13 @@ async def delete(session: SessionDep, chart_id: int): |
58 | 58 |
|
59 | 59 |
|
60 | 60 | @router.post("/mcp_start", operation_id="mcp_start") |
61 | | -async def mcp_start(session: SessionDep, chat: ChatToken): |
| 61 | +async def mcp_start(session: SessionDep, chat: ChatMcp): |
62 | 62 | user = await get_current_user(session, chat.token) |
63 | 63 | return create_chat(session, user, CreateChat(), False) |
64 | 64 |
|
65 | 65 |
|
66 | 66 | @router.post("/mcp_question", operation_id="mcp_question") |
67 | | -async def mcp_question(session: SessionDep, chat: ChatToken): |
| 67 | +async def mcp_question(session: SessionDep, chat: ChatMcp): |
68 | 68 | user = await get_current_user(session, chat.token) |
69 | 69 | return await stream_sql(session, user, chat) |
70 | 70 |
|
|
0 commit comments