Method execute

src/tools/builtin/orchestrate.ts:40–106

(args: z.infer<typeof Args>, ctx: ToolContext)

  argsSchema = Args;

  async execute(args: z.infer<typeof Args>, ctx: ToolContext): Promise<ToolResult> {
    if (!getSubAgentRunner()) {
      return {
        content: 'Orchestration needs sub-agents enabled. Turn them on with `/subagents parallel` (or `sequential`), then retry.',
        isError: true,
      };
    }

    const { Orchestrator } = await import('../../orchestration/engine.js');
    const designTokens = await extractDesignTokens(ctx.cwd);

    const events: string[] = [];
    const engine = new Orchestrator({
      cwd: ctx.cwd,
      maxConcurrency: args.max_concurrency ?? 3,
      maxAttempts: 2,
      designTokens,
      qaHooks: buildQaHooks(ctx.cwd),
      onEvent: (ev) => {
        const line = formatEvent(ev);
        if (line) { events.push(line); ctx.emit({ type: 'progress', message: line }); }
      },
    });

    // 1. Decompose.
    ctx.emit({ type: 'progress', message: `Orchestrator: decomposing goal…` });
    let graph;
    try {
      graph = await engine.decompose(args.goal, ctx.signal);
    } catch (e: any) {
      return { content: `Decomposition failed: ${e.message}`, isError: true };
    }

    const planLines = [`# Task DAG (${graph.nodes.size} nodes)`];
    for (const n of graph.nodes.values()) {
      const deps = n.dependsOn.length ? ` ← [${n.dependsOn.join(', ')}]` : '';
      planLines.push(`  ${n.id} (${n.kind})${deps}: ${n.title}  → ${n.targetFiles.join(', ')}`);
    }

    if (args.dry_run) {
      return { content: planLines.join('\n') + '\n\n(dry run — not executed)' };
    }

    // 2. Execute.
    const report = await engine.execute(graph, ctx.signal);

    // 3. Report.
    const out = [...planLines, ''];
    out.push(`## Execution report`);
    out.push(`  ✓ committed: ${report.committed.length}  [${report.committed.join(', ')}]`);
    if (report.failed.length) out.push(`  ✗ failed: ${report.failed.length}  [${report.failed.join(', ')}]`);
    if (report.blocked.length) out.push(`  ⊘ blocked: ${report.blocked.length}  [${report.blocked.join(', ')}]`);
    out.push(`  ⧉ tool calls: ${report.totalToolCalls}`);
    out.push(`  ⤓ tokens saved vs naive context: ~${report.tokensSavedEstimate.toLocaleString()}`);
    out.push(`  ⏱ duration: ${(report.durationMs / 1000).toFixed(1)}s`);
    if (report.conflicts.length) {
      out.push(`  ⚠ conflicts:`);
      for (const c of report.conflicts) out.push(`     ${c.kind} on ${c.file} (${c.taskA} vs ${c.taskB}) → ${c.resolution}`);