qyingji0122 / fanout-plugin

fanout-plugin · DeepSeek Harness 并行多智能体编排插件

发布一条指令，同时派出多个 DeepSeek 副进程并行执行；主进程可随时与任一进程通话、修改指令、中断或收集结果。带对话流内嵌的可视化状态面板。

English Documentation

✨ 功能特性

• 并行派出：/fanout 命令或 fanout_dispatch 工具，一次派出 1~8 个 DeepSeek 副进程同时独立执行
• 按分工派出：roles 参数或 /fanout 任务A | 任务B | ... 语法，每个角色一个进程；不指定则全部执行同一任务
• 随时通话修改：fanout_talk 向任一副进程发送新指令/修改要求；priority=interrupt 时先中断其当前工作再立即执行新指令
• 冷唤醒续谈：副进程是可续会话（continuable），即使已完成也可以再次通话唤醒继续工作
• 状态面板：对话流中自动展开的细长状态条（🛰 并行副进程），实时显示每个进程的运行状态、结束原因、输出摘要，可一键发送指令/中断
• 状态查看：fanout_status 查看全部进程状态；fanout_collect 收集已完成进程的最终汇报
• 中断控制：fanout_interrupt 中断单个或全部进程（会话保留，可后续再谈）

📦 交付物

文件	说明
host.js	Host 半部源码（工具/命令/RPC/事件/注册表，返回 Cordis Plugin 的函数体）
client.js	Client 半部源码（对话流面板，React + 主题 token）
README.md	本文档

🚀 安装方式

本插件为 DSH（DeepSeek Harness）的动态 Cordis 插件，进程内定义并运行：

1. 在 DSH 会话中调用 cordis_define：
   • plugin.kind: "new"，idPrefix: "fanou"
   • code.host = host.js 内容（函数体，return { inject, apply(ctx) {...} }）
   • code.client = client.js 内容
2. 调用 cordis_run 激活（首次需在 GUI 批准）
3. 插件运行后自动注册 5 个模型工具、/fanout 命令与对话流面板

📖 使用方法

方式一：命令（不经模型，立即派出）

/fanout 3 帮我审查项目代码          # 3 个进程执行相同任务
/fanout 审查A模块 | 审查B模块      # 按分工各派一个进程

方式二：对话（主进程自动调度）

「派 5 个进程并行分析这份文档」

主进程（模型）会自动调用 fanout_dispatch 并全程协调。

方式三：面板（对话流内）

对话里自动出现的 🛰 并行副进程 长条：

• 显示每个进程：状态圆点（呼吸=运行中 / 绿=完成 / 灰=未知）+ 序号 + 分工 + 状态
• 点击进程行展开：完整 ID、输出摘要、发送新指令、中断、「先中断当前工作」选项
• 点击标题条可收起/展开

模型工具一览

工具	作用
fanout_dispatch	发布指令并派出多个副进程并行执行（mission / roles / workers / model）
fanout_talk	与指定副进程通话/修改指令（worker_id 支持唯一前缀，priority: queue|interrupt）
fanout_status	查看本会话所有副进程状态
fanout_interrupt	中断一个或全部副进程
fanout_collect	收集已完成副进程的最终汇报

🏗️ 架构说明

┌─ 主会话（主进程 Agent）──────────────────────────────┐
│  /fanout 命令 · fanout_* 工具 · 对话流面板 (Client)  │
└──────────────┬───────────────────────────────────────┘
               │ harness.registerTool / commands / RPC
┌──────────────▼───────────────────────────────────────┐
│ Host 插件（apply）                                    │
│  · registry: parentId → Map<childId, {label,role,    │
│    startedAt, state, stopReason, lastOutput}>         │
│  · dispatch: subagents.startContinuable() 并行启动    │
│  · talk:     subagents.followup()（冷唤醒可续会话）   │
│  · interrupt:subagents.interrupt(ancestor 授权)       │
│  · subagent/end 事件 → 状态/输出写回注册表            │
│  · RPC: fanout:list / fanout:talk / fanout:interrupt  │
└──────────────┬───────────────────────────────────────┘
               │ startContinuable / followup / interrupt
┌──────────────▼───────────────────────────────────────┐
│ 副进程 × N（continuable subagent，独立会话并行执行）  │
│  自动继承默认模型/工作目录，按统一格式汇报             │
└──────────────────────────────────────────────────────┘

关键实现点：

• 并行派出：Promise.allSettled 同时调用 subagents.startContinuable({provider, label, request: {prompt, parent, agentOptions?}, signal})；provider 自动选取第一个支持 prepareContinuable 的（spawn/fork）
• 副进程 prompt 模板：编号身份 + 总任务 + 分工 + 独立执行要求 + 统一汇报格式（状态/成果摘要/产出）+ 等待后续指令
• 状态恢复：插件更新/重启后内存注册表清空，fanout_status 通过 listChildren 持久化枚举补全；fanout_talk 将历史进程登记回注册表，使 subagent/end 事件能恢复其结束状态与输出
• 面板：挂载于 conversation.chat.turnTail（chain，注册序在宿主「产出的文件」提示之后，不抢占）；每 3 秒经 RPC 轮询状态

⚠️ 已知限制

• 通话权限绑定发起会话：只有派出副进程的会话（主进程）能通话/修改；新开会话不能接管
• 插件更新/重启后，历史副进程状态短暂显示「未知」，再次通话后自动恢复
• 副进程消耗 API 额度；被中断的工作不会自动重排
• 副进程数量上限 8（clamp(workers, 1, 8)）

📋 版本历史

版本	说明
v1	初始实现：5 工具 + /fanout 命令 + 输入区上方面板
v2	修正 output schema 为 value schema DSL 风格（属性级 required）
v3	修复 fanout_status render 函数签名
v4	UI 改为对话流内细长圆角长条（turnTail），移除输入区面板
v5	resolveWorker 增加持久化枚举回退，重启后仍可通话历史进程
v6	通话/枚举时登记注册表，subagent/end 可恢复历史进程状态
v7	行内改「进程 N」序号（按派出时间排序），完整 ID 移至详情，默认字体
v8	面板默认自动展开
v9	仅当有「运行中」的副进程时显示面板，全部结束后自动隐藏

📄 许可

MIT