Class TeamsConversationStore

packages/bot-teams/src/conversation-store.ts:53–109

 * implement {@link ConversationStore} against a real datastore and pass it in.
 */
export class TeamsConversationStore implements ConversationStore {
  private readonly history = new Map<string, StoredMessage[]>();

  /**
   * Append a user message to the conversation transcript. Accepts plain text or
   * multimodal content parts (uploaded files); empty content is ignored.
   */
  recordUser(
    conversationKey: string,
    content: string | AgentContentPart[],
  ): void {
    if (typeof content === "string" ? !content : content.length === 0) return;
    this.append(conversationKey, { id: randomUUID(), role: "user", content });
  }

  /** Append an assistant message to the conversation transcript. */
  recordAssistant(conversationKey: string, content: string): void {
    if (!content) return;
    this.append(conversationKey, {
      id: randomUUID(),
      role: "assistant",
      content,
    });
  }

  /** The accumulated transcript as bot-ui `ThreadMessage`s (backs `thread.getMessages()`). */
  getTranscript(conversationKey: string): ThreadMessage[] {
    const transcript = this.history.get(conversationKey) ?? [];
    return transcript.map((m) => ({
      text: contentToText(m.content),
      isBot: m.role === "assistant",
    }));
  }

  private append(conversationKey: string, message: StoredMessage): void {
    const existing = this.history.get(conversationKey);
    if (existing) existing.push(message);
    else this.history.set(conversationKey, [message]);
  }

  async getOrCreate(
    conversationKey: string,
    _replyTarget: ReplyTarget,
    makeAgent: (threadId: string) => AbstractAgent,
  ): Promise<AgentSession> {
    // Fresh AG-UI thread per turn. Our `history` map is the durable record, so
    // the server-side thread only needs to live for this turn (mirrors the
    // Slack adapter's rationale for not reusing a stable thread id).
    const threadId = `teams-${conversationKey}-${randomUUID()}`;
    const agent = makeAgent(threadId);
    const transcript = this.history.get(conversationKey) ?? [];
    (agent as unknown as { messages: StoredMessage[] }).messages = [
      ...transcript,
    ];
    return { agent };
  }
}