Multi-Agent：子进程隔离与多渠道路由

// src/context-engine/index.ts
export interface ContextEngine {
  // SubAgent 生命周期
  prepareSubagentSpawn(task: SubagentTask): SpawnConfig
  onSubagentEnded(result: SubagentResult): void
}

// 主 Agent 中派生子 Agent
const subagentResult = await spawnSubagent({
  task: '审查 src/auth.py 的安全问题，返回发现的漏洞列表',
  tools: ['Read', 'Grep', 'Bash'],  // 子 Agent 可用的工具子集
  budget: { maxTokens: 32000 },       // 独立的 token 预算
  systemPrompt: '你是安全审计专家...'  // 可以有专用指令
})

// subagentResult 只包含最终输出，不包含中间过程
// 主 Agent 的上下文不会被子 Agent 的工具调用记录污染

// Git Worktree：每个子 Agent 在独立的工作目录中操作
async function spawnWithWorktree(task: SubagentTask): Promise<SubagentResult> {
  // 创建临时 worktree
  const worktreePath = await git.worktree.add(`/tmp/agent-${uuid()}`, 'HEAD')

  const result = await spawnSubagent({
    ...task,
    workingDirectory: worktreePath  // 子 Agent 在 worktree 中工作
  })

  if (result.hasChanges) {
    // 子 Agent 有代码修改：返回 worktree 路径和分支
    return { ...result, worktreePath, branch: result.branch }
  } else {
    // 无修改：自动清理 worktree
    await git.worktree.remove(worktreePath)
    return result
  }
}

// src/channels/index.ts
export interface Channel {
  name: string
  connect(): Promise<void>
  onMessage(handler: MessageHandler): void
  sendMessage(userId: string, content: string): Promise<void>
}

// src/gateway/router.ts
export class SessionRouter {
  private sessions: Map<string, AgentSession> = new Map()

  async route(channelMessage: ChannelMessage): Promise<string> {
    // 用 channel + userId 唯一标识一个 session
    const sessionKey = `${channelMessage.channel}:${channelMessage.userId}`

    let session = this.sessions.get(sessionKey)
    if (!session) {
      session = await this.createSession(sessionKey)
      this.sessions.set(sessionKey, session)
    }

    // 将消息路由到对应 session 的 Agent
    return session.agent.processMessage(channelMessage.text)
  }
}

session:
  resetPolicy: "daily"      // 每天 4 AM 重置上下文
  // 或
  resetPolicy: "idle"       // 5 分钟无活动后重置
  // 或
  resetPolicy: "manual"     // 只有用户手动 /reset 时重置

  isolationScope: "channel" // 按渠道隔离
  // 或
  isolationScope: "user"    // 按用户隔离（跨渠道共享）

// 配置跨 Agent 记忆访问
memorySearch:
  qmd:
    extraCollections:
      - agentId: "security-bot"
        scope: "readonly"
      - agentId: "docs-bot"
        scope: "readonly"

// 任务可并行拆分时
const tasks = [
  { task: '分析 auth 模块', agent: 'security-reviewer' },
  { task: '分析 api 模块', agent: 'security-reviewer' },
  { task: '检查测试覆盖', agent: 'test-analyst' }
]

// 并行执行所有子任务
const results = await Promise.all(
  tasks.map(t => spawnSubagent(t))
)

// 合并结果
const report = await synthesize(results)

// 任务有先后依赖时
const analysis = await spawnSubagent({ task: '分析代码结构' })
const plan = await spawnSubagent({ task: `基于以下分析制定重构计划：${analysis}` })
const implementation = await spawnSubagent({ task: `执行以下重构计划：${plan}` })

// 需要减少幻觉时：一个生成，一个验证
const proposal = await spawnSubagent({
  task: '给出修复方案',
  systemPrompt: '你是修复专家...'
})
const review = await spawnSubagent({
  task: `审查以下修复方案是否正确：${proposal}`,
  systemPrompt: '你是严格的代码审查者，找出方案中的问题...'
})