Method runSubagent

src/agent/loop.ts:276–364

* Run a sub-agent inline. Used by the `task` tool. * * Architecture: sub-agent gets a fresh AgentLoop with the same router/registry/perms * but a new session id and an isolated message history. Tools run in 'subagent' mode * (task and present_plan filtered). We drain the event stream and

(
    prompt: string,
    opts: {
      maxIterations: number;
      signal?: AbortSignal;
      sessionId: string;
      modelOverride?: string;
      /** Role name — drives model selection, system prompt, tool restriction. Default 'subagent'. */
      role?: string;
    },
  )

    this.cwd = path.resolve(cwd);
    this.effectiveCwd = undefined;
    if (this.snapshotService) {
      this.snapshotService = new SnapshotService(this.cwd, 'pending', {
        retentionTurns: (this.config as any).safety?.snapshotRetentionTurns ?? 50,
      });
    }
  }

  workingDirectory(): string {
    return this.effectiveCwd ?? this.cwd;
  }

  /** Update the snapshot service's session id when a real session starts. */
  private setSessionForSnapshot(sessionId: string): void {
    if (this.snapshotService) {
      // Recreate with the proper session id — cleaner than mutating private state.
      this.snapshotService = new SnapshotService(this.cwd, sessionId, {
        retentionTurns: (this.config as any).safety?.snapshotRetentionTurns ?? 50,
      });
    }
  }

  /** Public read accessor for slash commands to operate on snapshots. */
  getSnapshotService(): SnapshotService | undefined {
    return this.snapshotService;
  }

  private insightsFor(sessionId: string): SessionInsights {
    let s = this.insightsBySession.get(sessionId);
    if (!s) {
      s = new SessionInsights(sessionId);
      this.insightsBySession.set(sessionId, s);
    }
    return s;
  }

  /** Live snapshot for `/insights`. */
  getInsights(sessionId: string): InsightsSnapshot {
    return this.insightsFor(sessionId).snapshot();
  }

  resetInsights(sessionId: string): void {
    this.insightsBySession.get(sessionId)?.reset();
  }

  persistInsights(sessionId: string): void {
    const s = this.insightsBySession.get(sessionId);
    if (!s || s.isEmpty()) return;
    try { getSessionStore().saveInsights(sessionId, s.snapshot()); } catch { /* never stall the loop */ }
  }

  /**
   * Write a lean episode for THIS turn so the next similar task can recall it.
   * Must be awaited — headless `process.exit` otherwise kills the append.
   */
  private async maybeRecordEpisode(opts: {
    prompt: string;
    summary: string;
    filesChanged: string[];