Method runOne

src/bot/gateway.ts:130–168

(t: Transport, chatId: string, key: string, text: string)

    // 2) Living-artifact card actions (Approve / Edit / Reject) — handled before permission asks.
    if (m.callbackData?.startsWith('art:')) {
      if (m.callbackId && t.ackCallback) await t.ackCallback(m.callbackId);
      await this.handleCardAction(t, m.chatId, key, m.callbackData);
      return;
    }

    // 3) A pending permission prompt swallows the next tap/reply (not a new turn).
    if (this.asks.has(key)) {
      const answer = m.callbackData ? this.stripAsk(m.callbackData) : m.text.trim();
      if (m.callbackId && t.ackCallback) await t.ackCallback(m.callbackId);
      if (answer) { this.resolveAsk(key, answer); return; }
    }
    if (m.callbackData) { if (m.callbackId && t.ackCallback) await t.ackCallback(m.callbackId); return; }

    let text = m.text.trim();
    if (!text) return;

    // 4) An "Edit" tap left this chat awaiting the change instruction → fold it into an update turn.
    const editId = this.pendingEdit.get(key);
    if (editId && !text.startsWith('/')) {
      this.pendingEdit.delete(key);
      text = `Update the "${editId}" artifact and keep it live: ${text}`;
    }

    // 5) Commands — dispatched through the declarative registry (drives the native `/` menu + /help).
    if (text.startsWith('/')) {
      const hit = findCommand(text);
      if (!hit) { await t.send(m.chatId, `Unknown command \`${text.split(/\s/)[0]}\`. Try /help.`); return; }
      await hit.cmd.run({
        args: hit.args, key, agent: this.opts.agent,
        gateway: this.controlsFor(t, m.chatId, key),
        reply: async (s, b) => { await t.send(m.chatId, s, b); },
      });
      return;
    }

    // 6) Run it as a turn (serialized per chat; queued if one is already running).
    await this.runAndDrain(t, m.chatId, key, text);
  }

  private async runOne(t: Transport, chatId: string, key: string, text: string): Promise<void> {
    const ac = new AbortController();
    this.busy.set(key, ac);