【実装】Next.js + Prismaでチャット履歴を永続化する設計と実装

model Character {
  id         String   @id @default(cuid())
  slug       String   @unique  // URL に使う識別子
  name       String             // 表示名
  imagePath  String             // アバター画像パス
  promptFile String             // プロンプトファイル名
  userId     String?            // null=全員利用可, 有=個人専用
  createdAt  DateTime @default(now())
  updatedAt  DateTime @updatedAt

  user         User?         @relation(...)
  chatSessions ChatSession[]
}

model ChatSession {
  id             String   @id @default(cuid())
  userId         String
  characterId    String
  date           DateTime @db.Date  // 日付のみ（時刻なし）
  lastResponseId String?            // OpenAI文脈維持用
  createdAt      DateTime @default(now())
  updatedAt      DateTime @updatedAt

  user      User          @relation(...)
  character Character     @relation(...)
  messages  ChatMessage[]

  @@unique([userId, characterId, date])  // 核心の複合ユニーク制約
}

model ChatMessage {
  id        String   @id @default(cuid())
  sessionId String
  role      String   // "user" | "assistant"
  content   String
  createdAt DateTime @default(now())

  session ChatSession @relation(...)

  @@index([sessionId, createdAt])  // 時系列取得の高速化
}

"use server";

function todayDate() {
  const now = new Date();
  return new Date(now.getFullYear(), now.getMonth(), now.getDate());
}


export async function getOrCreateTodaySession(characterId: string) {
  // userId は引数で受け取らず、セッションから取る。
  // Server Action は外部から直接 POST できるので、
  // 引数で受けると「他人の userId を渡す」だけで他人の履歴を引けてしまう。
  const session = await auth();
  if (!session?.user?.id) throw new Error("Unauthorized");
  const userId = session.user.id;

  const date = todayDate();

  const existing = await prisma.chatSession.findUnique({
    where: {
      userId_characterId_date: { userId, characterId, date },
    },
    include: {
      messages: { orderBy: { createdAt: "asc" } },
    },
  });

  if (existing) return existing;

  return prisma.chatSession.create({
    data: { userId, characterId, date },
    include: {
      messages: { orderBy: { createdAt: "asc" } },
    },
  });
}

// メッセージ送信後にresponseIdを保存
await updateLastResponseId(sessionId, responseId);

// 次のリクエストでprevious_response_idとして渡す
const response = await client.responses.create({
  model: "gpt-4.1-mini",
  input: userInput,
  previous_response_id: session.lastResponseId,
  instructions: systemPrompt,
});