文档
代理循环（Moltbot）

代理循环（Moltbot）

适用范围

在以下情况使用此页面：

  • 您需要代理循环或生命周期事件的精确演练

代理循环是代理的完整"真实"运行：输入 → 上下文组装 → 模型推理 → 工具执行 → 流式回复 → 持久化。它是将消息转换为操作和最终回复的权威路径，同时保持会话状态一致。

在 Moltbot 中，循环是每个会话的单个序列化运行，随着模型思考、调用工具和流式输出发出生命周期和流事件。此文档解释了该真实循环如何端到端连接。

入口点

  • 网关 RPC：agent 和 agent.wait。
  • CLI：agent 命令。

工作原理（高级）

  1. agent RPC 验证参数，解析会话（sessionKey/sessionId），持久化会话元数据，立即返回 { runId, acceptedAt }。
  2. agentCommand 运行代理：
    • 解析模型 + thinking/verbose 默认值
    • 加载技能快照
    • 调用 runEmbeddedPiAgent（pi-agent-core 运行时）
    • 如果嵌入式循环不发出，则发出 生命周期结束/错误
  3. runEmbeddedPiAgent：
    • 通过每会话 + 全局队列序列化运行
    • 解析模型 + 身份验证配置文件并构建 pi 会话
    • 订阅 pi 事件并流式传输 assistant/tool 差异
    • 强制执行超时 -> 如果超过则中止运行
    • 返回负载 + 使用元数据
  4. subscribeEmbeddedPiSession 将 pi-agent-core 事件桥接到 Moltbot agent 流：
    • 工具事件 => stream: "tool"
    • assistant 差异 => stream: "assistant"
    • 生命周期事件 => stream: "lifecycle" (phase: "start" | "end" | "error")
  5. agent.wait 使用 waitForAgentJob：
    • 等待 生命周期结束/错误 为 runId
    • 返回 { status: ok|error|timeout, startedAt, endedAt, error? }

排队 + 并发

  • 运行按会话键（会话通道）序列化，并可选择通过全局通道。
  • 这可以防止工具/会话竞争并保持会话历史记录一致。
  • 消息通道可以选择队列模式（collect/steer/followup），以此馈送到该通道系统。 请参阅命令队列。

会话 + 工作空间准备

  • 工作空间被解析并创建；沙箱化运行可能会重定向到沙箱工作空间根目录。
  • 技能被加载（或从快照重用）并注入到环境和提示中。
  • 引导/上下文文件被解析并注入到系统提示报告中。
  • 获取会话写入锁；SessionManager 在流式传输之前被打开并准备。

提示组装 + 系统提示

  • 系统提示由 Moltbot 的基本提示、技能提示、引导上下文和每运行覆盖构建。
  • 强制执行特定模型的限制和压缩保留令牌。
  • 请参阅系统提示了解模型看到的内容。

挂钩点（可以拦截的地方）

Moltbot 有两个挂钩系统：

  • 内部挂钩（网关挂钩）：用于命令和生命周期事件的事件驱动脚本。
  • 插件挂钩：代理/工具生命周期和网关管道内的扩展点。

内部挂钩（网关挂钩）

  • agent:bootstrap：在系统提示最终确定之前构建引导文件时运行。 使用此挂钩添加/删除引导上下文文件。
  • 命令挂钩：/new、/reset、/stop 和其他命令事件（参见挂钩文档）。

请参阅挂钩了解设置和示例。

插件挂钩（代理 + 网关生命周期）

这些在代理循环或网关管道内运行：

  • before_agent_start：在运行开始之前注入上下文或覆盖系统提示。
  • agent_end：完成后检查最终消息列表和运行元数据。
  • before_compaction / after_compaction：观察或注释压缩周期。
  • before_tool_call / after_tool_call：拦截工具参数/结果。
  • tool_result_persist：在工具结果写入会话脚本之前同步转换它们。
  • message_received / message_sending / message_sent：入站 + 出站消息挂钩。
  • session_start / session_end：会话生命周期边界。
  • gateway_start / gateway_stop：网关生命周期事件。

请参阅插件了解挂钩 API 和注册详细信息。

流式传输 + 部分回复

  • Assistant 差异从 pi-agent-core 流式传输并作为 assistant 事件发出。
  • 块流式传输可以在 text_end 或 message_end 上发出部分回复。
  • 推理流式传输可以作为单独的流或作为块回复发出。
  • 请参阅流式传输了解分块和块回复行为。

工具执行 + 消息传递工具

  • 工具开始/更新/结束事件在 tool 流上发出。
  • 工具结果在记录/发出之前经过大小和图像负载清理。
  • 消息传递工具发送被跟踪以抑制重复的 assistant 确认。

回复塑造 + 抑制

  • 最终负载由以下内容组装：
    • assistant 文本（和可选的推理）
    • 内联工具摘要（当 verbose + 允许时）
    • 模型错误时的 assistant 错误文本
  • NO_REPLY 被视为静默令牌并从传出负载中过滤。
  • 消息传递工具重复项从最终负载列表中删除。
  • 如果没有可渲染的负载剩余且工具出错，则会发出回退工具错误回复（除非消息传递工具已经发送了用户可见的回复）。

压缩 + 重试

  • 自动压缩发出 compaction 流事件并可以触发重试。
  • 重试时，内存缓冲区和工具摘要被重置以避免重复输出。
  • 请参阅压缩了解压缩管道。

事件流（当前）

  • lifecycle：由 subscribeEmbeddedPiSession 发出（并作为回退由 agentCommand 发出）
  • assistant：来自 pi-agent-core 的流式差异
  • tool：来自 pi-agent-core 的流式工具事件

聊天通道处理

  • Assistant 差异被缓冲到聊天 delta 消息中。
  • 在 生命周期结束/错误 上发出聊天 final。

超时

  • agent.wait 默认：30s（仅等待）。timeoutMs 参数覆盖。
  • 代理运行时：agents.defaults.timeoutSeconds 默认 600s；在 runEmbeddedPiAgent 中止计时器中强制执行。

事情可以提前结束的地方

  • 代理超时（中止）
  • AbortSignal（取消）
  • 网关断开连接或 RPC 超时
  • agent.wait 超时（仅等待，不停止代理）
代理工作空间代理运行时 🤖