Class Orchestrator

src/orchestration/engine.ts:79–237

{"tasks":[{"id":"t1","kind":"schema","title":"...","instruction":"...","targetFiles":["..."],"contextFiles":[],"dependsOn":[],"visualReview":false}]}`;

export class Orchestrator implements OrchestrationEngine {
  private graphCache?: ImportGraph;

  constructor(private opts: EngineOptions) {}

  /** Build the file-level import graph for the whole project once. */
  private async projectGraph(): Promise<ImportGraph> {
    if (this.graphCache) return this.graphCache;
    const files = await walkProjectSource(this.opts.cwd, 3000);
    this.graphCache = await buildImportGraph(
      this.opts.cwd,
      files.map(f => ({ rel: f.rel, content: f.content })),
    );
    return this.graphCache;
  }

  /** ORCHESTRATOR: produce the task DAG. */
  async decompose(goal: string, signal?: AbortSignal): Promise<TaskGraph> {
    const raw = this.opts.planner
      ? await this.opts.planner(goal, signal)
      : await this.planViaModel(goal, signal);

    const nodes = new Map<TaskId, TaskNode>();
    for (const t of raw.tasks) {
      nodes.set(t.id, {
        id: t.id,
        kind: t.kind,
        title: t.title,
        instruction: t.instruction,
        targetFiles: t.targetFiles ?? [],
        contextFiles: t.contextFiles ?? [],
        contextSymbols: t.contextSymbols,
        dependsOn: t.dependsOn ?? [],
        role: defaultRoleForKind(t.kind),
        visualReview: t.visualReview ?? false,
        status: 'pending',
        attempts: 0,
      });
    }

    const graph: TaskGraph = { nodes, goal, acyclic: false };
    const order = topoSort(graph);
    if (!order) {
      throw new Error('Planner produced a cyclic task graph; cannot schedule. Re-plan with acyclic dependencies.');
    }
    graph.acyclic = true;
    logger.info('Decomposed goal into DAG', { tasks: nodes.size, order });
    return graph;
  }

  /** Ask the planning model for the DAG as JSON. */
  private async planViaModel(goal: string, signal?: AbortSignal): Promise<RawPlan> {
    const runner = getSubAgentRunner();
    if (!runner) throw new Error('No sub-agent runner registered; orchestration requires the agent runtime.');

    const prompt = `${PLANNER_SYSTEM}\n\n# Goal\n${goal}\n\nReturn the JSON plan now.`;
    const res = await runner(prompt, {
      maxIterations: 1,