Jesse_Chen
106 lines
5.0 KiB
TypeScript
106 lines
5.0 KiB
TypeScript
import assert from "node:assert/strict";
|
|
import { readFileSync } from "node:fs";
|
|
import test from "node:test";
|
|
|
|
const component = readFileSync(
|
|
new URL("../src/components/conversational-birth-time-rectification.tsx", import.meta.url),
|
|
"utf8",
|
|
);
|
|
const chat = readFileSync(
|
|
new URL("../src/components/rectification-agentic-chat.tsx", import.meta.url),
|
|
"utf8",
|
|
);
|
|
const route = readFileSync(
|
|
new URL("../src/app/api/rectification/agent/route.ts", import.meta.url),
|
|
"utf8",
|
|
);
|
|
const page = readFileSync(new URL("../src/app/page.tsx", import.meta.url), "utf8");
|
|
|
|
test("birth-time rectification entry no longer routes through V4", () => {
|
|
assert.doesNotMatch(component, /loadActiveRectificationV4|RectificationV4Panel|transitionRectificationV4/);
|
|
assert.match(component, /return <AgenticRectificationChat \{\.\.\.props\} \/>/);
|
|
});
|
|
|
|
test("opening is a server-owned operation rather than a hidden user prompt", () => {
|
|
assert.doesNotMatch(chat, /agenticOpeningInstruction|用户刚进入生时校正会话/);
|
|
assert.match(chat, /action: "opening"/);
|
|
assert.match(route, /z\.literal\("opening"\)/);
|
|
assert.match(route, /parsed\.data\.action === "opening"/);
|
|
});
|
|
|
|
test("incomplete profiles stay in the shared onboarding flow", () => {
|
|
const opening = page.slice(
|
|
page.indexOf("async function openBirthTimeRectification"),
|
|
page.indexOf("resumeRectificationSession.current ="),
|
|
);
|
|
assert.match(opening, /const missingStep = missingProfileStep\(profile\)/);
|
|
assert.match(opening, /setOnboardingStep\(missingStep\)/);
|
|
assert.ok(
|
|
opening.indexOf("const missingStep = missingProfileStep(profile)")
|
|
< opening.indexOf("setRectificationSessionId(rectificationSession.id)"),
|
|
);
|
|
assert.match(chat, /payload\?\.code === "profile_incomplete"/);
|
|
});
|
|
|
|
test("server profile failures pause automatic rectification resume", () => {
|
|
const resumeEffect = page.slice(
|
|
page.indexOf('useEffect(() => {\n if (!hydrated'),
|
|
page.indexOf('useEffect(() => {\n if (!hydrated || !accountId'),
|
|
);
|
|
const incompleteHandler = page.slice(
|
|
page.indexOf("function handleRectificationProfileIncomplete"),
|
|
page.indexOf("async function draftSynastryQuestionFromChart"),
|
|
);
|
|
assert.match(resumeEffect, /\|\| rectificationError\) return/);
|
|
assert.match(incompleteHandler, /setRectificationError\("profile_incomplete"\)/);
|
|
assert.ok(
|
|
incompleteHandler.indexOf('setRectificationError("profile_incomplete")')
|
|
< incompleteHandler.indexOf("setRectificationSessionId(null)"),
|
|
);
|
|
});
|
|
|
|
test("account rehydration normalizes persisted ISO birth dates before completeness checks", () => {
|
|
const profileReader = page.slice(
|
|
page.indexOf("function readProfile"),
|
|
page.indexOf("function readSessions"),
|
|
);
|
|
assert.match(profileReader, /const date = normalizePersistedBirthDate\(/);
|
|
});
|
|
|
|
test("agent tool calls leave a final step for visible prose and never end silently", () => {
|
|
assert.match(route, /const agenticRectificationMaxSteps = 8/);
|
|
assert.match(route, /\{ maxSteps: agenticRectificationMaxSteps \}/);
|
|
assert.match(route, /if \(!emitted \|\| !reply\.text\) \{[\s\S]*type: "error"[\s\S]*await settle\(false\)[\s\S]*return;/);
|
|
assert.doesNotMatch(route, /send\(\{ type: "done", emitted \}\)/);
|
|
});
|
|
|
|
test("rectification messages survive remounts and suppress duplicate openings", () => {
|
|
assert.match(chat, /initialMessages: readonly ChatMessage\[\]/);
|
|
assert.match(chat, /if \(initialMessages\.length > 0 \|\| openingStarted\.current\) return/);
|
|
assert.match(chat, /sessionId,/);
|
|
assert.match(chat, /onMessagesChange\?\.\(/);
|
|
assert.match(page, /key=\{rectificationSessionId\}/);
|
|
assert.match(page, /initialMessages=\{activeSession\?\.messages \?\? \[\]\}/);
|
|
assert.match(page, /onMessagesChange=\{handleRectificationMessagesChange\}/);
|
|
});
|
|
|
|
test("successful Agent turns are persisted by the authenticated rectification route", () => {
|
|
assert.match(route, /sessionId: z\.string\(\)\.uuid\(\)/);
|
|
assert.match(route, /\.from\("chat_sessions"\)[\s\S]*\.eq\("user_id", userId\)/);
|
|
assert.match(route, /parsed\.data\.action === "opening" && persistedMessages\.length > 0/);
|
|
assert.match(route, /\.update\(\{ messages: nextMessages, updated_at:/);
|
|
assert.match(route, /if \(saveError \|\| !savedSession\) throw new Error\("RectificationSessionPersistenceError"\)/);
|
|
});
|
|
|
|
test("stream failures remove empty assistant placeholders", () => {
|
|
assert.match(chat, /streamFailed = true/);
|
|
assert.match(chat, /const succeeded = completed && !streamFailed && Boolean\(parsed\.text\)/);
|
|
assert.match(chat, /current\.filter\(\(message\) => message\.renderKey !== assistantRenderKey\)/);
|
|
assert.match(chat, /if \(succeeded\)/);
|
|
});
|
|
|
|
test("new rectification sessions are created before the Agent surface mounts", () => {
|
|
assert.match(page, /await rectificationPersistence\.current\.enqueue[\s\S]*setRectificationSessionId\(rectificationSession\.id\)/);
|
|
assert.doesNotMatch(page, /setRectificationSessionId\(rectificationSession\.id\)[\s\S]{0,500}persistSession\(rectificationSession, "create"\)/);
|
|
});
|