显示层与 Web 服务¶
智能体不直接 print,而是向 DisplayAbstract 广播事件;所有确认请求也经同一层发出。这样同一份执行逻辑可以落到终端、浏览器或完全静默。
调用侧 API(智能体内部使用)¶
| 方法 | 触发的钩子 | 发出的事件 |
|---|---|---|
display_event(payload) |
无 | 任意事件(不限状态) |
info(message) |
before_display_info |
InfoEvent |
warning(message) |
before_display_warning |
WarningEvent |
error(message) |
before_display_error |
ErrorEvent |
get_choice(prompt, choices, ...) |
自动确认下 default 不在选项内时触发 before_display_warning |
ConfirmEvent(source 为 "user" 或 "auto") |
get_confirm(prompt, ..., default=True) |
无 | 同上(选项为 Yes/No) |
需要富文本提示时直接发 display_event(HTMLInfoEvent(html=..., title=...)),不限状态:Web 端渲染 HTML(经 DOMPurify 消毒),控制台把 title 渲染成面板、没有 title 时退化为一条 info,NullDisplay 直接丢弃。
除 display_event 外都要求智能体处于 Init 状态;三个显示钩子可就地改写 args.message,常用于过滤或加前缀(见 扩展系统 的示例)。
get_choice / get_confirm 返回 ChoiceOutcome[T](choice 与 source),它的真值被故意禁止(bool() 抛 TypeError),原因见 工具系统。
事件模型¶
事件为 pydantic 模型,外层统一信封 DisplayEvent:timestamp、name(类名)、agent(AgentInfo:name / identifier / workdir)、payload。
| 事件 | 关键字段 |
|---|---|
UserMessageEvent |
content、images(kind 为 url 或 base64) |
UserCommandEvent |
name、arguments |
ModelWorkingEvent |
model_call_id、remaining_iterations |
ModelMessageEvent |
model_call_id、content、reasoning、total_tokens |
ToolCallEvent |
tool_call_id、tool_name、args |
ToolResultEvent |
tool_call_id、result |
ShowHistoryEvent / ShowHelpEvent / ShowToolsEvent |
历史、命令表、工具表 |
ShowExtensionsEvent |
extensions:name、description、status、reason(见 扩展系统) |
InfoEvent / WarningEvent / ErrorEvent |
message |
HTMLInfoEvent |
html、title;Web 端渲染富文本,控制台回退到 to_text()(去标签、保留换行),NullDisplay 丢弃 |
ConfirmEvent |
choice、choices、source、prompt、message |
AgentBindEvent / AgentUnbindEvent |
无(绑定/解绑信号) |
AgentRunningStartEvent / AgentRunningEndEvent |
无;运行状态机在 idle ↔ running 跃迁时发出,与 run_start / run_end 钩子同时机,Web 端据此点亮或熄灭「运行中」状态 |
自定义显示层¶
只需实现两个抽象方法:
from xun import Agent, DisplayAbstract, ToolBox
class RawDisplay(DisplayAbstract):
def on_event(self, event):
print(f"{event.name}: {event.payload}")
def get_choice(self, request) -> str:
print(f"[{request.prompt}] {request.choices}")
return input(">>> ")
with Agent(display=RawDisplay(), toolbox=ToolBox().with_defaults()) as agent:
agent.instruct("...").execute()
get_choice 收到 DisplayAbstract.ChoiceRequest:agent_info、prompt、choices、message、title、subtitle、default、allow_extra;返回选中的字符串。
内置实现:
| 实现 | 行为 |
|---|---|
NullDisplay() |
丢弃事件;get_choice 抛 NotImplementedError(开启 auto_confirm 时不会走到这里)。裸 Agent() 的默认值 |
Display() |
控制台输出(rich),setup_agent 与 xun 的默认值 |
WebDisplay(expose_files=False, max_events=5000) |
Web 后端,保留事件历史供前端回放;事件数超过上限后丢弃最旧的事件 |
终端提示与 readline
控制台 Display 的选项/确认提示走 input():提示文本先由 rich 渲染成 ANSI,再把每段色码用 \001…\002 包起来(readline 不计其宽度)。于是方向键、历史回溯、行内编辑都正常,彩色提示也不会把光标画歪;输入非法序号时会红字提示并重问。
Web 服务编程接口¶
xuns 只是下面这段的封装:
from xun import WebDisplay, WebDisplayService, setup_agent
display = WebDisplay(expose_files=True)
setup_agent(display=display, default_tools=True, workdir=".test")
service = WebDisplayService(host="localhost", port=18960, token="", base_path="")
service.mount("/", display)
service.start(blocking=False) # 打印每个会话的访问 URL
...
service.stop()
token=""时自动生成随机令牌;--token的三种携带方式与路由约定见 xuns · Web 服务。port=0表示随机端口,真实端口写在service.port上。mount()可挂多个显示实例,路径互不重叠;/srv段被保留。- 站点根路径自动重定向到
/chat/;FastAPI 自带的/docs被禁用,/docs/留给打包进来的文档站点。
会话工厂¶
传入 session_manager 后,界面可以自行创建/删除会话。工厂是一个同步上下文管理器,产出 (mount_path, display),finally 负责清理:
from contextlib import contextmanager
from uuid import uuid4
from xun import WebDisplay, WebDisplayService, setup_agent
@contextmanager
def session_manager():
display = WebDisplay(expose_files=True)
agent = setup_agent(display=display, default_tools=True, workdir=".test")
try:
yield f"/{uuid4()}", display
finally:
agent.finalize()
service = WebDisplayService(session_manager=session_manager)
web_session(manage_sessions=True) 提供的就是这套默认工厂(未显式给 workdir 时每个会话分配独立临时目录,给了则所有会话共用它)。
前后端契约¶
下表端点(除标注 {base} 的那一行)都挂在 {base}/session/<mount>/ 下:<mount> 是会话挂载路径,{base} 即 --base-path;前端用 {base}/chat/?session=<mount>&token=… 选定会话。
| 端点 | 说明 |
|---|---|
WS /ws |
主通道:客户端发 message、command、choice、cancel;服务端推送序列化的 DisplayEvent(运行状态即其中的 AgentRunningStartEvent / AgentRunningEndEvent),外加 pending_prompt、prompt_resolved、accepted 三类控制消息 |
GET /api/events |
断线重连时补拉事件 |
GET /api/prompts、POST /api/prompts/{id}/resolve |
待回答的确认请求 |
GET /api/agents、GET /api/running、GET /api/config |
智能体列表、运行状态、是否开放文件接口 |
GET /api/commands/{agent_id}、GET /api/capabilities/{agent_id} |
命令表、模型与能力 |
GET/POST /api/files/*、/api/serve/* |
文件浏览与临时静态托管(仅 expose_files=True 时注册);托管请求的 path 为空串即工作目录根 |
{base}/api/sessions(含 /create、/remove、/rename)、{base}/login、{base}/chat |
服务级路由(由 WebDisplayService 而非 WebDisplay 提供):会话列表与增删改名、登录页、前端界面;关闭会话管理时增删改返回 405,删除最后一个会话返回 409 |
WebSocket 消息体:message(client_id?、agent_id、content、最多 8 张图片)、command(client_id?、name、arguments)、choice(prompt_id、value)、cancel(agent_id)。
受理回执与去重¶
message 与 command 可以带上客户端生成的 client_id(最长 128 字符)。服务端处理这条消息后回一句 accepted:
{"type": "accepted", "client_id": "9f1c…"}
- 每个显示实例记住最近 2000 个
client_id,重复出现的client_id不再执行,但仍会补一条accepted(因此重连后重发是安全的)。 - 不带
client_id的消息照旧直接执行,没有回执也没有去重——自己写客户端时可以按需选用。
文档站点
WebDisplayService 会把 src/xun/assets/docs 作为静态站点挂在 {base}/docs/,不需要令牌;这份站点正是本目录用 MkDocs 生成后由 make doc-dist 拷贝进去的产物。