Method runTurn

src/bot/runner.ts:80–173

(convKey: string, userText: string, sink: TurnSink, signal: AbortSignal)

    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();
    const match = store.loadSession(idOrPrefix) ? idOrPrefix
      : store.listRecentSessions(100).find(s => s.id.startsWith(idOrPrefix))?.id;
    if (!match) return false;
    await this.map.set(convKey, match);
    return true;
  }

  async runTurn(convKey: string, userText: string, sink: TurnSink, signal: AbortSignal): Promise<string> {
    const store = getSessionStore();
    const model = this.modelFor(convKey);
    const config = model === this.deps.config.defaults.model
      ? this.deps.config
      : { ...this.deps.config, defaults: { ...this.deps.config.defaults, model } }; // per-chat model override
    // Resolve (or create) the durable session FIRST so the AgentLoop is born
    // with that session's cwd — not the directory the bot process happened to
    // start in. `/continue` binds a CLI session; tools must edit THAT project.
    let sessionId = await this.map.get(convKey);
    const existing = sessionId ? store.loadSession(sessionId) : null;
    const cwd = this.cwdFor(sessionId);

    const agent = new AgentLoop({
      router: this.deps.router,
      registry: this.deps.registry,
      permissions: this.deps.permissions,
      config,
      cwd,
    });

    let messages;
    if (existing) {
      messages = [...existing.messages, { role: 'user' as const, content: userText }];
    } else {
      sessionId = store.createSession(cwd, model);
      await this.map.set(convKey, sessionId);
      messages = await agent.buildInitialMessages(userText, 'normal', model);
    }
    const sid: string = sessionId!; // always set by the branch above
    store.recordTurn(sid, [{ role: 'user', content: userText }], { input: 0, output: 0, costUsd: 0 });

    // /auto on → approve permission prompts automatically (skip the buttons) for the affirmative
    // option only; a prompt with no clear "yes/allow" still falls back to asking, so we never
    // silently green-light something ambiguous.
    const auto = this.autoByKey.get(convKey) ?? false;
    const askUser = async (prompt: string, options: string[] = ['yes', 'no']): Promise<string> => {
      if (auto) { const yes = options.find(o => /^(y|yes|allow|approve|ok|always)\b/i.test(o.trim())); if (yes) return yes; }
      return getOperatorHub().requestApproval('bot', prompt, options, {
        lane: botLane(convKey),
        origin: convKey,
      });
    };