Amazon Bedrock RAGチャットボットで複数問い合わせの回答が混ざる問題をワーキングバッファ＋アーカイブパターンで解決した

const [messages, setMessages] = useState<ChatMessage[]>([]);

// Q1送信
setMessages([{ role: "user", content: "プリンターの設置依頼をしたい" }]);

// Q1回答受信後、messagesに追加
setMessages(prev => [...prev, { role: "assistant", content: q1Answer }]);

// Q2送信 — messagesにはQ1の全やり取りが残っている
setMessages(prev => [...prev, { role: "user", content: "Salesforceにログインできない" }]);

user:      プリンターの設置依頼をしたい
assistant: [プリンター関連の詳細回答 + メール文案]
user:      Salesforceにログインできない  ← Q2

// 最終回答受信時
setMessages([]);

const [messages, setMessages] = useState<ChatMessage[]>([]);
const [archivedMessages, setArchivedMessages] = useState<ChatMessage[]>([]);

if (chatResponse.response_type === "results") {
  // 最終回答: 現在のメッセージをアーカイブに移動してワーキングバッファをリセット
  setMessages((currentMessages) => {
    const finalAssistantMsg: ChatMessage = {
      role: "assistant",
      content: JSON.stringify({
        response_type: chatResponse.response_type,
        general_advice: chatResponse.general_advice,
      }),
    };
    setArchivedMessages((arch) => [...arch, ...currentMessages, finalAssistantMsg]);
    return []; // ワーキングバッファをリセット
  });
} else {
  // 確認質問（clarification）: 引き続きワーキングバッファに追加（文脈を維持）
  setMessages((prev) => [
    ...prev,
    {
      role: "assistant",
      content: JSON.stringify({
        response_type: chatResponse.response_type,
        question: chatResponse.question,
        options: chatResponse.options,
      }),
    },
  ]);
}

body: JSON.stringify({
  messages: nextMessages,
  previous_ticket_ids: previousTicketIds,
  archived_messages: archivedMessages, // アーカイブを追加
}),

# backend/app/models/chat.py
class ChatRequest(BaseModel):
    messages: list[ChatMessage] = Field(...)
    archived_messages: list[ChatMessage] = Field(
        default_factory=list,
        description="完了済みの過去の問い合わせ（参照用）。現在の問い合わせには影響しない。",
    )

# backend/app/api/routes/chat.py
def _format_archived_context(archived: list) -> str:
    """完了済みの問い合わせを参照用テキストに整形する。"""
    lines: list[str] = []
    exchange_num = 0
    i = 0
    while i < len(archived):
        if archived[i].role == "user":
            exchange_num += 1
            lines.append(f"【問い合わせ{exchange_num}】{archived[i].content}")
            i += 1
            if i < len(archived) and archived[i].role == "assistant":
                try:
                    resp = json.loads(archived[i].content)
                    advice = resp.get("general_advice", "")
                    if advice:
                        lines.append(f"【回答{exchange_num}】{advice[:400]}")
                except (ValueError, KeyError):
                    lines.append(f"【回答{exchange_num}】{archived[i].content[:400]}")
                i += 1
        else:
            i += 1
    return "\n".join(lines)

archived_section = ""
if request.archived_messages:
    archived_text = _format_archived_context(request.archived_messages)
    archived_section = f"\n\n## 過去の問い合わせ回答（参照用）\n{archived_text}"

augmented = (
    f"## 過去チケットデータ（Knowledge Base検索結果）\n{context}"
    f"{domain_ctx}"
    f"{archived_section}"    # ← アーカイブをここに注入
    f"\n\n## 問い合わせ\n{request.messages[0].content}"
)

## 過去の問い合わせ（参照用）について

メッセージに「過去の問い合わせ回答（参照用）」セクションが含まれている場合:
- 現在の問い合わせが明示的に過去のトピックを参照している場合のみ使用してください
  （例：「さっきのチケット#123についてもっと教えて」→ 参照可）
- 現在の問い合わせが新しいトピックの場合は、過去の内容を回答に含めないでください
- mail_draft と todo_actions は必ず現在の問い合わせのチケットのみに基づいて生成してください
- 過去の回答の内容を現在の回答に混在させないでください