第七章：Agent 编排

// 通过 ctx.agents 创建 Subagent
const subagent = ctx.agents.create({
  sessionId: generateSessionId(),
  meta: {
    origin: 'subagent',
    delegationDepth: parentAgent.options.delegationDepth + 1
  }
})

// 向 Subagent 发送任务
subagent.inbox.insert({
  role: 'user',
  content: '请帮我分析这段代码'
})

// 等待结果
const result = await subagent.waitForCompletion()

// tool-subagent 将 Subagent 能力暴露为模型工具
ctx.tools.register({
  name: 'subagent',
  description: 'Delegate a task to a subagent',
  parameters: {
    type: 'object',
    properties: {
      task: { type: 'string', description: 'The task to delegate' },
      model: { type: 'string', description: 'Model to use' }
    },
    required: ['task']
  },
  async execute(input, context) {
    const subagent = ctx.agents.create({
      sessionId: generateSessionId(),
      meta: { origin: 'subagent' }
    })
    
    subagent.inbox.insert({
      role: 'user',
      content: input.task
    })
    
    const result = await subagent.waitForCompletion()
    return result
  }
})

// 来自 packages/workflow/workflow-worker-thread/src/host.ts
class WorkerRun {
  /** 启动 Worker */
  async start(): Promise<void> {
    this.worker = new Worker(this.workerPath, {
      workerData: this.config
    })
    
    this.worker.on('message', (message) => {
      this.handleMessage(message)
    })
    
    this.worker.on('error', (error) => {
      this.handleError(error)
    })
  }
  
  /** 向 Worker 发送消息 */
  post(message: WorkerMessage): void {
    this.worker.postMessage(message)
  }
  
  /** 处理 Worker 消息 */
  private handleMessage(message: WorkerMessage): void {
    // 处理结果、状态更新等
  }
}

// Worker 通信消息类型
type WorkerMessage =
  | { type: 'task'; task: string; config: AgentConfig }
  | { type: 'result'; result: TaskResult }
  | { type: 'status'; status: AgentStatus }
  | { type: 'error'; error: Error }
  | { type: 'cancel' }

// 来自 packages/workflow（概念性）
interface Workflow {
  /** Workflow 名称 */
  name: string
  /** 步骤定义 */
  steps: WorkflowStep[]
  /** 配置 */
  config: WorkflowConfig
}

interface WorkflowStep {
  /** 步骤名称 */
  name: string
  /** 步骤类型 */
  type: 'agent' | 'tool' | 'condition' | 'parallel'
  /** 配置 */
  config: Record<string, unknown>
  /** 依赖的步骤 */
  dependsOn?: string[]
}

// 执行一个 Workflow
const workflow = ctx.workflow.get('code-review')
const result = await workflow.execute({
  files: ['src/index.ts', 'src/utils.ts']
})

// Workflow 执行流程：
// 1. 分析代码（使用 Subagent）
// 2. 生成审查意见（使用 Subagent）
// 3. 应用修复（使用工具）
// 4. 验证结果（使用测试）

# presets/code-reviewer/cordis.yml
- id: code-reviewer
  name: Code Reviewer
  plugins:
    - '@deepseek-ai/dsh-tools'
    - '@deepseek-ai/dsh-fs'
    - '@deepseek-ai/dsh-shell'
  config:
    systemPrompt: |
      你是一个代码审查专家。你的任务是：
      1. 分析代码质量
      2. 检查潜在问题
      3. 提供改进建议
    tools:
      - file_read
      - file_write
      - bash

// 加载 Preset
const preset = ctx.preset.get('code-reviewer')

// 创建使用 Preset 的 Agent
const agent = ctx.agents.create({
  sessionId: generateSessionId(),
  preset: 'code-reviewer'
})

// 创建团队
const team = ctx.agentTeams.create({
  name: 'development-team',
  members: ['architect', 'developer', 'reviewer']
})

// 分配任务
team.tasks.assign({
  title: '实现用户认证',
  assignee: 'developer',
  priority: 'high'
})

// 成员间通信
team.mailbox.send({
  from: 'architect',
  to: 'developer',
  content: '请使用 JWT 方案'
})

// 串行执行
const result1 = await agent1.execute(task1)
const result2 = await agent2.execute(result1)
const result3 = await agent3.execute(result2)

// 并行执行
const [result1, result2, result3] = await Promise.all([
  agent1.execute(task1),
  agent2.execute(task2),
  agent3.execute(task3)
])

// 条件执行
if (condition) {
  await agent1.execute(task)
} else {
  await agent2.execute(task)
}

// 循环执行
while (!condition) {
  await agent.execute(task)
}

// 定时任务
ctx.schedule.add({
  name: 'daily-report',
  cron: '0 9 * * *',  // 每天早上 9 点
  async execute() {
    await generateDailyReport()
  }
})

// 一次性任务
ctx.schedule.addOnce({
  name: 'remind-deploy',
  delay: 3600000,  // 1 小时后
  async execute() {
    await sendNotification('记得部署')
  }
})