From bc14d3aa162c8658f5d96056e410590e1a75a00a Mon Sep 17 00:00:00 2001 From: liubiren Date: Tue, 4 Aug 2026 20:13:08 +0800 Subject: [PATCH] 1 --- agent/application/agents/__init__.py | 7 + agent/application/agents/chat_agent.py | 39 +++ .../agents/generating_prd_agent.py | 39 +++ agent/application/domain_models.py | 12 +- agent/application/pages/conversation.py | 267 +++++++++--------- agent/application/states/auth.py | 25 +- agent/application/states/conversation.py | 212 +++++++------- agent/application/states/database.py | 12 +- agent/assets/styles.css | 25 ++ agent/database.db | Bin 253952 -> 331776 bytes agent/reflex.lock/bun.lock | 1 - agent/reflex.lock/package.json | 1 - 12 files changed, 395 insertions(+), 245 deletions(-) create mode 100644 agent/application/agents/__init__.py create mode 100644 agent/application/agents/chat_agent.py create mode 100644 agent/application/agents/generating_prd_agent.py diff --git a/agent/application/agents/__init__.py b/agent/application/agents/__init__.py new file mode 100644 index 0000000..52476ef --- /dev/null +++ b/agent/application/agents/__init__.py @@ -0,0 +1,7 @@ +# -*- coding: utf-8 -*- +from application.agents.chat_agent import chat_agent + + +__all__ = [ + "chat_agent", +] diff --git a/agent/application/agents/chat_agent.py b/agent/application/agents/chat_agent.py new file mode 100644 index 0000000..5a908e6 --- /dev/null +++ b/agent/application/agents/chat_agent.py @@ -0,0 +1,39 @@ +# -*- coding: utf-8 -*- +""" +开放式对话智能体 +""" +from pydantic_ai import Agent +from pydantic_ai.models.openai import OpenAIChatModel +from pydantic_ai.providers.openai import OpenAIProvider + +instructions: str = """ +# 角色 +专业友好AI助手，结构化解答各类问题。 + +# 输出硬性规则 +1. 全文强制标准Markdown，禁止纯文本；不要额外说明排版格式，直接输出内容； +2. 层级使用 `#/##/###`，列表用 `-` 无序列表或数字有序列表； +3. 代码块用 ```语言名``` 包裹； +4. 重点内容标注 **粗体**/*斜体*； +5. 思考、工具日志仅输出文本，适配前端折叠面板，禁止输出HTML标签； +6. 内容分点拆分，排版整洁适配前端Markdown渲染。 + +# 行文要求 +语言通俗，逻辑完整简洁，无多余废话。 +""" + +# 实例化智能体 +chat_agent: Agent = Agent( + name="chat_agent", + model=OpenAIChatModel( + model_name="deepseek-v4-flash", + provider=OpenAIProvider( + base_url="https://tokenhub.tencentmaas.com/v1", + api_key="sk-D9Y1mCe8VlvNqLuSC4mAjqEwxJ2nW4C0h8a7EPn8kg9RLsHq", + ), + ), + instructions=instructions, + capabilities=None, + output_type=str, + retries=1, +) diff --git a/agent/application/agents/generating_prd_agent.py b/agent/application/agents/generating_prd_agent.py new file mode 100644 index 0000000..2793f8d --- /dev/null +++ b/agent/application/agents/generating_prd_agent.py @@ -0,0 +1,39 @@ +# -*- coding: utf-8 -*- +""" +生成产品需求文档智能体 +""" +from pydantic_ai import Agent +from pydantic_ai.models.openai import OpenAIChatModel +from pydantic_ai.providers.openai import OpenAIProvider + +instructions: str = """ +# 角色 +专业友好AI助手，结构化解答各类问题。 + +# 输出硬性规则 +1. 全文强制标准Markdown，禁止纯文本；不要额外说明排版格式，直接输出内容； +2. 层级使用 `#/##/###`，列表用 `-` 无序列表或数字有序列表； +3. 代码块用 ```语言名``` 包裹； +4. 重点内容标注 **粗体**/*斜体*； +5. 思考、工具日志仅输出文本，适配前端折叠面板，禁止输出HTML标签； +6. 内容分点拆分，排版整洁适配前端Markdown渲染。 + +# 行文要求 +语言通俗，逻辑完整简洁，无多余废话。 +""" + +# 实例化智能体 +chat_agent: Agent = Agent( + name="chat_agent", + model=OpenAIChatModel( + model_name="deepseek-v4-flash", + provider=OpenAIProvider( + base_url="https://tokenhub.tencentmaas.com/v1", + api_key="sk-D9Y1mCe8VlvNqLuSC4mAjqEwxJ2nW4C0h8a7EPn8kg9RLsHq", + ), + ), + instructions=instructions, + capabilities=None, + output_type=str, + retries=1, +) diff --git a/agent/application/domain_models.py b/agent/application/domain_models.py index 749bee6..d9a6966 100644 --- a/agent/application/domain_models.py +++ b/agent/application/domain_models.py @@ -7,6 +7,7 @@ from typing import Dict, List from pydantic import BaseModel, Field from pydantic_ai._uuid import uuid7 +from enum import StrEnum class Thought(BaseModel): @@ -24,7 +25,7 @@ class Dialog(BaseModel): """ id: str = Field(default_factory=lambda: str(uuid7()), description="对话唯一标识") - user_prompt: str = Field(..., description="用户提示词") + user_prompt: str = Field(default="", description="用户提示词") thoughts: Dict[int, Thought] = Field(default_factory=dict, description="思考列表") result_output: str = Field(default="", description="结果输出") is_thinking: bool = Field( @@ -50,3 +51,12 @@ class Conversation(BaseModel): ..., description="创建时间", ) + + +class TaskType(StrEnum): + """ + 任务类型枚举 + """ + + CHAT = "chat" + GENERATING_PRD = "generating_prd" diff --git a/agent/application/pages/conversation.py b/agent/application/pages/conversation.py index 9d073f0..72e92bc 100644 --- a/agent/application/pages/conversation.py +++ b/agent/application/pages/conversation.py @@ -288,7 +288,8 @@ def greeting_showing() -> rx.Component: ), rx.hstack( rx.box( - "智能客服", + "生成产品需求文档", + on_click=ConversationState.generate_prd, padding="10px 16px", background_color="var(--prismui-background-color-6)", border_radius="var(--prismui-border-radius-9)", @@ -372,96 +373,122 @@ def dialog_showing(item: Tuple[str, Dialog]) -> rx.Component: is_expanded = dialog.is_expanded return rx.vstack( - rx.hstack( - rx.spacer(), - rx.vstack( - # 用户提示词 - rx.text( - dialog.user_prompt, - max_width="600px", - padding="12px 16px", - background_color="var(--prismui-background-color-3)", - border_radius="var(--prismui-border-radius-3)", - line_height="1.5", - word_wrap="break-word", - word_break="break-all", - white_space="pre-line", - ), - rx.hstack( - # 再次发送 - rx.box( - rx.icon( - "rotate-ccw", - width="14px", - height="14px", - color="var(--prismui-color-2)", - ), - padding="4px", - border_radius="var(--prismui-border-radius-1)", - cursor="pointer", - style={ - "_hover": { - "background_color": "var(--prismui-background-color-2)", - } - }, - ), - width="100%", - margin_top="8px", - ), - ), - align_items="flex-start", - gap="4px", - width="100%", - margin_top="8px", - ), - # 思考折叠面板 - rx.vstack( - # 标题 - rx.box( - rx.hstack( + # 用户提示词 + rx.cond( + dialog.user_prompt, + rx.hstack( + rx.spacer(), + rx.vstack( rx.text( - rx.cond(is_thinking, "思考中", "思考完成"), - font_size="var(--prismui-font-size-1)", - color="var(--prismui-color-3)", + dialog.user_prompt, + max_width="600px", + padding="12px 16px", + background_color="var(--prismui-background-color-3)", + border_radius="var(--prismui-border-radius-3)", + line_height="1.5", + word_wrap="break-word", + word_break="break-all", + white_space="pre-line", ), - rx.icon( - "chevron-right", - width="14px", - height="14px", - color="var(--prismui-color-3)", - transform=rx.cond(is_expanded, "rotate(90deg)", "rotate(0deg)"), - transition="transform 0.18s ease-in-out", - ), - align_items="center", - gap="4px", - margin_bottom="8px", - line_height="22px", - ), - # 点击事件，展开/折叠思考折叠面板 - on_click=lambda: ConversationState.toggle_collapse(dialog.id), - cursor="pointer", - ), - # 思考 - rx.box( - rx.box( - rx.auto_scroll( - rx.foreach( - dialog.thoughts, - thought_showing, + rx.hstack( + # 再次发送 + rx.box( + rx.icon( + "rotate-ccw", + width="14px", + height="14px", + color="var(--prismui-color-2)", + ), + padding="4px", + border_radius="var(--prismui-border-radius-1)", + cursor="pointer", + style={ + "_hover": { + "background_color": "var(--prismui-background-color-2)", + } + }, ), width="100%", margin_top="8px", - align_self="start", ), - style={"overflow": "hidden", "min-height": "0"}, ), - display="grid", - grid_template_rows=rx.cond(is_expanded, "1fr", "0fr"), + align_items="flex-start", + gap="4px", width="100%", + margin_top="8px", + ), + rx.fragment(), + ), + # 思考折叠面板 + rx.cond( + dialog.thoughts, + rx.vstack( + # 标题 + rx.box( + rx.hstack( + rx.text( + rx.cond(is_thinking, "思考中", "思考完成"), + font_size="var(--prismui-font-size-1)", + color="var(--prismui-color-3)", + ), + rx.icon( + "chevron-right", + width="14px", + height="14px", + color="var(--prismui-color-3)", + transform=rx.cond( + is_expanded, "rotate(90deg)", "rotate(0deg)" + ), + transition="transform 0.18s ease-in-out", + ), + align_items="center", + gap="4px", + margin_bottom="8px", + line_height="22px", + ), + # 点击事件，展开/折叠思考折叠面板 + on_click=lambda: ConversationState.toggle_collapse(dialog.id), + cursor="pointer", + ), + # 思考 + rx.box( + rx.box( + rx.auto_scroll( + rx.foreach( + dialog.thoughts, + thought_showing, + ), + width="100%", + align_self="start", + ), + style={"overflow": "hidden", "min-height": "0"}, + ), + display="grid", + grid_template_rows=rx.cond(is_expanded, "1fr", "0fr"), + width="100%", + opacity=rx.cond(is_expanded, "1", "0"), + overflow="hidden", + transition="grid-template-rows 0.18s ease-in-out, opacity 0.18s ease-in-out", + ), margin_bottom="8px", - opacity=rx.cond(is_expanded, "1", "0"), - overflow="hidden", - transition="grid-template-rows 0.18s ease-in-out, opacity 0.18s ease-in-out", + ), + # 若思考列表为空且正在运行则显示加载动效 + rx.cond( + ConversationState.running_status, + rx.box( + rx.box( + class_name="loadin", + flex_shrink="0", + ), + display="flex", + justify_content="center", + align_items="center", + width="32px", + height="18px", + margin_bottom="8px", + overflow="hidden", + ), + rx.fragment(), ), ), # 结果输出 @@ -643,58 +670,34 @@ def conversation_creating() -> rx.Component: """ ), rx.spacer(), - rx.dialog.root( - rx.dialog.trigger( - rx.box( - rx.tooltip( - rx.icon( - "plus", - width="14px", - height="14px", - style={ - "_hover": { - "color": "var(--prismui-color-5)", - } - }, - ), - content="新建会话", - side="top", - side_offset=9, - background_color="var(--prismui-background-color-1)", - box_shadow="var(--prismui-box-shadow-3)", - ), - display="flex", - justify_content="center", - align_items="center", - width="24px", - height="24px", - background_color="var(--prismui-background-color-1)", - box_shadow="var(--prismui-box-shadow-8)", - border_radius="var(--prismui-border-radius-9)", - cursor="pointer", - ) - ), - rx.dialog.content( - rx.form( - rx.hstack( - rx.input( - name="description", - placeholder="请输入会话描述", - flex="auto", - min_width="20ch", - ), - rx.button("新建"), - spacing="2", - wrap="wrap", - width="100%", - ), - # 提交事件：新建对话 - on_submit=ConversationState.create_conversation, + rx.box( + rx.tooltip( + rx.icon( + "plus", + on_click=ConversationState.create_conversation, + width="14px", + height="14px", + style={ + "_hover": { + "color": "var(--prismui-color-5)", + } + }, ), - background_color=rx.color("mauve", 1), + content="创建会话", + side="top", + side_offset=9, + background_color="var(--prismui-background-color-1)", + box_shadow="var(--prismui-box-shadow-3)", ), - open=ConversationState.is_conversation_creating, - on_open_change=ConversationState.toggle_conversation_creating, + display="flex", + justify_content="center", + align_items="center", + width="24px", + height="24px", + background_color="var(--prismui-background-color-1)", + box_shadow="var(--prismui-box-shadow-8)", + border_radius="var(--prismui-border-radius-9)", + cursor="pointer", ), display="flex", justify_content="flex-end", diff --git a/agent/application/states/auth.py b/agent/application/states/auth.py index f679624..fe85e03 100644 --- a/agent/application/states/auth.py +++ b/agent/application/states/auth.py @@ -6,7 +6,7 @@ from asyncio import sleep from email.header import Header from email.mime.text import MIMEText import re -from typing import AsyncGenerator +from typing import AsyncGenerator, Optional from aiosmtplib import SMTP, SMTPException import reflex as rx @@ -50,6 +50,9 @@ class AuthState(rx.State): # 激活的导航按钮 activated_nav_button: str = "conversation" + # 数据库状态 + _db_state: Optional[DatabaseState] = None + @rx.event def reset_login_error_message(self) -> None: """ @@ -91,6 +94,7 @@ class AuthState(rx.State): ): self.login_error_message = "邮箱格式不正确，请重新输入" return False + self.login_error_message = "" return True @@ -123,10 +127,12 @@ class AuthState(rx.State): 发送验证码（后台任务） :return: None """ + if not self._db_state: + return + async with self: # 创建验证码记录并获取验证码 - database_state = await self.get_state(DatabaseState) - captcha = await database_state.create_captcha_record(email=self.email) + captcha = await self._db_state.create_captcha_record(email=self.email) # 构建验证码邮件 message = MIMEText( @@ -166,6 +172,9 @@ class AuthState(rx.State): self.is_captcha_sent = True + # 获取数据库状态 + self._db_state = await self.get_state(DatabaseState) + # 将倒计时和发送验证码事件添加至后台任务队列 yield type(self).countdown() yield type(self).send_captcha_background() @@ -221,19 +230,20 @@ class AuthState(rx.State): self.login_error_message = "请先阅读并同意协议和政策" return + if not self._db_state: + return + self.is_logging_in = True - # 获取数据库状态 - database_state = await self.get_state(DatabaseState) # 核验验证码 - if not await database_state.verify_captcha( + if not await self._db_state.verify_captcha( email=self.email, captcha=self.captcha ): self.is_logging_in = False self.login_error_message = "验证码错误" return # 创建用户记录 - user_id = await database_state.create_user_record(email=self.email) + user_id = await self._db_state.create_user_record(email=self.email) # 恢复当前用户会话状态 conversation_state = await self.get_state(ConversationState) @@ -271,7 +281,6 @@ class AuthState(rx.State): conversation_state.conversations = {} conversation_state.conversation_id = "" conversation_state.is_conversation_history_shown = False - conversation_state.is_conversation_creating = False self.user_id = "" diff --git a/agent/application/states/conversation.py b/agent/application/states/conversation.py index fe6c8ed..e217133 100644 --- a/agent/application/states/conversation.py +++ b/agent/application/states/conversation.py @@ -3,8 +3,8 @@ 会话状态 """ from datetime import datetime -from typing import Any, AsyncGenerator, Dict, List -from pydantic_ai import Agent, ThinkingPartDelta +from typing import Any, AsyncGenerator, Dict, List, Optional +from pydantic_ai import Agent, ThinkingPartDelta, ModelMessage from pydantic_ai.messages import ( FunctionToolCallEvent, FunctionToolResultEvent, @@ -18,48 +18,19 @@ from pydantic_ai.messages import ( ToolCallPart, ToolSearchCallPart, ) -from pydantic_ai.models.openai import OpenAIChatModel -from pydantic_ai.providers.openai import OpenAIProvider + from pydantic_ai.run import AgentRunResultEvent import reflex as rx + from application.states.database import DatabaseState from application.domain_models import ( Conversation, Dialog, Thought, + TaskType, ) - -instructions: str = """ -# 角色 -专业友好AI助手，结构化解答各类问题。 - -# 输出硬性规则 -1. 全文强制标准Markdown，禁止纯文本；不要额外说明排版格式，直接输出内容； -2. 层级使用 `#/##/###`，列表用 `-` 无序列表或数字有序列表； -3. 代码块用 ```语言名``` 包裹； -4. 重点内容标注 **粗体**/*斜体*； -5. 思考、工具日志仅输出文本，适配前端折叠面板，禁止输出HTML标签； -6. 内容分点拆分，排版整洁适配前端Markdown渲染。 - -# 行文要求 -语言通俗，逻辑完整简洁，无多余废话。 -""" - -# 实例化智能体（因无法序列化故剥离出状态管理） -agent: Agent = Agent( - model=OpenAIChatModel( - model_name="deepseek-v4-flash", - provider=OpenAIProvider( - base_url="https://tokenhub.tencentmaas.com/v1", - api_key="sk-D9Y1mCe8VlvNqLuSC4mAjqEwxJ2nW4C0h8a7EPn8kg9RLsHq", - ), - ), - instructions=instructions, - capabilities=None, - output_type=str, - retries=1, -) +from application.agents import chat_agent class ConversationState(rx.State): @@ -79,12 +50,14 @@ class ConversationState(rx.State): # 显示更多的会话唯一标识 shown_more_conversation_id: str = "" - # 会话创建状态，True表示正在创建，False表示未正在创建 - is_conversation_creating: bool = False - + # 任务类型 + task_type: TaskType = TaskType.CHAT # 用户提示词 user_prompt: str = "" + # 数据库状态（私有变量，不予序列化） + _db_state: Optional[DatabaseState] = None + async def resume(self, user_id: str) -> None: """ 恢复当前用户会话状态 @@ -95,18 +68,19 @@ class ConversationState(rx.State): if not self.user_id: return - database_state = await self.get_state(DatabaseState) + self._db_state = await self.get_state(DatabaseState) + # 获取会话字典 - self.conversations = await database_state.get_conversations( + self.conversations = await self._db_state.get_conversations( user_id=self.user_id ) # 若会话字典为空则先创建会话记录再在会话字典中添加会话实例 if not self.conversations: self.conversations.update( - await database_state.create_conversations_record(user_id=self.user_id) + await self._db_state.create_conversations_record(user_id=self.user_id) ) # 将最后一个会话作为当前会话并更新会话唯一标识 - self.conversation_id = next(reversed(self.conversations)) + self.conversation_id = next(reversed(self.conversations.keys())) @rx.event def toggle_conversation_history_shown(self) -> None: @@ -133,9 +107,11 @@ class ConversationState(rx.State): :param conversation_id: 需删除的会话唯一标识 :return: None """ + if not self._db_state: + return + # 先设置会话记录为已删除再在会话字典中删除会话实例 - database_state = await self.get_state(DatabaseState) - await database_state.set_conversations_record_deleted( + await self._db_state.set_conversations_record_deleted( conversation_id=conversation_id ) del self.conversations[conversation_id] @@ -143,12 +119,12 @@ class ConversationState(rx.State): # 删除后，若会话字典为空则先创建会话记录再添加会话实例 if not self.conversations: self.conversations.update( - await database_state.create_conversations_record(user_id=self.user_id) + await self._db_state.create_conversations_record(user_id=self.user_id) ) # 删除后，若当前会话不存在则将最后一个会话作为当前会话并更新会话唯一标识 if self.conversation_id not in self.conversations: - self.conversation_id = next(reversed(self.conversations)) + self.conversation_id = next(reversed(self.conversations.keys())) @rx.event def switch_conversation(self, conversation_id: str) -> None: @@ -160,34 +136,22 @@ class ConversationState(rx.State): self.conversation_id = conversation_id @rx.event - async def create_conversation(self, form_data: Dict[str, Any]) -> None: + async def create_conversation(self) -> None: """ 创建会话 - :param form_data: 表单数据 :return: None """ - # 解析会话描述 - description = form_data["description"].strip() or "新会话" - # 创建会话记录再添加会话实例 - database_state = await self.get_state(DatabaseState) + if not self._db_state: + return + self.conversations.update( - await database_state.create_conversations_record( - user_id=self.user_id, description=description + await self._db_state.create_conversations_record( + user_id=self.user_id, description="新会话" ) ) # 将最后一个会话作为当前会话并更新会话唯一标识 - self.conversation_id = next(reversed(self.conversations)) - - # 会话创建状态设置为未正在创建 - self.is_conversation_creating = False - - @rx.event - def toggle_conversation_creating(self) -> None: - """ - 切换会话创建状态 - """ - self.is_conversation_creating = not self.is_conversation_creating + self.conversation_id = next(reversed(self.conversations.keys())) @rx.event def set_user_prompt(self, user_prompt: str) -> None: @@ -234,46 +198,30 @@ class ConversationState(rx.State): return {} return conversation.dialogs - @rx.event - async def handle_user_prompt(self) -> AsyncGenerator[None]: + async def run_stream_events( + self, + conversation: Conversation, + dialog: Dialog, + agent: Agent, + message_history: Optional[List[ModelMessage]] = None, + ) -> AsyncGenerator[None]: """ - 处理用户提示词 + 运行并处理流式事件 + :param agent: 代理 + :param conversation: 当前会话 + :param dialog: 当前对话 + :param message_history: 消息历史列表 :return: AsyncGenerator[None] """ - if not self.user_prompt: + if not self._db_state: return - # 清空前端用户提示词 - user_prompt = self.user_prompt - self.user_prompt = "" - - # 当前会话 - conversation = self.conversations[self.conversation_id] - # 将运行状态设置为正在运行 - conversation.is_running = True - - database_state = await self.get_state(DatabaseState) - - # 创建对话记录再添加对话实例 - conversation.dialogs.update( - await database_state.create_dialog_record( - conversation_id=self.conversation_id, user_prompt=user_prompt - ) - ) - # 强制更新会话并推送前端 - self.conversations[self.conversation_id] = conversation - yield - - # 将最后一个对话作为当前对话 - dialog = next(reversed(conversation.dialogs.values())) # 初始化工具调用唯一标识和片段索引映射字典 tool_call_ids: Dict[str, int] = {} async with agent.run_stream_events( conversation_id=self.conversation_id, - user_prompt=user_prompt, - message_history=await database_state.get_message_history( - conversation_id=self.conversation_id - ), + user_prompt=dialog.user_prompt, + message_history=message_history, ) as events: async for event in events: match event: @@ -397,25 +345,91 @@ class ConversationState(rx.State): # ========== 智能体运行结果事件 ========== case AgentRunResultEvent(result=result): + # 获取数据库状态 # 补全对话记录 - await database_state.complete_dialog_record( + await self._db_state.complete_dialog_record( id=dialog.id, thoughts=dialog.thoughts, result_output=dialog.result_output, ) # 创建结果记录 - await database_state.create_result_record( + await self._db_state.create_result_record( conversation_id=self.conversation_id, dialog_id=dialog.id, new_messages=result.new_messages(), ) - # 将当前会话的运行状态设置为运行完成 + # 将正在运行设置为否 conversation.is_running = False # 强制更新会话并推送前端 self.conversations[self.conversation_id] = conversation yield + @rx.event + async def handle_user_prompt(self) -> AsyncGenerator[None]: + """ + 处理用户提示词 + :return: AsyncGenerator[None] + """ + if not self.user_prompt: + return + + if not self._db_state: + return + + # 当前会话 + conversation = self.conversations[self.conversation_id] + # 将正在运行设置为是 + conversation.is_running = True + # 创建对话记录再添加对话实例 + conversation.dialogs.update( + await self._db_state.create_dialog_record( + conversation_id=self.conversation_id, user_prompt=self.user_prompt + ) + ) + # 将最后一个对话作为当前对话 + dialog = next(reversed(conversation.dialogs.values())) + # 清空前端用户提示词 + self.user_prompt = "" + # 强制更新会话并推送前端 + self.conversations[self.conversation_id] = conversation + yield + + match self.task_type: + # 开放式对话 + case TaskType.CHAT: + async for _ in self.run_stream_events( + conversation=conversation, + dialog=dialog, + agent=chat_agent, + message_history=await self._db_state.get_message_history( + conversation_id=self.conversation_id + ), + ): + yield + + case TaskType.GENERATING_PRD: + ... + + @rx.event + async def generate_prd(self) -> AsyncGenerator[None]: + """ + 生成产品需求文档 + """ + if not self._db_state: + return + + # 当前会话 + conversation = self.conversations[self.conversation_id] + + # 创建对话记录再添加对话实例 + conversation.dialogs.update( + await self._db_state.create_dialog_record( + conversation_id=self.conversation_id, result_output="请输入产品需求" + ) + ) + yield + @rx.event def toggle_collapse(self, dialog_id: str) -> None: """ diff --git a/agent/application/states/database.py b/agent/application/states/database.py index b1b6701..2758e3e 100644 --- a/agent/application/states/database.py +++ b/agent/application/states/database.py @@ -298,23 +298,29 @@ class DatabaseState(rx.State): await session.commit() async def create_dialog_record( - self, conversation_id: str, user_prompt: str + self, conversation_id: str, user_prompt: str = "", result_output: str = "" ) -> Dict[str, Dialog]: """ 创建对话记录 :param conversation_id: 会话唯一标识 :param user_prompt: 用户提示词 + :param result_output: 结果输出 :return: 创建对话记录的唯一标识 """ async with rx.asession() as session: record = DialogRecord( conversation_id=conversation_id, user_prompt=user_prompt, + result_output=result_output, ) session.add(record) await session.commit() await session.refresh(record) - return {record.id: Dialog(id=record.id, user_prompt=user_prompt)} + return { + record.id: Dialog( + id=record.id, user_prompt=user_prompt, result_output=result_output + ) + } async def complete_dialog_record( self, @@ -366,7 +372,7 @@ class DatabaseState(rx.State): async def get_message_history(self, conversation_id: str) -> List[ModelMessage]: """ - 获取消息历史 + 获取消息历史列表 :param conversation_id: 会话唯一标识 :return: 消息历史 """ diff --git a/agent/assets/styles.css b/agent/assets/styles.css index 2d45ce1..73a043b 100644 --- a/agent/assets/styles.css +++ b/agent/assets/styles.css @@ -59,4 +59,29 @@ pre { pre, pre code { font-family: Consolas, "Microsoft YaHei", sans-serif !important; +} + +.loadin { + width: 6px; + aspect-ratio: 1; + border-radius: 50%; + animation: loadin 0.9s infinite ease-in-out; +} +@keyframes loadin { + 0% { + box-shadow: 12px 0 var(--prismui-color-5), -12px 0 var(--prismui-color-9); + background: var(--prismui-color-5); + } + 33% { + box-shadow: 12px 0 var(--prismui-color-5), -12px 0 var(--prismui-color-9); + background: var(--prismui-color-9); + } + 66% { + box-shadow: 12px 0 var(--prismui-color-9), -12px 0 var(--prismui-color-5); + background: var(--prismui-color-9); + } + 100% { + box-shadow: 12px 0 var(--prismui-color-9), -12px 0 var(--prismui-color-5); + background: var(--prismui-color-5); + } } \ No newline at end of file diff --git a/agent/database.db b/agent/database.db index b4433d48796d366f1396c468f62ef41b03ef9ff0..9efe3dd30775acf567e6e1bf5100d9a23129d046 100644 GIT binary patch delta 47920 zcmd753wTu5buX?n0&Ijpn3s7O3vm3v8F?OO&Y2;pAGLAwa*XY`ZBixnJd@ZCHfeqH zbdGokBq8)bpaTdHU|z-`fx(~`C~j|WbKBm3nx;2t+JAf-TW4m}+tg{l?Wo2cLwO8M#^qqhD*gf-Z zn6s^{>d&ioSAC}H&N=@&XK2p03pdSuVUAC|q2uZM7OVR@bb zAhtFftOp_X%t->jMapqVKu6%)44A#7*a#}m}Zf+p;%2csE1>k zI*poj+8y&OvdV_4omETcoSdW1eq;8>D;Lf>I_sW_ zp$jWsI8^cejknEs^2u9od>{~vWs-?h+#kurRllx(EgcMn(&=jf5=z%M8~hc{^E+ffX73nejUHLd$&suuBU5jB)ahP7}ym>$Q`e4P--X=_D5ssus;#hVrn=P%f!M#r=yT8CpywVV>Q$`8myS} zR@tmM3(My8SAD;#r>efHwkljzF{f?LXXo5IXW@kvbw8VJ+*$slGLoBUV~XA1mnNR{B^;AGgrQa{5?JAFJqN*|o^!@XuyXBVdW< zrZYY8H(qf5#w*I-R=VwE)$m5)RbCcu#(3v%j9C80h~saJ8TvMR*>p^1e$^3tmVLaV z^4!wOs)4H4tIk!uT6Lo82+og#6&Joe@YmB;;Q2?F$vZSi} zgPNKoo}l~VY7E;j6xY?LmWX6B>B2%MRn4Ccs^DpANcG1uVBztUo(RRGFAb;t2vHonGqF zPBIkpt9k}(A`-?ql+GjpN;;TIr?m`N{}NBbs6P>k(b(Y#n0GqlPY1wFQXxH|MKg5vxAXrY^(mdQj~^=Cq0b9xZqV(f%J9ZRM(FsP8K z1{M`H49CCg+!cr1;7;kd5P^E4!0 zlwN{0(QvZGVzG!nr6$xwCYA~6dhDhP8~;a#&qGF)KLsIOn~bg@aumqu8Vw6%bd81{ zGP*{~0vTPSVS$XU(a=Li*J$Y>qtY^&hm1-$979GW#5^w5s*K0|KUuk;;=2{~75dE4nO!pdlx?(zoYYlFQyaQFkSJo0t_F4liDGz1@{$ z*bArHn-Q0}mgedUrrMqKb`91)-_x5>de@3fg_ESj0Wr_h-Bfx*o5CS7Z`>(z)0UOL z+`jUc%H@^6^u7H@bElX0msRE~H&rg3b)me!{P)kdKU8i!wGguS-8api3V70{G+-lF z4(GRAu{P}=8LS)WZ}{3vtzTMjaIaAOF4XpwlzjDJg6phCmS)V`=kLQ%BiccA6rmxvlo;&zxRNe^yFbs59Y8DEn@I4U<;xinN)V>H^2cTv$fuvd0 z?_2rNa1sq7=@=lOAJGiDFPa4cXsiV?VLTP+p+Y)ygnWY`A~?L!GLb?L;Xoi{-uJMw z)ZFqbWgb*_?n)0PxI>Jtrqk#!5>Dcm2+RTe3VzoEX@W42jF@c|<<+VH5lQO=L{tL` zG%bLs0xYzS1e5qZ5)0@~FNAvY&F}k`{;s^Kr&9n*kf(*hXeY}eAnWNge!(YA+5^6> zMS*}wP-7U=m^4kOc0=t3b7jA8fq@a}4MtNmK{L@I0Rk$>)!T^RQZLa^EvY;jsQPBbj0a(&m1o9!ZTR~E**Btl(U z7-WksG64{obZu`GY$q3pM2c1k1|`9#`90HjJGP64O<=E}8pNbB8QLN;aT|P{S2h!* z^-W}w=8rVr0`v19QRa92{gqkf_Kzqlj7TyJbP4!^3_TbI(xRCZrV@>+ynX?EkAxG> zWs1#OJgC&ws5fId)we(nE3$%c=SzH!?#jvS17&dD!`DQNH6H!bi3UQtqGl{w6 zZ*DpbhH=k#l^e|e?>kCmg~m9Jz!YMx{A9h*iE)Md|aPR}bECh0dy=sos0C5@PqjdN4c zIIJ~Is5IRRt;wBF2{X?m<6O>vy?k-9^RIloF3f+qpxoT?>d0*i$dvYpKoq8SGRo`WP!y-u%8!+Y#ytsZdhqi3qrMxI zCm@MGU{>7(kj~yTb&!fAl(A<$4shSHjzihS?zk{R!{`fmVrrlmBIijYBoHbq8bvzEyYd?YhnR;eE6L`|3vePGjp?eSO$>c*Pp3vknYk zOIUUL(2UM3%k0Ib!Hxy#=1*XA9?N!~&FwywZMcjVMy?FwJKo9e>$P?@=MHomR?i`! za&#c=u-!#<8|ii>a$xe z5JYVbq`m$5UIIUR`Mh<0vy6iF`QGEyb6<1zKv&jiXeTz&x&!hR*g$`(DZJ@1*|DoUqy&uo}en78qC!bdx{1 zE8qB9zUQjdvmc$&l#gA+u*FSt})^6%>>m{qLCBOYNh94Q+ zksI7e*xTEZI|8;wD9sPNIx=_#YeP%W)J51k0F<_%{}Dq7V5ly;`znxw*0l7k$El0n z-PVcCfS@%01x(cV;BjkckJURQxB?EX?E_Z*<&i5LvPft{BzO3-pw2pX9?;~s8>az& zez+@tqikft&lL5UI-IE%B(@@ph%FpETdOyC!lzm*`_YQ zf)~O3(fdf>PMeO8?aUs$b+e3w)+56Qv(20Ay~E1}66&b_r|pYn-~1;%xNfiyF7t&y zP(ItS@yGX<@fu( zd%pe8e8#hjaB@B9QR+%qFQ>xGX?OHBf!hfs;FDORt>EqZt%XqV?mneF`NyDs{@$*A5vB>OlWAJrbz{eW}=RG|IUY$W#->~NSS4bZl*&@ z##pH^`iZ1z<)Vo=sUry$qs!-bWyMxpSX&j?v~Y^?LTa~-J64!v!QgH{Z=$N%&>Akd z7#^l}o-iRO5Fw2%6Tx>x1ps||Dg?C#uMyF)iUYSdqm@?~J`J=9#|bIXD5)Es-tZP7 zk@YVv5~XEGX9$TgBS6Ebghhb}+6mO0>nns$G`N~I>YC}vdv{q11z#`}bVf_Nu9~_1w13Mr)kbHD( zKaPm}iEX*APVkK}x&}!ZtZ3xUHbTn4ztMw7@sCcGz8&~ti&_I+BYlH7ut*YVYky~G z{|726{C0otAEnnvA=rFnq2qseD5}}r`*}yYt~fwtMeyc##gIt>*&#KR(H3s zuXlzT%)36S+-AHp)QC1Bvt&oe$-@{? zCX>HfkK;e{4Dj=V`eYx$@jblsDTn`G%~c;YVO3-?4e5# zC?H|wdyaTVdh5W>clufh3+VUC0UE2J3txDwZ0Gjuk%sK9b9hL7bZ*bRdN_OO1Y|Y( zb5H$<0RlO+HCuNOBaUwF85z7p51Ni!?X&{fAx!VJ+^J!FC&8j+o515tvZDzD1E1NQ zJyyfE?4dRcFUXLo9@|Qb03r48khG$HKxhqZ+4jAlqYA%KJz6)IzuKNXdI3%8F$+$Z z^T_a#?5184#9BL@@tV5{sZ6PY1DPeMz!!5pN2CW5mIqJgI$J>w=x}6UV02%7_Opy4n|9}}U_n7oBp){Ju$oSZpl?$Sk?BzgaM{jt_%~`oFx*7sYhEf~;!69dapZMt zTfNoOPn%$OF9bL&5>|nZ`XN{l8mz9XxyJ2ydHq8V2b4|7C_b`S6W%( z*nyt$`)FMo=$;gp`s4YYQ!rY1J6bckXBh3W2hPawj2ei&q$)v-J+|N4e%RW%X{3*U z1di-?4Vp5D7eMgV1EL3xWnbTfnUD0HMTeMde#d$Fk~NRxi@iIA@#I?0K>@Q3EA37B z-bOG%Vp~@ZL-iUNY_U2{3p=CLIk`h@E@YO0E?s6dT%NIB*`h!WWW7BD7jFO>Y%CZd z*LElfNi&>;{p?++v3J}CVSPd^b)>(WICA$u?ns^a>Bp7(W{6^A9(^1P@gD1Vzo;=H z?-w*!QB7=Bv|)d?vBT~T5~ zhL4O4l9uAtK*8SW_3q=Nn~V-QMT8>*dm{r~q6fJeC6v>VtHUFModl}2?E-W@=!iHd zphRI)lVr+bDFM|$N^tJL4*WyEq~o@ouH>`wnP=f=kY55i?BnQCrt`S%{BIerMg4PMiv&4Z94#tK^ytR=Io&Z z)|C#cac8cj*E+gInqetUrJ@csjZ4VpNl4f-GCjnKpb2bx@4;-E%C;8Pbl z>|rtL1VRUoIyI@oAhBa|siOeeb%`AX=q46Cs9TXd3`g{sSn{BT*AzXR(Iyu@cp4K* zABI=_aHJ1vK6UZK86Fa62?2zsJYE7ZWQ#i@2#-7k5u`BY1VRYUc8XGnQMaGRES5vC zgC`S13L{^)Ai{8skwlEiL=i_4;g{Z1QG{k-Z`?I&j0xnC!jK{gylZ*H+tDNfi7~lE z;(h!2B@)jpOGzawN{c0A2FtJsY~v5h?=6QFi)>-fDM2!Y&37zb@EU|dHDLsn$IS24 zD$TAbj30<8tYi5*%T~t{dKd--e>xNl`_*`i!uHZhe=;4<#8UAPJa?`o>^+cxF2j(2 zTJ`QC3PA5s=ClE?tBgPJ1%mVV8*)NJhs+<%u*0QYmstj~-OLh!o( zK_p}?3aVs;VrPCNMrJzOD8j}MdzOf$B+~|k9u$1C=40!WWi#0dNE6^Gnjd{bnYUIP z#^UzX5;RKDSd1Gj87Iq+PIenHDn&x!fLZ-DxTR?tzh8`Cas(spzy$+gA!Mydk`q@P z=&;q1ZHvuBg$~KsLSAW27rRv~Vg6f}uiDr&y6+fSQ~P&7I3sPU;T(zJn_q_TOM((a zo#DMC?QGf)iJpJlUu5}c>4A!vzx1-zeqm%_7j!{ZOh@;fCQon6E0FG>^t`E)Hb{w+(J=wD_!?q$mj(qP<^j;9%9Cw>&&Z5afa)-JFEf5Bj zT-RQMz!}^JM?~)65keAd2Log=f!`&2@T%7$@snAPdy5@D9r2-DN(_GZ{WbB41yY4O-HC5va{uVVbqI@S&|9qA`KS-x=~d!U!Wf?%FK+lWC;x)f@HacCG~bTBM5 zw4o0{h1G5TWmS2F0b3>hk>btDY_=N{IW1Z@cqBZN*0Iysj(SL5@*XT5SaI{>dB#&ju}i zKb-#3heYV0WwzxgbbPD+5^N$a7)K*FLn;ZLdTIZIB9)YmiJgj2G6OTkpys&;m5BN6 zgXNW-Gs{0n^2luSzap;k@tCIJa1)n6=>sqph{I>1rYS1T>uj>$ic!oXIY`W7LrIyaeHV8_n^K!2QHuH-UHf>3(ctLH{x}Vaf~P((0tY#(I~8P4{e{m2&j9o zVdYl8par7ozoYkbRbbWH>aVT(qp!SRzWI4&4Ujs+eBoJTo_WtH_&)u8zQxnX4QM|7 z17EfI2T|WVv-TOK(ri7Y+-BC%x9ktl_;0@lkLPDThd*ciJsf@aX5frIv;j@XgNooZ zm3?FghW+Lq5>;Sg!abgkVu(>|F3Q0D@1q;d5d^2 z$qWl7+u0xvpYIoCGrsKm#rgJs_N_nhhYJu3^_QQV%I2BMCgkuevwL3o9d^(GGOM+< zYPbezu2D6@(NMMyR(OK!*~{%0m7Ts%Nj4LJT-PyuJ^(xR(v$(aMvOZFw$%K3y;4~Y zq?nCw`&PJN5#hkvfL;>}g~O3xalDrM1Tn)DLB{b~w3os`7`lUG=te@apOTm|Nc6(S z%v_(LyV~5jUzxcKtIJe5L1=>c50@3Tgu_ZN21cAaZd4FrZ$#$C@^}8WZ=rdn-d8n` z%&m=eWM!s!2O@Rze50~*1%?r75*A9%xPkmVOh$K(D~LeC&S7}<&OD1r&& z$z(K$h}kHDv7IoQ_lT<2c(hQ8dR7 z4PhE876=>YCz^@T(=e|bhiTYR^hsKm7~4uHJss;xffpN8o??RX7ou@OzMi4*AOM1H z>?x+=I9E9eWkZCTQ*s495$TUlPt*uvDJUc#OGe^M1}Ov^G;UuMK~fYzLWtKgcnLYS zG*50BNkr&7hsH$0DGW}yfcw@(f#h*SDN0CUZ5R>82AyY9G89GxFK<4F6f0Iti_s(^Nm_GMtH5^-uJY{WqAet0SQ2OzF+w5G6gC48C!pE* z;TR!M4U50B^;w{HGg&Yp*qhQ{c>bBs<5kHAVPe&ivchAku_h=iERJjQtGr*B5>SKr0Z0soWFqQRC$23sF5>2# zSw#_a0FUD6s=w-6@ELGwqJ|jlEn6h^1jaEkFiA(S20kU2i_^R8kgPamj>w`3ZwC(% zm^AZ8$n%-&r3|8mg3ZzFU#HA7Y@1{tiA9b?h`@z&6qdpci{pGAn=m{9eUoPR0Eg(& zo8S{*x=ds+TbCxxp>;}?`HlulF4A)Vj-;R^DI*G84vb6?g=G|W$s3(;Oe)u7818&=PfNsgn-vyDAjbL}DDtQ(zR74!LT z_?8$Am!XK{p_=qHkb=^(&1!uOK|f;YvIEmOKwDlD`w{GPVx5ITV>O;c*b2SNkyCcF z#_idj*B#T%$ydni*3bomju>SfyG_2=FzL-=3r@j0y5+*?_IAXhV?0E}=eM@QRGHlm z<*PxmX<#yhArL)~+SCLC3|T+$Xa4oeR@=_prq?+}zR`hWcMF-2#9i5PicP;p3v9`- z^DsnYj^d{htp@chw}WN|8zY&)&K*GS1PTXh!Lp0cIIHV0#U<2V$X(zVC9Dua`Ufu} zddg$FYHp)-;1C@NTMz^wY{%dqVfD`UBJhTyb|_xQJU-g}3XD$H)yoBI-|!&XxZ!8E zId9e*GuhNH4@CNmLxgIKkb}+F1w+g9h#RrX8?Ol6L_u z$WR5tAp+fcOlP^XMrS`vj)aPeHdD--H-d%ZxuAXloyE~^2FGu9ABPd|+Tm_TUKisjE#YZc zJnf)P0FiIGOlaVMIhg+PJ-rSnUXyp-NzaNvrOfZ!Z@>tieQjT^YZsB;a2sV}aC{}! zMT8r#M?h?!SVghdJ`(@pv#IC5v_V#bP~#YI32TRkDBq^JlhWU|51_w~Jn`tq(dfY^ zeixrIO3q+LVH3For6ER9Ot^LAHDD_%jE-aj*?xGWzeO0L#Nwil;*z#|_8L7)Mff^CZqy8y_7%I0D^0-VS^3MV?!%*LMf(N|!WZKA1NM!F8CO18IO zT&n8{RD=nl7z`vQe-xg&R094@m=3ScHnG}#WKsFz+az2Lz`zIw?npL-alStD7Y)7@ zM)oyCDmIGcNvNz~zG`Z+eS@zZ5yKi~rd`=)N3tQxv6YPF@>c%HajU)_1cPumo+;;n z?L^dQUGC&gI{xZU!KFY8g5z>`H`qSCYaBV1zj_r10B8=cxj|d`lZ}X$!*L524SK}> zEAmD5oyO4%KuO^P!~W zUI3c4JTEEJz#K$WOA4J(wQziJM>!-|b@MWE03)nhC|Q^;;1O0$+ut}mB%8RF^e`{$ z!@FR7V!bNneE=Q`mN0^B<4GoMo9Rf1A69_~(8HC4?TLSlXOCqAV;I;C=gRSHQ`L{{MX(<&Jc&TN)rjmSnyW&Q}F*7Sq%guON-b^>}spwRm)(PDgoT& zn9vaU$w`P9o^=>n82I4MAu*70^e{RlBSMPkLYgKe^x1T1wVtq!QLbS2!YP)RDAiIn zkahXB++ZuH5pGH`1Jb4;?~Q5fP%5ebFyeEp)&?}eb94Qo@`b<*<;M{sk#fh|K{^9m zV*A66VCPe}Y%Lm@15dH-?buUrDBj+P#kP)<(^euz0kD`FWn2oVJiQ6%CF%C)K}>?= zT4Pr;{ms%Y{>IC)(FFxIU0{GMO;+at$SKZld)Cs~1_JKtaf4Y_+&&_`WNxlG!SC%(yVcwPH zX_%=9^9;_ErTN0(W8`^*g79T(b|C&W1$t^NqQw*?`oiGjWqN}L_ek}V3iUkf)TH{t zfRoDg)EfdmETgq^ykrl)FM>U{g6wcD$)4IxQM50>#=^ZZPP%u-yq0uN?WQi?7lths z@D2E{CzbGV%3+M_l z-GJ5!WPLf)uS3{3rYi0KI|=*7HKcu-ur2SuhvNRK_pkbVYSr2eFFt2}^$(QVa^!ik zsR3n$`8Aw`AEWFn#aDIu6j zN+$iVCnw@sD1<7PLEB>`g(rV=UE}u7>hjbh3*qg(a@Ul-y%R;K76Mewl}CM=>ws2O zcJD@D0SbQ5M=QK(JQyI!cI27;)qiMLF!l8(s4qcxLwZ^=7!gup0 zAfLJ_hZEl72v|tyffmm3IChc<$54`tgklF=upqbl{Kxq&GXMI3k?!$ zoT4^}36km$W1AYl9geK;^+pF{5bYOq(+kP9KSJCAwW`) z9iQS@1CqXmk=R;?1Sz{aWGacY2w{vvL0y5*mMgn1+VK?!&ROU8K%%qNL#I8d!vkIB z^QU}!-c@j^hr!sQ)A#^WVqGHrl#DPnKRUa7$r51N*5Nt0w7@CHM3=f8xqIUHQs$Ra z2{5IGZmg%UNP>ZLGsXM}R5}r+28Eb1OxFrAExCC>DE!b}-p zHrGut&a?phm`GE@4mG77vure)LZ~T2em$|K-1~&VrbcnJX#q~}scc(@xR>jXH!VOr zLBOfuM4T2zM$G91A*Y_f-&M>hy+1+FsbNQ176n;S+o?pI7GRz@?v!CJ9e8SRk}pcy zfEN+B^+ujL8yDNf4LqeTNjuoy8R0RAt;of5)FC17s+g75xvRo5wr=oz1;dm@2EfQZ$o zF+CLIf;z4^rK+9J`}Eb2$Knyx&56cP+Di>21AY|tO8El;Es+dIW2pM2I?@!U-2CQZ z$L*aj_-4#_vuxU%)1E!w{?xQuzAWNVCvB*7q4KGSUnC2_6pEDHGiS^|qq6W1zV=e* ztxG6>sCDLnTO>&Ey~<9SEPZIP`Kg)Z^X~L!?MQ`1_~+rS_J-S%ch@}7U!}oiNj?5=Op^TE!8APi5`6TBZY|d_aUgauN{T|QCD=hn#dyHSb#Y`u zc99+~SL6-E=I{c9jBwr9g%PS=BM}XS+Lh)fKZF7>h_Xf~fW(tbP_q)jz+9k=lI7rJ z8R>%rybWB8*qP&runwGaog;DpAtziUVX+Z%ODcs%A{#sIv4KP+25TJSu569(Ra6A;Cp!PimWx^CyMS%q6DM%uxBw7FA0%iZFnBM7Sb^=;$ua5L{xfiF1 z%|UXuQtC2l$8i0U;jYoWml%2&ci=F%hl+6A!zDQGG2qrMIB_|Bf~LhKPiPFD8Nj#B zZG*3Ur2o8};Zh`pQY@UbeYfUHu}hL(?d_+OhGY8?2y4T|A=BtSD|t!Qu!Cne>G-n0StCed*j z8~6^OnK{T8Qh;X&J_tfB5>?I};Ji2|%E3DFs+(p9#AOfnQ(+pIVNfEn{=(?)9{4R# z?FQlLsPQ7cDLPd9I&*ta{$(@anuFAZp2XKhBekBB+#GUVp_&q8pWTjk+UPbni=gUV zSYX_`vI`W%7{}U=cA@Oc%Tg@}l@2M=gKGwntKZ2^^U{i#$0c4s6aus)@5JVQ+JokC z$_c{^Th0IZl5Z}BAOOuspwIPCm;*Mnb+8U!&@g+T+k;|{*_U>w1Z1G1%fN{-Q5_uA zkv~VqVDvLGY<~g$kw2UZGs)Hh6gk5a*a1*bh%mQj9|gL=r3Oz+TQgO?fy%s{iX{rE z0MVpzvEBnW3x*+eH>nLF%hrsOR8qd_*Q z?UdZJ4UX#kIiw0wp(d*b#dvlKTB&O;Y=k63ki5I>Wc%Mz4;c#$MmKe2&o*LBsqxnC z{JEp}4*#Hx3p9Wm(gHAvJpgVB@FCZsGOmy*?NyL?b0>-o<{Q;Ei?Gls z0c^PfwB&+pqs4VBO5GJ7_q53Fp}-wG`HCYX&=lQydvT2)!WiAHk7mfhD7*Z?ANvfH z_DPaB7Y!h)AVe3!q!GcM2**&7J(&t4T>M>_#1*F32{%0&^A?%RTYwWhsq2up490Zt%qTVILT7 z*&3O?w4mZb11IpZnD@XcCbjDeZ1f^q1hYS= z4-Y$K@yC^Z=ru@V6gYX^@{bFCcPR;oMwn0pq8(>TK*lDo2*fa5rwqi?pRy2CfLx>? z!>yCY(v3$9;(o734zgdEiXg=Egn--HY5w3PsG!%Bh6-R`TOMLKoa%H_5r}FHTBz%k zhip45+V{?2z{z*ZrrKdSB~@yF%d=sMIKl9 z7*(xC#ifL5$20%z)EQ#ap{luchL)}lBQ*j^2@!uL8bYoh9I=SsOyWaNMH0H6(t>gG zo1a$hd~d`tsx!2k>I|Xe_NB5pbIUKCZ$DkWe)sR)3_t9tl~XYUilwi#L6Ng=XBOKF z&0TN%7K(E=7+4!r*M@>MS~QAlls(Q_?-N|*;yPz}INUX;!;FOsb2T_;Gf~{mqQ}F@ zSm633QOUingmgFtK+3o!sZgpa*n%P0BTBch*^_KKPWHGh5|SjyL7b930Z9;HbLc`| z9{-voog*lYjL=+#NrF%*ijF`*@hksH%g=w#E~lg3&c=#=Nvuh+Bw$bhD4}WP97{)j4Yv!hKy$kD-liz?U^#fu@eNJ}1 zFv>_xI7D6+4~M{o?ZjH?336mPJAbw^7h3CwsK|j*@p4(k%N1eVsdz_)v4O5?{;RGsF0LHc6qEAL2dsR{;N`9wp{YfF>9kJyjG~XvEt9Uq=rtO1*#K9*H=|YmLI?U z=C^R)+&zD-RFuR0V6Oirs^5PrgQ6VIe+vaSsz-2lF}WGcf9OO(kAFQ>K5tQktF@66 zh0^NCalm!f==QKjBA(mBq=i&?^Io(ywTsN)F6eml>cZ7XnWU^lK<;F(;t769MZ>V= zr;t!u&3AdB1pLHzd1l#;?mMv`=4@G$-}Yq z;h0=g=5gG_a8WOMXV-%)j7%O|5zYt!Skh>1YxgKyal+LwEB_WnQQSo^ zYo5h&5IX}y=ck!zKdeXy+jnX(VI zw+DWA+uh5lrcLAXo9?znkCOK|PjOF~{zhPQ{8pl>H8+}n{*1ERtUj&Gns5`Lbj|cT zAhZ%8d8!n;Ik;GSzNrqx6EvUxxw7C!DJeX%v<26gnHgKg(8LK8$Va( zuSd3Q;nuz1WZ%@()R0VTDsP|!%7(qjguU=L7@jA${=X}gKE#mM{XL#VH(-nZ!!x+M zu0T!`76aj9R-_Uf`+UYyMevFWIrSzx^7hSNh9&&)=_j_yB`d@hCuGIz#&V3fI zg$~X0f1}*43dWtYx&6;hdjArAfx4w?IY2a;O(8&r_iQ#?Ybh1#-^vD{m$VRD2$RM)OLk)%oo zQbs1qSFB2G1$H#`38J;R5(G1-Pr6D*-I;EkwCQg#d z64|Gr)zN@|kaS2rgl>M-gw9VfA%iVa7fHlzSD*tpq(k&A^(HLr`tH@Id+>svZ zE?j0p7ckl-x*)e99DuyPxZUF1d3waEE=&Lt>n+-~^aUR<;K4&hgwj;NzOLVoFwc`CaxuM!F?I6m?KP32@v(j0yjC}xRYnz zP>E-d5u_KhZU_-~Bpt|*U{57VB-nKdC^CwC*wQb$!};$5MU3qD75s?fU;4z=IdX3f z+9UP4V7ixgMosgDb-rmviEV}54O$^4M#dE6;7?3Ua)~MtE2xTZoCPxhoa0$4ijBig z2WqpMA=%l$Ju_@gm2H8+5c`7?nRuC5nwO(ZY|eSBZa4n9)?Jsi6aVfxG^P_7SSoOU zxJUYof}I#+quhbC5QZ%&+AuJBc`$**v?lSIVz83zxgS9duN+6W7<#4X8aUp*+Fflk4`@r z;yM!)#RpanrY>-i>nmw<5j!bSt{!tXvYgl)#Y52)RF{Ic=ziynKoke$IXf@V{&ix{ z)q>@=VamJfr85VfiUPfx-)KZBXev?rQ4BRkY6dR@NRwElsE^6)Ql|35^5>>Ol>*hG z;Hxjn7bhdngPphqqQyFBSfOZa4AIi>UZM@8QZNKW{K)`QZWINAajB_46iY=?uvrJx zOw=XX_huRS-sI`Zm&=qdpKsrwB!*tP1va+3N5ieFZShz4gIbcvXASHAxEc%lqoKI2 zMzusFlSxm7wrOdH=w5alR#w|dTzF5_)4v1LGnMQ{Y(16qgxU&qTohIq#>}5}`ff2> ze&DMypZE)9zWI=jyXk-bbISagY!4>|Qq=7~eg=MuKh%87YDB42xx{&qqR)i^ZM`~8 zx5~n_6D}z0=DvquTKlJO!7TTyHd^f#Bj|);yrJ@`<{RHu7TgL&6qNwQf8c1$te%oK9SWLt zr=W9w8->r!+7NDS{`D`Ene!NMsun9MIm}7sqcB!{T1v%=QN=c%#Hj3}j2XcSISRMj zRb#^Ofg1I~`k^#aVM}pKnpIMSI4bQvcOEw%o@nwk|O- zkPn4wuHRlxAb&ygRZk-uo%zOhlm&Ns8#-nO0)DJjl=XZ+o9)PSl5$GJvhhx`Lt;U) zKREu9jB2*WV2=6g?;#t9Y%(S&<(6qwT8QVg+&i*NKoG+=fgFh#B@atG#Z)> zt`BVRn))W|*qh8$G)OTOOq*FAyo)7yrc^SbxYsI?QH^S}a+cGEAT2UEDqQlp-7Vw4 z1YLNnucdIxq~pco-0v#YWbSiO8KgBOYLbCaO!e-_hM>pt8o}MofR@XWdLZ=Xd2I+f z3&K=N8_WEO4i+>8J{6`LAm**6o$uhpHe@A2Ni2j|l8G?Ku&k#XiYG&x7YE~6A~OlJ zku0t-+841nv72Ey%5+Ll!EPdEbNrT_ZLT`2%rB>;Hf+gzm&=XGU`$ zYns7`1QJlvcBQZrFIRF5v6My@i)73Xysa#`TMvfuXGBH3!K3)EjEY}RysA2bw3r!` zjn}cP#&*_seIF;-L$4|~&3Biln62HOv5|%;Q88NA+XB>)q~l-@+>}b~GJo|}8`eWq zrCR1AjuJ^KBuvuLl*UsgnfSM`tdINx9>HIq!U_7>A7U9zL=hMOZ0y(=S`5dNJaZi9 zg`&z6#|xlmaijBXX-M7!Mx&XGdl(Yo&2vt}f-&6WaD^?uQf?wJZ!*vIDAUY2Z$dz6 z`4eS{dEd{KS$+yf06ro*$toUuJ5Q28V6MI!)GF&!xX{J? z(f?HDR}=_=+&}ig3vcU9bG_X5GA?1;vNu?2?AVt#);L7qlq*F|MOr*0`dRVgzBYdQ|?fV{>kQjh4BufX}UGAk* zp+TWdFpyyJy3RGmI@TOe$B|>vNh}~ve9Ex~GSrTQJ?Lz8~lv3PIM z34Cn`x$b^pjo71DBlvcoy>*xA&$#rHq#vbzOn>f#W8+Qle~(*$VYhs{LV0!Y`1L8y8I!u(UeQl>8f`AqzZdG}wyWA^DclogQz z*C$@c2PYp+Mf(*D4je>IBxq-GCab{sGa51pn1g)UjMMeR;(UZmd0P!mtFhEZjMwg6 zloxXKVT)5F;`J^z~g@hrJ?%`@UBn( z1umXUeMgx~M}fdoyu<7xBl489^b(C!;QR4P|Er)Y`gsKGua8I23hizFrCWWW})E)tOnK$>$uhp?N~ z{l0nAs8+xEZ~v&gA6J56ZQ2oeX6Sr#1%xGXTE-%H)po%_6@~57@w`!~53$6$`l-~x zt*;j2#pw2(u&#Pt4=@wB*SMiGGBQd!?ZG42OASaUMDBIHflJNEH#dPz0cD8cq9ezf z1OUQZ&-I#Id$j9sVCyzgbKT%7GI1Uw9U3+ct8O36nn>nE#1z25?eDpRbz=KKg5C_6 z6&(}E2hk6H!Y|h}rb{!th>m1p94NRBJpkbJJ-V&e=)dm%A2-;3H)WO+r6Sb)Vt z6x=9ec13|++?2Slo@zaOtXZl4Kt+WZISFRi;W+{pqm6$XIW_2ymdkO4nCJi0w{jue z4KOdcOCYvP^S;@>g-ej?i(?qCz}Hay)`5D$GlxT)-~O?($hA?0D!^7ti81 z1)VeW)MHB--^@l0@?|MymMIjj4_xwy^#C-ut#RZ^EAS0MmjPTqsvB`kslmhhKmp=G zrN}Hurynfa2SQ-Pot8Cs0l|u(h&@Uh*p36-G=cq8<3u?5+ssD>$V7G=N2__Hi#i|FZu|%eE>4_ zQS4c-T~*{uDju@g+IgWcDmgjW3quI+y~q#7^d{Wl4!}v3V@Yi(!fgK~$u;H5{Opr) zy+3r1*O@aB7gj2|PGgiN>DpB;zaXHvbP=ckaRl^?bw|vt3TwyrZ)CLaW zCh784LW#|eYFE+Ryno|0cZP%zPL*&&_$7EBR6v`CR}v`qPQ)bzo~!w%<-R3}qZe?) z1Kr!X2Uj=rbHG15(ym(-bFitB40ae3KL|?)s=&{o3*d`vLdWe3P9;#HE#43td)sW^ z^eTBD9SU8UR~PvfCC7T9OZoeyKsQ4n)Zh(4DRxL>EO#~eM1U7vc$>`0edxsyt&11o zI6c~k#$};F*ESC-g;#PKV+(^(x>(>PMX}5_6Q~8Z6g+rywq23D_#OKd7xm*`@gf_D z#YkS>jNx4GwK4u>oDJ@HfQeUSVjsL45#TPKn+(J_qoF-#0wI7TZMSzkH@6MJT}YC) zOdr)^sAe~(th;ix_XR@ah7izI^rPn-A^F)Rbm6Ei=cuft&AVJi59_^bb$G>%1E+AX zAgPI_%QB2`rYQJ6ogE^r^qr+G)YLR~|2SidgB)ErtYb_=pyUpB8-rb-H(RPO_SF~f zLZ%j*hq1?qI10*^=k{G;TC&?5jH3%Up~e5;5^HpIg{6LY}BZ#KF6?D|!=f+3nH zs?qF9L_iw`bg19_(KO$J88R*2rl^?099@oISrHf0MDgfLc(D7cgDo%q51g{kLtX?q zJzUTW>j{9})ewA{+ZOw(mSIgG6hQjLQ(^z$UX;~;e7~D0h4FtgQJKJSYtDgiF_s|0 zJy1woo={pQVPVah>gw7J*Cj90h}SDIQ*gV8DV{^xj5aE>?*$O{)6&Olp^trs5msHc7Rlk6DuX>fZKEo8@7I9Y?aBG+=!#jzd(X#+|5R z!YZ97dMs85fp~8w{yy{9TYa}I1e>(A77uvl{W;%lg)%iba^wi{>Nj$3xUYM-4~6pL zpn9urFSsTSwzuj?`I5s=P7F$wLYDBrVQ_J`2X09bw)S2%oHS#+3Aq?!yZZ{=71}w? za58yMC4`t2y7tUXKoMcxJx*;IfF)n(B&hc_GGMe|r(-Ji0fU&U9@MHHun#~{?0^>c zLTZT45QaR`GxH*uuzhfx!TmpoDcL6)YqeQp_V(zyA`A&-+hAYN>kViSWd8 z=?wdm*%+NW4x5q{a|av0KK!U?i98~>3+EJ$4iO4T5Py7olUEX_g>%VklK5$lwC-xb!~_p$nuog~tcEYKLl zl^_VO2+x~$KF!RP;{|mbd;1yuZZC^RjCbeiDnBl^9gctwoq`vx5IF%K`tfn!;)mV6 cO12=JL~KJ)A*qAbT>2V69S{G31!(>M4-Yiz+W-In delta 1840 zcmah~U1(fI6rQ_3X|lPSNi$e45D;<5K0bqjbD;Vbw}{5&3Q^mGs4oGhfr#(L93W1mBk zAROYWnBWCSK7iBHPut8$8XP?j*>!~f#2ffFUWe=|PS;=P-)Z;7{z1n*iQJPrt;Wzx z@05B%-*93iWi&~+NobUg&xrK(X;6y!U-ruetu2>=n+O_{IPtlsy}*y+ z(B7nlgja<&ARLekPvAR3auyP)BSDO2ig?mQB&3FG%{-l`7)TC0$vEYj(5(xJnp8C| ztCCa2I6}@R+gvmuG6}S83L{>^6^T6t6>3^HmTR`< z)mTlz&s3%2LPFQk%eFaNep4Qi5i_7QlO&M!kockwZ^l)klh|TB6KW#rj1mKeC81%O z#KLF+h>*qN)>{{T`0VW3$8Y~jO~NQ#zQ%QxYe_v_>bilPt|ip9w9{$~&25xtL9ffr z84&hRqXf*re+S3~;Mpc{mtpAy;N&*&?t@VR;8PDZk-JPmM>@GWS{wxYP`teOv+;5`+yn*mNHtL0_c(0ADm>oUv zDC}jIa~tIX^x(3!dLI0cRz5sf%-U^tidjExVX}r~QKonnSxKj} zD3i=as;S9dV^D2K0ApCKBP-e>x-Q~%2-=zwqj+E2q zzG!bueR(Rk!|v*-+)yW8v0Mso;@|PF_$T}$zJXWqxA+_U6<)b`=E1_^;p5J$o$1QY skL9~NE9t&pEb$+uS1OyYRW_Z)%4Y87@ixa@L+%q&Z(l;;761SM diff --git a/agent/reflex.lock/bun.lock b/agent/reflex.lock/bun.lock index e8e3f43..25f70a0 100644 --- a/agent/reflex.lock/bun.lock +++ b/agent/reflex.lock/bun.lock @@ -5,7 +5,6 @@ "": { "name": "reflex", "dependencies": { - "@radix-ui/react-form": "0.1.8", "@radix-ui/themes": "3.3.0", "@react-router/node": "7.15.0", "isbot": "5.1.40", diff --git a/agent/reflex.lock/package.json b/agent/reflex.lock/package.json index 47cf4cd..bea6203 100644 --- a/agent/reflex.lock/package.json +++ b/agent/reflex.lock/package.json @@ -6,7 +6,6 @@ "export": "react-router build" }, "dependencies": { - "@radix-ui/react-form": "0.1.8", "@radix-ui/themes": "3.3.0", "@react-router/node": "7.15.0", "isbot": "5.1.40",