457 lines
31 KiB
Markdown
457 lines
31 KiB
Markdown
# 后端代码 vs 设计文档对照审查报告
|
||
|
||
> 审查人:庞统(副军师)🐦
|
||
> 日期:2026-05-19
|
||
> 代码版本:v2.7.0(main.py 声明)
|
||
> 设计文档版本:architecture-v2.6 + v2.7-subtask-model + v2.8-state-enhancement 等
|
||
|
||
---
|
||
|
||
## 后端模块审查
|
||
|
||
### main.py (文件: src/main.py, 253行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| FastAPI + Daemon ticker 共享 asyncio event loop | architecture-v2.6 §2 架构总览; technical-design §5.3 | ✅ 已实现 | lifespan() 中启动 Ticker,yield 时 stop |
|
||
| YAML 配置加载 | technical-design §2.1 | ✅ 已实现 | config/default.yaml, L42-52 |
|
||
| Ticker 全局实例 | architecture-v2.6 §4 | ✅ 已实现 | get_ticker() 全局访问器 |
|
||
| ProjectRegistry 初始化 | v2.7-subtask-model §3 | ✅ 已实现 | get_registry(), L82 |
|
||
| YAML 迁移 + 自动发现 | v2.7-subtask-model §3 | ✅ 已实现 | registry.migrate_from_yaml() + discover_projects(), L76-82 |
|
||
| Agent Profiles 配置驱动 | agent-routing-redesign §4 | ✅ 已实现 | 从 daemon.agent_profiles 构建 AgentProfile, L97-106 |
|
||
| LLM Driver 构建(Mode A 路由) | agent-routing-redesign §4.2 | ✅ 已实现 | 从 daemon.routing 构建 LLMDriver, L109-120 |
|
||
| Router + Dispatcher + Spawner + Counter 组件装配 | agent-integration-v2.6 §4.1 | ✅ 已实现 | L122-142 |
|
||
| CORS 中间件 | technical-design §9 | ✅ 已实现 | L171-177 |
|
||
| 6 组 API 路由注册 | technical-design §9 | ✅ 已实现 | blackboard/checkpoint/daemon/project/sse/mail, L181-192 |
|
||
| /api/projects 兼容端点 | 无 | ✅ 已实现(超前) | 兼容旧前端, L197-201 |
|
||
| 前端静态文件服务 | architecture-v2.6 §11 | ✅ 已实现 | DIST_DIR mount, L208-210 |
|
||
| 版本号 2.7.0 | v2.7-subtask-model | ✅ 已实现 | FastAPI(version="2.7.0"), L166 |
|
||
| 日志配置 | technical-design §5 | ✅ 已实现 | _setup_logging(), L31-46 |
|
||
|
||
### blackboard/models.py (文件: src/blackboard/models.py, 182行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| Task dataclass | architecture-v2.6 §3.2 | ✅ 已实现 | 包含全部设计字段 + v2.6.1/v2.7/v2.8 扩展 |
|
||
| Task.from_row() 安全构造 | 无设计文档 | ✅ 已实现(超前) | 防止 DB 新增字段导致构造失败 |
|
||
| Comment dataclass | architecture-v2.6 §3.2 | ✅ 已实现 | 含 comment_type、mentions |
|
||
| Output dataclass | architecture-v2.6 §3.2 | ✅ 已实现 | 含 attempt_number、metadata |
|
||
| Decision dataclass | architecture-v2.6 §3.2 | ✅ 已实现 | 含 alternatives |
|
||
| Observation dataclass | architecture-v2.6 §3.2 | ✅ 已实现 | 含 severity、resolved_by/at |
|
||
| Event dataclass | architecture-v2.6 §3.2 | ✅ 已实现 | task_id 可选(全局事件) |
|
||
| Review dataclass | architecture-v2.6 §9.6 | ✅ 已实现 | 含 round、max_rounds、consensus_reached、confidence |
|
||
| Experience dataclass | architecture-v2.6 §9.6 / v2.6.7 | ✅ 已实现 | 含 tags(独立查询)、skill_id、usage_count |
|
||
| Task v2.6.1 路由扩展字段 | agent-routing-redesign §5 | ✅ 已实现 | current_agent, previous_agent, next_capability |
|
||
| Task v2.7 SubTask 字段 | v2.7-subtask-model §2.1 | ✅ 已实现 | stage, stages_json |
|
||
| Task v2.8 归档字段 | v2.8-state-enhancement §二 | ✅ 已实现 | archived, archived_at |
|
||
|
||
### blackboard/db.py (文件: src/blackboard/db.py, 444行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| tasks 表 Schema | architecture-v2.6 §3.2 | ✅ 已实现 | 完整匹配设计,含 CHECK 约束 |
|
||
| comments 表 Schema | architecture-v2.6 §3.5 | ✅ 已实现 | 含 comment_type CHECK |
|
||
| outputs 表 Schema | architecture-v2.6 §3.2 | ✅ 已实现 | 含 output_type CHECK |
|
||
| decisions 表 Schema | architecture-v2.6 §3.2 | ✅ 已实现 | |
|
||
| observations 表 Schema | architecture-v2.6 §3.2 | ✅ 已实现 | 含 severity CHECK |
|
||
| events 表 Schema | architecture-v2.6 §3.2 | ✅ 已实现 | 索引 on task_id + created_at |
|
||
| agents 表 Schema | technical-design §4.2 | ✅ 已实现 | |
|
||
| task_attempts 表 Schema | architecture-v2.6 §4.3 | ✅ 已实现 | 含 outcome CHECK |
|
||
| reviews 表 Schema | architecture-v2.6 §9.6 | ✅ 已实现 | 含 review_type + verdict CHECK |
|
||
| experiences + experience_tags 表 | architecture-v2.6 §9.6 / v2.6.7 | ✅ 已实现 | 含 source/category/status CHECK |
|
||
| routing_decisions 表 | agent-routing-redesign §5 | ✅ 已实现 | 含 mode CHECK, 3 索引 |
|
||
| checkpoints 表 | v2.8-state-enhancement §四.4 | ✅ 已实现 | 含 type + status CHECK, M3 |
|
||
| 11 状态 + CHECK 约束 | v2.8-state-enhancement §1.2 | ✅ 已实现 | pending/claimed/working/review/paused/escalated/waiting_human/done/failed/blocked/cancelled |
|
||
| 状态机 VALID_TRANSITIONS | v2.8-state-enhancement §1.2 | ✅ 已实现 | 完全匹配设计文档的状态转换表 |
|
||
| TERMINAL_STATUSES | v2.8-state-enhancement §1.2 | ✅ 已实现 | {done} — cancelled 已从终态移除? |
|
||
| MANUAL_STATUSES | v2.7-subtask-model §2.2 | ✅ 已实现 | {cancelled, paused} — 不参与聚合 |
|
||
| WAL + busy_timeout + foreign_keys | technical-design §2.2 | ✅ 已实现 | _connect() L284-287 |
|
||
| v2.6.1 数据迁移 | agent-routing-redesign | ✅ 已实现 | _migrate_v261(): current_agent 等字段 |
|
||
| v2.7 数据迁移 | v2.7-subtask-model §2.1 | ✅ 已实现 | _migrate_v27(): stages_json + stage |
|
||
| v2.8 数据迁移(重建表) | v2.8-state-enhancement §二.3 | ✅ 已实现 | _migrate_v28(): CHECK 更新 + 归档字段 + checkpoints + outputs 扩展 |
|
||
| COMMENT_TYPES | architecture-v2.6 §3.5 / §9.5 | ✅ 已实现 | 含 debate 系列 |
|
||
| EVENT_TYPES | architecture-v2.6 §4.2 | ✅ 已实现 | 含 v2.8 的 archived/unarchived |
|
||
| outputs 扩展字段(M3) | v2.8-state-enhancement §五.1 | ✅ 已实现 | file_name/file_size/file_path/mime_type |
|
||
|
||
**⚠️ 注意**: TERMINAL_STATUSES 只有 `{done}`,cancelled 设计文档中也是终态(`cancelled: []`),但代码中 cancelled 不在 TERMINAL_STATUSES 里。实际上 VALID_TRANSITIONS 中 cancelled 的目标为空集,效果等价,但语义上应加入。
|
||
|
||
### blackboard/operations.py (文件: src/blackboard/operations.py, 823行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| Blackboard 类 | architecture-v2.6 §3.4 | ✅ 已实现 | per-project SQLite |
|
||
| create_task | architecture-v2.6 §3.4 | ✅ 已实现 | 含事件写入 |
|
||
| get_task | architecture-v2.6 §3.4 | ✅ 已实现 | |
|
||
| update_task_status | architecture-v2.6 §3.3/§3.4 | ✅ 已实现 | 校验合法转换 + 事件写入 + 时间戳 |
|
||
| claim_task(原子 CAS) | architecture-v2.6 §3.6 | ✅ 已实现 | BEGIN IMMEDIATE + WHERE status='pending' |
|
||
| list_tasks | architecture-v2.6 §3.4 | ✅ 已实现 | 支持 status/assignee/parent_task 过滤 |
|
||
| add_comment | architecture-v2.6 §3.5 | ✅ 已实现 | 含 comment_type 校验 + 事件 |
|
||
| get_comments | architecture-v2.6 §3.5 | ✅ 已实现 | 支持 comment_type 过滤 |
|
||
| write_output | architecture-v2.6 §3.2 | ✅ 已实现 | 含 output_type 校验 + 事件 |
|
||
| get_outputs | architecture-v2.6 §3.2 | ✅ 已实现 | |
|
||
| add_decision | architecture-v2.6 §3.2 | ✅ 已实现 | 含事件 |
|
||
| add_observation | architecture-v2.6 §3.2 | ✅ 已实现 | 含 severity |
|
||
| add_review | architecture-v2.6 §9.6 | ✅ 已实现 | 含 review_type + verdict 校验 |
|
||
| add_experience | architecture-v2.6 §9.6 / v2.6.7 | ✅ 已实现 | 含 tags 处理 |
|
||
| query_experiences | architecture-v2.6 §9.6 | ✅ 已实现 | 支持 tag 过滤 + usage_count 排序 |
|
||
| touch_experience | architecture-v2.6 v2.6.7 | ✅ 已实现 | 引用计数 +1 |
|
||
| add_task_attempt | architecture-v2.6 §4.3 | ✅ 已实现 | |
|
||
| Agent CRUD(upsert/get/update_status) | architecture-v2.6 §3.2 | ✅ 已实现 | |
|
||
| archive_task / unarchive_task | v2.8-state-enhancement §二.1 | ✅ 已实现 | 含事件写入 |
|
||
| archive_done_tasks | v2.8-state-enhancement §二.1 | ✅ 已实现 | 一键归档 done 任务 |
|
||
| Checkpoint CRUD | v2.8-state-enhancement §四 | ✅ 已实现 | create/list/get/resolve |
|
||
| Checkpoint approve/reject 状态推进 | v2.8-state-enhancement §四.3 | ✅ 已实现 | verify→done, 其他→working; reject→working |
|
||
| BUG-32 安全校验(waiting_human) | v2.8-state-enhancement §四.3 | ✅ 已实现 | resolve_checkpoint() 校验 task_status |
|
||
| BUG-33 payload 结构校验 | v2.8-state-enhancement §四.4 | ✅ 已实现 | version 字段必须存在 |
|
||
| update_must_haves | architecture-v2.6 §9 | ✅ 已实现 | 用于 Mail 元数据 |
|
||
|
||
### blackboard/queries.py (文件: src/blackboard/queries.py, 356行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| task_summary | architecture-v2.6 §3.4 | ✅ 已实现 | GROUP BY status |
|
||
| tasks_by_assignee | architecture-v2.6 §3.4 | ✅ 已实现 | |
|
||
| blocked_tasks_with_deps | architecture-v2.6 §4.2 | ✅ 已实现 | 依赖链查询 |
|
||
| pending_dispatchable | architecture-v2.6 §4.2 | ✅ 已实现 | 依赖全部满足的 pending 任务 |
|
||
| recent_events | architecture-v2.6 §4.2 | ✅ 已实现 | |
|
||
| task_detail 聚合 | architecture-v2.6 §5.2 | ✅ 已实现 | comments_count + outputs_count + review_status |
|
||
| list_subtasks | v2.7-subtask-model §2.1 | ✅ 已实现 | parent_task 过滤 |
|
||
| top_level_tasks | v2.7-subtask-model §2.6 | ✅ 已实现 | parent_task IS NULL |
|
||
| compute_parent_status | v2.7-subtask-model §2.2 | ✅ 已实现 | 聚合优先级:escalated > waiting_human > review > working > pending > failed > blocked |
|
||
| MANUAL_STATUSES 不参与聚合 | v2.7-subtask-model §2.2 | ✅ 已实现 | cancelled + paused 跳过 |
|
||
| parent_task_progress | v2.7-subtask-model §2.6 | ✅ 已实现 | 按 stage 分组统计 + active_stage |
|
||
|
||
### blackboard/registry.py (文件: src/blackboard/registry.py, 286行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| ProjectRegistry(registry.db SQLite) | architecture-v2.6 §10/v2.6.10 | ✅ 已实现 | 替代原 YAML 方案 |
|
||
| projects 表 Schema | technical-design §4.2 | ✅ 已实现 | 含 config_json、source、archived_at |
|
||
| create_project | v2.7-subtask-model §3 | ✅ 已实现 | 含目录创建 + project.yaml 骨架 |
|
||
| get/list/update/archive/delete | technical-design §9.4 | ✅ 已实现 | |
|
||
| 自动发现(扫描含 blackboard.db 的目录) | v2.7-subtask-model §3 | ✅ 已实现 | discover_projects() |
|
||
| YAML 迁移 | v2.7-subtask-model §3 | ✅ 已实现 | migrate_from_yaml() |
|
||
|
||
### daemon/ticker.py (文件: src/daemon/ticker.py, 580行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| Tick 循环(可配置间隔) | architecture-v2.6 §4.1 | ✅ 已实现 | 默认 30s |
|
||
| 遍历所有 active 项目 | architecture-v2.6 v2.6.10 | ✅ 已实现 | _tick_project per project |
|
||
| 依赖推进(blocked → pending) | architecture-v2.6 §4.2 D2-2 | ✅ 已实现 | _advance_dependencies() |
|
||
| 僵尸/超时处理 | architecture-v2.6 §4.1 | ✅ 已实现 | _check_timeouts(): claimed 超时→pending, working 超时→failed |
|
||
| Pending 任务调度 | agent-integration-v2.6 §4.1 | ✅ 已实现 | _dispatch_pending(): Dispatcher → Spawner |
|
||
| Review 任务调度 | agent-routing-redesign §1.1 | ✅ 已实现 | _dispatch_reviews(): 无产出→failed, 有产出→派审查者 |
|
||
| 父 Task 状态聚合 | v2.7-subtask-model §2.5 | ✅ 已实现 | _refresh_parent_statuses() |
|
||
| daemon_tick 事件 | architecture-v2.6 §4.2 | ✅ 已实现 | |
|
||
| max_dispatch_per_tick 并发控制 | technical-design §5.4 | ✅ 已实现 | |
|
||
| claim_timeout / task_timeout | architecture-v2.6 §4.5 | ✅ 已实现 | 可配置 |
|
||
| per-task 超时(deadline 优先) | architecture-v2.6 §4.5 | ✅ 已实现 | deadline > default_task_timeout |
|
||
| 手动 tick API | technical-design §9.2 | ✅ 已实现 | manual_tick() |
|
||
| 防重复 dispatch(_check_recent_routing) | agent-routing-redesign | ✅ 已实现 | 5 分钟内同 task 不重复 dispatch |
|
||
|
||
**⚠️ 注意**: Ticker 未集成 HealthChecker(health.py 存在但未被 Ticker 调用)。设计文档 §14 + v2.6.9.1 要求"Daemon 逻辑健康自检纳入"。
|
||
|
||
### daemon/dispatcher.py (文件: src/daemon/dispatcher.py, 402行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| Dispatcher 类(执行层) | agent-routing-redesign §1 | ✅ 已实现 | Router 做决策,Dispatcher 做执行 |
|
||
| decide() 委托给 Router | agent-routing-redesign §4 | ✅ 已实现 | |
|
||
| dispatch() 完整流程 | agent-integration-v2.6 §4.1 | ✅ 已实现 | 决策 + 并发检查 + spawn + 审计日志 |
|
||
| DispatchLevel 四级 | agent-routing-redesign §4 | ✅ 已实现 | LOCAL/FULL_AGENT/SUB_AGENT/ESCALATE |
|
||
| 路由审计日志(routing_decisions) | agent-routing-redesign §5 | ✅ 已实现 | _record_routing() 写入项目 DB |
|
||
| 并发控制检查 | technical-design §5.4 | ✅ 已实现 | counter.can_acquire() |
|
||
| spawn 消息构建 | agent-integration-v2.6 §4.2 | ✅ 已实现 | _build_spawn_message() 含 retry context |
|
||
| Legacy 兼容模式 | 无 | ✅ 已实现(超前) | 无 Router 时降级旧逻辑 |
|
||
| 批量决策接口 | 无 | ✅ 已实现(超前) | dispatch_pending() |
|
||
|
||
### daemon/router.py (文件: src/daemon/router.py, 376行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| AgentRouter 决策层 | agent-routing-redesign §4 | ✅ 已实现 | 三种路由模式 |
|
||
| Mode A LLM 路由 | agent-routing-redesign §4.2 | ✅ 已实现 | LLMDriver: OpenAI API 调用, ~200 token |
|
||
| Mode B Agent 声明式交接 | agent-routing-redesign §4.3 | ✅ 已实现 | next_capability 匹配 |
|
||
| AgentProfile 能力画像 | agent-routing-redesign §4 | ✅ 已实现 | capabilities, can_review, max_concurrent, is_fallback |
|
||
| RouteDecision 数据结构 | agent-routing-redesign §5 | ✅ 已实现 | agent_id, reason, mode, confidence, model, latency_ms |
|
||
| 快速路径(确定性路由) | agent-routing-redesign §4 | ✅ 已实现 | 本地 action + retry + 生命周期查表 + 直接 assignee |
|
||
| LLM 合法性校验 | agent-routing-redesign §4.2 | ✅ 已实现 | agent_id 必须在 profiles 中 |
|
||
| LLM 低置信度 fallback | agent-routing-redesign §4.2 | ✅ 已实现 | confidence < 0.7 → fallback 庞统 |
|
||
| BUG-2 next_capability 校验 | agent-routing-redesign | ✅ 已实现 | _validate_capability() 白名单 |
|
||
| 负载均衡(多候选选最低负载) | agent-routing-redesign §4 | ✅ 已实现 | counter.active_agents |
|
||
|
||
### daemon/spawner.py (文件: src/daemon/spawner.py, 367行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| AgentSpawner 类 | architecture-v2.6 §4.3 | ✅ 已实现 | |
|
||
| spawn_full_agent | agent-integration-v2.6 §4.1 | ✅ 已实现 | openclaw agent CLI 异步非阻塞 |
|
||
| spawn_subagent | agent-integration-v2.6 | ⚠️ 占位 | spawn_subagent() 为 placeholder, TODO F17 |
|
||
| Spawn prompt 模板 | agent-api-contract §1 | ✅ 已实现 | SPAWN_PROMPT_TEMPLATE 含完整状态机 + API 引导 |
|
||
| 进程监控 + 超时 kill | architecture-v2.6 §4.3 | ✅ 已实现 | _monitor_process(): wait_for + TimeoutError |
|
||
| task_attempts 记录 | architecture-v2.6 §4.3 | ✅ 已实现 | _record_attempt() |
|
||
| Session 注册表 | architecture-v2.6 §4.3 | ✅ 已实现 | _sessions dict |
|
||
| on_complete 回调 | agent-integration-v2.6 §4.1 | ✅ 已实现 | 释放 counter |
|
||
| dry_run 测试模式 | 无 | ✅ 已实现(超前) | |
|
||
| API host/port 配置 | agent-api-contract | ✅ 已实现 | 供 Agent 回写 |
|
||
|
||
### daemon/counter.py (文件: src/daemon/counter.py, 73行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| ActiveAgentCounter 异步计数器 | architecture-v2.6 v2.6.10 / technical-design §5.4 | ✅ 已实现 | |
|
||
| 全局上限 + per-agent 串行 | technical-design §5.4 | ✅ 已实现 | max_global=5, max_per_agent=1 |
|
||
| 延迟创建 Semaphore | 无 | ✅ 已实现(超前) | 兼容 Python 3.9 |
|
||
| active_agents 属性 | technical-design §5.4 | ✅ 已实现 | 供 Router 负载均衡 |
|
||
|
||
### daemon/bootstrap.py (文件: src/daemon/bootstrap.py, 215行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| BootstrapBuilder 四层上下文 | architecture-v2.6 v2.6.5 / technical-design §5.5 | ✅ 已实现 | L0-L3 四层 |
|
||
| L2a 角色模板 | architecture-v2.6 v2.6.5 | ✅ 已实现 | 按 role 加载 {role}.md |
|
||
| L2b 项目背景 | architecture-v2.6 v2.6.5 | ✅ 已实现 | |
|
||
| L2c 任务上下文 | architecture-v2.6 v2.6.5 | ✅ 已实现 | |
|
||
| L2d 前序产出(depends_on) | architecture-v2.6 v2.6.5 | ✅ 已实现 | |
|
||
| L2e Guardrail 规则(仅执行者) | architecture-v2.6 v2.6.5 | ✅ 已实现 | role == "executor" |
|
||
| L2f 审查协议 | architecture-v2.6 v2.6.5 | ✅ 已实现 | executor/reviewer/pangtong |
|
||
| L2g 经验注入 | architecture-v2.6 v2.6.7 | ✅ 已实现 | 最多 5 条 |
|
||
| L3 Skill 描述 | architecture-v2.6 v2.6.5 | ✅ 已实现 | 最多 10 条 |
|
||
| Token 估算 + 截断 | technical-design §5.5 | ✅ 已实现 | estimate_tokens(), max_tokens=4096 |
|
||
| build_for_task 便捷方法 | 无 | ✅ 已实现(超前) | |
|
||
|
||
**⚠️ 注意**: BootstrapBuilder 未被 Ticker/Spawner 实际调用。当前 Spawner 用自己的 SPAWN_PROMPT_TEMPLATE 构建 prompt,未走 BootstrapBuilder。这是一个设计意图与实现的偏差。
|
||
|
||
### daemon/sse.py (文件: src/daemon/sse.py, 312行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| SSEBroker 订阅/发布 | technical-design §9.3 | ✅ 已实现 | asyncio.Queue per subscriber |
|
||
| SSE 事件格式 | technical-design §9.3 | ✅ 已实现 | id + event + data |
|
||
| HookManager 可插拔事件处理 | technical-design §10 | ✅ 已实现 | webhook / script / callback 三种 |
|
||
| Hook 超时控制 | technical-design §10 | ✅ 已实现 | 默认 10s |
|
||
| 事件历史 | technical-design §9.3 | ✅ 已实现 | 最大 100 条 |
|
||
|
||
### daemon/inbox.py (文件: src/daemon/inbox.py, 305行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| InboxWatcher JSONL 监听 | architecture-v2.6 §4.2 D2-1 | ✅ 已实现 | 轮询 + truncate |
|
||
| 原子追加写入 | architecture-v2.6 §4.2 | ✅ 已实现 | write_event() append 模式 |
|
||
| 事件类型:agent_output/agent_status/agent_claim/agent_heartbeat | architecture-v2.6 §4.2 | ✅ 已实现 | |
|
||
| default_inbox_callback 翻译黑板操作 | architecture-v2.6 §4.2 | ✅ 已实现 | 4 种事件类型处理 |
|
||
|
||
**⚠️ 注意**: InboxWatcher 未被 Ticker 实际启动。Ticker 目前直接走 API(Agent 通过 HTTP 回写黑板),Inbox JSONL 作为备用通道未集成。
|
||
|
||
### daemon/review.py (文件: src/daemon/review.py, 334行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| ReviewPipeline 四步验证 | architecture-v2.6 §9.2 | ✅ 已实现 | existence → format → quality → gate |
|
||
| Guardrail 四级门控 | architecture-v2.6 §9.2 | ✅ 已实现 | auto/optional/mandatory/dual |
|
||
| RebuttalManager 反驳权 | architecture-v2.6 §9.5 | ✅ 已实现 | 最多 2 轮, 升级目标: simayi → pangtong |
|
||
| 自定义质量检查 | architecture-v2.6 §9.3 | ✅ 已实现 | custom_checks dict |
|
||
|
||
### daemon/experience.py (文件: src/daemon/experience.py, 291行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| ExperienceDistiller 经验蒸馏 | architecture-v2.6 v2.6.7 | ✅ 已实现 | 模式识别 + 分类 |
|
||
| ExperienceStore JSONL 持久化 | architecture-v2.6 v2.6.7 | ✅ 已实现 | |
|
||
| 模式关键词映射 | architecture-v2.6 v2.6.7 | ✅ 已实现 | pitfall/best_practice/environment |
|
||
| recommend() 推荐经验 | architecture-v2.6 v2.6.7 | ✅ 已实现 | |
|
||
|
||
**⚠️ 注意**: ExperienceDistiller 未被 Ticker 集成调用。经验蒸馏是独立模块,未接入自动流程。
|
||
|
||
### daemon/health.py (文件: src/daemon/health.py, 158行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| HealthChecker 僵尸检测 | architecture-v2.6 §14 / v2.6.9.1 | ✅ 已实现 | 连续 N tick 无变更 → 告警 |
|
||
| 告警 observation 写入 | architecture-v2.6 §14 | ✅ 已实现 | severity=warning |
|
||
| 恢复自动解除 | architecture-v2.6 §14 | ✅ 已实现 | |
|
||
|
||
**⚠️ 注意**: HealthChecker 未被 Ticker 实例化和调用。设计文档 v2.6.9.1 明确要求"Daemon 逻辑健康自检纳入§14"。
|
||
|
||
### daemon/skill_system.py (文件: src/daemon/skill_system.py, 247行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| SkillRegistry 技能注册 | architecture-v2.6 v2.6.5 / technical-design §8 | ✅ 已实现 | JSON 文件加载 |
|
||
| Skill 三层自由度(high/medium/low) | architecture-v2.6 v2.6.5 | ✅ 已实现 | SkillFreedom 枚举 |
|
||
| SkillExecutor 构建 prompt | architecture-v2.6 v2.6.5 | ✅ 已实现 | 按自由度构建 |
|
||
| Skill match 关键词匹配 | technical-design §8 | ✅ 已实现 | 名称/描述/标签权重 |
|
||
| Skill 生命周期(draft/active/deprecated) | architecture-v2.6 v2.6.7 | ⚠️ 部分实现 | models.py 中有 status 字段,但 SkillExecutor 未检查生命周期 |
|
||
|
||
### cli/blackboard.py (文件: src/cli/blackboard.py, 332行)
|
||
|
||
| 功能点 | 设计文档位置 | 代码实现状态 | 备注 |
|
||
|--------|------------|------------|------|
|
||
| read 命令 | architecture-v2.6 §5.2 | ✅ 已实现 | |
|
||
| create 命令 | architecture-v2.6 §5.2 | ✅ 已实现 | |
|
||
| update-status 命令 | architecture-v2.6 §5.2 | ✅ 已实现 | |
|
||
| output 命令 | architecture-v2.6 §5.2 | ✅ 已实现 | |
|
||
| comment 命令 | architecture-v2.6 §5.2 | ✅ 已实现 | |
|
||
| review 命令 | architecture-v2.6 §9.6 | ✅ 已实现 | |
|
||
| experience 命令 | architecture-v2.6 v2.6.7 | ✅ 已实现 | |
|
||
|
||
---
|
||
|
||
## 数据库 Schema 审查
|
||
|
||
### 表 vs 设计文档对照
|
||
|
||
| 表名 | 设计文档 | 代码实现 | 状态 |
|
||
|------|---------|---------|------|
|
||
| tasks | architecture-v2.6 §3.2 + v2.7 + v2.8 | db.py L321-350 | ✅ 完全匹配(含 v2.8 全部扩展) |
|
||
| comments | architecture-v2.6 §3.5 | db.py L355-366 | ✅ 完全匹配 |
|
||
| outputs | architecture-v2.6 §3.2 + v2.8 M3 | db.py L368-380 | ✅ 含 v2.8 扩展字段 |
|
||
| decisions | architecture-v2.6 §3.2 | db.py L382-392 | ✅ |
|
||
| observations | architecture-v2.6 §3.2 | db.py L394-406 | ✅ |
|
||
| events | architecture-v2.6 §3.2 | db.py L408-416 | ✅ |
|
||
| agents | technical-design §4.2 | db.py L418-424 | ✅ |
|
||
| task_attempts | architecture-v2.6 §4.3 | db.py L426-439 | ✅ |
|
||
| reviews | architecture-v2.6 §9.6 | db.py L441-457 | ✅ |
|
||
| experiences | architecture-v2.6 v2.6.7 | db.py L459-476 | ✅ |
|
||
| experience_tags | architecture-v2.6 v2.6.7 | db.py L478-483 | ✅ |
|
||
| routing_decisions | agent-routing-redesign §5 | db.py L485-503 | ✅ |
|
||
| checkpoints | v2.8-state-enhancement §四.4 | db.py L505-520 | ✅ |
|
||
|
||
### 迁移链完整性
|
||
|
||
| 迁移 | 目的 | 状态 |
|
||
|------|------|------|
|
||
| _migrate_v261 | current_agent 等路由字段 | ✅ |
|
||
| _migrate_v27 | stages_json + stage | ✅ |
|
||
| _migrate_v28 | CHECK 更新 + 归档 + checkpoints + outputs 扩展 | ✅ |
|
||
|
||
---
|
||
|
||
## API 端点审查
|
||
|
||
### 黑板 CRUD (blackboard_routes.py)
|
||
|
||
| API | 设计文档 | 代码行 | 状态 |
|
||
|-----|---------|-------|------|
|
||
| GET /tasks | architecture-v2.6 §5.2 | L40-45 | ✅ |
|
||
| GET /tasks/{id} | architecture-v2.6 §5.2 + expand=all | L48-68 | ✅ |
|
||
| POST /tasks | architecture-v2.6 §5.2 | L71-94 | ✅ 含 v2.8 title 自动生成 |
|
||
| GET /tasks/{id}/progress | v2.7-subtask-model §2.6 | L97-102 | ✅ |
|
||
| POST /tasks/{id}/claim | architecture-v2.6 §3.6 | L105-109 | ✅ |
|
||
| POST /tasks/{id}/status | agent-api-contract §2 | L112-147 | ✅ 含详细错误信息 |
|
||
| GET/POST /tasks/{id}/comments | architecture-v2.6 §3.5 | L151-166 | ✅ |
|
||
| GET/POST /tasks/{id}/outputs | agent-api-contract §1 | L170-225 | ✅ 含 content 直传 + content_path |
|
||
| GET/POST /tasks/{id}/decisions | architecture-v2.6 §3.2 | L229-239 | ✅ |
|
||
| POST /tasks/{id}/observations | architecture-v2.6 §3.2 | L243-247 | ✅ |
|
||
| GET/POST /tasks/{id}/reviews | architecture-v2.6 §9.6 | L251-266 | ✅ |
|
||
| GET /tasks/{id}/events | architecture-v2.6 §4.2 | L270-273 | ✅ |
|
||
| GET /tasks/{id}/experiences | architecture-v2.6 v2.6.7 | L276-278 | ✅ |
|
||
| GET /events | architecture-v2.6 §4.2 | L282-284 | ✅ |
|
||
| GET /summary | architecture-v2.6 §3.4 | L288-290 | ✅ |
|
||
| POST /tasks/{id}/archive | v2.8-state-enhancement §二.1 | L295-305 | ✅ |
|
||
| POST /tasks/archive-done | v2.8-state-enhancement §二.1 | L308-311 | ✅ |
|
||
|
||
### Checkpoint API (checkpoint_routes.py)
|
||
|
||
| API | 设计文档 | 代码行 | 状态 |
|
||
|-----|---------|-------|------|
|
||
| GET /checkpoints | v2.8-state-enhancement §四.5 | L48-52 | ✅ |
|
||
| POST /checkpoints | v2.8-state-enhancement §四.5 | L55-73 | ✅ |
|
||
| POST /checkpoints/{id}/approve | v2.8-state-enhancement §四.5 | L76-83 | ✅ |
|
||
| POST /checkpoints/{id}/reject | v2.8-state-enhancement §四.5 | L86-93 | ✅ |
|
||
|
||
### Daemon API (daemon_routes.py)
|
||
|
||
| API | 设计文档 | 代码行 | 状态 |
|
||
|-----|---------|-------|------|
|
||
| GET /daemon/status | technical-design §9.2 | L10-21 | ✅ |
|
||
| POST /daemon/tick | technical-design §9.2 | L24-29 | ✅ |
|
||
|
||
### Project API (project_routes.py)
|
||
|
||
| API | 设计文档 | 代码行 | 状态 |
|
||
|-----|---------|-------|------|
|
||
| GET /projects | technical-design §9.4 | L16-20 | ✅ |
|
||
| POST /projects | technical-design §9.4 | L23-31 | ✅ |
|
||
| GET /projects/{id} | technical-design §9.4 | L34-39 | ✅ |
|
||
| POST /projects/{id}/archive | technical-design §9.4 | L42-46 | ✅ |
|
||
|
||
### SSE API (sse_routes.py)
|
||
|
||
| API | 设计文档 | 代码行 | 状态 |
|
||
|-----|---------|-------|------|
|
||
| GET /api/events | technical-design §9.3 | L26-47 | ✅ 含 heartbeat |
|
||
|
||
### Mail API (mail_routes.py)
|
||
|
||
| API | 设计文档 | 代码行 | 状态 |
|
||
|-----|---------|-------|------|
|
||
| GET /api/mail | v2.7-subtask-model §2.6 | L56-87 | ✅ |
|
||
| GET /api/mail/agents/list | 无 | ✅(超前) | 筛选用 |
|
||
| GET /api/mail/summary | 无 | ✅(超前) | |
|
||
| GET /api/mail/{id} | 无 | ✅(超前) | 含 comments |
|
||
| POST /api/mail | v2.7-subtask-model §2.6 | L110-135 | ✅ |
|
||
| PATCH /api/mail/{id} | 无 | ✅(超前) | 标记已读/已执行 |
|
||
|
||
---
|
||
|
||
## 超前实现清单
|
||
|
||
> 代码已实现但设计文档中未记录(或仅隐含)的功能
|
||
|
||
| # | 功能 | 文件 | 说明 |
|
||
|---|------|------|------|
|
||
| 1 | Mail Tab 完整后端 API | mail_routes.py | v2.7-subtask-model 仅提到"后续独立实现",代码已完整实现 |
|
||
| 2 | Legacy 兼容路由模式 | dispatcher.py | _legacy_decide/_legacy_dispatch 完整保留,设计文档未提及保留策略 |
|
||
| 3 | dispatch_pending() 批量决策 | dispatcher.py | 无设计文档,但作为调试/诊断工具有价值 |
|
||
| 4 | dry_run 模式 | spawner.py | 测试用,设计文档未提及 |
|
||
| 5 | _check_recent_routing 防重复 | ticker.py | 设计未明确记录,但属于必要工程措施 |
|
||
| 6 | Mail 元数据存在 must_haves 字段 | mail_routes.py | 复用 must_haves 字段存 JSON,设计未明确记录 |
|
||
| 7 | outputs content 直传自动写文件 | blackboard_routes.py | 设计只提 content_path,代码额外支持 content → 自动存文件 |
|
||
| 8 | Project delete(从注册表移除) | registry.py | 设计只提 archive,代码额外实现了 delete |
|
||
| 9 | /api/projects 兼容旧端点 | main.py | 旧前端兼容,设计未记录 |
|
||
|
||
## 缺口清单
|
||
|
||
> 设计文档已设计但代码未实现的功能
|
||
|
||
| # | 功能 | 设计文档位置 | 严重度 | 说明 |
|
||
|---|------|------------|--------|------|
|
||
| 1 | **HealthChecker 未集成到 Ticker** | architecture-v2.6 §14 / v2.6.9.1 | 🔴 高 | health.py 完整实现但 Ticker 未调用,僵尸检测不生效 |
|
||
| 2 | **BootstrapBuilder 未集成到 Spawner** | architecture-v2.6 v2.6.5 / technical-design §5.5 | 🔴 高 | bootstrap.py 完整实现但 Spawner 用自己的 SPAWN_PROMPT_TEMPLATE,L0-L3 四层上下文未生效 |
|
||
| 3 | **InboxWatcher 未集成到 Ticker** | architecture-v2.6 §4.2 D2-1 | 🟡 中 | inbox.py 完整实现但 Ticker 未启动 InboxWatcher,事件驱动降级为纯轮询 |
|
||
| 4 | **ExperienceDistiller 未集成** | architecture-v2.6 v2.6.7 | 🟡 中 | experience.py 完整实现但未接入 Ticker 自动蒸馏流程 |
|
||
| 5 | **Skill 生命周期管理** | architecture-v2.6 v2.6.7 | 🟢 低 | SkillExecutor 未检查 draft/active/deprecated 状态 |
|
||
| 6 | **Guardrail YAML 解析** | architecture-v2.6 §9.8 | 🟡 中 | 声明式 guardrails.yaml 配置未实现,review.py 中硬编码了门控逻辑 |
|
||
| 7 | **Review Protocol 模板文件** | architecture-v2.6 §9.4 | 🟡 中 | prompt_templates/reviewer.md + review_protocols/*.yaml 未在代码中加载 |
|
||
| 8 | **outputs download API** | v2.8-state-enhancement §五.1 | 🟢 低 | GET /outputs/{oid}/download 未实现 |
|
||
| 9 | **TERMINAL_STATUSES 应包含 cancelled** | v2.8-state-enhancement §1.2 | 🟢 低 | cancelled 转换表为空集(等价),但未加入 TERMINAL_STATUSES |
|
||
| 10 | **对抗辩论模式** | architecture-v2.6 §9.10 | 🟢 低 | 设计标注为"P3 仅用户明确要求时启用",未实现符合预期 |
|
||
| 11 | **Subagent spawn** | agent-integration-v2.6 | 🟡 中 | spawn_subagent() 为 placeholder(TODO F17),当前只走 Full Agent |
|
||
| 12 | **Handoff Comment Schema 校验** | architecture-v2.6 §3.7 | 🟡 中 | schemas/handoff.schema.json 校验未在 CLI 中集成 |
|
||
|
||
---
|
||
|
||
## 代码质量观察
|
||
|
||
### 正面
|
||
|
||
1. **Schema 迁移链设计优秀**:v2.6.1 → v2.7 → v2.8 渐进式迁移,幂等安全(_safe_add_column)
|
||
2. **状态机严格实现**:VALID_TRANSITIONS + CHECK 约束双重保障
|
||
3. **Agent 友好 API**:详细的错误响应含 hint + valid_values
|
||
4. **并发控制完整**:Semaphore + counter + BEGIN IMMEDIATE
|
||
5. **per-project SQLite 隔离**:registry.db + 多 blackboard.db,架构清晰
|
||
|
||
### 需关注
|
||
|
||
1. **Ticker 缺少 HealthChecker 集成**:僵尸项目无法自动告警
|
||
2. **BootstrapBuilder 和 Spawner 存在重复功能**:两个系统各自构建 Agent prompt,需统一
|
||
3. **operations.py 中有冗余 `return refreshed`**:ticker.py L343-344 出现两次 return
|
||
4. **checkpoint_routes.py 的 _bb() 实例化 ProjectRegistry 未传 root**:`registry.get_db_path(project_id)` 方法不存在(registry.py 只有 db_path 属性无 get_db_path 方法),运行时会报错
|
||
5. **经验沉淀系统完全独立**:db.py 中 experiences 表 + experience.py 中 Experience 类 + operations.py 中 Experience dataclass 三套 Experience 定义并存,可能造成混淆
|
||
|
||
---
|
||
|
||
*审查完毕。核心模块(黑板 CRUD + 状态机 + Daemon Ticker + Router/Dispatcher + Spawner)与设计文档高度一致,v2.7 SubTask 和 v2.8 状态增强均已完整实现。主要缺口集中在辅助系统集成(HealthChecker/BootstrapBuilder/InboxWatcher/ExperienceDistiller)。*
|