Class QodexAgentRunner

src/bot/runner.ts:29–174

  permissions: PermissionEngine;
  cwd: string;
}

export class QodexAgentRunner implements AgentRunner {
  private map = new SessionMap();
  private modelByKey = new Map<string, string>();   // per-conversation model override (/model)
  private autoByKey = new Map<string, boolean>();    // per-conversation auto-approve (/auto)
  constructor(private deps: RunnerDeps) {}

  async reset(convKey: string): Promise<void> {
    await this.map.clear(convKey);
  }

  private modelFor(convKey: string): string {
    return this.modelByKey.get(convKey) ?? this.deps.config.defaults.model;
  }

  /**
   * Working root for this conversation. After `/continue` or `/resume` this is
   * the session's cwd (the CLI project), not wherever `qodex bot` was launched.
   */
  private cwdFor(sessionId: string | undefined): string {
    const sessionCwd = sessionId ? getSessionStore().loadSession(sessionId)?.meta.cwd : undefined;
    return pickWorkingCwd({ sessionCwd, hostCwd: this.deps.cwd });
  }

  async status(convKey: string): Promise<RunnerStatus> {
    const sessionId = (await this.map.get(convKey)) ?? undefined;
    return { model: this.modelFor(convKey), cwd: this.cwdFor(sessionId), sessionId, auto: this.autoByKey.get(convKey) ?? false };
  }

  async setModel(convKey: string, model: string): Promise<string> {
    this.modelByKey.set(convKey, model);
    return model;
  }

  async setAuto(convKey: string, on: boolean): Promise<void> {
    this.autoByKey.set(convKey, on);
  }

  async listSessions(convKey?: string, limit = 8): Promise<{ id: string; title: string; when: string }[]> {
    const sid = convKey ? await this.map.get(convKey) : undefined;
    return getSessionStore().listRecentSessions(limit, this.cwdFor(sid)).map(s => ({
      id: s.id,
      title: s.title?.trim() || `${s.turn_count} turn${s.turn_count === 1 ? '' : 's'}`,
      when: relTime(s.updated_at),
    }));
  }

  async listEpisodes(convKey?: string, limit = 8): Promise<{ when: string; prompt: string; summary: string }[]> {
    const { readEpisodes } = await import('../context/episodic-memory.js');
    const sid = convKey ? await this.map.get(convKey) : undefined;
    const eps = await readEpisodes(this.cwdFor(sid));
    return eps.slice(-limit).reverse().map(e => ({ when: relTime(e.ts), prompt: e.prompt, summary: e.summary }));
  }

  /** Rebind a conversation to a past session by full id OR short prefix (as shown by /sessions). */
  async resume(convKey: string, idOrPrefix: string): Promise<boolean> {
    const store = getSessionStore();