1. plugin/hooks/hooks.json       ← 入口：看系统注册了哪些 Hook
   ↓ 追踪 command 字段中的脚本路径
2. src/cli/hook-command.ts       ← 所有 Hook 的统一入口
   ↓ 看 getEventHandler(event) 的分发逻辑
3. src/cli/handlers/index.ts     ← 7 个 Handler 的注册表
   ↓ 选一个感兴趣的（推荐 observation.ts）
4. src/cli/handlers/observation.ts ← 追踪到 Worker API 调用
   ↓ 看 executeWithWorkerFallback 的目标 URL
5. src/services/worker-service.ts  ← Worker 的 Express API 和路由注册
   ↓ 找 SessionRoutes / SearchRoutes
6. src/services/sqlite/Database.ts ← 数据库层

┌─────────────────────────────────────────────────────────────┐
│  Layer 1: Claude Code (Host)                                 │
│  宿主层 — 提供 Hook 触发点和 MCP Client                      │
├─────────────────────────────────────────────────────────────┤
│  Layer 2: CLI Layer (Bun/Node)                               │
│  命令层 — Hook 编排、输入标准化、输出格式化                    │
├─────────────────────────────────────────────────────────────┤
│  Layer 3: Worker Daemon (Express)                            │
│  处理层 — AI 压缩、会话管理、搜索编排、SSE 广播              │
├─────────────────────────────────────────────────────────────┤
│  Layer 4: Storage Layer                                      │
│  存储层 — SQLite + ChromaDB + MCP Server                     │
└─────────────────────────────────────────────────────────────┘

// src/cli/hook-command.ts（简化）
export async function hookCommand(platform: string, event: string): Promise<number> {
  // 1. 静默 stderr（防止污染 JSON 输出）
  process.stderr.write = (() => true) as typeof process.stderr.write;
 
  // 2. 获取平台适配器（claude-code / cursor / gemini-cli）
  const adapter = getPlatformAdapter(platform);
 
  // 3. 获取事件处理器
  const handler = getEventHandler(event);
 
  try {
    // 4. 执行管道：读 stdin → 标准化输入 → 处理 → 格式化输出
    const rawInput = await readJsonFromStdin();
    const input = adapter.normalizeInput(rawInput);
    const result = await handler.execute(input);
    const output = adapter.formatOutput(result);
    console.log(JSON.stringify(output));
    return HOOK_EXIT_CODES.SUCCESS;
  } catch (error) {
    // 5. 错误分级：传输错误 → exit 0（不阻塞）
    //             代码错误 → exit 2（需要修复）
    if (isWorkerUnavailableError(error)) {
      process.exit(0); // 永不阻塞 Claude Code
    }
    process.exit(2);
  }
}

用户让 Claude 编辑一个文件
  → Claude 调用 Edit 工具
  → Claude Code 触发 PostToolUse Hook
  → Hook 通过 stdin 传入 { tool_name: "Edit", tool_input: {...}, tool_response: {...} }
  → CLI Layer 读取 stdin，标准化输入
  → observationHandler 发 POST /api/sessions/observations 到 Worker
  → Worker 将原始数据入队 pending_messages 表
  → Hook 返回 { continue: true, suppressOutput: true }
  → Claude Code 继续工作（整个过程 < 30ms）

Worker 的 SessionManager 检测到新的 pending message
  → 将 tool 输入/输出序列化为 prompt
  → 发送给 Claude Agent SDK 进行 AI 压缩
  → SDK 返回结构化的 Observation（type / title / narrative / facts）
  → 计算 content_hash = SHA256(session_id + title + narrative)[:16]
  → 检查 30 秒窗口内是否有相同 hash（去重）
  → INSERT INTO observations
  → ChromaSync 生成 Embedding 并同步到 ChromaDB
  → SSE 广播新 Observation 到 Viewer UI
  → 清除 pending_messages 中已处理的记录

用户开始新的 Claude Code 会话
  → SessionStart Hook 触发
  → contextHandler 发 GET /api/context/inject 到 Worker
  → Worker 查询最近 50 条 observations + 10 个 session summaries
  → 格式化为 Progressive Disclosure 索引
  → 通过 hookSpecificOutput.additionalContext 注入到会话

  → 用户开始工作，Claude 发现索引中某条记录可能相关
  → Claude 调用 MCP search 工具
  → MCP Server 转发到 Worker HTTP API
  → Worker 执行 FTS5 查询并返回结果
  → Claude 使用 get_observations 获取完整内容
  → Claude 基于历史上下文做出更准确的判断

// src/cli/hook-command.ts
export function isWorkerUnavailableError(error: unknown): boolean {
  // 传输层错误：连不上 Worker
  const transportPatterns = [
    'econnrefused', 'econnreset', 'epipe',
    'etimedout', 'fetch failed', 'socket hang up'
  ];
  if (transportPatterns.some(p => lower.includes(p))) return true;
 
  // 超时
  if (lower.includes('timed out') || lower.includes('timeout')) return true;
 
  // 5xx 服务端错误
  if (/failed:\s*5\d{2}/.test(message)) return true;
 
  // 4xx 客户端错误：NOT transport issue，是代码 bug
  if (/failed:\s*4\d{2}/.test(message)) return false;
 
  // TypeError/ReferenceError：代码 bug
  if (error instanceof TypeError || error instanceof ReferenceError) return false;
 
  return false;
}

Hook 层：Worker 挂了 → exit 0（不阻塞）
Worker 层：AI 调用失败 → 重试 3 次后放弃（不影响其他会话）
存储层：数据库锁 → 跳过这次写入，下次补上