Method run

packages/bot/src/thread.ts:319–479

(
    initialResume?: { resume: unknown },
    extra?: {
      context?: ContextEntry[];
      tools?: BotTool[];
      prompt?: string | AgentContentPart[];
      transcript?: boolean | { limit?: number };
    },
  )

  }

  private async run(
    initialResume?: { resume: unknown },
    extra?: {
      context?: ContextEntry[];
      tools?: BotTool[];
      prompt?: string | AgentContentPart[];
      transcript?: boolean | { limit?: number };
    },
  ): Promise<MessageRef | undefined> {
    const session = await this.deps.adapter.conversationStore.getOrCreate(
      this.deps.conversationKey,
      this.deps.replyTarget,
      this.deps.agentFactory,
    );
    // Inject an explicit user message when the input isn't in the adapter's
    // reconstructed history (e.g. a slash command's args, or inbound image/file
    // attachments built into multimodal content parts). A non-empty array is
    // truthy, so this guard also admits multimodal prompts.
    if (extra?.prompt) {
      session.agent.addMessage({
        id: globalThis.crypto.randomUUID(),
        role: "user",
        // AG-UI types `content` as `string`, but multimodal works at runtime by
        // setting it to an `AgentContentPart[]` — the runtime's LLM adapter
        // converts the parts to the provider's multimodal format. We cast to
        // satisfy the string-typed field (bot-slack parity — it does the same
        // when assigning multimodal `content` to its reconstructed messages).
        content: extra.prompt as unknown as string,
      });
    }
    const renderer = this.deps.adapter.createRunRenderer(this.deps.replyTarget);

    // Transcript auto-bridge (step 1 + 2): inject prior cross-platform history
    // as a context entry, then append the current user turn. This flag owns the
    // bridge — see `runAgent`'s `transcript` doc. No-ops with one warning when
    // identity/transcripts aren't configured.
    const transcripts = this.deps.transcripts;
    const userKey = this.deps.userKey;
    let transcriptContext: ContextEntry | undefined;
    if (extra?.transcript) {
      if (transcripts && userKey) {
        const limit =
          typeof extra.transcript === "object"
            ? (extra.transcript.limit ?? 20)
            : 20;
        // List BEFORE appending the current user turn so the current message
        // isn't counted as its own "prior history".
        const prior = await transcripts.list({ userKey, limit });
        if (prior.length > 0) {
          transcriptContext = {
            description: `Prior cross-platform conversation history with this user. Current channel: ${this.platform}.`,
            value: prior
              .map((e) => `[${e.platform}] ${e.role}: ${e.text}`)
              .join("\n"),
          };
        }
        if (this.deps.message) {
          await transcripts.append(this, this.deps.message, { userKey });