feat(dream): REST/控制台入口

只做了这一件事，没有跟着做「dream 改成 org/work graph 来跑」——两者被单独评估过：org/work graph 是单公司作用域（org graph=公司级 workflow， work graph=公司内某任务的节点图），dream 却是跨公司扫描，套进去要么破坏作用域假设要么得新开图类型；且 graph 引擎自带的验收机制（goal-contract benchmark/test-script）判的是「产物过没过验收脚本」，对「经验提炼得对不对」这种自由文本判断没有对应机制——不管套不套 graph 都得单独设计 rubric，是同一件事。用户明确只要 REST/控制台这一半。 ## REST（server/routes/dream.js，挂 /api/dream）路由本身没有新业务逻辑，全部委托给已测过的 dream-service.js： GET /agents（总览）、GET /agents/:id（详情，含定义文件可写性 + 经验审计）、POST /agents/:id/run（手动跑一次，dryRun 只看有没有新原料不起 LLM）、POST /sweep + GET /sweep/status（全量扫描后台跑 + 轮询，内存态并发锁防止连点两下）。 ## 控制台（web/src/views/DreamConsole.vue，路由 /dream）一个表格 + 两个弹窗：本体列表（详情/跑一次/dry-run）+ 全量扫描按钮（15 秒轮询状态）。导航栏加 🌙 Dream 入口。 ## 验证 server/tests/unit/dream-routes.test.js 4 例，monkeypatch 掉 dream-service 导出对象上的六个函数（不走真文件系统，不误扫真仓库 76 个本体），只验路由层自己的逻辑：端点接线、sweep 并发锁状态机。真起服务器打了真数据：GET /agents/innovator-evolver 正确报 SKILL.md 因没进 git 历史而不可写、经验审计吐出上次真跑沉淀的 4 条经验及原文；dry-run 正确报 no-new-material，没多花一次 LLM 调用。浏览器里走了一遍列表→详情→dry-run，与直接打 API 结果一致。 955 个单测全绿。文档：29-dream-design.md §5.7 记录实现与「为什么不做 graph 化」的理由；28-followups.md / docs/README.md 同步更新 dream 现状。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>

feat(dream): REST/控制台入口
只做了这一件事，没有跟着做「dream 改成 org/work graph 来跑」——两者被单独评估过：org/work graph 是单公司作用域（org graph=公司级 workflow， work graph=公司内某任务的节点图），dream 却是跨公司扫描，套进去要么破坏作用域假设要么得新开图类型；且 graph 引擎自带的验收机制（goal-contract benchmark/test-script）判的是「产物过没过验收脚本」，对「经验提炼得对不对」这种自由文本判断没有对应机制——不管套不套 graph 都得单独设计 rubric，是同一件事。用户明确只要 REST/控制台这一半。 ## REST（server/routes/dream.js，挂 /api/dream）路由本身没有新业务逻辑，全部委托给已测过的 dream-service.js： GET /agents（总览）、GET /agents/:id（详情，含定义文件可写性 + 经验审计）、POST /agents/:id/run（手动跑一次，dryRun 只看有没有新原料不起 LLM）、POST /sweep + GET /sweep/status（全量扫描后台跑 + 轮询，内存态并发锁防止连点两下）。 ## 控制台（web/src/views/DreamConsole.vue，路由 /dream）一个表格 + 两个弹窗：本体列表（详情/跑一次/dry-run）+ 全量扫描按钮（15 秒轮询状态）。导航栏加 🌙 Dream 入口。 ## 验证 server/tests/unit/dream-routes.test.js 4 例，monkeypatch 掉 dream-service 导出对象上的六个函数（不走真文件系统，不误扫真仓库 76 个本体），只验路由层自己的逻辑：端点接线、sweep 并发锁状态机。真起服务器打了真数据：GET /agents/innovator-evolver 正确报 SKILL.md 因没进 git 历史而不可写、经验审计吐出上次真跑沉淀的 4 条经验及原文；dry-run 正确报 no-new-material，没多花一次 LLM 调用。浏览器里走了一遍列表→详情→dry-run，与直接打 API 结果一致。 955 个单测全绿。文档：29-dream-design.md §5.7 记录实现与「为什么不做 graph 化」的理由；28-followups.md / docs/README.md 同步更新 dream 现状。 Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
yibo
1 parent 411af4e5
Showing 10 changed files with 608 additions and 24 deletions
CLAUDE.md
docs/README.md
docs/todo/system-design/28-followups.md
docs/todo/system-design/29-dream-design.md
server/index.js
server/routes/dream.js
server/tests/unit/dream-routes.test.js
web/src/components/AppNav.vue
web/src/router/index.js
web/src/views/DreamConsole.vue
@@ -109,6 +109,7 @@ npm run okr:migrate               # goals → okr 存量迁移
 | `/ws/claude` | Claude 实时对话（仅 `index.js`） |
 | `/api/health` `/api/plugins` | 健康检查 / 插件状态 |
 | `/api/devloop/projects` | DevLoop：创建项目 + 跑 PM/Architect（POST）、列项目 / 查状态（GET，见下） |
+| `/api/dream/*` | 经验汇流（29-DREAM）：`dream-service.js` 能力的 REST 封装，只读查询 + 触发 `dreamOnce`/`dreamSweep`，不新增业务逻辑，见 [`docs/todo/system-design/29-dream-design.md`](docs/todo/system-design/29-dream-design.md) |
 ### DevLoop 子系统
@@ -45,7 +45,8 @@ Graph Agent 架构重构（27 系列）。**已完成的阶段文档已移入 `d
 | [27-p3b-real-run-runway.md](./todo/system-design/27-p3b-real-run-runway.md) | P3 收尾之真跑跑道（从 mock 走到真 Claude CLI）— 📝 **只剩验收 9**。2026-08-20 第四次真跑（§六ter）验掉 2 与 8，验收 4 由零注入链路验掉，7 早已修好。验收 9 的准确状态是「产出端通了、消费端没等到那个形状」—— 需要一次 **org 层回退边指向 subgraph 节点**。⚠️ 这份文档里 ⛔/🟡 的段落多为**当时的现场记录**，读之前先看头部状态行 |
 | [27-goal-contract-format.md](./todo/system-design/27-goal-contract-format.md) | 验收契约格式（`goal-benchmark` / `goal-test-data` / `goal-test-script` 的产物形态与跨节点传递） |
 | [27-p4-parallel-and-artifacts.md](./todo/system-design/27-p4-parallel-and-artifacts.md) | **P4（回收编号）并行执行与产物索引** — 📝 设计中，未实现。fan-out 真并发 + 同 agent 多实例隔离 + `files.json` 产物索引。三个 Phase，C 可插队 |
-| [28-followups.md](./todo/system-design/28-followups.md) | 28 号（Agent 注册表统一）的遗留清单 — 主文档已在 `done/`，这份装没做完的：dream 机制（只有口述、无设计）、任务态清理（源码树无限增长）、`source_kind`/`legacy_path` 删列、三项「已实施未验证」。§五 是**已立起来的守卫清单**（别重复造，也别删） |
+| [28-followups.md](./todo/system-design/28-followups.md) | 28 号（Agent 注册表统一）的遗留清单 — 主文档已在 `done/`，这份装没做完的：dream 机制（设计见 29 号，已实现，见下）、`source_kind`（✅已删）/`legacy_path`（不能删）删列、三项「已实施未验证」。任务态清理（✅已实现，见下）。§五 是**已立起来的守卫清单**（别重复造，也别删） |
+| [29-dream-design.md](./todo/system-design/29-dream-design.md) | **dream（经验汇流）**— ✅ 已实现。定时整理所有 agent 在所有公司的记忆，提炼后跨公司沉淀（不泄漏公司信息）。四条取舍已拍板并实现：去敏独立判定、四落点分层写入（经验/`SKILL.md`/`soul.md`/`agent.md`，受管区块+三道闸门）、每日定时（串行+空转保护）、引用真伪自动查、REST+控制台入口（`/api/dream/*`、`/dream`）。`innovator-evolver` 真 CLI 跑通一次。**仍缺的**：「结论对不对」只能人抽查；「套进 org/work graph 来跑」评估后用户选了不做（作用域不匹配，见文内 §5.7） |
 ## todo/future/（暂缓，非当前重心）
@@ -20,23 +20,32 @@
 ### 1.1 dream 机制
-**状态**：用户口述过要解决什么问题和大致形态，**设计尚未开始**。
-
-已知的只有这些：
-- 定时跑的另一套逻辑，整理**所有 agent 在所有公司**的 history 与 memory，**显式提炼**后沉淀到 skill memory
-- 它是「经验汇流」的正解；错误版本是「每轮对话自动把原文写进共享 `SKILL.md`」——
-  方向对，但直接灌原始对话等于把 A 公司的机密喂给 B 公司
-  （这个错误版本真的发生过，是 28 号第一轮验收挖出的最严重 blocker，已修）
-
-**尚未设计的**：触发时机与频率、提炼规则、去敏策略（什么算「不含公司特定信息」）、
-产物落点与格式、失败与重试、提炼质量怎么评。
+**状态（2026-08-20 更新）**：设计已成文并已实现，见
+[29-dream-design.md](./29-dream-design.md)。四条取舍（去敏判据 / 沉淀落点 / 触发时机 /
+质量评估）均已拍板，五步推进顺序 + 定时挂载 + 定义文件写入均已落地，
+`innovator-evolver` 上真 CLI 跑通一次（40 条原料 → 4 条抽象经验，8 条引用全部核对回原文）。
+
+已实现的：
+- 定时（每日一次，串行，挂在 `server/index.js` 的 `DISABLE_BACKGROUND_AGENTS` 早退之后）
+  整理**所有 agent 在所有公司**的原始记录，**显式提炼**（`dream-distiller`）+
+  独立去敏判定（`dream-screener`）后沉淀
+- 落点四选四：本体 `memory/experience.md`（经验积累）+ `SKILL.md` / `soul.md` / `agent.md`
+  （受管区块，三道闸门缺一不写，见 29 号文档 §5.6）
+- 引用真伪自动查（编造出处直接拒）+ `auditDistilled()` 把结论与原料原文并排列出，
+  几秒内可回查
+
+- REST（`/api/dream/*`）+ 控制台（`/dream`，导航栏 `🌙 Dream`）：查总览/详情、手动跑单个本体（含 dry-run）、
+  触发并轮询全量扫描（2026-08-21）
+
+**仍未做的**：「结论对不对」的判据（机器判不了，只能靠人抽查，`auditDistilled` 的输出不是质量分）。
+「把 dream 套进 org/work graph 来跑」评估过、用户明确选了不做——
+org/work graph 是单公司作用域的，dream 是跨公司扫描，两者模型不匹配；
+且 graph 引擎自带的验收机制（goal-contract benchmark/test-script）判的是「产物过没过验收脚本」，
+对「经验提炼得对不对」这种自由文本判断没有对应机制，套不套 graph 都得单独设计 rubric。
 **已经生效的约束**（这条是确定的，不随 dream 的设计变化）：
 公司态目录（`system/agents/{aid}/{cid}/` 下的 `memory/` / `conversations/`）是 dream 的唯一原料，
-**不许被任何清理策略当垃圾扫掉**。详见主文档 §5.6b。
-
-> 真要做时另开设计文档。**不要**照主文档 §5.6b 的措辞去写代码 ——
-> 那一节的目的是锁住上面那条约束，不是给 dream 下定义。
+**不许被任何清理策略当垃圾扫掉**。详见主文档 §5.6b，任务态清理已按此约束实现（见下 §3.2）。
 ---
 # 29-DREAM · 经验汇流（dream）—— 设计草案
 > **所属**: [28 Agent 注册表统一](../../done/system-design/28-agent-registry-unification.md) §5.6b 锁住的那条约束的下游设计；未确认项来源 [28-followups §1.1](./28-followups.md)。
-> **日期**: 2026-08-20
-> **状态**: 📝 **四条取舍已由用户拍板（2026-08-20，见 §三），实现未开始。**
+> **日期**: 2026-08-20 / REST 与控制台入口 2026-08-21
+> **状态**: ✅ **四条取舍已拍板并已实现（五步 + 定时挂载 + 定义文件写入 + REST/控制台入口，均已落地并真跑验证，见 §四/§五/§5.7）。**
+> 仍未做的只剩「结论对不对」的判据——机器判不了，只能靠人抽查（决策 D，见上）。
 > 标 ✅ 的是已生效的约束或有实测证据的事实；标 🔒 的是本轮拍板的决定。
 ---
@@ -319,13 +320,15 @@ mtime 会被任何一次无关写入推动（例如别处重写整份 `memory.md
 ### 5.4 还没做的（别当成 dream 上线了）
-1. **定时挂载没做**（决策 C 说每日一次）。现在只有 `dreamOnce(agentId)` 这个可调用的单元，
-   没有挂到任何调度上，也没有 REST / 控制台入口。空转保护已经在，挂之前先想清楚
-   「每天对哪些本体跑」——全量 76 个本体逐个跑，即使空转也要 76 次目录读。
-2. **还没写定义文件**。`writeDistilled` 目前只写本体根的 `memory/experience.md`
-   （纯经验积累，删掉无副作用）。`SKILL.md` / `soul.md` / `agent.md` 三个 git 跟踪的定义
-   留给下一步；`definitionWritability()` 已经能报出「这三份现在能不能写、不能写是为什么」，
-   闸门（§B.3）也已就位，缺的是「往里写什么、写成什么形状」这半边设计。
+1. ~~定时挂载没做~~ ✅ **已完成**（§5.6）—— `dream-service.startDaily()` 已挂在
+   `server/index.js` 的 `DISABLE_BACKGROUND_AGENTS` 早退之后，每日一次、串行扫、
+   定时器 `unref`。~~仍然没有的是 REST / 控制台入口~~ ✅ **已完成**（§5.7）——
+   `/api/dream/*` + `web/src/views/DreamConsole.vue`（导航栏 `🌙 Dream`）。
+2. ~~还没写定义文件~~ ✅ **已完成**（§5.6）—— `writeDefinitionFiles()` 已实现，
+   落点是 `SKILL.md` / `soul.md` / `agent.md` 三个 git 跟踪的定义文件，
+   形状是受管区块（`<!-- dream:begin/end -->`，区块外不碰、整体重写幂等），
+   写之前过三道闸门（definition-write-gate → agent.md 前 2000 字符自足性 →
+   写完复核毕业闸门，不过立刻还原），任何一道不过就不写、原因逐文件返回。
 3. ~~决策 D~~ ✅ 已落地（见上）—— 但「结论对不对」仍然只能靠人抽查。
 ---
@@ -386,3 +389,100 @@ mtime 会被任何一次无关写入推动（例如别处重写整份 `memory.md
 ### 空转保护实跑
 第二次调用（原料没变）：`{"skipped":"no-new-material"}`，**一次 agent 调用都没起**。
+
+---
+
+## 5.6 定时挂载（决策 C）+ 定义文件写入（决策 B）（2026-08-20，`e9f380a`）
+
+### 定时：每日一次，串行
+
+`dreamSweep` 逐个本体扫，**不并发** —— 每轮可能起两次 LLM 调用，几十个本体并发
+= 同时拉起几十个 claude 子进程，这个代价本仓库付过（2h43m 漏出 82 个进程 / 17.5 GB，
+[28-followups §五第五条](./28-followups.md)）。慢一点没有代价，空转保护已经把
+「读一遍全量本体」的成本压到「N 次目录读」。
+
+挂点：`server/index.js` 里 `DISABLE_BACKGROUND_AGENTS` 早退之后，调
+`dream-service.startDaily()`。定时器 `unref`；只挂定时**不立刻跑一轮**
+（启动那一刻跑没有额外收益，反而让每次重启都烧一遍）。一个本体抛异常不拖垮整轮，
+但必须留下是谁抛的 —— 否则现场只看到「今天没沉淀」，查不出是没原料还是一直在抛。
+
+**没做的**：REST / 控制台入口。现在触发只有两条路：等每日定时，或代码 / 脚本直接调
+`dreamOnce(agentId)`。人想立刻看一次提炼结果，目前没有 API/页面。
+
+### 定义文件：受管区块 + 三道闸门
+
+落点是 `SKILL.md` / `soul.md` / `agent.md`（决策 B 的另外两个落点，本体根
+`memory/experience.md` 在步骤 3 已经在写）。形状是一对
+`<!-- dream:begin/end -->` 之间的**受管区块**，区块外一个字节不碰 —— 自由追加会让
+「哪些是人写的、哪些是 dream 写的」几轮之后再也分不开，分不开就没法分别回滚。
+区块整体重写还顺带**幂等**：同一批经验重复跑不会越写越长。
+
+三道闸门，缺一不写：
+1. **definition-write-gate**（§B.3）：当前内容必须已在 git 历史里，且没有未提交改动；
+2. **agent.md 的前 2000 字符必须仍然自足**：`graph-engine.js:915` 的「角色定义摘录」
+   只看这一段，改了等于悄悄换掉规划 agent 读到的画像；
+3. **写完复核毕业闸门**（`missingBodyDefinition`），不过就**立刻还原** ——
+   `agent.md` 写坏会让本体退回「定义没填满」，雇不进任何公司。
+
+任何一道不过：不写，原因逐文件返回（`definitions[]`）。**不写不该是静默的。**
+
+守卫：`dream-service.test.js` 新增 3 例，对真被 git 跟踪且干净的本体（`dream-screener`）
+走真路径 —— 真写、验区块外字节不变 / 幂等 / 毕业闸门仍过，`finally` 还原并断言还原干净；
+`agent.md` 那条验「不写 + 理由点名前 2000 字符 + 一个字节都没动」。`dreamSweep` 加了
+`agents` 参数，让错误隔离那条能真调而不是真扫全量本体。
+
+全量：144 文件 / 1330 测试全绿。
+
+---
+
+## 5.7 REST / 控制台入口（2026-08-21）
+
+只做了这一件事，没有跟着做「dream 改成 org/work graph 来跑」——
+两者被单独评估过（见对话记录）：org/work graph 的执行模型是**单公司作用域**的
+（org graph = 公司级 workflow，work graph = 公司内某任务的节点图），dream 却是
+**跨公司**扫描（按 agent 扫全部公司的记忆），套进去要么破坏这个作用域假设，
+要么得新开一种「跨公司图」类型。而且 graph 引擎自带的「自动质量判断」
+（goal-contract 的 benchmark / test-script、triager 驳回重做）判的是「产物有没有
+过验收脚本」，对「这条提炼的经验对不对」这种自由文本判断没有对应机制——
+那道题不管包不包进 graph 都得单独设计一个 rubric，是同一件事，graph 化本身
+不会替你解决它。所以只做了用户点了头的这一半。
+
+### REST（`server/routes/dream.js`，挂在 `/api/dream`）
+
+路由本身**没有新业务逻辑**，全部委托给已经测过的 `dream-service.js`：
+
+| 端点 | 做什么 |
+|---|---|
+| `GET /api/dream/agents` | 总览：每个可 dream 的本体，公司数、上次跑的时间、上次沉淀/拒绝了几条 |
+| `GET /api/dream/agents/:agentId` | 详情：状态、定义文件（`agent.md`/`soul.md`/`SKILL.md`）现在能不能写及原因、`auditDistilled()` 的可回查列表 |
+| `POST /api/dream/agents/:agentId/run` | 手动跑一次（`{dryRun}` 可选；`dryRun` 只看有没有新原料，不起 LLM 调用） |
+| `POST /api/dream/sweep` | 手动触发全量扫描，202 立即返回，后台跑（串行扫全部本体可能要几分钟到几十分钟，不能塞进一次 HTTP 请求里等） |
+| `GET /api/dream/sweep/status` | 轮询上面那个后台任务：`sweeping` / `results` / `error` |
+
+`sweep` 的并发锁是路由自己的状态（内存里一个 `sweepState`，不落库）——
+`dream-service.js` 没有「正在跑」这个概念，`dreamSweep()` 单纯是个 promise。
+两次并发 `POST /sweep` 第二次会拿到 409，防的是「人在控制台连点两下」而不是
+分布式场景（单进程部署，够用）。
+
+守卫：`server/tests/unit/dream-routes.test.js`，monkeypatch 掉
+`dream-service` 导出对象上的六个函数（不走真文件系统，不会误扫真仓库的
+76 个本体），只验路由这一层独有的东西——六个端点接没接对、`sweep` 的并发锁
+状态机对不对。`dream-service.js` 自身的正确性由 `dream-service.test.js` 覆盖，
+这里不重复验。
+
+### 控制台（`web/src/views/DreamConsole.vue`，路由 `/dream`，导航栏 `🌙 Dream`）
+
+一个表格 + 两个弹窗，没有别的：本体列表（点「详情」看状态/定义文件可写性/
+经验审计，点「跑一次」或「dry-run」手动触发单个本体），页头一个「全量扫描」按钮
+（触发后台 sweep，15 秒轮询一次状态直到跑完）。
+
+### 真跑验证（2026-08-21）
+
+起真服务器（`DISABLE_BACKGROUND_AGENTS=1 bash start.sh`），对真数据打过一轮：
+`GET /api/dream/agents` 拿到全部 76 个本体真实的 `companies` / `lastRunAt`；
+`GET /api/dream/agents/innovator-evolver` 的 `definitions` 如实报出
+`agent.md`/`soul.md` 可写、`SKILL.md` 不可写（没有 git 历史）及具体原因，
+`experience` 把 §5.5 那次真跑沉淀的 4 条经验连同原料原文一起吐出来；
+`dry-run` 对 `innovator-evolver` 正确报 `no-new-material`（材料已在上次真跑时被
+消费，本轮**没有起一次 LLM 调用**）。控制台页面在浏览器里过了一遍同样的路径
+（列表 → 详情弹窗 → dry-run 弹窗），数据与直接打 API 一致。
@@ -96,6 +96,7 @@ app.use(&#39;/api/tasks&#39;,        require(&#39;./routes/tasks&#39;));
 app.use('/api/devloop',      require('./routes/devloop'));
 app.use('/api/graph-runs',   require('./routes/graph-run'));                    // P3 图执行（T6）
 app.use('/api/company',      require('./routes/graph-run').companyRouter);      // GET /:cid/graph-runs
+app.use('/api/dream',        require('./routes/dream'));                       // 29-DREAM 经验汇流
 app.use('/public', require('express').static(require('path').join(__dirname, 'public')));
 // ─── 系统端点 ───
+/**
+ * dream —— 经验汇流的 REST 入口（[29-DREAM](../../docs/todo/system-design/29-dream-design.md)）。
+ *
+ * 只做一件事：把 `dream-service.js` 已有的能力（`dreamOnce` / `dreamSweep` /
+ * `auditDistilled` / `definitionWritability`）从「只能靠脚本或定时器触发」
+ * 变成「REST 可查可触发」。不新增业务逻辑。
+ */
+const express = require('express');
+const router = express.Router();
+const dream = require('../services/dream-service');
+
+// dreamSweep 串行跑几十个本体、每个可能起两次 LLM 调用，不能塞进一次 HTTP 请求里等。
+// 用最小的内存态跟踪「在跑没在跑」+「上一轮结果」，够控制台轮询用。
+let sweepState = { sweeping: false, startedAt: null, finishedAt: null, results: null, error: null };
+
+// GET /api/dream/agents — 总览：每个可 dream 的本体，跑没跑过、上次沉淀了几条
+router.get('/agents', (req, res) => {
+  try {
+    const list = dream.listDreamableAgents().map((agentId) => {
+      const state = dream.readState(agentId);
+      return {
+        agentId,
+        companies: dream.companiesOf(agentId).length,
+        lastRunAt: state.lastRunAt || null,
+        lastAccepted: state.lastAccepted || 0,
+        lastRejected: state.lastRejected || 0,
+      };
+    });
+    res.json({ agents: list });
+  } catch (err) {
+    res.status(500).json({ error: err.message });
+  }
+});
+
+// GET /api/dream/agents/:agentId — 详情：状态 + 定义文件能不能写 + 已沉淀经验的可回查列表
+router.get('/agents/:agentId', (req, res) => {
+  try {
+    const { agentId } = req.params;
+    res.json({
+      agentId,
+      companies: dream.companiesOf(agentId),
+      state: dream.readState(agentId),
+      definitions: dream.definitionWritability(agentId),
+      experience: dream.auditDistilled(agentId), // 每条结论并排列出引用的原料原文，回查成本降到几秒
+    });
+  } catch (err) {
+    res.status(500).json({ error: err.message });
+  }
+});
+
+// POST /api/dream/agents/:agentId/run — 手动跑一次（真会起 LLM 调用，dryRun 只想看会不会有新原料时用）
+router.post('/agents/:agentId/run', async (req, res) => {
+  try {
+    const dryRun = req.body && req.body.dryRun === true;
+    const result = await dream.dreamOnce(req.params.agentId, { dryRun });
+    res.json(result);
+  } catch (err) {
+    res.status(500).json({ error: err.message });
+  }
+});
+
+// POST /api/dream/sweep — 手动触发全量扫描（后台跑，别等；串行跑完可能是几分钟到几十分钟）
+router.post('/sweep', (req, res) => {
+  if (sweepState.sweeping) return res.status(409).json({ error: '上一轮扫描还没跑完', ...sweepState });
+  sweepState = { sweeping: true, startedAt: new Date().toISOString(), finishedAt: null, results: null, error: null };
+  dream.dreamSweep()
+    .then((results) => { sweepState = { ...sweepState, sweeping: false, finishedAt: new Date().toISOString(), results }; })
+    .catch((err) => { sweepState = { ...sweepState, sweeping: false, finishedAt: new Date().toISOString(), error: err.message }; });
+  res.status(202).json({ started: true, startedAt: sweepState.startedAt });
+});
+
+// GET /api/dream/sweep/status — 轮询上面那个后台任务
+router.get('/sweep/status', (req, res) => res.json(sweepState));
+
+module.exports = router;
+/**
+ * dream 的 REST 入口（29-DREAM，见 docs/todo/system-design/29-dream-design.md）。
+ *
+ * 路由本身没有业务逻辑 —— 全部委托给已经测过的 `dream-service.js`。
+ * 这份只验两件路由层独有的东西：
+ * ① 六个端点确实接到了对应的 service 函数上（不是「实现在、零调用方」）；
+ * ② `POST /sweep` 的并发锁 —— 上一轮没跑完时第二次触发要拒（409），
+ *   跑完之后 `GET /sweep/status` 要能看到结果。这段状态机全部写在 route 里，
+ *   `dream-service.test.js` 覆盖不到。
+ *
+ * `dream-service` 的六个被测函数在这里整体替身（monkeypatch 掉导出对象上的属性，
+ * 用完在 afterAll 里还原）—— 不走真文件系统，也不会误扫真仓库里的 76 个本体。
+ */
+import { describe, it, expect, beforeAll, afterAll } from 'vitest';
+
+const express = require('express');
+const dream = require('../../services/dream-service');
+const dreamRouter = require('../../routes/dream');
+
+const AGENT = 'zz-route-agent';
+const orig = {};
+function patch(name, fn) { orig[name] = dream[name]; dream[name] = fn; }
+function restore(name) { dream[name] = orig[name]; }
+
+let server;
+let base;
+let resolveSweep;
+
+beforeAll(() => {
+  patch('listDreamableAgents', () => [AGENT]);
+  patch('readState', () => ({ lastRunAt: '2026-08-20T00:00:00.000Z', lastAccepted: 2, lastRejected: 1 }));
+  patch('companiesOf', () => ['zz-route-co']);
+  patch('definitionWritability', () => [{ file: 'agent.md', allowed: true, reason: '' }]);
+  patch('auditDistilled', () => [{ title: 'X', sources: [{ source: 'zz-route-co:memory.md#1', text: '原文' }] }]);
+  patch('dreamOnce', async (agentId, opts) => ({ agentId, skipped: null, dryRun: !!(opts && opts.dryRun), accepted: 1 }));
+  patch('dreamSweep', () => new Promise((resolve) => { resolveSweep = resolve; }));
+
+  const app = express();
+  app.use(express.json());
+  app.use('/api/dream', dreamRouter);
+  server = app.listen(0);
+  base = `http://127.0.0.1:${server.address().port}/api/dream`;
+});
+
+afterAll(() => {
+  ['listDreamableAgents', 'readState', 'companiesOf', 'definitionWritability', 'auditDistilled', 'dreamOnce', 'dreamSweep']
+    .forEach(restore);
+  server.close();
+});
+
+describe('dream REST 入口', () => {
+  it('GET /agents 用 listDreamableAgents + readState + companiesOf 拼总览', async () => {
+    const res = await fetch(`${base}/agents`);
+    expect(res.status).toBe(200);
+    const body = await res.json();
+    expect(body.agents).toEqual([
+      { agentId: AGENT, companies: 1, lastRunAt: '2026-08-20T00:00:00.000Z', lastAccepted: 2, lastRejected: 1 },
+    ]);
+  });
+
+  it('GET /agents/:id 把状态、定义文件可写性、经验审计一起交出去', async () => {
+    const res = await fetch(`${base}/agents/${AGENT}`);
+    const body = await res.json();
+    expect(body.agentId).toBe(AGENT);
+    expect(body.companies).toEqual(['zz-route-co']);
+    expect(body.definitions[0].file).toBe('agent.md');
+    expect(body.experience[0].sources[0].text).toBe('原文');
+  });
+
+  it('POST /agents/:id/run 把 body.dryRun 原样传给 dreamOnce', async () => {
+    const res = await fetch(`${base}/agents/${AGENT}/run`, {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ dryRun: true }),
+    });
+    const body = await res.json();
+    expect(body.dryRun).toBe(true);
+  });
+
+  it('sweep 并发锁：跑着的时候第二次触发要 409，跑完 status 要能看到结果', async () => {
+    const start = await fetch(`${base}/sweep`, { method: 'POST' });
+    expect(start.status).toBe(202);
+
+    const mid = await fetch(`${base}/sweep/status`);
+    expect((await mid.json()).sweeping).toBe(true);
+
+    const blocked = await fetch(`${base}/sweep`, { method: 'POST' });
+    expect(blocked.status).toBe(409);
+
+    resolveSweep([{ agentId: AGENT, accepted: 3 }]);
+    await new Promise((r) => setTimeout(r, 20)); // 让 .then() 回调跑完
+
+    const done = await fetch(`${base}/sweep/status`);
+    const doneBody = await done.json();
+    expect(doneBody.sweeping).toBe(false);
+    expect(doneBody.results).toEqual([{ agentId: AGENT, accepted: 3 }]);
+  });
+});
@@ -21,6 +21,10 @@
         <span>📊</span> Quota
       </a>
+      <a href="/dream" target="_blank" class="nav-link" :class="{ active: $route.path === '/dream' }">
+        <span>🌙</span> Dream
+      </a>
+
       <div class="nav-divider"></div>
       <!-- Company Switcher -->
@@ -80,6 +80,11 @@ const routes = [
     name: 'QuotaMonitor',
     component: () => import('@/views/QuotaMonitor.vue'),
   },
+  {
+    path: '/dream',
+    name: 'DreamConsole',
+    component: () => import('@/views/DreamConsole.vue'),
+  },
   // P5 · DevLoop Projects 列表 + Dashboard + Ops
   {
     path: '/devloop',
+<template>
+  <div class="dream-page">
+    <AppNav />
+    <div class="dream-layout">
+      <header class="page-header">
+        <div>
+          <h1>🌙 Dream 经验汇流</h1>
+          <p class="subtitle">定时把所有 agent 在所有公司的记忆提炼成不含公司信息的经验，跨公司沉淀</p>
+        </div>
+        <div class="header-actions">
+          <button class="btn-refresh" @click="loadAgents">🔄 刷新</button>
+          <button class="btn-sweep" :disabled="sweepStatus.sweeping" @click="triggerSweep">
+            {{ sweepStatus.sweeping ? '⏳ 全量扫描中…' : '🌙 全量扫描' }}
+          </button>
+        </div>
+      </header>
+
+      <div v-if="sweepStatus.startedAt" class="sweep-banner" :class="{ running: sweepStatus.sweeping }">
+        <span v-if="sweepStatus.sweeping">上一轮 {{ formatTime(sweepStatus.startedAt) }} 起跑，串行扫描中，可能要几分钟到几十分钟——刷新本页不会打断它。</span>
+        <span v-else-if="sweepStatus.error">上一轮 {{ formatTime(sweepStatus.startedAt) }} 扫描失败：{{ sweepStatus.error }}</span>
+        <span v-else-if="sweepStatus.results">
+          上一轮 {{ formatTime(sweepStatus.finishedAt) }} 完成：{{ sweepStatus.results.length }} 个本体，
+          {{ sweepStatus.results.filter(r => !r.skipped && !r.error).length }} 个有新原料，
+          沉淀 {{ sweepStatus.results.reduce((n, r) => n + (r.accepted || 0), 0) }} 条。
+        </span>
+      </div>
+
+      <div v-if="loading" class="loading-state">⏳ 加载中…</div>
+      <div v-else-if="agents.length === 0" class="empty-state">没有可 dream 的本体</div>
+
+      <div v-else class="agents-table">
+        <div class="table-header">
+          <span>本体</span>
+          <span>公司数</span>
+          <span>上次跑</span>
+          <span>沉淀 / 拒绝</span>
+          <span>操作</span>
+        </div>
+        <div v-for="a in agents" :key="a.agentId" class="table-row">
+          <span class="col-agent">{{ a.agentId }}</span>
+          <span>{{ a.companies }}</span>
+          <span class="col-time">{{ a.lastRunAt ? formatTime(a.lastRunAt) : '从未' }}</span>
+          <span>
+            <span class="badge accepted">{{ a.lastAccepted }}</span>
+            <span class="badge rejected">{{ a.lastRejected }}</span>
+          </span>
+          <span class="col-actions">
+            <button class="btn-action" @click="viewDetail(a.agentId)">👁 详情</button>
+            <button class="btn-action" :disabled="runningAgent === a.agentId" @click="runOne(a.agentId, false)">
+              {{ runningAgent === a.agentId ? '跑中…' : '▶ 跑一次' }}
+            </button>
+            <button class="btn-action" :disabled="runningAgent === a.agentId" @click="runOne(a.agentId, true)" title="只看有没有新原料，不起 LLM 调用">
+              dry-run
+            </button>
+          </span>
+        </div>
+      </div>
+
+      <!-- 详情弹窗 -->
+      <div v-if="detail" class="modal-overlay" @click="detail = null">
+        <div class="modal-content" @click.stop>
+          <div class="modal-header">
+            <h2>{{ detail.agentId }}</h2>
+            <button class="btn-close" @click="detail = null">✕</button>
+          </div>
+          <div class="modal-body">
+            <section class="detail-section">
+              <h4>状态</h4>
+              <pre class="state-pre">{{ JSON.stringify(detail.state, null, 2) }}</pre>
+            </section>
+
+            <section class="detail-section">
+              <h4>定义文件能不能写</h4>
+              <div class="def-list">
+                <div v-for="d in detail.definitions" :key="d.file" class="def-row">
+                  <span class="def-file">{{ d.file }}</span>
+                  <span class="badge" :class="d.allowed ? 'accepted' : 'rejected'">
+                    {{ d.allowed ? '可写' : '不可写' }}
+                  </span>
+                  <span class="def-reason">{{ d.reason || '' }}</span>
+                </div>
+              </div>
+            </section>
+
+            <section class="detail-section">
+              <h4>已沉淀经验（结论与原料原文并排，抽查用）</h4>
+              <div v-if="detail.experience.length === 0" class="empty-inline">还没有沉淀过</div>
+              <div v-for="(e, i) in detail.experience" :key="i" class="exp-card">
+                <div class="exp-title">{{ e.title }}</div>
+                <div v-for="(s, j) in e.sources" :key="j" class="exp-source">
+                  <span class="exp-source-id">{{ s.source }}</span>
+                  <span v-if="s.text !== null" class="exp-source-text">{{ s.text }}</span>
+                  <span v-else class="exp-source-dangling">⚠️ 指针悬空（原料被清理过 / 出处编造）</span>
+                </div>
+              </div>
+            </section>
+          </div>
+        </div>
+      </div>
+
+      <!-- 手动跑结果弹窗 -->
+      <div v-if="runResult" class="modal-overlay" @click="runResult = null">
+        <div class="modal-content" @click.stop>
+          <div class="modal-header">
+            <h2>{{ runResult.agentId }} 跑一次的结果</h2>
+            <button class="btn-close" @click="runResult = null">✕</button>
+          </div>
+          <div class="modal-body">
+            <pre class="state-pre">{{ JSON.stringify(runResult, null, 2) }}</pre>
+          </div>
+        </div>
+      </div>
+    </div>
+  </div>
+</template>
+
+<script setup>
+import { ref, onMounted, onUnmounted } from 'vue'
+import AppNav from '@/components/AppNav.vue'
+
+const agents = ref([])
+const loading = ref(true)
+const detail = ref(null)
+const runResult = ref(null)
+const runningAgent = ref(null)
+const sweepStatus = ref({ sweeping: false, startedAt: null, finishedAt: null, results: null, error: null })
+let pollTimer = null
+
+async function loadAgents() {
+  loading.value = true
+  try {
+    const res = await fetch('/api/dream/agents')
+    const data = await res.json()
+    agents.value = data.agents || []
+  } catch (e) {
+    console.error('加载 dream 本体列表失败', e)
+  } finally {
+    loading.value = false
+  }
+}
+
+async function loadSweepStatus() {
+  try {
+    const res = await fetch('/api/dream/sweep/status')
+    sweepStatus.value = await res.json()
+  } catch (e) {
+    console.error('加载 sweep 状态失败', e)
+  }
+}
+
+async function triggerSweep() {
+  try {
+    const res = await fetch('/api/dream/sweep', { method: 'POST' })
+    if (res.status === 409) { alert('上一轮扫描还没跑完'); return }
+    await loadSweepStatus()
+  } catch (e) {
+    alert('触发失败: ' + e.message)
+  }
+}
+
+async function viewDetail(agentId) {
+  try {
+    const res = await fetch(`/api/dream/agents/${agentId}`)
+    detail.value = await res.json()
+  } catch (e) {
+    alert('加载详情失败: ' + e.message)
+  }
+}
+
+async function runOne(agentId, dryRun) {
+  runningAgent.value = agentId
+  try {
+    const res = await fetch(`/api/dream/agents/${agentId}/run`, {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ dryRun }),
+    })
+    runResult.value = await res.json()
+    await loadAgents()
+  } catch (e) {
+    alert('跑失败: ' + e.message)
+  } finally {
+    runningAgent.value = null
+  }
+}
+
+function formatTime(iso) {
+  if (!iso) return '-'
+  return new Date(iso).toLocaleString('zh-CN')
+}
+
+onMounted(() => {
+  loadAgents()
+  loadSweepStatus()
+  // 全量扫描可能跑几十分钟，轮询一下让「还在跑」不需要手动刷新才能看到
+  pollTimer = setInterval(() => { if (sweepStatus.value.sweeping) loadSweepStatus() }, 15000)
+})
+onUnmounted(() => { if (pollTimer) clearInterval(pollTimer) })
+</script>
+
+<style scoped>
+.dream-page { min-height: 100vh; background: var(--bg-primary); color: var(--text-primary); }
+.dream-layout { max-width: 1100px; margin: 0 auto; padding: 32px 40px; }
+
+.page-header { display: flex; justify-content: space-between; align-items: flex-start; margin-bottom: 20px; }
+.page-header h1 { font-size: 24px; font-weight: 700; margin: 0 0 6px; }
+.subtitle { color: var(--text-secondary); font-size: 13px; margin: 0; }
+.header-actions { display: flex; gap: 10px; }
+
+.btn-refresh, .btn-sweep {
+  padding: 8px 16px; border-radius: 8px; cursor: pointer; font-size: 13px; font-weight: 600;
+  border: 1px solid var(--border-primary); background: var(--bg-surface); color: var(--text-secondary);
+}
+.btn-sweep { background: var(--accent); border-color: transparent; color: white; }
+.btn-sweep:disabled { opacity: 0.6; cursor: not-allowed; }
+.btn-refresh:hover { background: var(--bg-surface-hover); }
+
+.sweep-banner {
+  padding: 10px 14px; border-radius: 8px; margin-bottom: 16px; font-size: 13px;
+  background: var(--accent-bg); color: var(--text-secondary); border: 1px solid var(--border-active);
+}
+.sweep-banner.running { color: var(--accent-light); }
+
+.loading-state, .empty-state, .empty-inline { text-align: center; padding: 40px; color: var(--text-muted); }
+.empty-inline { padding: 12px; text-align: left; font-style: italic; }
+
+.agents-table {
+  background: var(--bg-surface); border: 1px solid var(--border-primary); border-radius: 12px; overflow: hidden;
+}
+.table-header, .table-row {
+  display: grid; grid-template-columns: 1.4fr 0.6fr 1fr 1fr 1.6fr;
+  gap: 12px; padding: 12px 16px; align-items: center;
+}
+.table-header { font-size: 12px; font-weight: 600; color: var(--text-muted); border-bottom: 1px solid var(--border-primary); }
+.table-row { border-bottom: 1px solid var(--border-primary); font-size: 13px; }
+.table-row:last-child { border-bottom: none; }
+.col-agent { font-weight: 600; }
+.col-time { color: var(--text-secondary); }
+.col-actions { display: flex; gap: 6px; flex-wrap: wrap; }
+
+.badge { display: inline-block; padding: 2px 8px; border-radius: 10px; font-size: 11px; font-weight: 700; margin-right: 6px; }
+.badge.accepted { background: var(--accent-bg); color: var(--accent-light); }
+.badge.rejected { background: rgba(248, 81, 73, 0.12); color: #f85149; }
+
+.btn-action {
+  padding: 5px 10px; border-radius: 6px; border: 1px solid var(--border-primary);
+  background: var(--bg-surface); color: var(--text-primary); font-size: 12px; cursor: pointer;
+}
+.btn-action:hover { background: var(--bg-surface-hover); }
+.btn-action:disabled { opacity: 0.5; cursor: not-allowed; }
+
+/* Modal */
+.modal-overlay {
+  position: fixed; inset: 0; background: rgba(0,0,0,0.5); display: flex; align-items: center;
+  justify-content: center; z-index: 1000; backdrop-filter: blur(4px);
+}
+.modal-content {
+  background: var(--bg-secondary); border: 1px solid var(--border-primary); border-radius: 12px;
+  width: 640px; max-width: 92vw; max-height: 84vh; overflow-y: auto;
+}
+.modal-header {
+  display: flex; justify-content: space-between; align-items: center; padding: 16px 20px;
+  border-bottom: 1px solid var(--border-primary); position: sticky; top: 0; background: var(--bg-secondary);
+}
+.modal-header h2 { margin: 0; font-size: 16px; font-family: monospace; }
+.btn-close { background: none; border: none; font-size: 16px; color: var(--text-secondary); cursor: pointer; }
+.modal-body { padding: 20px; }
+
+.detail-section { margin-bottom: 20px; }
+.detail-section h4 { font-size: 13px; color: var(--text-secondary); margin: 0 0 8px; }
+.state-pre {
+  background: var(--bg-primary); padding: 12px; border-radius: 8px; font-size: 12px;
+  overflow-x: auto; max-height: 200px; overflow-y: auto;
+}
+
+.def-list { display: flex; flex-direction: column; gap: 6px; }
+.def-row { display: flex; align-items: center; gap: 10px; font-size: 12px; }
+.def-file { font-family: monospace; min-width: 80px; }
+.def-reason { color: var(--text-muted); }
+
+.exp-card {
+  background: var(--bg-primary); border: 1px solid var(--border-primary); border-radius: 8px;
+  padding: 12px; margin-bottom: 10px;
+}
+.exp-title { font-weight: 700; font-size: 13px; margin-bottom: 6px; }
+.exp-source { font-size: 12px; margin-bottom: 4px; padding-left: 8px; border-left: 2px solid var(--border-active); }
+.exp-source-id { color: var(--text-muted); font-family: monospace; margin-right: 8px; }
+.exp-source-text { color: var(--text-secondary); }
+.exp-source-dangling { color: #f85149; }
+</style>