feat: HSR DreamWriter - complete product redesign

Transform FanFic Lab from generic AI writing tool to autonomous
Honkai: Star Rail story delivery service.

- Adaptive LangGraph agent with 5 nodes + quality loop
- Pre-built HSR knowledge pack (characters, relationships, world)
- Single-input creation flow with SSE progress streaming
- New pages: landing, create, story reader, shelf
- Updated navigation for new product flow

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: ChanMeng666

package-lock.json

@@ -7,7 +7,7 @@
   },
   "scripts": {
     "dev": "next dev",
-    "dev:agent": "langgraphjs dev --host 0.0.0.0 --port 8123 --config src/agent/langgraph.json",
+    "dev:agent": "dotenvx run --env-file=.env.local --env-file=.env -- langgraphjs dev --host 0.0.0.0 --port 8123 --config src/agent/langgraph.json",
     "dev:all": "concurrently \"npm run dev\" \"npm run dev:agent\"",
     "build": "prisma generate && next build",
     "postinstall": "prisma generate",
@@ -50,6 +50,7 @@
     "motion": "^12.23.26",
     "next": "16.1.1",
     "next-themes": "^0.4.6",
+    "openai": "^6.33.0",
     "pg": "^8.17.1",
     "prisma": "^7.2.0",
     "react": "19.2.3",
@@ -60,10 +61,12 @@
     "zod": "^3.25.76"
   },
   "devDependencies": {
+    "@dotenvx/dotenvx": "^1.59.1",
     "@tailwindcss/postcss": "^4",
     "@types/node": "^20",
     "@types/react": "^19",
     "@types/react-dom": "^19",
+    "commander": "^14.0.3",
     "eslint": "^9",
     "eslint-config-next": "16.1.1",
     "tailwindcss": "^4",

package.json

@@ -52,6 +52,13 @@ model UserPreferences {
   aiPersonality   String   @default("helpful") // AI writing style preference
   darkMode        Boolean  @default(false)
 
+  // DreamWriter preference learning
+  preferredCPs    String[] // Learned from generation history
+  preferredTropes String[] // e.g., ["现代AU", "甜饼", "ABO"]
+  avoidTropes     String[] // e.g., ["主要角色死亡", "NTR"]
+  tonePreference  String?  // e.g., "偏虐带HE", "纯甜"
+  lengthPreference String? // "short" | "medium" | "long"
+
   createdAt DateTime @default(now())
   updatedAt DateTime @updatedAt
 }
@@ -350,6 +357,22 @@ enum GenerationStatus {
   FAILED
 }
 
+// ============================================
+// KNOWLEDGE BASE (RAG for DreamWriter)
+// ============================================
+
+model KnowledgeChunk {
+  id        String   @id @default(cuid())
+  fandom    String   @default("hsr")
+  content   String   @db.Text
+  embedding Unsupported("vector(1536)")
+  metadata  Json     // { chapter?, characters?, location?, version? }
+
+  createdAt DateTime @default(now())
+
+  @@index([fandom])
+}
+
 // ============================================
 // RESEARCH CACHE (Cost optimization)
 // ============================================

prisma/schema.prisma

@@ -0,0 +1,42 @@
+import { StateGraph, MemorySaver, START, END } from "@langchain/langgraph";
+import { DreamWriterStateAnnotation } from "./state";
+import { intentParserNode } from "./nodes/intent-parser";
+import { storyArchitectNode } from "./nodes/story-architect";
+import { writerNode } from "./nodes/writer";
+import { qualityGuardNode } from "./nodes/quality-guard";
+import { deliveryNode } from "./nodes/delivery";
+import type { DreamWriterState } from "./state";
+
+const MAX_REVISIONS = 2;
+
+function routeAfterQualityCheck(state: DreamWriterState): string {
+  const report = state.qualityReport;
+  if (!report) return "delivery_node";
+  if (!report.passesThreshold && state.revisionCount < MAX_REVISIONS) {
+    console.log(`[DreamWriter] Quality score ${report.overallScore}/10, revision ${state.revisionCount + 1}/${MAX_REVISIONS}`);
+    return "writer_node";
+  }
+  return "delivery_node";
+}
+
+async function revisionCounterNode(state: DreamWriterState): Promise<Partial<DreamWriterState>> {
+  return { revisionCount: state.revisionCount + 1, stage: "revising", logs: [{ message: `正在根据反馈修改第 ${state.revisionCount + 1} 版...`, done: true }] };
+}
+
+const workflow = new StateGraph(DreamWriterStateAnnotation)
+  .addNode("intent_parser_node", intentParserNode)
+  .addNode("story_architect_node", storyArchitectNode)
+  .addNode("writer_node", writerNode)
+  .addNode("quality_guard_node", qualityGuardNode)
+  .addNode("revision_counter_node", revisionCounterNode)
+  .addNode("delivery_node", deliveryNode)
+  .addEdge(START, "intent_parser_node")
+  .addEdge("intent_parser_node", "story_architect_node")
+  .addEdge("story_architect_node", "writer_node")
+  .addEdge("writer_node", "quality_guard_node")
+  .addConditionalEdges("quality_guard_node", routeAfterQualityCheck, { writer_node: "revision_counter_node", delivery_node: "delivery_node" })
+  .addEdge("revision_counter_node", "writer_node")
+  .addEdge("delivery_node", END);
+
+const memory = new MemorySaver();
+export const graph = workflow.compile({ checkpointer: memory });

src/agent/dreamwriter/graph.ts

@@ -0,0 +1,35 @@
+import { ChatOpenAI } from "@langchain/openai";
+import { SystemMessage, HumanMessage } from "@langchain/core/messages";
+import type { RunnableConfig } from "@langchain/core/runnables";
+import type { DreamWriterState } from "../state";
+import { DELIVERY_PROMPT } from "../prompts/system";
+import type { StoryResult } from "../../../lib/types/dreamwriter";
+
+function parseJsonSafe(text: string): unknown {
+  const cleaned = text.replace(/```json?\s*/g, "").replace(/```\s*/g, "").trim();
+  return JSON.parse(cleaned);
+}
+
+function countWords(text: string): number {
+  const chinese = (text.match(/[\u4e00-\u9fff]/g) || []).length;
+  const english = text.replace(/[\u4e00-\u9fff]/g, "").trim().split(/\s+/).filter(Boolean).length;
+  return chinese + english;
+}
+
+export async function deliveryNode(state: DreamWriterState, _config: RunnableConfig): Promise<Partial<DreamWriterState>> {
+  console.log("[DreamWriter] ========== DELIVERY ==========");
+  const outline = state.outline;
+  const story = state.storyDraft;
+  if (!outline || !story) return { stage: "error", logs: [{ message: "缺少故事数据", done: true }] };
+
+  let suggestions: string[] = [];
+  try {
+    const model = new ChatOpenAI({ temperature: 0.7, model: "gpt-4o-mini" });
+    const response = await model.invoke([new SystemMessage(DELIVERY_PROMPT), new HumanMessage(`当前故事：${outline.title}\nCP: ${outline.cp.join(" × ")}\n设定: ${outline.setting}\n基调: ${outline.tone}`)]);
+    const content = typeof response.content === "string" ? response.content : JSON.stringify(response.content);
+    suggestions = parseJsonSafe(content) as string[];
+  } catch { suggestions = ["换一个设定试试？", "试试不同的情感基调？", "看看其他CP？"]; }
+
+  const result: StoryResult = { title: outline.title, body: story, cp: outline.cp, tags: [outline.setting, outline.tone], setting: outline.setting, wordCount: countWords(story), qualityScore: state.qualityReport?.overallScore ?? 7, language: state.detectedLanguage, suggestions };
+  return { stage: "complete", result, logs: [{ message: `创作完成！《${result.title}》共 ${result.wordCount} 字`, done: true }] };
+}

src/agent/dreamwriter/nodes/delivery.ts

@@ -0,0 +1,28 @@
+import { ChatOpenAI } from "@langchain/openai";
+import { SystemMessage, HumanMessage } from "@langchain/core/messages";
+import type { RunnableConfig } from "@langchain/core/runnables";
+import type { DreamWriterState } from "../state";
+import { INTENT_PARSER_PROMPT } from "../prompts/system";
+
+function parseJsonSafe(text: string): Record<string, unknown> {
+  const cleaned = text.replace(/```json?\s*/g, "").replace(/```\s*/g, "").trim();
+  return JSON.parse(cleaned);
+}
+
+export async function intentParserNode(
+  state: DreamWriterState,
+  _config: RunnableConfig
+): Promise<Partial<DreamWriterState>> {
+  console.log("[DreamWriter] ========== INTENT PARSER ==========");
+  const lastMessage = state.messages[state.messages.length - 1];
+  const userInput = typeof lastMessage.content === "string" ? lastMessage.content : JSON.stringify(lastMessage.content);
+  const model = new ChatOpenAI({ temperature: 0.3, model: "gpt-4o-mini" });
+  const response = await model.invoke([new SystemMessage(INTENT_PARSER_PROMPT), new HumanMessage(userInput)]);
+  const content = typeof response.content === "string" ? response.content : JSON.stringify(response.content);
+  try {
+    const parsed = parseJsonSafe(content) as { cp: string[]; setting: string; tone: string; constraints: Record<string, string>; language: "zh" | "en" };
+    return { stage: "parsing", parsedCP: parsed.cp || [], parsedSetting: parsed.setting || "原著向", parsedTone: parsed.tone || "甜", parsedConstraints: parsed.constraints || {}, detectedLanguage: parsed.language || "zh", logs: [{ message: "已理解你的创作需求", done: true }] };
+  } catch {
+    return { stage: "parsing", parsedCP: [], parsedSetting: "原著向", parsedTone: "甜", parsedConstraints: { ending: "HE", rating: "T", length: "medium" }, detectedLanguage: "zh", logs: [{ message: "已理解你的创作需求（使用默认设定）", done: true }] };
+  }
+}

src/agent/dreamwriter/nodes/intent-parser.ts

@@ -0,0 +1,29 @@
+import { ChatOpenAI } from "@langchain/openai";
+import { SystemMessage, HumanMessage } from "@langchain/core/messages";
+import type { RunnableConfig } from "@langchain/core/runnables";
+import type { DreamWriterState } from "../state";
+import { QUALITY_GUARD_PROMPT } from "../prompts/system";
+import { getHSRKnowledgePrompt } from "../prompts/hsr";
+import type { QualityReport } from "../../../lib/types/dreamwriter";
+
+function parseJsonSafe(text: string): Record<string, unknown> {
+  const cleaned = text.replace(/```json?\s*/g, "").replace(/```\s*/g, "").trim();
+  return JSON.parse(cleaned);
+}
+
+export async function qualityGuardNode(state: DreamWriterState, _config: RunnableConfig): Promise<Partial<DreamWriterState>> {
+  console.log("[DreamWriter] ========== QUALITY GUARD ==========");
+  if (!state.storyDraft) return { stage: "error", logs: [{ message: "没有故事草稿可供检查", done: true }] };
+  const knowledgePrompt = getHSRKnowledgePrompt();
+  const systemPrompt = QUALITY_GUARD_PROMPT(knowledgePrompt);
+  const checkInput = `故事需求：\nCP: ${state.parsedCP.join(" × ")}\n设定: ${state.parsedSetting}\n基调: ${state.parsedTone}\n\n故事正文：\n${state.storyDraft}`;
+  const model = new ChatOpenAI({ temperature: 0.3, model: "gpt-4o-mini" });
+  const response = await model.invoke([new SystemMessage(systemPrompt), new HumanMessage(checkInput)]);
+  const content = typeof response.content === "string" ? response.content : JSON.stringify(response.content);
+  try {
+    const report = parseJsonSafe(content) as QualityReport;
+    return { stage: "checking", qualityReport: report, logs: [{ message: report.passesThreshold ? `质量检查通过 (${report.overallScore}/10)` : `质量检查未通过 (${report.overallScore}/10)，正在修改...`, done: true }] };
+  } catch {
+    return { stage: "checking", qualityReport: { overallScore: 7, oocIssues: [], consistencyIssues: [], proseNotes: [], passesThreshold: true }, logs: [{ message: "质量检查完成", done: true }] };
+  }
+}

src/agent/dreamwriter/nodes/quality-guard.ts

@@ -0,0 +1,29 @@
+import { ChatOpenAI } from "@langchain/openai";
+import { SystemMessage, HumanMessage } from "@langchain/core/messages";
+import type { RunnableConfig } from "@langchain/core/runnables";
+import type { DreamWriterState } from "../state";
+import { STORY_ARCHITECT_PROMPT } from "../prompts/system";
+import { getHSRKnowledgePrompt } from "../prompts/hsr";
+import type { StoryOutline } from "../../../lib/types/dreamwriter";
+
+function parseJsonSafe(text: string): Record<string, unknown> {
+  const cleaned = text.replace(/```json?\s*/g, "").replace(/```\s*/g, "").trim();
+  return JSON.parse(cleaned);
+}
+
+export async function storyArchitectNode(state: DreamWriterState, _config: RunnableConfig): Promise<Partial<DreamWriterState>> {
+  console.log("[DreamWriter] ========== STORY ARCHITECT ==========");
+  const knowledgePrompt = getHSRKnowledgePrompt();
+  const systemPrompt = STORY_ARCHITECT_PROMPT(knowledgePrompt);
+  const requestSummary = `CP: ${state.parsedCP.join(" × ")}\n设定: ${state.parsedSetting}\n基调: ${state.parsedTone}\n约束: ${JSON.stringify(state.parsedConstraints)}`;
+  const model = new ChatOpenAI({ temperature: 0.8, model: "gpt-4o" });
+  const response = await model.invoke([new SystemMessage(systemPrompt), new HumanMessage(requestSummary)]);
+  const content = typeof response.content === "string" ? response.content : JSON.stringify(response.content);
+  try {
+    const parsed = parseJsonSafe(content) as StoryOutline;
+    return { stage: "planning", outline: parsed, logs: [{ message: `故事构思完成：${parsed.title}`, done: true }] };
+  } catch {
+    const fallbackOutline: StoryOutline = { title: `${state.parsedCP.join("×")}的故事`, cp: state.parsedCP, setting: state.parsedSetting, tone: state.parsedTone, wordTarget: 3000, scenes: [{ summary: "完整短篇", characters: state.parsedCP, emotion: state.parsedTone }], emotionalArc: "起承转合" };
+    return { stage: "planning", outline: fallbackOutline, logs: [{ message: `故事构思完成：${fallbackOutline.title}`, done: true }] };
+  }
+}

src/agent/dreamwriter/nodes/story-architect.ts

@@ -0,0 +1,28 @@
+import { ChatOpenAI } from "@langchain/openai";
+import { SystemMessage, HumanMessage } from "@langchain/core/messages";
+import type { RunnableConfig } from "@langchain/core/runnables";
+import type { DreamWriterState } from "../state";
+import { WRITER_PROMPT } from "../prompts/system";
+import { getHSRKnowledgePrompt, buildRAGContext } from "../prompts/hsr";
+import { retrieveRelevantChunks } from "../../../knowledge/base/rag";
+
+export async function writerNode(state: DreamWriterState, _config: RunnableConfig): Promise<Partial<DreamWriterState>> {
+  console.log("[DreamWriter] ========== WRITER ==========");
+  const outline = state.outline;
+  if (!outline) return { stage: "error", logs: [{ message: "没有故事大纲", done: true }] };
+
+  const ragQuery = `${outline.cp.join(" ")} ${outline.setting} ${outline.scenes.map((s) => s.summary).join(" ")}`;
+  let ragChunks: { content: string }[] = [];
+  try { ragChunks = await retrieveRelevantChunks(ragQuery, "hsr", 3); } catch (e) { console.log("[DreamWriter] RAG retrieval failed, continuing without:", e); }
+
+  const knowledgePrompt = getHSRKnowledgePrompt();
+  const ragContext = buildRAGContext(ragChunks);
+  const systemPrompt = WRITER_PROMPT(knowledgePrompt + ragContext);
+
+  const outlineText = `标题：${outline.title}\nCP：${outline.cp.join(" × ")}\n设定：${outline.setting}\n基调：${outline.tone}\n目标字数：${outline.wordTarget}\n情感曲线：${outline.emotionalArc}\n\n场景安排：\n${outline.scenes.map((s, i) => `${i + 1}. ${s.summary}（角色：${s.characters.join("、")}，情绪：${s.emotion}）`).join("\n")}${state.qualityReport ? `\n\n上一版的质量反馈（请针对性修改）：\n${state.qualityReport.oocIssues.map((i) => `- ${i.character}: ${i.issue} → ${i.suggestion}`).join("\n")}\n${state.qualityReport.proseNotes.map((n) => `- ${n}`).join("\n")}` : ""}`;
+
+  const model = new ChatOpenAI({ temperature: 0.9, model: "gpt-4o" });
+  const response = await model.invoke([new SystemMessage(systemPrompt), new HumanMessage(outlineText)]);
+  const story = typeof response.content === "string" ? response.content : JSON.stringify(response.content);
+  return { stage: "writing", storyDraft: story, ragContext: ragChunks.map((c) => c.content), logs: [{ message: "故事初稿完成，正在进行质量检查...", done: true }] };
+}

src/agent/dreamwriter/nodes/writer.ts

@@ -0,0 +1,10 @@
+import { hsrKnowledge } from "../../../knowledge/hsr";
+
+export function getHSRKnowledgePrompt(): string {
+  return hsrKnowledge.toSystemPrompt();
+}
+
+export function buildRAGContext(chunks: { content: string }[]): string {
+  if (chunks.length === 0) return "";
+  return `\n\n## 原著参考段落\n以下是与当前创作相关的原著段落，请参考其中的描写风格和细节：\n\n${chunks.map((c, i) => `[参考${i + 1}] ${c.content}`).join("\n\n")}`;
+}