认领超时的 pending 事件（消费者崩溃恢复）。

添加流转记录（原子操作）

更新任务状态（原子操作，含流转合法性校验 + 高风险拦截）

确保消费者组存在（幂等）。

列表所有已添加的远程 skills 及其源信息

Periodic stall scanner — runs in a background thread. Uses ``modify_tasks`` to hold the file lock during the mutation phase, preventing concu

是否已设置密码。

自动迁移旧配置 (feishu_webhook) 到新结构 (notification)

Atomically read-modify-write the tasks file. ``modifier(tasks)`` receives the current task list, mutates it in place (or returns a new list),

将旧版 task JSON 转换为 Edict Task 参数。

执行状态流转。SELECT FOR UPDATE 防止并发 flow_log 丢失。

校验 URL 合法性，防 SSRF

检查 Edict API 是否可用。

向 Edict API 发送 PUT 请求。

分层注入三级记忆：全局规则 → Agent 经验 → 任务上下文。

在 prompt 尾部注入动态提醒（借鉴 Claude 的 reminderInstructions）。

从 dispatch 事件 payload 中提取结构化任务上下文。

异步调用 OpenClaw CLI — 在线程池中执行，带富上下文注入。

检测是否有该 Agent 的 openclaw-agent 进程正在运行。

检查 Agent 是否有权执行该命令。未知 Agent 不拦截（向前兼容）。

扫描数据库中 Doing/Next 状态超过阈值未更新的任务。

收集消息中的可检索文本，用于 task_id/关键词过滤。

从 openclaw.json 中收集所有已配置的 model id，与 KNOWN_MODELS 合并去重。 解决 #127: 自定义 provider 的 model 不在下拉列表中。

计算内容的简单校验和

从 flow_log 计算每个阶段的停留时长。

计算两个 todos 快照之间的差异。

计算 todos 完成率汇总。

从 URL 下载文件内容（文本格式），支持重试

从任务标题中提取有意义的关键词（用于 session 内容匹配）。

Get access_token with local cache (7200s TTL, refresh 300s early).

读取 Agent 的 sessions.json 获取活跃状态。 返回: (last_active_ts_ms, session_count, is_busy)

根据 agent 类型返回对应桶的信号量。

Return a user-provided skills hub base URL, if configured.

获取 skill 的 Hub URL，支持环境变量/本地配置覆盖

从 openclaw 配置读取 LLM 设置，支持环境变量覆盖。 优先级: 环境变量 > github-copilot token > 本地 copilot-proxy > anthropic > 其他 provider

处理客户端发送的消息（心跳、订阅过滤等）。

校验标题是否足够作为一个旨意任务。

返回可用的任务数据目录候选（优先 workspace，其次本地 data）。

使用 LLM 生成多官员讨论。

用 LLM 总结讨论结果。

按任务特征动态加载 Agent Skills（延迟能力加载）。

从 edict/backend 源码解析状态转换表，无需 import（避免 SQLAlchemy 依赖）。

获取共享锁（读锁）。

任务完成 → 记录日志。

任务创建 → 派发给太子 agent 起草。

任务停滞 → 自动重试或升级。 恢复策略： 1. 第一次停滞：在当前状态重新派发 agent（重试） 2. 重试耗尽：向上级升级（如六部→尚书省→门下省） 3. 升级到顶（太子）仍失败：标记 Blocked + 通知人工介入

状态变更 → 自动派发下一个 agent。

从 provider 的模型列表中选一个适合聊天的轻量模型。

一次轮询周期：多 topic 同时消费，按 task_id 分组并行处理。

读取 openclaw 管理的 GitHub Copilot token。

恢复崩溃前未 ACK 的事件。

处理一批未投递事件。返回本轮处理数量。

从 Redis Pub/Sub 接收事件，推送到 WebSocket。

Resolve final API URL and access token from webhook URL params. Supports two modes: - appid + secret: auto-fetch token from QQ API -

Return the OpenClaw CLI path used by dashboard dispatch. On Windows, npm-installed CLIs are commonly exposed as .cmd shims. Using shutil.whi

定位项目根目录。

安全解析 XML：限制大小，禁用外部实体（防 XXE）。

检测 Agent 输出中的注入模式。返回 (原始文本, 告警列表)。

清洗标题（最长 80 字符）。

从 dist/ 目录提供静态文件。

生成短 UUID 后缀。

无 LLM 时的规则生成讨论内容。

定时扫描 Doing/Next 状态超时任务，发布 task.stalled 事件。

给任务源打分：优先非 demo 任务，其次任务数，再按文件更新时间。

返回 (completed, total) 便于完成态校验。

尝试从被截断的 JSON 中提取已完成的 messages 条目。

Create a new skill for an agent with a standardised SKILL.md template.

只保留最近 MAX_BACKUPS 个备份

标记阻塞（原子操作）

确认或驳回 PendingConfirm 状态的高风险操作。 action: approve / reject

创建委派子任务，由目标 Agent 独立执行。 防死锁：记录 delegation_depth 和 delegation_path，超过 3 层或循环委派时拒绝。

提交委派子任务结果，回写到父任务的 task_memory。