"use client";

import Link from "next/link";
import dynamic from "next/dynamic";
import { ArrowUp, ArrowUpRight, ShieldCheck, Sparkles, Square, X } from "lucide-react";
import { useGSAP } from "@gsap/react";
import { gsap } from "gsap";
import { useEffect, useRef, useState } from "react";
import type { FormEvent, KeyboardEvent } from "react";
import { AppSidebar } from "@/components/app-sidebar";
import { UserAvatar } from "@/components/user-avatar";
import {
  BirthTimeAssessmentOverlay,
  type BirthTimeAssessmentPhase,
} from "@/components/birth-time-assessment-overlay";
import { BirthTimeIntakeFields } from "@/components/birth-time-intake";
import { AppLoadingIndicator } from "@/components/app-loading-indicator";
import { ConversationalBirthTimeRectification } from "@/components/conversational-birth-time-rectification";
import { ChatMessageContent } from "@/components/chat-message-content";
import { GeneratePersonalReportButton } from "@/components/personal-report/generate-personal-report-button";
import { AgentAvatar, ChatMessageRow } from "@/components/chat-message-row";
import { ModelSelector } from "@/components/model-selector";
import {
  LocationSearchCombobox,
  type ResolvedBirthLocation,
} from "@/components/location-search-combobox";
import { Button } from "@/components/ui/button";
import { SidebarInset, SidebarProvider, SidebarTrigger } from "@/components/ui/sidebar";
import { Textarea } from "@/components/ui/textarea";
import { chinaLocations, type ProvinceNode } from "@/data/china-locations";
import { parseAgentReply, resolveSessionTitle, type ReplyTheme } from "@/lib/agent-reply";
import {
  beamAvatarPalettes,
  beamAvatarSchema,
  type BeamAvatar,
  type BeamAvatarPatch,
} from "@/lib/beam-avatar";
import type { ConsultationEntrypoint } from "@/lib/consultation-entrypoint";
import {
  applyBirthTimeDraftPatch,
  assistantIntentCopy,
  birthTimeDisplayState,
  birthTimePersistenceValues,
  declaredBirthInputChanged,
  describeBirthTimeDraft,
  isBirthTimeReadyForConsultation,
  isDeclaredBirthProfileComplete,
  isBirthTimeDraftReady,
  normalizePersistedBirthDate,
  type BirthTimeDraft,
  type BirthTimeSource,
} from "@/lib/birth-time-intake-model";
import {
  birthTimeConsultationOptionsCopy,
  clearBirthTimeConsultationConsent,
  createLatestAccountRequestGuard,
  createBirthTimeConsultationConsentState,
  grantBirthTimeConsultationConsent,
  resolveBirthTimeConsultationRoute,
  resolveRectificationCardAction,
  type AccountRectificationCaseState,
  type BirthTimeConsultationConsentState,
  type RectificationCardAction,
} from "@/lib/birth-time-consultation-consent";
import type { ConsultationBirthTimeMode } from "@/lib/consultation-birth-time-mode";
import {
  createRectificationQuestionHandoffCoordinator,
} from "@/lib/rectification-question-handoff";
import { useBirthTimeGuidedJourney } from "@/hooks/use-birth-time-guided-journey";
import {
  requestBirthTimeAssessment,
  type JourneyClientResponse,
} from "@/lib/birth-time-journey-client";
import {
  guidedBirthTimePreview,
  isGuidedBirthTimePreview,
  previewRectificationJourney,
} from "@/lib/birth-time-guided-preview";
import { defaultGuidedJyotishTopics, generalGuidedJyotishTopics } from "@/lib/guided-jyotish-topics";
import { keepFocusWithin } from "@/lib/focus-trap";
import { chatMessageViews, type ChatMessage } from "@/lib/chat-message-view";
import { writeChatSession } from "@/lib/chat-session-write-contract";
import { consultationReportMarkdown } from "@/lib/consultation-report-export";
import {
  OnboardingAuthenticationError,
  type OnboardingContent,
  createStartGreeting,
  isCurrentOnboardingRequest,
  onboardingProfileFingerprint,
  onboardingRequestIdentity,
  requestOnboardingWithRecovery,
} from "@/lib/onboarding-client";
import { protectOnboardingPhrases } from "@/lib/onboarding-copy";
import {
  SessionModelPersistenceQueue,
  persistSessionModelSelection,
} from "@/lib/session-model-persistence";
import {
  parsePublicModelCatalog,
  resolveSessionModelId,
  type PublicLanguageModelCatalog,
} from "@/lib/public-models";
import { selfHostedOtpActions } from "@/modules/identity/client";

gsap.registerPlugin(useGSAP);

const BirthTimeRectification = dynamic(
  () => import("@/components/birth-time-rectification").then((module) => module.BirthTimeRectification),
  {
    ssr: false,
    loading: () => <p className="birth-time-assistant-intent" role="status">正在加载出生时间评估...</p>,
  },
);

type Theme = ReplyTheme;
type Message = ChatMessage;
type Profile = BirthTimeDraft & {
  name: string;
  countryCode: string;
  provinceCode: string;
  cityCode: string;
  districtCode: string;
  birthPlaceLabel: string;
  birthPlaceType: string;
  birthPlaceProvider: string;
  birthPlaceProviderId: string;
  timezoneId: string;
  timezoneSource: string;
  latitude: number | null;
  longitude: number | null;
  timezoneOffset: number | null;
  rectificationCaseId: string;
};
type ChartLibraryRecord = {
  id: string;
  role: "self" | "other";
  profile: Profile;
  updatedAt: number;
};
type SynastryRelationshipType = "romance" | "business" | "family" | "general";
type ChartLibraryApiRecord = {
  id: string;
  role: "self" | "other";
  profile: Profile;
  updated_at?: string;
};
type SynastryReportCard = {
  id: string;
  partnerName: string;
  score?: number;
  maxScore?: number;
  assessment?: string;
  headline?: string;
  scoreBand?: string;
  strengths?: string[];
  risks?: string[];
  nextEvidence?: string[];
  createdAt: number;
};
type SynastryReportApiRecord = {
  id: string;
  partner_name?: string;
  report?: SynastryReportCard;
  created_at?: string;
};
type ChatSessionType = "consultation" | "birth_time_rectification";
type ChatSession = {
  id: string;
  title: string;
  theme: Theme;
  modelId: string;
  messages: Message[];
  updatedAt: number;
  sessionType: ChatSessionType;
  rectificationCaseId: string | null;
};

type RequestError = { sessionId: string; message: string };
type StreamingReply = { sessionId: string; text: string };
type BirthPlace = {
  label: string;
  lat: number;
  lon: number;
  tz: number | null;
  timezoneId: string;
};
type Account = {
  user: { id: string; email: string | null };
  avatar: BeamAvatar | null;
  credits: number;
  isAdmin: boolean;
  adminUrl: string | null;
  rectificationPriceCredits: number;
  activeSubscription: {
    id: string;
    status: string;
    startsAt: string;
    endsAt: string;
    productCode: string;
    productVersion: number;
    product: { name?: string; productType?: string } | null;
    entitlements: unknown;
  } | null;
  hasConfirmedBirthTime: boolean;
  hasUsableBirthTime: boolean;
  rectificationCase: AccountRectificationCaseState | null;
  profile: unknown;
};
type OnboardingStep = "name" | "birth" | "place" | "rectification";
type AccountDialog = "profile" | "redeem" | "logout";
type DailyStarlanguageCard = { trend: string; action: string; caution: string };
type DailyStarlanguageApiResponse = {
  status?: "ok";
  card?: DailyStarlanguageCard;
  source?: "calculation_lite";
  claim_status?: "exploratory_unvalidated";
  boundary?: "not_deterministic_prediction";
};
type SessionReadResult = { readonly sessions: ChatSession[]; readonly fallbackSessionIds: string[] };
type ConsultationRectificationHandoff = Readonly<{
  protocol?: "conversational-evidence-v3";
  caseId: string;
  turnVersion: number;
  claimActionId: string;
  requestId: string;
}> | Readonly<{
  protocol: "rectification-evidence-v4";
  caseId: string;
  caseVersion: number;
  claimActionId: string;
  requestId: string;
}>;
type PendingConsultation = {
  readonly requestId: string;
  readonly sessionId: string;
  readonly question: string;
  readonly entrypoint: ConsultationEntrypoint | null;
  readonly theme: Theme;
  readonly rectificationHandoff: ConsultationRectificationHandoff | null;
  readonly previousSession: ChatSession;
  readonly optimisticSession: ChatSession;
  readonly previousOnboardingState: boolean;
  readonly controller: AbortController;
  readonly cancelled: boolean;
  readonly phase: "undo" | "streaming";
  readonly partialReply: string;
};
const undoWindowMs = 2_500;
const china = chinaLocations.country;

const themes = defaultGuidedJyotishTopics;

const rectificationCardLabels = {
  start: "开始生时校正",
  resume: "继续上次校正",
  revise: "再次校正",
} as const satisfies Record<RectificationCardAction, string>;
const rectifyBeforeConsultationSuggestion = "先完成生时校正";

const accountDialogTitles = {
  profile: "个人资料",
  redeem: "兑换点数",
  logout: "退出登录？",
} as const satisfies Record<AccountDialog, string>;

const accountDialogClasses = {
  profile: "profile-modal",
  redeem: "redeem-modal",
  logout: "logout-modal",
} as const satisfies Record<AccountDialog, string>;

const previewModelCatalog = parsePublicModelCatalog({
  defaultModelId: "deepseek-pro",
  models: [
    { id: "deepseek-pro", label: "DeepSeek V4 Pro", description: "更适合复杂分析", creditCost: 1, isDefault: true },
    { id: "gpt-5-mini", label: "ChatGPT 5 Mini", description: "响应稳定、速度均衡", creditCost: 1, isDefault: false },
  ],
});

const presetOnboardingMessage = "你好，我是 Jyotisha。\n开始前，我想先认识你。\n请问我该怎么称呼你？";

const dailyStarlanguageCards: DailyStarlanguageCard[] = [
  { trend: "先收束，再推进。适合把一个悬而未决的问题拆小。", action: "选一件最重要的事，给它留出 45 分钟不被打断的时间。", caution: "避免在情绪最满时做承诺。" },
  { trend: "适合整理关系与边界。越清楚，越不容易被外界节奏带走。", action: "把今天要回复的人和要推迟的事分开列出来。", caution: "不要把暂时的沉默误读成最终答案。" },
  { trend: "执行力比灵感更重要。小步完成会比大计划更有力量。", action: "先完成一个可交付版本，再考虑优化。", caution: "别让完美感拖慢开始。" },
  { trend: "适合观察资源流向：时间、注意力、金钱都算。", action: "检查一个正在消耗你的习惯，并给它设上限。", caution: "不要为了短期安心做长期成本高的选择。" },
];

function greetingForHour(hour: number): string {
  if (hour < 11) return "早上好";
  if (hour < 18) return "下午好";
  return "晚上好";
}

const emptyProfile: Profile = {
  name: "",
  date: "",
  time: "",
  reportedTime: "",
  birthTimeSource: "",
  birthTimePeriod: "",
  birthTimeClue: "",
  uncertaintyBeforeMinutes: null,
  uncertaintyAfterMinutes: null,
  birthTimeStatus: "",
  rectificationCaseId: "",
  countryCode: "CN",
  provinceCode: "",
  cityCode: "",
  districtCode: "",
  birthPlaceLabel: "",
  birthPlaceType: "",
  birthPlaceProvider: "",
  birthPlaceProviderId: "",
  timezoneId: "",
  timezoneSource: "",
  latitude: null,
  longitude: null,
  timezoneOffset: null,
};

function timestamp() {
  return Date.now();
}

function createSession(
  modelId: string,
  sessionType: ChatSessionType = "consultation",
): ChatSession {
  return {
    id: globalThis.crypto.randomUUID(),
    title: sessionType === "birth_time_rectification" ? "生时校正" : "新对话",
    theme: "general",
    modelId,
    messages: [],
    updatedAt: timestamp(),
    sessionType,
    rectificationCaseId: null,
  };
}

function findProvince(code: string) {
  return china.provinces.find((province) => province.code === code);
}

function findCity(province: ProvinceNode | undefined, code: string) {
  return province?.cities.find((city) => city.code === code);
}

function selectedBirthPlace(profile: Profile): BirthPlace | null {
  if (profile.birthPlaceLabel
    && Number.isFinite(profile.latitude)
    && Number.isFinite(profile.longitude)
    && profile.timezoneId.trim()
    && (profile.timezoneOffset === null || Number.isFinite(profile.timezoneOffset))) {
    return {
      label: profile.birthPlaceLabel,
      lat: profile.latitude as number,
      lon: profile.longitude as number,
      tz: profile.timezoneOffset,
      timezoneId: profile.timezoneId,
    };
  }

  const province = findProvince(profile.provinceCode);
  const city = findCity(province, profile.cityCode);
  if (!province || !city) return null;

  const district = city.districts.find((item) => item.code === profile.districtCode);
  if (city.districts.length > 0 && !district) return null;

  const location = district ?? city;
  const label = [china.name, province.name, city.name, district?.name]
    .filter((name, index, names) => Boolean(name) && names.indexOf(name) === index)
    .join(" · ");

  return {
    label,
    lat: location.center[1],
    lon: location.center[0],
    tz: china.timezone,
    timezoneId: "Asia/Shanghai",
  };
}

function selectedLocationValue(profile: Profile): ResolvedBirthLocation | null {
  const birthPlace = selectedBirthPlace(profile);
  if (!birthPlace) return null;
  return {
    id: profile.birthPlaceProviderId || `legacy-cn:${profile.provinceCode}:${profile.cityCode}:${profile.districtCode}`,
    label: birthPlace.label,
    placeType: profile.birthPlaceType || "legacy_china_admin",
    provider: profile.birthPlaceProvider || "legacy_china_locations",
    providerPlaceId: profile.birthPlaceProviderId,
    countryCode: profile.countryCode || "CN",
    countryName: profile.countryCode === "CN" ? "中国" : "",
    admin1: "",
    admin2: "",
    locality: "",
    latitude: birthPlace.lat,
    longitude: birthPlace.lon,
    timezoneId: birthPlace.timezoneId,
    timezoneOffset: birthPlace.tz,
    timezoneSource: profile.timezoneSource || "legacy_fixed_offset",
  };
}

function chartLibraryStorageKey(accountId: string) {
  return `jyotisha_chart_library:${accountId}`;
}
function synastryHistoryStorageKey(accountId: string) {
  return `jyotisha_synastry_history:${accountId}`;
}

function profileReadyForLibrary(profile: Profile) {
  return !missingProfileStep(profile);
}

function buildSelfChartRecord(profile: Profile): ChartLibraryRecord {
  return { id: "self", role: "self", profile, updatedAt: timestamp() };
}

function upsertSelfChart(library: ChartLibraryRecord[], profile: Profile) {
  if (!profileReadyForLibrary(profile)) return library.filter((record) => record.role !== "self");
  const others = library.filter((record) => record.role !== "self");
  return [buildSelfChartRecord(profile), ...others];
}

function readChartLibrary(accountId: string): ChartLibraryRecord[] {
  try {
    const parsed = JSON.parse(localStorage.getItem(chartLibraryStorageKey(accountId)) || "[]") as ChartLibraryRecord[];
    return Array.isArray(parsed) ? parsed.filter((record) => record?.id && record?.profile) : [];
  } catch {
    return [];
  }
}
function readSynastryHistory(accountId: string): SynastryReportCard[] {
  try {
    const parsed = JSON.parse(localStorage.getItem(synastryHistoryStorageKey(accountId)) || "[]") as SynastryReportCard[];
    return Array.isArray(parsed) ? parsed.filter((record) => record?.id && record?.partnerName).slice(0, 10) : [];
  } catch {
    return [];
  }
}

function writeSynastryHistory(accountId: string, history: SynastryReportCard[]) {
  localStorage.setItem(synastryHistoryStorageKey(accountId), JSON.stringify(history.slice(0, 10)));
}

function normalizeSynastryReportApiRecord(record: SynastryReportApiRecord): SynastryReportCard | null {
  if (!record.report || typeof record.report !== "object") return null;
  return {
    ...record.report,
    id: record.id,
    partnerName: record.partner_name || record.report.partnerName || "对方",
    createdAt: Date.parse(record.created_at || "") || record.report.createdAt || timestamp(),
  };
}

async function fetchCloudSynastryHistory() {
  const response = await fetch("/api/synastry-reports", { cache: "no-store" });
  if (!response.ok) throw new Error("cloud_synastry_history_unavailable");
  const payload = await response.json().catch(() => null) as { reports?: SynastryReportApiRecord[] } | null;
  return (payload?.reports || []).map(normalizeSynastryReportApiRecord).filter(Boolean) as SynastryReportCard[];
}

async function saveCloudSynastryReport(report: SynastryReportCard) {
  const response = await fetch("/api/synastry-reports", {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ partnerName: report.partnerName, report }),
  });
  if (!response.ok) throw new Error("cloud_synastry_report_save_failed");
  const payload = await response.json().catch(() => null) as { report?: SynastryReportApiRecord } | null;
  return payload?.report ? normalizeSynastryReportApiRecord(payload.report) || report : report;
}

function normalizeChartLibraryApiRecord(record: ChartLibraryApiRecord): ChartLibraryRecord {
  return {
    id: record.role === "self" ? "self" : record.id,
    role: record.role,
    profile: record.profile,
    updatedAt: Date.parse(record.updated_at || "") || timestamp(),
  };
}

async function fetchCloudChartLibrary() {
  const response = await fetch("/api/chart-profiles", { cache: "no-store" });
  if (!response.ok) throw new Error("cloud_chart_library_unavailable");
  const payload = await response.json().catch(() => null) as { profiles?: ChartLibraryApiRecord[] } | null;
  return (payload?.profiles || []).map(normalizeChartLibraryApiRecord);
}

async function saveCloudChartProfile(record: ChartLibraryRecord) {
  const response = await fetch("/api/chart-profiles", {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({
      role: record.role,
      profile: record.profile,
    }),
  });
  const payload = await response.json().catch(() => null) as { profile?: ChartLibraryApiRecord; error?: string } | null;
  if (!response.ok) throw new Error(payload?.error || "cloud_chart_profile_save_failed");
  return payload?.profile ? normalizeChartLibraryApiRecord(payload.profile) : record;
}

async function deleteCloudChartProfile(recordId: string) {
  const response = await fetch(`/api/chart-profiles/${encodeURIComponent(recordId)}`, { method: "DELETE" });
  if (!response.ok) throw new Error("cloud_chart_profile_delete_failed");
}

function profilePlaceLabel(profile: Profile) {
  return selectedBirthPlace(profile)?.label || "地点未完整";
}

function buildSynastryQuestion(selfProfile: Profile, partnerProfile: Profile, relationshipType: SynastryRelationshipType) {
  const relationshipLabel = relationshipType === "business" ? "商业合作" : relationshipType === "family" ? "亲友/家庭" : relationshipType === "general" ? "其他关系" : "婚恋";
  const evidenceRequest = relationshipType === "business"
    ? "请先说明 D2/D10/D11 已用层与 A10、双方 Dasha/Narayana、功能吉凶等缺失层；不得给出合作成败、收益保证或精确时点。"
    : relationshipType === "romance"
      ? "请先说明会使用哪些证据层，再分析关系模式、冲突点、适合发展的方式和需要谨慎的时间窗口。"
      : "请先说明当前缺少专用合盘计算合同，只基于可验证资料提出需要补充的现实关系信息，不作确定性判断。";
  return [
    `请用印度占星分析我和${partnerProfile.name || "对方"}的${relationshipLabel}关系。`,
    `我的资料：${selfProfile.name || "本人"}，${selfProfile.date} ${selfProfile.time}，${profilePlaceLabel(selfProfile)}。`,
    `对方资料：${partnerProfile.name || "对方"}，${partnerProfile.date} ${partnerProfile.time}，${profilePlaceLabel(partnerProfile)}。`,
    evidenceRequest,
  ].join("\n");
}

function buildDailyStarlanguageCard(profile: Profile) {
  const today = new Date().toISOString().slice(0, 10);
  const seed = `${today}-${profile.date}-${profile.time}-${profile.provinceCode}-${profile.cityCode}`;
  const index = Array.from(seed).reduce((sum, char) => sum + char.charCodeAt(0), 0) % dailyStarlanguageCards.length;
  return dailyStarlanguageCards[index];
}

async function fetchDailyStarlanguage(profile: Profile) {
  const response = await fetch("/api/daily-starlanguage", {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ profile }),
  });
  if (!response.ok) throw new Error("daily_starlanguage_unavailable");
  const payload = await response.json().catch(() => null) as DailyStarlanguageApiResponse | null;
  if (payload?.status !== "ok" || !payload.card) throw new Error("daily_starlanguage_invalid");
  return payload.card;
}

function missingProfileStep(profile: Profile): OnboardingStep | null {
  if (!profile.name.trim()) return "name";
  if (!isDeclaredBirthProfileComplete(profile)) return "birth";
  if (!isDeclaredBirthProfileComplete(profile, selectedBirthPlace(profile))) return "place";
  return null;
}

function missingOtherProfileStep(profile: Profile): "name" | "birth" | "place" | null {
  if (!profile.name.trim()) return "name";
  if (!isBirthTimeDraftReady(profile)) return "birth";
  if (!selectedBirthPlace(profile)) return "place";
  return null;
}

function birthQuestion(name: string) {
  return `${name}，你好。接下来请告诉我出生日期，以及你对出生时间知道到什么程度。不确定也没关系，我不会要求你猜一个具体时间。`;
}

function formatBirthMoment(profile: Profile) {
  return describeBirthTimeDraft(profile);
}

function placeQuestion(profile: Profile) {
  return `记下了：${formatBirthMoment(profile)}。最后一个问题，你出生在哪里？`;
}

function completedOnboardingMessage(name: string) {
  return `${name}，我们可以开始了。你可以从下面三个方向选择，也可以直接告诉我现在最想问的事。`;
}

function completedOnboardingTranscript(profile: Profile, greeting: string): Message[] {
  const name = profile.name.trim();
  const birthPlace = selectedBirthPlace(profile);
  if (!name || !isDeclaredBirthProfileComplete(profile) || !birthPlace) return [];

  return [
    { role: "assistant", text: presetOnboardingMessage },
    { role: "user", text: name },
    { role: "assistant", text: birthQuestion(name) },
    { role: "user", text: formatBirthMoment(profile) },
    { role: "assistant", text: placeQuestion(profile) },
    { role: "user", text: birthPlace.label },
    { role: "assistant", text: greeting || completedOnboardingMessage(name) },
  ];
}

function readSuggestions(value: unknown) {
  if (!Array.isArray(value)) return [];
  return [...new Set(value
    .filter((item): item is string => typeof item === "string")
    .map((item) => item.replace(/\s+/g, " ").trim().slice(0, 80))
    .filter(Boolean))].slice(0, 3);
}

function readProfile(value: unknown): Profile {
  if (!value || typeof value !== "object") return emptyProfile;
  const profile = value as Partial<Profile> & {
    birth_date?: unknown;
    birth_time?: unknown;
    reported_birth_time?: unknown;
    active_birth_time?: unknown;
    birth_time_source?: unknown;
    birth_time_period?: unknown;
    birth_time_clue?: unknown;
    uncertainty_before_minutes?: unknown;
    uncertainty_after_minutes?: unknown;
    birth_time_status?: unknown;
    rectification_case_id?: unknown;
    country_code?: unknown;
    province_code?: unknown;
    city_code?: unknown;
    district_code?: unknown;
    birth_place_label?: unknown;
    birth_place_type?: unknown;
    birth_place_provider?: unknown;
    birth_place_provider_id?: unknown;
    timezone_id?: unknown;
    timezone_source?: unknown;
    latitude?: unknown;
    longitude?: unknown;
    timezone_offset?: unknown;
  };
  const date = normalizePersistedBirthDate(
    typeof profile.birth_date === "string" ? profile.birth_date : profile.date,
  );
  const legacyTime = typeof profile.birth_time === "string" ? profile.birth_time.slice(0, 5) : profile.time;
  const time = typeof profile.active_birth_time === "string"
    ? profile.active_birth_time.slice(0, 5)
    : legacyTime;
  const persistedReportedTime = typeof profile.reported_birth_time === "string"
    ? profile.reported_birth_time.slice(0, 5)
    : "";
  const knownSources: readonly BirthTimeSource[] = [
    "hospital_record", "family_exact", "approximate", "period_only", "unknown", "legacy_import",
  ];
  const source = knownSources.find((item) => item === profile.birth_time_source)
    ?? (time ? "legacy_import" : "");
  const reportedTime = persistedReportedTime || (source === "legacy_import" ? time : "");
  const knownPeriods = ["early_morning", "morning", "afternoon", "evening", "late_night"] as const;
  const period = knownPeriods.find((item) => item === profile.birth_time_period) ?? "";
  const knownStatuses = ["reported", "assessing", "rectifying", "candidate", "accepted", "confirmed"] as const;
  const status = knownStatuses.find((item) => item === profile.birth_time_status)
    ?? (time ? "confirmed" : "");
  const provinceCode = typeof profile.province_code === "string" ? profile.province_code : profile.provinceCode;
  const cityCode = typeof profile.city_code === "string" ? profile.city_code : profile.cityCode;
  const districtCode = typeof profile.district_code === "string" ? profile.district_code : profile.districtCode;
  const countryCode = typeof profile.country_code === "string" ? profile.country_code : profile.countryCode;
  const birthPlaceLabel = typeof profile.birth_place_label === "string" ? profile.birth_place_label : profile.birthPlaceLabel;
  const birthPlaceType = typeof profile.birth_place_type === "string" ? profile.birth_place_type : profile.birthPlaceType;
  const birthPlaceProvider = typeof profile.birth_place_provider === "string" ? profile.birth_place_provider : profile.birthPlaceProvider;
  const birthPlaceProviderId = typeof profile.birth_place_provider_id === "string" ? profile.birth_place_provider_id : profile.birthPlaceProviderId;
  const timezoneId = typeof profile.timezone_id === "string" ? profile.timezone_id : profile.timezoneId;
  const timezoneSource = typeof profile.timezone_source === "string" ? profile.timezone_source : profile.timezoneSource;
  const latitude = typeof profile.latitude === "number" && Number.isFinite(profile.latitude) ? profile.latitude : null;
  const longitude = typeof profile.longitude === "number" && Number.isFinite(profile.longitude) ? profile.longitude : null;
  const timezoneOffset = typeof profile.timezone_offset === "number" && Number.isFinite(profile.timezone_offset)
    ? profile.timezone_offset
    : typeof profile.timezoneOffset === "number" && Number.isFinite(profile.timezoneOffset)
      ? profile.timezoneOffset
      : null;

  return {
    name: typeof profile.name === "string" ? profile.name.slice(0, 80) : "",
    date: typeof date === "string" ? date : "",
    time: typeof time === "string" ? time : "",
    reportedTime: typeof reportedTime === "string" ? reportedTime : "",
    birthTimeSource: source,
    birthTimePeriod: period,
    birthTimeClue: typeof profile.birth_time_clue === "string" ? profile.birth_time_clue.slice(0, 240) : "",
    uncertaintyBeforeMinutes: typeof profile.uncertainty_before_minutes === "number" ? profile.uncertainty_before_minutes : null,
    uncertaintyAfterMinutes: typeof profile.uncertainty_after_minutes === "number" ? profile.uncertainty_after_minutes : null,
    birthTimeStatus: status,
    rectificationCaseId: typeof profile.rectification_case_id === "string" ? profile.rectification_case_id : "",
    countryCode: typeof countryCode === "string" && countryCode ? countryCode : "CN",
    provinceCode: typeof provinceCode === "string" ? provinceCode : "",
    cityCode: typeof cityCode === "string" ? cityCode : "",
    districtCode: typeof districtCode === "string" ? districtCode : "",
    birthPlaceLabel: typeof birthPlaceLabel === "string" ? birthPlaceLabel : "",
    birthPlaceType: typeof birthPlaceType === "string" ? birthPlaceType : "",
    birthPlaceProvider: typeof birthPlaceProvider === "string" ? birthPlaceProvider : "",
    birthPlaceProviderId: typeof birthPlaceProviderId === "string" ? birthPlaceProviderId : "",
    timezoneId: typeof timezoneId === "string" ? timezoneId : "",
    timezoneSource: typeof timezoneSource === "string" ? timezoneSource : "",
    latitude,
    longitude,
    timezoneOffset,
  };
}

function readSessions(value: unknown, catalog: PublicLanguageModelCatalog | null): SessionReadResult {
  if (!Array.isArray(value)) return { sessions: [], fallbackSessionIds: [] };
  const fallbackSessionIds: string[] = [];
  const sessions = value.flatMap((item): ChatSession[] => {
    if (!item || typeof item !== "object") return [];
    const session = item as Partial<ChatSession> & {
      model_id?: unknown;
      rectification_case_id?: unknown;
      session_type?: unknown;
      updated_at?: unknown;
    };
    const messages: Message[] = Array.isArray(session.messages)
      ? session.messages.flatMap((message) => (
        message && typeof message === "object"
          && ((message as Message).role === "user" || (message as Message).role === "assistant")
          && typeof (message as Message).text === "string"
          ? [{
            role: (message as Message).role,
            text: (message as Message).text.slice(0, 12000),
            suggestions: readSuggestions((message as Message).suggestions),
          }]
          : []
      ))
      : [];

    if (typeof session.id !== "string") return [];
    const savedModelId = session.model_id ?? session.modelId;
    const selection = catalog
      ? resolveSessionModelId(savedModelId, catalog)
      : { modelId: typeof savedModelId === "string" ? savedModelId : "", fellBack: false };
    if (catalog && selection.fellBack) fallbackSessionIds.push(session.id);
    return [{
        id: session.id,
        title: typeof session.title === "string" ? session.title.slice(0, 36) : "新对话",
        theme: session.theme === "career" || session.theme === "marriage" || session.theme === "timing" ? session.theme : "general",
        modelId: selection.modelId,
        messages,
        sessionType: session.session_type === "birth_time_rectification"
          ? "birth_time_rectification"
          : "consultation",
        rectificationCaseId: typeof session.rectification_case_id === "string"
          ? session.rectification_case_id
          : null,
        updatedAt: typeof session.updatedAt === "number"
          ? session.updatedAt
          : typeof session.updated_at === "string"
            ? Date.parse(session.updated_at)
            : timestamp(),
      }];
  });
  return { sessions, fallbackSessionIds };
}

function BirthLocationFields({ value, onChange }: { value: Profile; onChange: (profile: Profile) => void }) {
  return (
    <fieldset className="location-fieldset">
      <legend>出生地点</legend>
      <LocationSearchCombobox
        value={selectedLocationValue(value)}
        birthDate={value.date}
        birthTime={value.reportedTime || value.time}
        onChange={(location) => onChange({
          ...value,
          countryCode: location?.countryCode || "CN",
          provinceCode: "",
          cityCode: "",
          districtCode: "",
          birthPlaceLabel: location?.label || "",
          birthPlaceType: location?.placeType || "",
          birthPlaceProvider: location?.provider || "",
          birthPlaceProviderId: location?.providerPlaceId || "",
          timezoneId: location?.timezoneId || "",
          timezoneSource: location?.timezoneSource || "",
          latitude: location?.latitude ?? null,
          longitude: location?.longitude ?? null,
          timezoneOffset: location?.timezoneOffset ?? null,
        })}
      />
    </fieldset>
  );
}

const birthLocationKeys = [
  "countryCode",
  "provinceCode",
  "cityCode",
  "districtCode",
  "birthPlaceLabel",
  "birthPlaceProviderId",
  "timezoneId",
  "latitude",
  "longitude",
  "timezoneOffset",
] as const;

function birthProfileDeclarationChanged(current: Profile, next: Profile) {
  return declaredBirthInputChanged(current, next)
    || birthLocationKeys.some((key) => current[key] !== next[key]);
}

function invalidateCandidateAfterLocationChange(current: Profile, next: Profile): Profile {
  const locationChanged = birthLocationKeys.some((key) => current[key] !== next[key]);
  if (!locationChanged
    || current.birthTimeStatus === "confirmed"
    || (current.birthTimeStatus !== "candidate" && !current.time)) return next;
  return { ...next, time: "", birthTimeStatus: "reported" };
}

function ProfileFields({ value, onChange, nameInputId }: { value: Profile; onChange: (profile: Profile) => void; nameInputId?: string }) {
  return (
    <>
      <label>
        <span>如何称呼你</span>
        <input id={nameInputId} required autoComplete="name" maxLength={80} placeholder="例如：林遥" value={value.name} onChange={(event) => onChange({ ...value, name: event.target.value })} />
      </label>
      <BirthTimeIntakeFields value={value} onPatch={(patch) => onChange(applyBirthTimeDraftPatch(value, patch))} />
      <BirthLocationFields
        value={value}
        onChange={(next) => onChange(invalidateCandidateAfterLocationChange(value, next))}
      />
    </>
  );
}

function OnboardingChatMessage({ role, text, streaming = false, length = text.length, phraseSafe = false }: { role: Message["role"]; text: string; streaming?: boolean; length?: number; phraseSafe?: boolean }) {
  const visibleText = streaming ? text.slice(0, length) : text;
  const protectedVisibleText = protectOnboardingPhrases(visibleText);
  return (
    <article className={`message message-${role} onboarding-message${phraseSafe ? " is-phrase-safe" : ""}`} aria-label={role === "assistant" ? "Jyotisha" : "你"}>
      {role === "assistant" && <AgentAvatar />}
      <div className="message-content">
        <div className="message-bubble">
          {role === "assistant" ? (
            streaming ? (
              <>
                <div className={`onboarding-stream ${length >= text.length ? "is-complete" : ""}`} aria-hidden="true"><ChatMessageContent text={protectedVisibleText} /></div>
                <span className="sr-only" aria-live="polite">{length >= text.length ? text : ""}</span>
              </>
            ) : <ChatMessageContent text={protectedVisibleText} />
          ) : <p>{protectedVisibleText}</p>}
        </div>
      </div>
    </article>
  );
}

function isProfileComplete(profile: Profile) {
  return missingProfileStep(profile) === null;
}

function friendlyError(message: string) {
  return message.includes("Supabase") && (message.includes("配置") || message.includes("environment") || message.includes("URL"))
    ? "Supabase 尚未配置"
    : message;
}

function payloadMessage(payload: unknown, fallback: string) {
  if (!payload || typeof payload !== "object") return fallback;
  const data = payload as Record<string, unknown>;
  const message = [data.recovery, data.message, data.error].find((value) => typeof value === "string") as string | undefined;
  return friendlyError(message || fallback);
}

class CancellationResponseError extends Error {
  readonly status: number;

  constructor(status: number, message: string) {
    super(message);
    this.name = "CancellationResponseError";
    this.status = status;
  }
}

function waitForUndoWindow(signal: AbortSignal) {
  return new Promise<void>((resolve) => {
    const finish = () => {
      window.clearTimeout(timer);
      signal.removeEventListener("abort", finish);
      resolve();
    };
    const timer = window.setTimeout(finish, undoWindowMs);
    signal.addEventListener("abort", finish, { once: true });
  });
}

async function fetchAccount(signal?: AbortSignal): Promise<Account> {
  const response = await fetch("/api/account", { signal, cache: "no-store" });
  if (response.status === 401) {
    window.location.assign("/login");
    throw new Error("请先登录");
  }
  const payload = await response.json().catch(() => null);
  if (!response.ok) throw new Error(payloadMessage(payload, "暂时无法读取账户信息"));
  return payload as Account;
}

async function fetchModelCatalog(signal?: AbortSignal) {
  const response = await fetch("/api/models", { signal, cache: "no-store" });
  const payload = await response.json().catch(() => null);
  if (!response.ok) throw new Error(payloadMessage(payload, "暂时无法读取可用模型"));
  return parsePublicModelCatalog(payload);
}

async function fetchSessions(signal?: AbortSignal): Promise<unknown> {
  const response = await fetch("/api/sessions", { signal, cache: "no-store" });
  if (response.status === 401) {
    window.location.assign("/login");
    throw new Error("请先登录");
  }
  const payload = await response.json().catch(() => null);
  if (!response.ok) throw new Error(payloadMessage(payload, "暂时无法读取聊天记录"));
  return payload && typeof payload === "object" ? (payload as { sessions?: unknown }).sessions : null;
}

async function patchSessionModel(sessionId: string, modelId: string, signal?: AbortSignal) {
  const response = await fetch(`/api/sessions/${encodeURIComponent(sessionId)}`, {
    method: "PATCH",
    headers: { "content-type": "application/json" },
    credentials: "same-origin",
    body: JSON.stringify({ model_id: modelId }),
    signal,
  });
  if (response.status === 401) {
    window.location.assign("/login");
    throw new Error("请先登录");
  }
  const payload = await response.json().catch(() => null);
  if (!response.ok) throw new Error(payloadMessage(payload, "模型选择暂时无法同步到云端。"));
}

export default function Home() {
  const [profile, setProfile] = useState<Profile>(emptyProfile);
  const [profileDraft, setProfileDraft] = useState<Profile>(emptyProfile);
  const [accountMenuOpen, setAccountMenuOpen] = useState(false);
  const [activeAccountDialog, setActiveAccountDialog] = useState<AccountDialog | null>(null);
  const [chartLibrary, setChartLibrary] = useState<ChartLibraryRecord[]>([]);
  const [chartLibraryOpen, setChartLibraryOpen] = useState(false);
  const [synastryRelationshipType, setSynastryRelationshipType] = useState<SynastryRelationshipType>("romance");
  const [synastryPendingId, setSynastryPendingId] = useState<string | null>(null);
  const [otherProfileDraft, setOtherProfileDraft] = useState<Profile>(emptyProfile);
  const [synastryReportCard, setSynastryReportCard] = useState<SynastryReportCard | null>(null);
  const [synastryHistory, setSynastryHistory] = useState<SynastryReportCard[]>([]);
  const [dailyStarlanguageCard, setDailyStarlanguageCard] = useState<DailyStarlanguageCard | null>(null);
  const [profileNotice, setProfileNotice] = useState("");
  const [avatarNotice, setAvatarNotice] = useState("");
  const [avatarSaving, setAvatarSaving] = useState(false);
  const [account, setAccount] = useState<Account | null>(null);
  const [accountError, setAccountError] = useState("");
  const [redeemCode, setRedeemCode] = useState("");
  const [redeemError, setRedeemError] = useState("");
  const [redeemMessage, setRedeemMessage] = useState("");
  const [redeeming, setRedeeming] = useState(false);
  const [paymentEnabled, setPaymentEnabled] = useState(false);
  const [paymentPackages, setPaymentPackages] = useState<Array<{ id: string; name: string; description: string; productType: "credit_pack" | "trial" | "subscription"; billingPeriod: string; intervalCount: number; priceCents: number; credits: number }>>([]);
  const [paymentOrder, setPaymentOrder] = useState<{ orderNo: string; payUrl: string | null; qrCode: string | null; status: string } | null>(null);
  const [paymentError, setPaymentError] = useState("");
  const [payingPackageId, setPayingPackageId] = useState<string | null>(null);
  const [signingOut, setSigningOut] = useState(false);
  const [sessions, setSessions] = useState<ChatSession[]>([]);
  const [pinnedSessionIds, setPinnedSessionIds] = useState<string[]>([]);
  const [archivedSessionIds, setArchivedSessionIds] = useState<string[]>([]);
  const [showArchivedSessions, setShowArchivedSessions] = useState(false);
  const [sessionMenuId, setSessionMenuId] = useState<string | null>(null);
  const [pendingSessionDeletion, setPendingSessionDeletion] = useState<ChatSession | null>(null);
  const [modelCatalog, setModelCatalog] = useState<PublicLanguageModelCatalog | null>(null);
  const [activeSessionId, setActiveSessionId] = useState("");
  const [draft, setDraft] = useState("");
  const [draftTheme, setDraftTheme] = useState<Theme | null>(null);
  const [draftEntrypoint, setDraftEntrypoint] = useState<ConsultationEntrypoint | null>(null);
  const [composerNotice, setComposerNotice] = useState("");
  const [consultationPhase, setConsultationPhase] = useState<"undo" | "streaming" | null>(null);
  const [cancellationPending, setCancellationPending] = useState(false);
  const [pendingSessionId, setPendingSessionId] = useState<string | null>(null);
  const [streamingReply, setStreamingReply] = useState<StreamingReply | null>(null);
  const [requestError, setRequestError] = useState<RequestError | null>(null);
  const [birthTimeConsultationConsent, setBirthTimeConsultationConsent] = useState<BirthTimeConsultationConsentState>(
    createBirthTimeConsultationConsentState,
  );
  const [rectificationSessionId, setRectificationSessionId] = useState<string | null>(null);
  const [rectificationPendingQuestion, setRectificationPendingQuestion] = useState<string | null>(null);
  const [rectificationLoading, setRectificationLoading] = useState(false);
  const [rectificationMutationPending, setRectificationMutationPending] = useState(false);
  const [rectificationError, setRectificationError] = useState("");
  const [hydrated, setHydrated] = useState(false);
  const [profileSaving, setProfileSaving] = useState(false);
  const [creatingSession, setCreatingSession] = useState(false);
  const [onboarding, setOnboarding] = useState<OnboardingContent | null>(null);
  const [onboardingError, setOnboardingError] = useState("");
  const [onboardingStep, setOnboardingStep] = useState<OnboardingStep>("name");
  const [onboardingJustCompleted, setOnboardingJustCompleted] = useState(false);
  const [birthTimeJourney, setBirthTimeJourney] = useState<JourneyClientResponse | null>(null);
  const [birthTimeError, setBirthTimeError] = useState("");
  const [birthTimeAssessmentPhase, setBirthTimeAssessmentPhase] = useState<BirthTimeAssessmentPhase | null>(null);
  const [startGreeting, setStartGreeting] = useState("");
  const [presetMessageLength, setPresetMessageLength] = useState(0);
  const conversationEnd = useRef<HTMLDivElement>(null);
  const accountTrigger = useRef<HTMLButtonElement>(null);
  const accountDialog = useRef<HTMLElement>(null);
  const creditTrigger = useRef<HTMLButtonElement>(null);
  const dialogReturnTarget = useRef<HTMLButtonElement | null>(null);
  const closeButton = useRef<HTMLButtonElement>(null);
  const redeemInput = useRef<HTMLInputElement>(null);
  const composerInput = useRef<HTMLTextAreaElement>(null);
  const starterWorkbench = useRef<HTMLDivElement>(null);
  const pendingConsultation = useRef<PendingConsultation | null>(null);
  const cancellationRequests = useRef(new Map<string, Promise<void>>());
  const cancellationFeedbackRequest = useRef<string | null>(null);
  const cancellationInFlight = useRef(false);
  const stoppedRequestAwaitingSettlement = useRef<string | null>(null);
  const stoppedSessionPersistence = useRef(new Map<string, Promise<void>>());
  const modelPersistence = useRef(new SessionModelPersistenceQueue());
  const rectificationPersistence = useRef(new SessionModelPersistenceQueue());
  const modelSyncFailures = useRef(new Set<string>());
  const modelSelectionVersions = useRef(new Map<string, number>());
  const activeSessionIdRef = useRef("");
  const chartLibraryLoadedAccount = useRef("");
  const activeOnboardingRequestIdentity = useRef("");
  const accountRefreshGuard = useRef(createLatestAccountRequestGuard());
  const rectificationQuestionHandoff = useRef(createRectificationQuestionHandoffCoordinator<Theme>());
  const resumeRectificationSession = useRef<(session: ChatSession) => void>(() => undefined);
  const rectificationOpenInFlight = useRef(false);
  const uiPreview = useRef(false);
  const uiPreviewMode = useRef<string | null>(null);
  const birthTimeRevisionPending = useRef(false);
  const birthTimeGuided = useBirthTimeGuidedJourney({
    journey: birthTimeJourney,
    preview: process.env.NODE_ENV === "development" && uiPreview.current,
    onJourney: setBirthTimeJourney,
    onReady: completeGuidedBirthTime,
    onEditBirthTimeDetails: editDeclaredBirthTimeDetails,
  });

  const activeSession = sessions.find((session) => session.id === activeSessionId) ?? sessions[0];
  const activeRectificationSession = activeSession?.sessionType === "birth_time_rectification";
  const rectificationSurfaceOpen = activeRectificationSession
    && activeSession.id === rectificationSessionId;
  const visibleSessions = sessions
    .filter((session) => showArchivedSessions ? archivedSessionIds.includes(session.id) : !archivedSessionIds.includes(session.id))
    .sort((left, right) => Number(pinnedSessionIds.includes(right.id)) - Number(pinnedSessionIds.includes(left.id)));
  const activeError = requestError && requestError.sessionId === activeSession?.id ? requestError.message : "";
  const isLoading = pendingSessionId === activeSession?.id;
  const productEntrypointsDisabled = !hydrated
    || Boolean(pendingSessionId)
    || cancellationPending
    || creatingSession
    || rectificationMutationPending
    || !account
    || !modelCatalog;
  const activeStreamingText = streamingReply && streamingReply.sessionId === activeSession?.id ? streamingReply.text : "";
  const accountId = account?.user.id;
  const rectificationCardAction = resolveRectificationCardAction({
    rectificationCase: account?.rectificationCase ?? null,
    hasUsableBirthTime: account?.hasUsableBirthTime ?? false,
  });
  const rectificationCardLabel = rectificationCardLabels[rectificationCardAction];
  const onboardingFingerprint = onboardingProfileFingerprint(profile);

  useEffect(() => {
    activeSessionIdRef.current = activeSessionId;
  }, [activeSessionId]);


  useEffect(() => {
    if (!hydrated
      || !account
      || !modelCatalog
      || activeSession?.sessionType !== "birth_time_rectification"
      || activeSession.id === rectificationSessionId
      || rectificationLoading
      || rectificationMutationPending
        || creatingSession
      || rectificationError) return;
    resumeRectificationSession.current(activeSession);
  }, [
    account,
    activeSession,
    creatingSession,
    hydrated,
    modelCatalog,
    rectificationError,
    rectificationLoading,
    rectificationMutationPending,
    rectificationSessionId,
  ]);

  useEffect(() => {
    if (!hydrated || !accountId) return;
    const prefix = `jyotisha-session-controls:${accountId}:`;
    setPinnedSessionIds(JSON.parse(localStorage.getItem(`${prefix}pinned`) || "[]"));
    setArchivedSessionIds(JSON.parse(localStorage.getItem(`${prefix}archived`) || "[]"));
  }, [accountId, hydrated]);

  useEffect(() => {
    if (!hydrated || !accountId) return;
    const prefix = `jyotisha-session-controls:${accountId}:`;
    localStorage.setItem(`${prefix}pinned`, JSON.stringify(pinnedSessionIds));
    localStorage.setItem(`${prefix}archived`, JSON.stringify(archivedSessionIds));
  }, [accountId, archivedSessionIds, hydrated, pinnedSessionIds]);

  const activeSuggestions = activeSession?.messages.reduce<readonly string[]>(
    (latest, message) => message.role === "assistant" && message.suggestions?.length ? message.suggestions : latest,
    [],
  ) ?? [];
  useEffect(() => {
    if (!accountId) {
      setChartLibrary([]);
      setSynastryHistory([]);
      chartLibraryLoadedAccount.current = "";
      return;
    }
    if (chartLibraryLoadedAccount.current === accountId) return;
    chartLibraryLoadedAccount.current = accountId;
    setChartLibrary(upsertSelfChart(readChartLibrary(accountId), profile));
    setSynastryHistory(readSynastryHistory(accountId));
    void fetchCloudChartLibrary()
      .then((cloudLibrary) => {
        setChartLibrary(() => {
          const next = upsertSelfChart(cloudLibrary.filter((record) => record.role !== "self"), profile);
          localStorage.setItem(chartLibraryStorageKey(accountId), JSON.stringify(next));
          return next;
        });
      })
      .catch(() => {
        // Cloud chart library is best-effort; local library remains usable.
      });
    void fetchCloudSynastryHistory()
      .then((cloudHistory) => {
        setSynastryHistory((current) => {
          const byId = new Map([...current, ...cloudHistory].map((record) => [record.id, record] as const));
          const next = [...byId.values()].sort((a, b) => b.createdAt - a.createdAt).slice(0, 10);
          writeSynastryHistory(accountId, next);
          return next;
        });
      })
      .catch(() => {
        // Cloud synastry history is best-effort; local history remains usable.
      });
  }, [accountId, profile]);

  useEffect(() => {
    if (!accountId) return;
    setChartLibrary((current) => {
      const next = upsertSelfChart(current, profile);
      localStorage.setItem(chartLibraryStorageKey(accountId), JSON.stringify(next));
      return next;
    });
  }, [accountId, profile]);

  const profileComplete = isProfileComplete(profile);
  const birthTimeRoute = resolveBirthTimeConsultationRoute(profile, birthTimeConsultationConsent, activeSessionId);
  const personalChartAvailable = birthTimeRoute.kind === "consult" && birthTimeRoute.mode !== "general_no_birth_time";

  // Client-side display hint only: an in-memory workflow receipt on the latest
  // assistant answer. After a reload receipts are gone, so the state falls back
  // to "unknown" (the button copy says the server will verify) instead of
  // fabricating an evidence boolean. The server owns real evidence validation.
  const latestAssistantMessage = [...(activeSession?.messages ?? [])]
    .reverse()
    .find((message) => message.role === "assistant");
  const reportEvidenceState: "ready" | "unknown" = latestAssistantMessage?.workflowReceipt
    ? "ready"
    : "unknown";
  // Mirror the server-side birth-time gate (accepted/confirmed + usable active
  // time): reported/candidate users must not see the entry, since the API would
  // reject them with 422. profileComplete alone is not enough.
  const reportBirthTimeUsable = isBirthTimeReadyForConsultation(profile);
  const reportEntryVisible = !rectificationSurfaceOpen
    && profileComplete
    && reportBirthTimeUsable
    && activeSession?.sessionType === "consultation"
    && activeSession.messages.length > 0;
  const starterThemes = personalChartAvailable ? themes : generalGuidedJyotishTopics;
  const dailyStarlanguage = dailyStarlanguageCard ?? (profileComplete ? buildDailyStarlanguageCard(profile) : null);
  const onboardingPending = profileComplete && !onboarding && !onboardingError;
  const currentOnboardingMessage = onboardingJustCompleted
    ? startGreeting || completedOnboardingMessage(profileDraft.name.trim())
    : onboardingStep === "birth"
      ? birthQuestion(profileDraft.name.trim())
      : onboardingStep === "place"
        ? placeQuestion(profileDraft)
        : onboardingStep === "rectification" && birthTimeJourney
          ? assistantIntentCopy(birthTimeJourney.snapshot.assistantIntent)
        : presetOnboardingMessage;
  const shouldStreamOnboarding = !profileComplete;
  const presetMessageFinished = !shouldStreamOnboarding || presetMessageLength >= currentOnboardingMessage.length;
  const onboardingCardReady = presetMessageFinished || birthTimeAssessmentPhase !== null;
  const starterSuggestions = starterThemes.map((theme) => personalChartAvailable
    ? onboarding?.suggestions.find((item) => item.theme === theme.id) ?? { theme: theme.id, text: theme.prompt }
    : { theme: theme.id, text: theme.prompt });
  const starterHomeVisible = profileComplete
    && presetMessageFinished
    && !onboardingPending
    && !rectificationSurfaceOpen
    && !activeSession?.messages.length;
  const daypartGreeting = greetingForHour(new Date().getHours());

  useEffect(() => {
    const controller = new AbortController();
    const bootstrapTimeout = window.setTimeout(() => {
      if (controller.signal.aborted) return;
      controller.abort();
      setAccountError("连接云端服务超时。请检查网络后重试，或返回登录页重新建立会话。");
      setHydrated(true);
    }, 8000);

    async function loadCloudData() {
      try {
        const previewMode = process.env.NODE_ENV === "development"
          ? new URLSearchParams(window.location.search).get("preview")
          : null;
        if (previewMode) {
          uiPreview.current = true;
          uiPreviewMode.current = previewMode;
          if (previewMode === "error") {
            setAccountError("连接云端服务超时。请检查网络后重试，或返回登录页重新建立会话。");
            setHydrated(true);
            return;
          }
          const isAssessmentLoadingPreview = previewMode === "birth-time-assessment-loading";
          const isCompletedCandidatePreview = previewMode === "birth-time-candidate-complete";
          const isRectificationPreview = isGuidedBirthTimePreview(previewMode);
          const previewJourney = isRectificationPreview
            ? guidedBirthTimePreview(previewMode)
            : previewRectificationJourney;
          const previewProfile: Profile = previewMode === "onboarding"
            ? emptyProfile
            : {
              ...emptyProfile,
              name: "林遥",
              date: "1990-06-15",
              time: isCompletedCandidatePreview ? "04:53" : isRectificationPreview || isAssessmentLoadingPreview ? "" : "12:30",
              reportedTime: isRectificationPreview ? "14:30" : isAssessmentLoadingPreview || isCompletedCandidatePreview ? "" : "12:30",
              birthTimeSource: isRectificationPreview ? "approximate" : isAssessmentLoadingPreview || isCompletedCandidatePreview ? "period_only" : "legacy_import",
              birthTimePeriod: isAssessmentLoadingPreview || isCompletedCandidatePreview ? "early_morning" : "",
              birthTimeClue: "",
              uncertaintyBeforeMinutes: isRectificationPreview ? 30 : null,
              uncertaintyAfterMinutes: isRectificationPreview ? 30 : null,
              birthTimeStatus: isCompletedCandidatePreview
                ? "candidate"
                : isAssessmentLoadingPreview
                ? "rectifying"
                : previewJourney.snapshot.state === "candidate"
                || previewJourney.snapshot.state === "confirming"
                || previewJourney.snapshot.state === "ready"
                  ? "candidate"
                  : isRectificationPreview ? "rectifying" : "confirmed",
              rectificationCaseId: isRectificationPreview ? previewJourney.caseId : "",
              countryCode: "CN",
              provinceCode: "110000",
              cityCode: "110000-city",
              districtCode: "110101",
            };
          const previewMessages: Message[] = previewMode === "conversation" || previewMode === "streaming" || previewMode === "partial"
            ? [
              { role: "user", text: "未来半年是否适合换工作？" },
              { role: "assistant", text: "可以先看职业方向、关键时间。\n同时评估现实风险。\n此处只展示本地预览，\n不调用真实星盘。", suggestions: ["先看事业方向", "再看关键时间", "评估现实风险"] },
            ]
            : [];
          const previewSession: ChatSession = {
            id: "preview-session",
            title: previewMessages.length > 0 ? "未来半年是否适合换工作" : "新对话",
            theme: "career",
            modelId: previewModelCatalog.defaultModelId,
            messages: previewMessages,
            updatedAt: timestamp(),
            sessionType: "consultation",
            rectificationCaseId: null,
          };
          setAccount({
            user: { id: "preview-user", email: "preview@local.test" },
            avatar: null,
            credits: 8,
            isAdmin: false,
            adminUrl: null,
            rectificationPriceCredits: 1,
            hasConfirmedBirthTime: previewProfile.birthTimeStatus === "confirmed",
            hasUsableBirthTime: previewProfile.birthTimeStatus === "accepted" || previewProfile.birthTimeStatus === "confirmed",
            rectificationCase: null,
            activeSubscription: null,
            profile: previewProfile,
          });
          setModelCatalog(previewModelCatalog);
          setProfile(previewProfile);
          setProfileDraft(previewProfile);
          if (isRectificationPreview) {
            setBirthTimeJourney(previewJourney);
          }
          if (isAssessmentLoadingPreview) {
            setBirthTimeAssessmentPhase("assessing");
          }
          setOnboardingStep(isAssessmentLoadingPreview ? "birth" : missingProfileStep(previewProfile) ?? "name");
          setSessions([previewSession]);
          setActiveSessionId(previewSession.id);
          const previewGreeting = previewProfile.name.trim() ? createStartGreeting(previewProfile.name) : "";
          setStartGreeting(previewGreeting);
          setOnboarding(previewMode === "onboarding"
            ? null
            : { greeting: previewGreeting, suggestions: themes.map(({ id, prompt }) => ({ theme: id, text: prompt })) });
          setHydrated(true);
          return;
        }

        const [nextAccount, modelCatalogResult, sessionsPayload] = await Promise.all([
          fetchAccount(controller.signal),
          fetchModelCatalog(controller.signal)
            .then((catalog) => ({ catalog, unavailable: false }))
            .catch((caught: unknown) => {
              if (caught instanceof Error && caught.name === "AbortError") throw caught;
              return { catalog: null, unavailable: true };
            }),
          fetchSessions(controller.signal),
        ]);
        const nextModelCatalog = modelCatalogResult.catalog;
        const parsedSessions = readSessions(sessionsPayload, nextModelCatalog);
        let nextSessions = parsedSessions.sessions;
        if (nextSessions.length === 0) {
          if (controller.signal.aborted) return;
          const initialSession = createSession(nextModelCatalog?.defaultModelId ?? "");
          if (nextModelCatalog) {
            await writeChatSession(initialSession.id, {
              title: initialSession.title,
              theme: initialSession.theme,
              model_id: initialSession.modelId,
              messages: initialSession.messages,
              session_type: initialSession.sessionType,
              rectification_case_id: initialSession.rectificationCaseId,
              updated_at: new Date(initialSession.updatedAt).toISOString(),
            }, "create");
          }
          nextSessions = [initialSession];
        }

        if (controller.signal.aborted) return;
        const nextProfile = readProfile(nextAccount.profile);
        setAccount(nextAccount);
        setModelCatalog(nextModelCatalog);
        setProfile(nextProfile);
        setProfileDraft(nextProfile);
        setStartGreeting(nextProfile.name.trim() ? createStartGreeting(nextProfile.name) : "");
        setOnboardingStep(missingProfileStep(nextProfile) ?? "name");
        setSessions(nextSessions);
        setActiveSessionId(nextSessions[0].id);
        if (modelCatalogResult.unavailable) {
          setComposerNotice("模型服务暂时不可用，当前无法发送问题。");
        } else if (parsedSessions.fallbackSessionIds.length > 0) {
          setComposerNotice("此前选择的模型已下线，已切换为默认模型。");
        }
        setAccountError("");

        if (nextModelCatalog && parsedSessions.fallbackSessionIds.length > 0) {
          try {
            await Promise.all(parsedSessions.fallbackSessionIds.map((sessionId) =>
              patchSessionModel(sessionId, nextModelCatalog.defaultModelId, controller.signal),
            ));
          } catch {
            if (!controller.signal.aborted) {
              setComposerNotice("已在当前页面切换为默认模型，但云端同步失败；刷新后可能需要重新选择。");
            }
          }
        }
      } catch (caught) {
        if ((caught as Error).name !== "AbortError" && !controller.signal.aborted) {
          setAccountError(friendlyError(caught instanceof Error ? caught.message : "暂时无法读取云端数据"));
        }
      } finally {
        window.clearTimeout(bootstrapTimeout);
        if (!controller.signal.aborted) setHydrated(true);
      }
    }

    void loadCloudData();
    return () => {
      window.clearTimeout(bootstrapTimeout);
      controller.abort();
    };
  }, []);

  useEffect(() => {
    if (!hydrated || !shouldStreamOnboarding) return;

    if (window.matchMedia("(prefers-reduced-motion: reduce)").matches) {
      const frame = window.requestAnimationFrame(() => setPresetMessageLength(currentOnboardingMessage.length));
      return () => window.cancelAnimationFrame(frame);
    }

    const timer = window.setInterval(() => {
      setPresetMessageLength((current) => {
        const next = Math.min(current + 1, currentOnboardingMessage.length);
        if (next === currentOnboardingMessage.length) window.clearInterval(timer);
        return next;
      });
    }, 26);
    return () => window.clearInterval(timer);
  }, [currentOnboardingMessage, hydrated, shouldStreamOnboarding]);

  useEffect(() => {
    if (!hydrated || !accountId || !profileComplete || uiPreview.current) return;
    const requestIdentity = onboardingRequestIdentity(accountId, onboardingFingerprint);
    if (isCurrentOnboardingRequest(activeOnboardingRequestIdentity.current, requestIdentity)) return;
    activeOnboardingRequestIdentity.current = requestIdentity;
    const presentationName = profile.name;
    const controller = new AbortController();
    setOnboarding(null);
    setOnboardingError("");
    void requestOnboardingWithRecovery(controller.signal, () => {
      if (!controller.signal.aborted
        && isCurrentOnboardingRequest(activeOnboardingRequestIdentity.current, requestIdentity)) {
        setOnboardingError("个性化入门问题准备超时");
      }
    })
      .then((content) => {
        if (controller.signal.aborted
          || !isCurrentOnboardingRequest(activeOnboardingRequestIdentity.current, requestIdentity)) return;
        setOnboarding({
          ...content,
          greeting: createStartGreeting(presentationName),
        });
        setOnboardingError("");
      })
      .catch((caught: unknown) => {
        if (controller.signal.aborted
          || !isCurrentOnboardingRequest(activeOnboardingRequestIdentity.current, requestIdentity)) return;
        if (caught instanceof OnboardingAuthenticationError) {
          window.location.assign("/login");
          return;
        }
        setOnboardingError(caught instanceof Error ? caught.message : "暂时无法准备初始问题");
      });
    return () => {
      if (isCurrentOnboardingRequest(activeOnboardingRequestIdentity.current, requestIdentity)) {
        activeOnboardingRequestIdentity.current = "";
      }
      controller.abort();
    };
  }, [accountId, hydrated, onboardingFingerprint, profile.name, profileComplete]);

  useEffect(() => {
    if (!hydrated || !profileComplete || birthTimeDisplayState(profile)) return;
    let cancelled = false;
    setDailyStarlanguageCard(null);
    void fetchDailyStarlanguage(profile)
      .then((card) => {
        if (!cancelled) setDailyStarlanguageCard(card);
      })
      .catch(() => {
        if (!cancelled) setDailyStarlanguageCard(buildDailyStarlanguageCard(profile));
      });
    return () => {
      cancelled = true;
    };
  }, [hydrated, profile, profileComplete]);

  useEffect(() => {
    if (starterHomeVisible) return;
    const reduceMotion = window.matchMedia("(prefers-reduced-motion: reduce)").matches;
    conversationEnd.current?.scrollIntoView({ behavior: isLoading || reduceMotion ? "auto" : "smooth", block: "end" });
  }, [activeSessionId, activeSession?.messages.length, activeStreamingText, isLoading, onboardingPending, onboardingStep, presetMessageFinished, profileComplete, starterHomeVisible]);

  useEffect(() => {
    if (hydrated && accountId && !profileComplete && onboardingStep === "name" && presetMessageFinished && activeAccountDialog === null) {
      composerInput.current?.focus();
    }
  }, [accountId, activeAccountDialog, hydrated, onboardingStep, presetMessageFinished, profileComplete]);

  useEffect(() => {
    if (activeAccountDialog === null) return;
    window.requestAnimationFrame(() => {
      if (signingOut) return;
      if (activeAccountDialog === "redeem") redeemInput.current?.focus();
      else closeButton.current?.focus();
    });
    const closeOnEscape = (event: globalThis.KeyboardEvent) => {
      if (event.key === "Escape") {
        if (signingOut) return;
        setActiveAccountDialog(null);
        const returnTarget = dialogReturnTarget.current;
        window.requestAnimationFrame(() => returnTarget?.focus());
        return;
      }
      const container = accountDialog.current;
      if (container) keepFocusWithin(event, container);
    };
    window.addEventListener("keydown", closeOnEscape);
    return () => window.removeEventListener("keydown", closeOnEscape);
  }, [activeAccountDialog, signingOut]);

  async function refreshAccount() {
    const requestIdentity = accountRefreshGuard.current.begin();
    try {
      const latest = await fetchAccount();
      if (!accountRefreshGuard.current.isCurrent(requestIdentity)) return;
      const nextProfile = readProfile(latest.profile);
      setProfile(nextProfile);
      setAccount((current) => {
        if (current?.rectificationCase
          && latest.rectificationCase?.caseId === current.rectificationCase.caseId
          && latest.rectificationCase.turnVersion < current.rectificationCase.turnVersion) {
          return {
            ...latest,
            hasConfirmedBirthTime: latest.hasConfirmedBirthTime,
            hasUsableBirthTime: latest.hasUsableBirthTime,
            rectificationCase: current.rectificationCase,
          };
        }
        return latest;
      });
      setAccountError("");
    } catch (caught) {
      if (!accountRefreshGuard.current.isCurrent(requestIdentity)) return;
      setAccountError(caught instanceof Error ? caught.message : "暂时无法读取账户信息");
    }
  }

  function updateSession(sessionId: string, change: (session: ChatSession) => ChatSession) {
    setSessions((current) => current.map((session) => (session.id === sessionId ? change(session) : session)));
  }

  async function persistSession(session: ChatSession, mode: "create" | "update" = "update") {
    if (!account) throw new Error("账户尚未加载完成");
    if (process.env.NODE_ENV === "development" && uiPreview.current) return;
    const values = {
      title: session.title,
      theme: session.theme,
      model_id: session.modelId,
      messages: session.messages,
      session_type: session.sessionType,
      rectification_case_id: session.rectificationCaseId,
      updated_at: new Date(session.updatedAt).toISOString(),
    };
    await writeChatSession(session.id, values, mode);
  }

  async function renameSession(session: ChatSession) {
    const title = window.prompt("重命名聊天记录", session.title)?.trim();
    if (!title || title === session.title) return;
    const nextSession = { ...session, title, updatedAt: timestamp() };
    updateSession(session.id, () => nextSession);
    try {
      await persistSession(nextSession);
    } catch (caught) {
      setComposerNotice(caught instanceof Error ? caught.message : "重命名同步失败");
    }
  }

  async function deleteSession(session: ChatSession) {
    if (!account) return;
    const previousSessions = sessions;
    const nextSessions = sessions.filter((item) => item.id !== session.id);
    setSessions(nextSessions);
    setBirthTimeConsultationConsent((current) => clearBirthTimeConsultationConsent(current, session.id));
    setPinnedSessionIds((current) => current.filter((id) => id !== session.id));
    setArchivedSessionIds((current) => current.filter((id) => id !== session.id));
    if (activeSessionId === session.id) setActiveSessionId(nextSessions[0]?.id ?? "");
    try {
      const response = await fetch(`/api/sessions/${encodeURIComponent(session.id)}`, { method: "DELETE" });
      const payload = await response.json().catch(() => null) as { error?: string } | null;
      if (!response.ok) throw new Error(payload?.error || "删除聊天记录失败");
    } catch (caught) {
      setSessions(previousSessions);
      setComposerNotice(caught instanceof Error ? `删除失败：${caught.message}` : "删除失败");
    }
  }

  function togglePinnedSession(sessionId: string) {
    setPinnedSessionIds((current) => current.includes(sessionId) ? current.filter((id) => id !== sessionId) : [sessionId, ...current]);
  }

  function toggleArchivedSession(sessionId: string) {
    const restoring = archivedSessionIds.includes(sessionId);
    setArchivedSessionIds((current) => restoring ? current.filter((id) => id !== sessionId) : [sessionId, ...current]);
    if (!restoring && activeSessionId === sessionId) {
      setActiveSessionId(visibleSessions.find((session) => session.id !== sessionId)?.id ?? "");
    }
    setComposerNotice(restoring ? "已恢复到聊天记录。" : "已归档，可在左侧归档中恢复。");
  }

  async function shareSession(session: ChatSession) {
    const sharePayload = {
      share_payload_version: 1,
      exported_at: new Date().toISOString(),
      title: session.title,
      theme: session.theme,
      message_count: session.messages.length,
      messages: session.messages.map((message) => ({ role: message.role, text: message.text })),
    };
    const reportMarkdown = consultationReportMarkdown({ title: session.title, messages: session.messages });
    const transcript = [
      `Jyotisha 对话：${session.title}`,
      "",
      ...session.messages.map((message) => `${message.role === "user" ? "我" : "Jyotisha"}：${message.text}`),
      "",
      "---- Markdown 报告 ----",
      reportMarkdown,
      "",
      "---- JSON 分享包 ----",
      JSON.stringify(sharePayload, null, 2),
    ].join("\n");
    try {
      await navigator.clipboard.writeText(transcript);
      setComposerNotice("已复制当前聊天，可粘贴转发。");
    } catch {
      setComposerNotice("无法访问剪贴板，请手动复制聊天内容。");
    }
  }

  async function startNewChat() {
    if (!account || !modelCatalog || creatingSession) return;
    const nextSession = createSession(modelCatalog.defaultModelId);
    const previousSessionId = activeSession?.id ?? "";
    setCreatingSession(true);
    setSessions((current) => [nextSession, ...current]);
    setActiveSessionId(nextSession.id);
    setDraft("");
    setDraftTheme(null);
    setDraftEntrypoint(null);
    setComposerNotice("");
    setRequestError(null);
    try {
      await persistSession(nextSession, "create");
    } catch (caught) {
      setSessions((current) => current.filter((session) => session.id !== nextSession.id));
      setActiveSessionId(previousSessionId);
      setRequestError({
        sessionId: previousSessionId,
        message: caught instanceof Error ? caught.message : "新对话未能保存到云端。",
      });
    } finally {
      setCreatingSession(false);
    }
  }

  function selectSession(sessionId: string) {
    const nextSession = sessions.find((session) => session.id === sessionId);
    setActiveSessionId(sessionId);
    setDraft("");
    setDraftEntrypoint(null);
    setComposerNotice("");
    if (nextSession?.sessionType === "birth_time_rectification") {
      setRectificationError("");
      if (nextSession.id !== rectificationSessionId) {
        resumeRectificationSession.current(nextSession);
      }
    }
  }

  async function selectSessionModel(modelId: string) {
    const userId = account?.user.id;
    if (!activeSession || !modelCatalog || !userId || pendingSessionId || cancellationPending || creatingSession) return;
    const selectedModel = modelCatalog.models.find((model) => model.id === modelId);
    const retryingFailedSync = activeSession.modelId === modelId && modelSyncFailures.current.has(activeSession.id);
    if (!selectedModel || (activeSession.modelId === modelId && !retryingFailedSync)) return;

    const nextSession: ChatSession = retryingFailedSync
      ? activeSession
      : { ...activeSession, modelId, updatedAt: timestamp() };
    const selectionVersion = (modelSelectionVersions.current.get(nextSession.id) ?? 0) + 1;
    modelSelectionVersions.current.set(nextSession.id, selectionVersion);
    if (!retryingFailedSync) updateSession(activeSession.id, () => nextSession);
    setRequestError(null);
    setComposerNotice("");

    try {
      await modelPersistence.current.enqueue(nextSession.id, () => persistSessionModelSelection(
        async ({ values, sessionId }) => {
          if (process.env.NODE_ENV === "development" && uiPreview.current) {
            return { found: true, error: null };
          }
          try {
            await patchSessionModel(sessionId, values.model_id);
            return { found: true, error: null };
          } catch (error) {
            return {
              found: false,
              error: error instanceof Error ? error.message : "模型选择暂时无法同步到云端。",
            };
          }
        },
        userId,
        nextSession.id,
        modelId,
      ));
      if (modelSelectionVersions.current.get(nextSession.id) !== selectionVersion) return;
      modelSelectionVersions.current.delete(nextSession.id);
      modelSyncFailures.current.delete(nextSession.id);
    } catch (caught) {
      if (modelSelectionVersions.current.get(nextSession.id) !== selectionVersion) return;
      modelSelectionVersions.current.delete(nextSession.id);
      modelSyncFailures.current.add(nextSession.id);
      if (activeSessionIdRef.current === nextSession.id) {
        setComposerNotice(`已在当前页面选择 ${selectedModel.label}，但云端同步失败；再次选择当前模型即可重试。`);
      }
      setRequestError({
        sessionId: nextSession.id,
        message: caught instanceof Error ? caught.message : "模型选择暂时无法同步到云端。",
      });
    }
  }

  function openAccountDialog(dialog: AccountDialog, returnTarget: HTMLButtonElement | null = accountTrigger.current) {
    dialogReturnTarget.current = returnTarget ?? accountTrigger.current;
    setAccountMenuOpen(false);
    setAccountError("");
    switch (dialog) {
      case "profile":
        setProfileDraft(profile);
        setProfileNotice("");
        setAvatarNotice("");
        break;
      case "redeem":
        setRedeemError("");
        setRedeemMessage("");
        setPaymentEnabled(false);
        setPaymentPackages([]);
        setPaymentOrder(null);
        setPaymentError("");
        break;
      case "logout":
        break;
      default: {
        const unreachable: never = dialog;
        return unreachable;
      }
    }
    setActiveAccountDialog(dialog);
  }

  function closeAccountDialog() {
    if (signingOut) return;
    setActiveAccountDialog(null);
    const returnTarget = dialogReturnTarget.current;
    window.requestAnimationFrame(() => returnTarget?.focus());
  }

  async function persistAvatar(patch: BeamAvatarPatch) {
    if (!account?.avatar || avatarSaving) return;
    setAvatarSaving(true);
    setAvatarNotice("");
    setAccountError("");
    try {
      const response = await fetch("/api/account/avatar", {
        method: "PATCH",
        credentials: "same-origin",
        headers: { "content-type": "application/json" },
        body: JSON.stringify(patch),
      });
      const payload = await response.json().catch(() => null) as { avatar?: unknown; error?: string } | null;
      if (!response.ok) throw new Error(payload?.error || "头像暂时无法保存。");
      const avatar = beamAvatarSchema.parse(payload?.avatar);
      setAccount((current) => current ? { ...current, avatar } : current);
      setAvatarNotice(patch.action === "randomize" ? "已生成并保存新头像。" : "头像配色已保存。");
    } catch (caught) {
      setAccountError(friendlyError(caught instanceof Error ? caught.message : "头像保存失败"));
    } finally {
      setAvatarSaving(false);
    }
  }

  async function persistProfile(nextProfile: Profile) {
    if (!account) throw new Error("账户尚未加载完成");
    if (process.env.NODE_ENV === "development" && uiPreview.current) return;
    const birthPlace = selectedBirthPlace(nextProfile);
    const response = await fetch("/api/account", {
      method: "PATCH",
      credentials: "same-origin",
      headers: { "content-type": "application/json" },
      body: JSON.stringify({
        name: nextProfile.name.trim() || null,
        birth_date: nextProfile.date || null,
        ...birthTimePersistenceValues(nextProfile),
        country_code: nextProfile.countryCode,
        province_code: nextProfile.provinceCode || null,
        city_code: nextProfile.cityCode || null,
        district_code: nextProfile.districtCode || null,
        birth_place_label: nextProfile.birthPlaceLabel || null,
        birth_place_type: nextProfile.birthPlaceType || null,
        birth_place_provider: nextProfile.birthPlaceProvider || null,
        birth_place_provider_id: nextProfile.birthPlaceProviderId || null,
        latitude: birthPlace?.lat ?? null,
        longitude: birthPlace?.lon ?? null,
        timezone_id: nextProfile.timezoneId || null,
        timezone_offset: birthPlace?.tz ?? null,
        timezone_source: nextProfile.timezoneSource || null,
      }),
    });
    if (!response.ok) {
      const payload = await response.json().catch(() => null) as { error?: string } | null;
      throw new Error(payload?.error || "账户资料暂时无法保存。");
    }
    await saveCloudChartProfile({ ...buildSelfChartRecord(nextProfile), updatedAt: timestamp() }).catch(() => null);
  }

  async function saveOtherChart(event: FormEvent<HTMLFormElement>) {
    event.preventDefault();
    const nextProfile = { ...otherProfileDraft, name: otherProfileDraft.name.trim() };
    if (missingOtherProfileStep(nextProfile)) {
      setAccountError("请补全其他星盘的称呼、出生时间和出生地点。");
      return;
    }
    if (!accountId) return;
    let record: ChartLibraryRecord = {
      id: globalThis.crypto.randomUUID(),
      role: "other",
      profile: nextProfile,
      updatedAt: timestamp(),
    };
    let cloudSaved = false;
    try {
      record = await saveCloudChartProfile(record);
      cloudSaved = true;
    } catch {
      setProfileNotice("已保存到本地星盘库；云端同步失败，稍后会继续使用本地记录。");
      setAccountError("");
    }
    setChartLibrary((current) => {
      const next = [...upsertSelfChart(current, profile), record];
      localStorage.setItem(chartLibraryStorageKey(accountId), JSON.stringify(next));
      return next;
    });
    setOtherProfileDraft(emptyProfile);
    if (cloudSaved) {
      setAccountError("");
      setProfileNotice("已保存到云端星盘库。请选择关系类型后点击“用于合盘”。");
    }
  }

  async function deleteOtherChart(recordId: string) {
    if (!accountId) return;
    let cloudDeleted = false;
    try {
      await deleteCloudChartProfile(recordId);
      cloudDeleted = true;
    } catch {
      setAccountError("");
    }
    setChartLibrary((current) => {
      const next = current.filter((record) => record.id !== recordId || record.role === "self");
      localStorage.setItem(chartLibraryStorageKey(accountId), JSON.stringify(next));
      return next;
    });
    setAccountError("");
    setProfileNotice(cloudDeleted
      ? "已从云端星盘库删除。"
      : "已从本地星盘库删除；云端同步失败，稍后云端可能仍显示旧记录。");
  }

  async function makeDefaultChart(record: ChartLibraryRecord) {
    if (record.role !== "other" || profileSaving) return;
    setProfileSaving(true);
    setAccountError("");
    try {
      await persistProfile(record.profile);
      setProfile(record.profile);
      setProfileDraft(record.profile);
      setProfileNotice("已设为当前默认星盘。");
    } catch (caught) {
      setAccountError(friendlyError(caught instanceof Error ? caught.message : "默认星盘保存失败"));
    } finally {
      setProfileSaving(false);
    }
  }

  async function assessSavedBirthTime(nextProfile: Profile) {
    const result = process.env.NODE_ENV === "development" && uiPreview.current
      ? previewRectificationJourney
      : await requestBirthTimeAssessment();
    const nextStatus = result.snapshot.state === "ready"
      ? "confirmed"
      : result.snapshot.state === "candidate"
        ? "candidate"
        : "rectifying";
    const assessedProfile: Profile = {
      ...nextProfile,
      time: result.snapshot.activeTime ?? "",
      birthTimeStatus: nextStatus,
      rectificationCaseId: result.caseId,
    };
    setBirthTimeJourney(result);
    setBirthTimeError("");
    setProfile(assessedProfile);
    setProfileDraft(assessedProfile);
    return assessedProfile;
  }

  async function saveProfile(event: FormEvent<HTMLFormElement>) {
    event.preventDefault();
    if (!profileDraft.name.trim() || !isBirthTimeDraftReady(profileDraft) || !selectedBirthPlace(profileDraft) || !account || profileSaving) return;
    setProfileSaving(true);
    setProfileNotice("");
    setAccountError("");
    try {
      const declarationChanged = birthProfileDeclarationChanged(profile, profileDraft);
      await persistProfile(profileDraft);
      setProfile(profileDraft);
      setProfileDraft(profileDraft);
      setRectificationError("");
      if (declarationChanged) {
        setBirthTimeConsultationConsent(createBirthTimeConsultationConsentState());
        setAccount((current) => current ? { ...current, rectificationCase: null } : current);
        void refreshAccount();
      }
      setProfileNotice(profileDraft.birthTimeStatus === "confirmed"
        ? "出生资料已保存到云端，可在同一账号的其他设备使用。"
        : `出生资料已保存。${birthTimeConsultationOptionsCopy(profileDraft)}`);
    } catch (caught) {
      setAccountError(friendlyError(caught instanceof Error ? caught.message : "出生资料保存失败"));
    } finally {
      setProfileSaving(false);
    }
  }

  async function saveOnboardingName() {
    const name = draft.replace(/\s+/g, " ").trim().slice(0, 80);
    if (!name || !account || profileSaving) return;
    const nextProfile = { ...profileDraft, name };
    setProfileSaving(true);
    setAccountError("");
    try {
      await persistProfile(nextProfile);
      setProfile(nextProfile);
      setProfileDraft(nextProfile);
      setStartGreeting(createStartGreeting(nextProfile.name));
      setDraft("");
      setPresetMessageLength(0);
      const nextStep = missingProfileStep(nextProfile);
      if (nextStep) setOnboardingStep(nextStep);
      else setOnboardingJustCompleted(false);
    } catch (caught) {
      setAccountError(friendlyError(caught instanceof Error ? caught.message : "称呼保存失败"));
    } finally {
      setProfileSaving(false);
    }
  }

  async function saveOnboardingBirth(event: FormEvent<HTMLFormElement>) {
    event.preventDefault();
    if (!isBirthTimeDraftReady(profileDraft) || !account || profileSaving) return;
    setProfileSaving(true);
    setBirthTimeAssessmentPhase("saving_profile");
    setAccountError("");
    try {
      await persistProfile(profileDraft);
      birthTimeRevisionPending.current = false;
      setProfile(profileDraft);
      setPresetMessageLength(0);
      const nextStep = missingProfileStep(profileDraft);
      if (nextStep) setOnboardingStep(nextStep);
      else setOnboardingJustCompleted(false);
    } catch (caught) {
      setAccountError(friendlyError(caught instanceof Error ? caught.message : "出生时间保存失败"));
    } finally {
      setBirthTimeAssessmentPhase(null);
      setProfileSaving(false);
    }
  }

  function editDeclaredBirthTimeDetails() {
    birthTimeRevisionPending.current = true;
    setBirthTimeError("");
    setPresetMessageLength(0);
    setOnboardingStep("birth");
  }

  async function saveOnboardingPlace(event: FormEvent<HTMLFormElement>) {
    event.preventDefault();
    if (!selectedBirthPlace(profileDraft) || !account || profileSaving) return;
    setProfileSaving(true);
    setBirthTimeAssessmentPhase("entering_home");
    setAccountError("");
    try {
      await persistProfile(profileDraft);
      setProfile(profileDraft);
      setProfileDraft(profileDraft);
      setStartGreeting(createStartGreeting(profileDraft.name));
      setPresetMessageLength(0);
      setOnboardingJustCompleted(false);
    } catch (caught) {
      setAccountError(friendlyError(caught instanceof Error ? caught.message : "出生地点保存失败"));
    } finally {
      setBirthTimeAssessmentPhase(null);
      setProfileSaving(false);
    }
  }

  function completeGuidedBirthTime(result: JourneyClientResponse) {
    if (result.nextAction.kind !== "ready") return;
    const confirmedProfile: Profile = {
      ...profileDraft,
      time: result.nextAction.activeTime,
      birthTimeStatus: "confirmed",
      rectificationCaseId: result.caseId,
    };
    setProfile(confirmedProfile);
    setProfileDraft(confirmedProfile);
    setPresetMessageLength(0);
    setOnboardingJustCompleted(false);
  }

  async function retryBirthTimeAssessment() {
    if (!account || profileSaving) return;
    setProfileSaving(true);
    setBirthTimeError("");
    try {
      const assessedProfile = await assessSavedBirthTime(profileDraft);
      setPresetMessageLength(0);
      if (assessedProfile.birthTimeStatus === "confirmed") setOnboardingJustCompleted(false);
    } catch (caught) {
      setBirthTimeError(caught instanceof Error ? caught.message : "生时评估暂时不可用，请稍后重试。");
    } finally {
      setProfileSaving(false);
    }
  }

  useEffect(() => {
    if (activeAccountDialog !== "redeem") return;
    void fetch("/api/payment/packages", { cache: "no-store" }).then(async (response) => {
      const payload = await response.json().catch(() => null);
      if (response.ok && payload?.enabled === true) {
        setPaymentEnabled(true);
        setPaymentPackages(payload.packages || []);
        return;
      }
      if (!response.ok) setPaymentError("套餐支付暂时不可用，请稍后重试");
    }).catch(() => {
      setPaymentError("套餐支付暂时不可用，请稍后重试");
    });
  }, [activeAccountDialog]);

  useEffect(() => {
    if (!paymentOrder || paymentOrder.status === "paid") return;
    const timer = window.setInterval(() => {
      void fetch(`/api/payment/epay/status?orderNo=${encodeURIComponent(paymentOrder.orderNo)}`, { cache: "no-store" }).then(async (response) => {
        const payload = await response.json().catch(() => null);
        if (!response.ok) return;
        setPaymentOrder((current) => current ? { ...current, status: payload.status } : current);
        if (payload.status === "paid") void refreshAccount();
      });
    }, 3000);
    return () => window.clearInterval(timer);
  }, [paymentOrder]);

  async function createPayment(packageId: string) {
    if (payingPackageId) return;
    setPayingPackageId(packageId); setPaymentError("");
    try {
      const response = await fetch("/api/payment/epay/create", { method: "POST", headers: { "content-type": "application/json" }, body: JSON.stringify({ packageId }) });
      const payload = await response.json().catch(() => null);
      if (!response.ok) throw new Error(payload?.error || "创建支付失败");
      if (typeof payload?.orderNo !== "string" || typeof payload?.payUrl !== "string") throw new Error("创建支付失败");
      setPaymentOrder({ orderNo: payload.orderNo, payUrl: payload.payUrl, qrCode: payload.qrCode ?? null, status: "pending" });
      window.open(payload.payUrl, "_blank", "noopener,noreferrer");
    } catch (caught) { setPaymentError(caught instanceof Error ? caught.message : "创建支付失败"); } finally { setPayingPackageId(null); }
  }

  async function redeem(event: FormEvent<HTMLFormElement>) {
    event.preventDefault();
    const code = redeemCode.trim();
    if (!code || redeeming) return;
    setRedeeming(true);
    setRedeemError("");
    setRedeemMessage("");
    try {
      const response = await fetch("/api/redeem", {
        method: "POST",
        headers: { "content-type": "application/json" },
        body: JSON.stringify({ code }),
      });
      const payload = await response.json().catch(() => null);
      if (response.status === 401) {
        window.location.assign("/login");
        return;
      }
      if (!response.ok) throw new Error(payloadMessage(payload, "兑换码无效或已使用"));
      const result = payload as { credits: number; message?: string };
      setAccount((current) => current ? { ...current, credits: result.credits } : current);
      setRedeemCode("");
      setRedeemMessage(result.message || `兑换成功，当前余额 ${result.credits} 点。`);
    } catch (caught) {
      setRedeemError(caught instanceof Error ? caught.message : "兑换失败，请稍后重试");
    } finally {
      setRedeeming(false);
    }
  }

  async function signOut() {
    if (signingOut) return;
    setSigningOut(true);
    setAccountError("");
    try {
      await selfHostedOtpActions.signOut();
      window.location.assign("/login");
    } catch (caught) {
      const message = caught instanceof Error ? caught.message : "退出失败";
      setAccountError(friendlyError(message));
      setSigningOut(false);
    }
  }

  function chooseSuggestedQuestion(
    question: string,
    theme?: Theme,
    entrypoint: ConsultationEntrypoint | null = null,
  ) {
    if (pendingSessionId || cancellationInFlight.current) return;
    setDraft(question);
    setDraftTheme(theme ?? null);
    setDraftEntrypoint(entrypoint);
    setComposerNotice("");
    window.requestAnimationFrame(() => composerInput.current?.focus());
  }

  function chooseConversationSuggestion(suggestion: string) {
    if (suggestion !== rectifyBeforeConsultationSuggestion
      || activeSession?.sessionType !== "consultation") {
      chooseSuggestedQuestion(suggestion);
      return;
    }
    const originalQuestion = [...activeSession.messages]
      .reverse()
      .find((message) => message.role === "user")?.text.trim();
    if (!originalQuestion) {
      void openBirthTimeRectification(null, activeSession);
      return;
    }
    rectificationQuestionHandoff.current.capture({
      question: originalQuestion,
      sessionId: activeSession.id,
      theme: activeSession.theme,
    });
    void openBirthTimeRectification(originalQuestion, activeSession);
  }

  function draftDailyStarlanguageQuestion() {
    chooseSuggestedQuestion(
      personalChartAvailable ? "深入看今日" : "印度占星通常如何观察每日趋势？",
      "timing",
      personalChartAvailable ? "daily_starlanguage" : null,
    );
  }

  async function openBirthTimeRectification(
    pendingConsultationQuestion: string | null = null,
    sourceSessionOverride: ChatSession | null = null,
  ) {
    if (!account || !modelCatalog || creatingSession || rectificationLoading || rectificationOpenInFlight.current
      || rectificationMutationPending) return;
    const missingStep = missingProfileStep(profile);
    if (missingStep) {
      setRectificationSessionId(null);
      setRectificationPendingQuestion(null);
      setOnboardingStep(missingStep);
      setComposerNotice("请先完成出生资料，再开始生时校正。");
      return;
    }
    const sourceSession = sourceSessionOverride ?? activeSession;
    if (!sourceSession) return;
    const existing = sourceSession.sessionType === "birth_time_rectification"
      ? sourceSession
      : sessions.find((session) => session.sessionType === "birth_time_rectification") ?? null;
    const rectificationSession = existing ?? createSession(modelCatalog.defaultModelId, "birth_time_rectification");
    const requestedQuestion = pendingConsultationQuestion ?? rectificationQuestionHandoff.current.peek()?.question ?? null;

    rectificationOpenInFlight.current = true;
    setRectificationLoading(true);
    setRectificationError("");

    try {
      if (!existing) {
        await rectificationPersistence.current.enqueue(
          rectificationSession.id,
          () => persistSession(rectificationSession, "create"),
        );
        setSessions((current) => [rectificationSession, ...current.filter((session) => session.id !== rectificationSession.id)]);
      }
      setRectificationPendingQuestion(requestedQuestion);
      setDraft("");
      setDraftTheme(null);
      setDraftEntrypoint(null);
      setRectificationSessionId(rectificationSession.id);
      activeSessionIdRef.current = rectificationSession.id;
      setActiveSessionId(rectificationSession.id);
    } catch {
      setComposerNotice("生时校正会话暂时无法创建，请稍后重试。");
    } finally {
      rectificationOpenInFlight.current = false;
      setRectificationLoading(false);
    }
  }

  resumeRectificationSession.current = (session) => {
    void openBirthTimeRectification(null, session);
  };

  function handleRectificationProfileIncomplete() {
    setRectificationError("profile_incomplete");
    setRectificationSessionId(null);
    setRectificationPendingQuestion(null);
    const missingStep = missingProfileStep(profile);
    if (missingStep) {
      setOnboardingStep(missingStep);
      setComposerNotice("请先完成出生资料，再开始生时校正。");
      return;
    }
    openAccountDialog("profile");
    setProfileNotice("服务端未能读取完整出生资料，请重新确认并保存。");
    void refreshAccount();
  }

  function handleRectificationMessagesChange(messages: Message[]) {
    if (!rectificationSessionId) return;
    updateSession(rectificationSessionId, (session) => ({
      ...session,
      messages,
      updatedAt: timestamp(),
    }));
  }

  async function draftSynastryQuestionFromChart(record: ChartLibraryRecord, relationshipType: SynastryRelationshipType) {
    if (record.role !== "other") return;
    if (synastryPendingId) return;
    const baseQuestion = buildSynastryQuestion(profile, record.profile, relationshipType);
    setSynastryPendingId(record.id);
    setComposerNotice("正在计算基础合盘证据，请稍候。");
    try {
      const response = await fetch("/api/synastry", {
        method: "POST",
        headers: { "Content-Type": "application/json" },
        body: JSON.stringify({ selfProfile: profile, partnerProfile: record.profile, relationshipType }),
      });
      const payload = await response.json().catch(() => null) as { status?: string; claimStatus?: string; blockedLayers?: string[]; evidenceLayers?: string[]; synastry?: { total_score?: number; max_score?: number; assessment?: string }; relationshipReport?: { headline?: string; scoreBand?: string; strengths?: string[]; risks?: string[]; nextEvidence?: string[] } } | null;
      if (response.ok && payload?.status === "ok") {
        const score = payload.synastry?.total_score;
        const max = payload.synastry?.max_score;
        const assessment = payload.synastry?.assessment;
        const layers = (payload.evidenceLayers || []).join(" / ") || "Ashtakoot / Moon / D9";
        const evidenceSummary = relationshipType === "business"
          ? `已完成基础商业合作证据筛查：${layers}；声明状态：${payload.claimStatus || "partial"}；未用层：${(payload.blockedLayers || []).join(" / ") || "A10 / 双方 Dasha-Narayana / 功能吉凶"}。请勿将其表述为合作保证或精确时点。`
          : `已计算基础合盘证据：${layers}；Ashtakoot ${score ?? "?"}/${max ?? "?"}，初步评级：${assessment || "待解释"}。请基于这个证据包继续分析。`;
        const reportCard: SynastryReportCard = {
          id: `${record.id}-${Date.now()}`,
          partnerName: record.profile.name || "对方",
          score,
          maxScore: max,
          assessment,
          headline: payload.relationshipReport?.headline,
          scoreBand: payload.relationshipReport?.scoreBand,
          strengths: payload.relationshipReport?.strengths,
          risks: payload.relationshipReport?.risks,
          nextEvidence: payload.relationshipReport?.nextEvidence,
          createdAt: Date.now(),
        };
        let savedReportCard = reportCard;
        if (accountId) {
          try {
            savedReportCard = await saveCloudSynastryReport(reportCard);
          } catch {
            // Local history remains the fallback when cloud persistence is unavailable.
          }
        }
        setSynastryReportCard(savedReportCard);
        if (accountId) {
          setSynastryHistory((current) => {
            const next = [savedReportCard, ...current.filter((item) => item.id !== savedReportCard.id)].slice(0, 10);
            writeSynastryHistory(accountId, next);
            return next;
          });
        }
        chooseSuggestedQuestion([
          baseQuestion,
          "",
          evidenceSummary,
          payload.relationshipReport?.headline ? `结构化摘要：${payload.relationshipReport.headline}` : "",
        ].join("\n"), relationshipType === "business" ? "career" : "marriage");
      } else {
        chooseSuggestedQuestion(baseQuestion, relationshipType === "business" ? "career" : "marriage");
        setComposerNotice(payload?.status === "blocked" ? "合盘计算暂时不可用，已先生成问题草稿。" : "已生成合盘问题草稿。");
      }
    } catch {
      chooseSuggestedQuestion(baseQuestion, relationshipType === "business" ? "career" : "marriage");
      setComposerNotice("合盘计算暂时不可用，已先生成问题草稿。");
    } finally {
      setSynastryPendingId(null);
    }
    closeAccountDialog();
  }

  async function requestCancellation(requestId: string) {
    const existing = cancellationRequests.current.get(requestId);
    if (existing) return existing;

    const cancellation = (async () => {
      const response = await fetch("/api/consult/cancel", {
        method: "POST",
        headers: { "content-type": "application/json" },
        body: JSON.stringify({ requestId }),
        keepalive: true,
      });
      const payload: unknown = await response.json().catch(() => null);
      if (!response.ok) {
        throw new CancellationResponseError(
          response.status,
          payloadMessage(payload, "暂时无法确认点数已退回"),
        );
      }
      if (!payload || typeof payload !== "object") return;
      const credits = "credits" in payload ? payload.credits : null;
      if (typeof credits === "number") {
        setAccount((current) => current ? { ...current, credits } : current);
      }
    })();
    cancellationRequests.current.set(requestId, cancellation);
    return cancellation;
  }

  async function confirmCancellation(requestId: string, sessionId: string, confirmedNotice: string) {
    try {
      await requestCancellation(requestId);
      if (cancellationFeedbackRequest.current === requestId && activeSessionIdRef.current === sessionId) {
        setComposerNotice(confirmedNotice);
      }
    } catch (error) {
      if (cancellationFeedbackRequest.current === requestId && activeSessionIdRef.current === sessionId) {
        setComposerNotice(error instanceof CancellationResponseError && error.status === 409
          ? "回答已完成结算，本次已计费；问题仍保留在输入框。"
          : "问题已放回输入框；暂时无法确认点数状态，请稍后在账户中核对。");
        setRequestError((current) => current?.sessionId === sessionId ? current : {
          sessionId,
          message: error instanceof Error ? error.message : "暂时无法确认点数状态。",
        });
      }
      void refreshAccount();
    }
  }

  async function stopResponse() {
    const pending = pendingConsultation.current;
    if (!pending || pending.cancelled) return;

    const isPreview = process.env.NODE_ENV === "development" && uiPreview.current;
    if (pending.phase === "streaming" && !isPreview) {
      stoppedRequestAwaitingSettlement.current = pending.requestId;
      cancellationInFlight.current = true;
      setCancellationPending(true);
    }
    pendingConsultation.current = { ...pending, cancelled: true };
    pending.controller.abort();

    if (pending.partialReply) {
      const stoppedSession: ChatSession = {
        ...pending.optimisticSession,
        messages: [...pending.optimisticSession.messages, { role: "assistant", text: pending.partialReply }],
        updatedAt: timestamp(),
      };
      updateSession(pending.sessionId, () => stoppedSession);
      setStreamingReply(null);
      setPendingSessionId(null);
      setConsultationPhase(null);
      setRequestError(null);
      setComposerNotice("已停止回答。模型已开始生成，本次将计费，现有内容已保留。");
      if (!isPreview) {
        const persistence = persistSession(stoppedSession).catch((error) => {
          setRequestError({
            sessionId: pending.sessionId,
            message: error instanceof Error ? error.message : "已停止的回答暂时无法同步。",
          });
        });
        stoppedSessionPersistence.current.set(pending.requestId, persistence);
      }
      if (!isPreview) {
        void refreshAccount();
      } else if (pendingConsultation.current?.requestId === pending.requestId) {
        pendingConsultation.current = null;
      }
      return;
    }

    updateSession(pending.sessionId, () => pending.previousSession);
    setOnboardingJustCompleted(pending.previousOnboardingState);
    setDraft(pending.question);
    setDraftTheme(pending.theme);
    setDraftEntrypoint(pending.entrypoint);
    setStreamingReply(null);
    setPendingSessionId(null);
    setConsultationPhase(null);
    setRequestError(null);
    cancellationFeedbackRequest.current = pending.rectificationHandoff ? null : pending.requestId;
    setComposerNotice(pending.rectificationHandoff
      ? "已停止，原问题仍由校正案例保留；正在释放本次继续操作…"
      : "已停止，问题已放回输入框，正在确认点数…");
    window.requestAnimationFrame(() => composerInput.current?.focus());

    if (pending.phase === "undo" || isPreview) {
      if (pendingConsultation.current?.requestId === pending.requestId) {
        pendingConsultation.current = null;
      }
      setComposerNotice("已停止，问题已放回输入框，本次未扣点。");
      return;
    }

    if (pending.rectificationHandoff) {
      setComposerNotice("已停止；原问题仍保留，可刷新校正状态后重试。");
    } else {
      await confirmCancellation(
        pending.requestId,
        pending.sessionId,
        "已停止，问题已放回输入框，本次未扣点。",
      );
    }
  }

  function completeConsultationInterface(requestId: string) {
    if (pendingConsultation.current?.requestId !== requestId) return;
    pendingConsultation.current = null;
    setStreamingReply(null);
    setPendingSessionId(null);
    setConsultationPhase(null);
  }

  async function send(
    text: string,
    requestedTheme?: Theme,
    entrypoint: ConsultationEntrypoint | null = null,
    consentGrantedForRequest: ConsultationBirthTimeMode | null = null,
    targetSessionId: string | null = null,
    rectificationHandoff: ConsultationRectificationHandoff | null = null,
  ): Promise<boolean> {
    const originalQuestion = text;
    const question = text.trim();
    const currentSession = targetSessionId
      ? sessions.find((session) => session.id === targetSessionId)
      : activeSession;
    if (!question || !currentSession || !modelCatalog || pendingSessionId
      || cancellationInFlight.current || pendingConsultation.current || !account) return false;

    if (!isProfileComplete(profile)) {
      openAccountDialog("profile");
      setProfileNotice("请先补充出生资料，才能进行星盘计算。");
      return false;
    }

    if (entrypoint === "birth_time_rectification") {
      await openBirthTimeRectification(null);
      return false;
    }

    const birthPlace = selectedBirthPlace(profile);
    if (!birthPlace) return false;

    const theme = requestedTheme ?? currentSession.theme;
    const sessionId = currentSession.id;
    const consentForDecision = consentGrantedForRequest === "unverified_birth_time"
      ? grantBirthTimeConsultationConsent(
        birthTimeConsultationConsent,
        sessionId,
        "unverified_birth_time",
      )
      : birthTimeConsultationConsent;
    const initialConsultationRoute = resolveBirthTimeConsultationRoute(
      profile,
      consentForDecision,
      sessionId,
    );
    const consultationRoute = initialConsultationRoute.kind === "choice"
      ? { kind: "consult" as const, mode: "general_no_birth_time" as const, time: null }
      : initialConsultationRoute;

    if (account.credits <= 0 && !account.activeSubscription) {
      openAccountDialog("redeem", creditTrigger.current);
      return false;
    }

    const [year, month, day] = profile.date.split("-").map(Number);
    const [hour, minute] = consultationRoute.time?.split(":").map(Number) ?? [];

    const preservedMessages = onboardingJustCompleted && currentSession.messages.length === 0
      ? completedOnboardingTranscript(profile, startGreeting)
      : currentSession.messages;
    const userSession: ChatSession = {
      ...currentSession,
      title: currentSession.title,
      theme,
      messages: [...preservedMessages, { role: "user", text: question }],
      updatedAt: timestamp(),
    };
    const requestId = rectificationHandoff?.requestId ?? globalThis.crypto.randomUUID();
    const controller = new AbortController();
    const previousOnboardingState = onboardingJustCompleted;
    cancellationFeedbackRequest.current = null;
    setRequestError(null);
    setComposerNotice("");
    setPendingSessionId(sessionId);
    setConsultationPhase("undo");
    pendingConsultation.current = {
      requestId,
      sessionId,
      question: originalQuestion,
      entrypoint,
      theme,
      rectificationHandoff,
      previousSession: currentSession,
      optimisticSession: userSession,
      previousOnboardingState,
      controller,
      cancelled: false,
      phase: "undo",
      partialReply: "",
    };
    setOnboardingJustCompleted(false);
    updateSession(sessionId, () => userSession);
    setDraft("");
    setDraftTheme(null);
    setDraftEntrypoint(null);

    if (process.env.NODE_ENV === "development" && uiPreview.current) {
      setStreamingReply({ sessionId, text: "" });
      if (uiPreviewMode.current === "partial") {
        const partialReply = "已开始查看事业方向与关键时间，先给你一个阶段性的判断。";
        if (pendingConsultation.current?.requestId === requestId) {
          pendingConsultation.current = {
            ...pendingConsultation.current,
            phase: "streaming",
            partialReply,
          };
        }
        setConsultationPhase("streaming");
        setStreamingReply({ sessionId, text: partialReply });
      }
      await new Promise((resolve) => window.setTimeout(resolve, uiPreviewMode.current === "streaming" || uiPreviewMode.current === "partial" ? 15_000 : 800));
      if (controller.signal.aborted) {
        if (pendingConsultation.current?.requestId === requestId) pendingConsultation.current = null;
        return false;
      }
      const previewReply = parseAgentReply([
        "这是本地交互预览。正式对话会结合你的星盘证据继续分析。",
        '<!--AYANAM_SUGGESTIONS:["继续梳理方向","查看时间窗口","评估现实行动"]-->',
        "<!--AYANAM_TITLE:事业方向与时间选择-->",
      ].join("\n"), theme);
      const previewSession: ChatSession = {
        ...userSession,
        title: currentSession.messages.length === 0
          ? resolveSessionTitle(question, previewReply.title)
          : userSession.title,
        messages: [...userSession.messages, {
          role: "assistant",
          text: previewReply.text,
          suggestions: previewReply.suggestions,
        }],
        updatedAt: timestamp(),
      };
      updateSession(sessionId, () => previewSession);
      completeConsultationInterface(requestId);
      return true;
    }

    await waitForUndoWindow(controller.signal);
    if (controller.signal.aborted) return false;
    if (pendingConsultation.current?.requestId === requestId) {
      pendingConsultation.current = {
        ...pendingConsultation.current,
        phase: "streaming",
      };
      setConsultationPhase("streaming");
    }
    setStreamingReply({ sessionId, text: "" });
    let latestPartialReply = "";
    try {
      const response = await fetch("/api/consult", {
        method: "POST",
        headers: { "content-type": "application/json" },
        body: JSON.stringify({
          requestId,
          sessionId: currentSession.id,
          modelId: currentSession.modelId,
          name: profile.name,
          consultationMode: consultationRoute.mode,
          ...(consultationRoute.mode === "general_no_birth_time"
            || rectificationHandoff?.protocol === "rectification-evidence-v4" ? {} : {
            entrypoint: entrypoint ?? undefined,
            year,
            month,
            day,
            hour,
            minute,
            city: birthPlace.label,
            lat: birthPlace.lat,
            lon: birthPlace.lon,
            tz: birthPlace.tz,
            entryMode: "direct_chart" as const,
          }),
          theme,
          question,
          history: currentSession.messages.slice(-12).map((message) => ({
            role: message.role,
            text: message.text.slice(0, 4000),
          })),
          ...(rectificationHandoff ? { rectificationHandoff } : {}),
        }),
        signal: controller.signal,
      });
      if (!response.ok) {
        const contentType = response.headers.get("content-type") ?? "";
        const errorPayload = contentType.includes("application/json") ? await response.json() : { message: await response.text() };
        if (response.status === 401) window.location.assign("/login");
        if (response.status === 402) openAccountDialog("redeem", creditTrigger.current);
        throw new Error(payloadMessage(errorPayload, "服务暂时不可用"));
      }
      if (!response.body) throw new Error("浏览器未收到可读取的回答流");
      const techniqueTruth = response.headers.get("x-jyotish-technique-truth") ?? "unknown";
      const workflowReceipt = {
        route: response.headers.get("x-jyotish-workflow-route") ?? "unknown",
        status: response.headers.get("x-jyotish-workflow-status") ?? "unknown",
        preciseTiming: response.headers.get("x-jyotish-precise-timing") ?? "unknown",
        missingLayers: (response.headers.get("x-jyotish-missing-layers") ?? "none")
          .split(",")
          .map((item) => item.trim())
          .filter((item) => item && item !== "none"),
      };

      const reader = response.body.getReader();
      const decoder = new TextDecoder();
      let answer = "";

      while (true) {
        const { done, value } = await reader.read();
        if (done) break;
        answer += decoder.decode(value, { stream: true });
        const partialReply = parseAgentReply(answer, theme).text;
        latestPartialReply = partialReply;
        setStreamingReply({ sessionId, text: partialReply });
        if (partialReply && pendingConsultation.current?.requestId === requestId) {
          pendingConsultation.current = {
            ...pendingConsultation.current,
            partialReply,
          };
        }
      }
      answer += decoder.decode();
      if (controller.signal.aborted) return Boolean(latestPartialReply);
      if (!answer.trim()) throw new Error("Agent 没有返回内容，请重试。");
      const reply = parseAgentReply(answer, theme);
      if (!reply.text) throw new Error("Agent 没有返回可显示的回答，请重试。");

      const completedSession: ChatSession = {
        ...userSession,
        title: currentSession.messages.length === 0
          ? resolveSessionTitle(question, reply.title)
          : userSession.title,
        messages: [...userSession.messages, { role: "assistant", text: reply.text, suggestions: reply.suggestions, techniqueTruth, workflowReceipt }],
        updatedAt: timestamp(),
      };
      updateSession(sessionId, () => completedSession);
      completeConsultationInterface(requestId);
      try {
        await persistSession(completedSession);
      } catch (caught) {
        void caught;
        setComposerNotice("回答已保留；网络恢复后，下一次对话会继续同步完整记录。");
      }
      void refreshAccount();
      return true;
    } catch (caught) {
      const cancelled = controller.signal.aborted;
      const ownsInterface = pendingConsultation.current?.requestId === requestId;
      const partialReply = latestPartialReply;
      if (ownsInterface && !partialReply) {
        updateSession(sessionId, () => currentSession);
        setOnboardingJustCompleted(previousOnboardingState);
        if (activeSessionIdRef.current === sessionId) {
          setDraft(originalQuestion);
          setDraftTheme(theme);
          setDraftEntrypoint(entrypoint);
        }
        if (!cancelled) {
          setRequestError({
            sessionId,
            message: `${caught instanceof Error ? caught.message : "服务暂时不可用，请稍后重试。"} 问题已放回输入框。`,
          });
          cancellationFeedbackRequest.current = requestId;
          if (activeSessionIdRef.current === sessionId) {
            setComposerNotice("问题已放回输入框，正在确认点数…");
          }
        }
      }
      if (ownsInterface && !partialReply && !rectificationHandoff) {
        await confirmCancellation(
          requestId,
          sessionId,
          "问题已放回输入框，本次未扣点。",
        );
      } else if (ownsInterface && !partialReply && rectificationHandoff) {
        setComposerNotice("原问题仍保留；请刷新校正状态后重试，本次不会重复扣点。");
      } else if (!cancelled && ownsInterface) {
        const interruptedSession: ChatSession = {
          ...userSession,
          messages: [...userSession.messages, { role: "assistant", text: partialReply }],
          updatedAt: timestamp(),
        };
        updateSession(sessionId, () => interruptedSession);
        try {
          await persistSession(interruptedSession);
          setRequestError({
            sessionId,
            message: "回答中途断开，已保留生成内容；请复制现有内容或继续追问，系统正在以账户记录为准同步点数。",
          });
        } catch (persistError) {
          void persistError;
          setComposerNotice("已保留当前回答；网络恢复后，下一次对话会继续同步完整记录。");
        }
        if (activeSessionIdRef.current === sessionId) {
          setComposerNotice("回答中途断开，已保留现有内容；请继续追问或复制保存。");
        }
      }
      return Boolean(partialReply);
    } finally {
      cancellationRequests.current.delete(requestId);
      completeConsultationInterface(requestId);
      if (stoppedRequestAwaitingSettlement.current === requestId) {
        const persistence = stoppedSessionPersistence.current.get(requestId);
        if (persistence) {
          await persistence;
          stoppedSessionPersistence.current.delete(requestId);
        }
        stoppedRequestAwaitingSettlement.current = null;
        cancellationInFlight.current = false;
        setCancellationPending(false);
      }
    }
  }


  useGSAP(() => {
    if (!starterHomeVisible || !starterWorkbench.current) return;
    const motion = gsap.matchMedia();
    motion.add("(prefers-reduced-motion: no-preference)", () => {
      const timeline = gsap.timeline({ defaults: { ease: "power3.out" } });
      timeline
        .from(".starter-hero-copy > *", {
          autoAlpha: 0,
          duration: 0.62,
          stagger: 0.07,
          y: 18,
        })
        .from(".starter-celestial-visual", {
          autoAlpha: 0,
          duration: 0.76,
          scale: 0.94,
        }, 0.08)
        .from(".product-entrypoint-card", {
          autoAlpha: 0,
          duration: 0.54,
          stagger: 0.08,
          y: 20,
        }, 0.2)
        .from(".starter-theme-card", {
          autoAlpha: 0,
          duration: 0.46,
          stagger: 0.055,
          y: 14,
        }, 0.34);
    });
    return () => motion.revert();
  }, { dependencies: [activeSession?.id, starterHomeVisible], scope: starterWorkbench });

  function submit(event: FormEvent<HTMLFormElement>) {
    event.preventDefault();
    if (!profileComplete) {
      if (onboardingStep === "name" && presetMessageFinished) void saveOnboardingName();
      return;
    }
    void send(draft, draftTheme ?? undefined, draftEntrypoint);
  }

  function handleComposerKeyDown(event: KeyboardEvent<HTMLTextAreaElement>) {
    if (event.nativeEvent.isComposing) return;
    if (event.key === "Enter" && !event.shiftKey) {
      event.preventDefault();
      event.currentTarget.form?.requestSubmit();
    }
  }

  if (!hydrated || (!account && !accountError)) {
    return (
      <main className="app-loading" aria-busy="true" aria-live="polite">
        <AppLoadingIndicator title="正在和星星对口供" detail="顺便同步你的账户与对话记录" />
      </main>
    );
  }

  if (!account) {
    return (
      <main className="app-loading app-loading-error" aria-live="assertive">
        <div className="app-loading-content">
          <strong>暂时无法进入 Jyotisha</strong>
          <span>{accountError}</span>
          <div className="app-loading-actions">
            <button className="button-primary" type="button" onClick={() => window.location.reload()}>重试</button>
            <Link className="button-secondary" href="/login">返回登录</Link>
          </div>
        </div>
      </main>
    );
  }

  const sidebarAccount = {
    name: profile.name.trim() || account.user.email || "账户",
    email: account.user.email || "尚未读取邮箱",
    credits: account.credits,
    isAdmin: account.isAdmin,
    adminUrl: account.adminUrl,
    avatar: account.avatar,
    initial: profile.name.trim().slice(0, 1)
      || account.user.email?.slice(0, 1).toUpperCase()
      || "你",
  };

  const sidebarSessions = visibleSessions.map((session) => ({
    id: session.id,
    title: session.title,
    messageCount: session.messages.length,
    pinned: pinnedSessionIds.includes(session.id),
    archived: archivedSessionIds.includes(session.id),
  }));

  return (
    <SidebarProvider escapeBlocked={accountMenuOpen || activeAccountDialog !== null}>
      <main className="chat-app">
        <AppSidebar
          sessions={sidebarSessions}
          activeSessionId={activeSession?.id ?? null}
          account={sidebarAccount}
          accountMenuOpen={accountMenuOpen}
          accountTriggerRef={accountTrigger}
          newChatDisabled={!hydrated || !modelCatalog || creatingSession || Boolean(pendingSessionId) || cancellationPending}
          creatingSession={creatingSession}
          sessionControls={{
            archivedCount: archivedSessionIds.length,
            showingArchived: showArchivedSessions,
            menuSessionId: sessionMenuId,
            disabled: Boolean(pendingSessionId) || cancellationPending,
            onToggleArchivedView: () => {
              setShowArchivedSessions((current) => !current);
              setSessionMenuId(null);
            },
            onMenuSessionChange: setSessionMenuId,
            onTogglePinned: togglePinnedSession,
            onRename: (sessionId) => {
              const session = sessions.find((candidate) => candidate.id === sessionId);
              if (session) void renameSession(session);
            },
            onShare: (sessionId) => {
              const session = sessions.find((candidate) => candidate.id === sessionId);
              if (session) void shareSession(session);
            },
            onToggleArchived: toggleArchivedSession,
            onDelete: (sessionId) => {
              const session = sessions.find((candidate) => candidate.id === sessionId);
              if (session) setPendingSessionDeletion(session);
            },
          }}
          onAccountMenuOpenChange={setAccountMenuOpen}
          onNewChat={() => void startNewChat()}
          onSelectSession={selectSession}
          onOpenProfile={() => openAccountDialog("profile")}
          onOpenRedeem={() => openAccountDialog("redeem")}
          onOpenLogout={() => openAccountDialog("logout")}
        />
        {pendingSessionDeletion ? (
          <div className="account-modal-overlay session-delete-overlay" role="presentation" onMouseDown={() => setPendingSessionDeletion(null)}>
            <section className="account-modal logout-modal session-delete-confirmation" role="alertdialog" aria-modal="true" aria-label="确认删除聊天记录" onMouseDown={(event) => event.stopPropagation()}>
              <h2>删除聊天记录？</h2>
              <p>“{pendingSessionDeletion.title}”将被永久删除，无法恢复。</p>
              <div className="dialog-actions">
                <button type="button" onClick={() => setPendingSessionDeletion(null)}>取消</button>
                <button className="danger-button" type="button" onClick={() => {
                  const session = pendingSessionDeletion;
                  setPendingSessionDeletion(null);
                  void deleteSession(session);
                }}>确认删除</button>
              </div>
            </section>
          </div>
        ) : null}
        <SidebarInset className="chat-panel" inert={activeAccountDialog !== null}>
          <header className="chat-header">
            <SidebarTrigger placement="inset" />
          <div>
            <strong>{activeSession?.title || "新对话"}</strong>
            <span><i className={`status ${isLoading ? "status-loading" : "status-idle"}`} />{isLoading
              ? (consultationPhase === "undo" ? "即将发送，可撤回" : activeStreamingText ? "正在回答" : "正在核对星盘信息")
              : rectificationSurfaceOpen || (!profileComplete && onboardingStep === "rectification")
                ? "正在校正出生时间"
                : personalChartAvailable ? "基于星盘证据回答" : "回答一般占星知识"}</span>
          </div>
          <div className="chat-header-actions">
            {reportEntryVisible && activeSession && (
              <GeneratePersonalReportButton
                sessionId={activeSession.id}
                evidenceState={reportEvidenceState}
              />
            )}
            {account.isAdmin && account.adminUrl ? (
              <Link className="admin-button" href={account.adminUrl} aria-label="后台管理" title="后台管理">
                <ShieldCheck aria-hidden="true" />
              </Link>
            ) : null}
            <button className="credit-button" ref={creditTrigger} type="button" onClick={() => openAccountDialog("redeem", creditTrigger.current)} aria-label={account ? `余额 ${account.credits} 点，兑换点数` : accountError || "读取余额中"}>
              <Sparkles className="credit-icon" aria-hidden="true" />
              <span>{account ? account.credits : "—"}</span>
            </button>
          </div>
          </header>

        {!rectificationSurfaceOpen && (
          <div className={`conversation ${activeSession?.messages.length ? "" : "is-empty"}`}>
            {!activeSession?.messages.length ? (
            <div className="welcome">
              {!profileComplete ? (
                <>
                  <OnboardingChatMessage role="assistant" text={presetOnboardingMessage} streaming={onboardingStep === "name" && !profileComplete} length={presetMessageLength} />
                  {(onboardingStep !== "name" || profileComplete) && <OnboardingChatMessage role="user" text={profileDraft.name.trim()} />}
                  {(onboardingStep !== "name" || profileComplete) && <OnboardingChatMessage role="assistant" text={birthQuestion(profileDraft.name.trim())} streaming={onboardingStep === "birth" && !profileComplete} length={presetMessageLength} />}
                  {(onboardingStep === "place" || onboardingStep === "rectification" || profileComplete) && <OnboardingChatMessage role="user" text={formatBirthMoment(profileDraft)} />}
                  {(onboardingStep === "place" || onboardingStep === "rectification" || profileComplete) && <OnboardingChatMessage role="assistant" text={placeQuestion(profileDraft)} streaming={onboardingStep === "place" && !profileComplete} length={presetMessageLength} />}
                  {!profileComplete && onboardingStep === "rectification" && selectedBirthPlace(profileDraft) && <OnboardingChatMessage role="user" text={selectedBirthPlace(profileDraft)?.label ?? ""} />}
                  {!profileComplete && onboardingStep === "rectification" && birthTimeJourney && <OnboardingChatMessage role="assistant" text={currentOnboardingMessage} streaming length={presetMessageLength} phraseSafe />}
                  {profileComplete && onboardingJustCompleted && selectedBirthPlace(profileDraft) && <OnboardingChatMessage role="user" text={selectedBirthPlace(profileDraft)?.label ?? ""} />}
                  {profileComplete && onboardingJustCompleted && <OnboardingChatMessage role="assistant" text={currentOnboardingMessage} streaming length={presetMessageLength} />}
                </>
              ) : null}

              {!profileComplete && onboardingStep === "birth" && onboardingCardReady && (
                <div className="onboarding-card-reveal">
                  <div className="onboarding-card-reveal-inner">
                    <form className="profile-form onboarding-card onboarding-step-card birth-time-transition-card" onSubmit={saveOnboardingBirth} aria-busy={birthTimeAssessmentPhase !== null}>
                      <div className="onboarding-card-heading">
                        <div className="onboarding-card-heading-copy">
                          <span className="onboarding-card-kicker">先完成出生资料</span>
                          <b>出生日期与时间</b>
                        </div>
                      </div>
                      <fieldset className="birth-time-transition-fields" disabled={birthTimeAssessmentPhase !== null}>
                        <BirthTimeIntakeFields value={profileDraft} onPatch={(patch) => setProfileDraft((current) => applyBirthTimeDraftPatch(current, patch))} />
                        {accountError && <p className="form-error" role="alert">{accountError}</p>}
                        <div className="onboarding-card-actions">
                          <button className="button-primary" type="submit" disabled={profileSaving || !isBirthTimeDraftReady(profileDraft)}>{profileSaving ? "保存中" : "继续"}</button>
                        </div>
                      </fieldset>
                      <BirthTimeAssessmentOverlay phase={birthTimeAssessmentPhase} />
                    </form>
                  </div>
                </div>
              )}

              {!profileComplete && onboardingStep === "place" && onboardingCardReady && (
                <div className="onboarding-card-reveal">
                  <div className="onboarding-card-reveal-inner">
                    <form className="profile-form onboarding-card onboarding-step-card birth-time-transition-card" onSubmit={saveOnboardingPlace} aria-busy={birthTimeAssessmentPhase !== null}>
                      <div className="onboarding-card-heading"><b>出生地点</b><small>搜索全球城市或区县，系统会匹配出生当日的时区。</small></div>
                      <fieldset className="birth-time-transition-fields" disabled={birthTimeAssessmentPhase !== null}>
                        <BirthLocationFields value={profileDraft} onChange={setProfileDraft} />
                        {accountError && <p className="form-error" role="alert">{accountError}</p>}
                        <div className="onboarding-card-actions"><button className="button-primary" type="submit" disabled={profileSaving || !selectedBirthPlace(profileDraft)}>{profileSaving ? "保存中" : "确定"}</button></div>
                      </fieldset>
                      <BirthTimeAssessmentOverlay phase={birthTimeAssessmentPhase} />
                    </form>
                  </div>
                </div>
              )}

              {!profileComplete && onboardingStep === "rectification" && presetMessageFinished && birthTimeJourney && (
                <div className="onboarding-card-reveal">
                  <div className="onboarding-card-reveal-inner">
                    <BirthTimeRectification
                      journey={birthTimeJourney}
                      controller={birthTimeGuided}
                      externalError={birthTimeError}
                    />
                  </div>
                </div>
              )}

              {!profileComplete && onboardingStep === "rectification" && presetMessageFinished && !birthTimeJourney && (
                <div className="onboarding-card birth-time-retry-card" role="status">
                  <b>出生时间尚未完成评估</b>
                  <p>{birthTimeError || "资料已经保留，但暂时无法恢复校正进度。系统不会应用未经验证的具体时间。"}</p>
                  <button className="button-primary" type="button" disabled={profileSaving} onClick={() => void retryBirthTimeAssessment()}>{profileSaving ? "评估中" : "重新评估"}</button>
                </div>
              )}

              {!profileComplete && onboardingStep === "name" && accountError && <p className="form-error onboarding-inline-error" role="alert">{accountError}</p>}

              {profileComplete && presetMessageFinished && !rectificationSurfaceOpen && (onboardingPending ? (
                <div className="starter-loading" role="status">
                  <AppLoadingIndicator title="正在准备三个入门问题…" detail="我会根据你的资料，整理适合开始的方向。" />
                </div>
              ) : (
                <div className="starter-list starter-workbench" ref={starterWorkbench} aria-label="Jyotisha 推荐的初始问题">
                  <section className="starter-hero" aria-labelledby="starter-heading">
                    <div className="starter-hero-copy">
                      <p className="starter-greeting">{daypartGreeting}，{profile.name.trim()}。</p>
                      <h1 id="starter-heading">今天想先理清什么？</h1>
                      <p className="starter-hero-note">{personalChartAvailable
                        ? "从此刻最在意的事开始，我会结合你的星盘证据，帮你把问题拆得更清楚。"
                        : "你可以先了解一般占星知识；完成生时校正后，再讨论个人星盘结论。"}</p>
                    </div>
                    <div className="starter-celestial-visual" aria-hidden="true">
                      <span className="starter-orbit starter-orbit-outer" />
                      <span className="starter-orbit starter-orbit-inner" />
                      <span className="starter-orbit-dot starter-orbit-dot-primary" />
                      <span className="starter-orbit-dot starter-orbit-dot-secondary" />
                      <span className="starter-celestial-mark" />
                    </div>
                  </section>

                  <section className="product-entrypoints" aria-label="常用占星入口">
                    <article className="daily-starlanguage-card product-entrypoint-card" aria-labelledby="daily-starlanguage-title">
                      <button
                        className="product-entrypoint-hitarea"
                        type="button"
                        aria-label={personalChartAvailable ? "深入看今日" : "了解每日趋势的分析方法"}
                        disabled={productEntrypointsDisabled}
                        onClick={draftDailyStarlanguageQuestion}
                      />
                      <div className="product-entrypoint-copy">
                        <span className="product-entrypoint-kicker">{personalChartAvailable ? "每日观察" : "一般知识"}</span>
                        <h2 id="daily-starlanguage-title">{personalChartAvailable ? "今日星语" : "如何看每日趋势"}</h2>
                        <p>{personalChartAvailable ? dailyStarlanguage?.trend : "了解印度占星通常会用哪些因素观察一天的主题。"}</p>
                      </div>
                      <div className="product-entrypoint-footer">
                        <small>{personalChartAvailable ? dailyStarlanguage?.action : "不依赖个人出生分钟。"}</small>
                        <span className="product-entrypoint-action" aria-hidden="true">{personalChartAvailable ? "深入看今日" : "了解方法"} <ArrowUpRight className="starter-arrow" /></span>
                      </div>
                    </article>
                    <article className="birth-rectification-card product-entrypoint-card" aria-labelledby="birth-rectification-title">
                      <button
                        className="product-entrypoint-hitarea"
                        type="button"
                        aria-label={rectificationCardLabel}
                        disabled={productEntrypointsDisabled || rectificationLoading || rectificationMutationPending}
                        onClick={() => void openBirthTimeRectification()}
                      />
                      <div className="product-entrypoint-copy">
                        <span className="product-entrypoint-kicker">出生资料</span>
                        <h2 id="birth-rectification-title">生时校正</h2>
                        <p>{rectificationCardAction === "resume"
                          ? "你有一段未完成的校正记录，可以从上次的位置继续。"
                          : "不确定准确出生时间时，可通过已经发生的人生事件逐步缩小范围。"}</p>
                      </div>
                      <div className="product-entrypoint-footer">
                        <small>进度会自动保存；结果只作为候选范围，不会改写已填报出生时间。</small>
                        <span className="product-entrypoint-action" aria-hidden="true">{rectificationCardLabel} <ArrowUpRight className="starter-arrow" /></span>
                      </div>
                    </article>
                  </section>

                  <section className="starter-themes" aria-labelledby="starter-themes-heading">
                    <div className="starter-section-heading">
                      <h2 id="starter-themes-heading">或者，从一个主题开始</h2>
                      <p>选择最接近你当下的问题。</p>
                    </div>
                    <div className="starter-theme-accordion">
                      {starterSuggestions.map((item) => {
                        const theme = starterThemes.find((candidate) => candidate.id === item.theme);
                        return (
                          <button
                            className="starter-theme-card"
                            key={`${item.theme}-${item.text}`}
                            type="button"
                            aria-label={`${theme?.label || "开始"}：${item.text}`}
                            disabled={!hydrated || Boolean(pendingSessionId) || cancellationPending || !account || !modelCatalog}
                            onClick={() => chooseSuggestedQuestion(item.text, item.theme)}
                          >
                            <span className="starter-content">
                              <b>{theme?.label || "开始"}</b>
                              <span>{item.text}</span>
                            </span>
                            <ArrowUpRight className="starter-arrow" aria-hidden="true" />
                          </button>
                        );
                      })}
                    </div>
                  </section>
                  {onboardingError && <p className="starter-note">个性化问题暂时不可用，已显示安全的默认问题。</p>}
                </div>
              ))}
              <div ref={conversationEnd} />
            </div>
          ) : (
            <div className="message-list" aria-busy={isLoading}>
              <span className="sr-only" aria-live="polite">{isLoading ? "Jyotisha 正在回答" : ""}</span>
              {chatMessageViews(activeSession.messages, isLoading, activeStreamingText).map((message) => (
                <ChatMessageRow key={message.renderKey} message={message} />
              ))}
              {activeError && <p className="error-message" role="alert">{activeError}</p>}
              <div ref={conversationEnd} />
            </div>
            )}
          </div>
        )}

        {rectificationSurfaceOpen && (
          <ConversationalBirthTimeRectification
            key={rectificationSessionId}
            sessionId={rectificationSessionId}
            initialMessages={activeSession?.messages ?? []}
            models={modelCatalog?.models ?? []}
            selectedModelId={activeSession?.modelId ?? ""}
            onSelectModel={(modelId) => void selectSessionModel(modelId)}
            onMessagesChange={handleRectificationMessagesChange}
            onCompleted={() => void refreshAccount()}
            pendingConsultationQuestion={rectificationPendingQuestion}
            onPendingChange={setRectificationMutationPending}
            onProfileIncomplete={handleRectificationProfileIncomplete}
            onSaved={() => void refreshAccount()}
          />
        )}

        {!rectificationSurfaceOpen && <div className={`composer-wrap ${starterHomeVisible ? "composer-wrap-starter" : ""}`}>
          {activeSuggestions.length > 0 && (
            <div className="composer-suggestions" aria-label="推荐继续提问">
              {activeSuggestions.map((question) => (
                <button key={question} type="button" disabled={!account || !modelCatalog || isLoading || cancellationPending || rectificationSurfaceOpen} onClick={() => chooseConversationSuggestion(question)}>{question}</button>
              ))}
            </div>
          )}
          <form className="composer" onSubmit={submit}>
            <Textarea
              ref={composerInput}
              aria-label={!profileComplete && onboardingStep === "name" ? "输入你的称呼" : "输入你的问题"}
              placeholder={!account
                ? "正在读取账户…"
                : !profileComplete
                  ? onboardingStep === "name"
                    ? presetMessageFinished ? "输入你的称呼" : "Jyotisha 正在输入…"
                    : "请先完成上方资料"
                  : account.credits === 0 && !account.activeSubscription
                    ? "余额不足，发送时将打开兑换码"
                    : "例如：未来半年是否适合换工作？"}
              rows={1}
              maxLength={!profileComplete && onboardingStep === "name" ? 80 : 500}
              disabled={isLoading || cancellationPending || rectificationSurfaceOpen || (!profileComplete && (onboardingStep !== "name" || !presetMessageFinished || profileSaving))}
              value={draft}
              onChange={(event) => {
                setDraft(event.target.value);
                setDraftTheme(null);
                setDraftEntrypoint(null);
                setComposerNotice("");
              }}
              onKeyDown={handleComposerKeyDown}
            />
            {isLoading ? (
              <Button
                className="composer-stop"
                aria-label={consultationPhase === "undo" ? "撤回发送，本次不扣点" : activeStreamingText ? "停止回答，保留已生成内容" : "停止回答并申请退回本次点数"}
                title={consultationPhase === "undo" ? "撤回发送，本次不扣点" : activeStreamingText ? "停止回答，本次已开始计费" : "停止回答"}
                size="icon"
                type="button"
                onClick={() => void stopResponse()}
              >
                <Square aria-hidden="true" />
              </Button>
            ) : (
              <Button aria-label={!profileComplete && onboardingStep === "name" ? "确认称呼" : "发送"} disabled={!draft.trim() || Boolean(pendingSessionId) || cancellationPending || rectificationSurfaceOpen || !account || !modelCatalog || (!profileComplete && (onboardingStep !== "name" || !presetMessageFinished || profileSaving))} size="icon" type="submit">
                <ArrowUp aria-hidden="true" />
              </Button>
            )}
          </form>
          <div className="composer-footer">
            <ModelSelector
              models={modelCatalog?.models ?? []}
              selectedModelId={activeSession?.modelId ?? ""}
              disabled={!activeSession || isLoading || cancellationPending || creatingSession}
              onSelect={(modelId) => void selectSessionModel(modelId)}
            />
            {(composerNotice || consultationPhase === "undo" || (!profileComplete && onboardingStep !== "name")) && (
              <p className={composerNotice || consultationPhase === "undo" ? "composer-notice" : undefined} role={composerNotice || consultationPhase === "undo" ? "status" : undefined}>{composerNotice || (consultationPhase === "undo"
                ? "已加入发送队列，2.5 秒内可免费撤回。"
                : onboardingStep === "rectification" ? "生时校正为可选增强" : "请先完成上方资料")}</p>
            )}
          </div>
        </div>}
        </SidebarInset>

      {activeAccountDialog !== null && (
        <div className="account-modal-overlay" onMouseDown={closeAccountDialog}>
          <section className={`account-modal ${accountDialogClasses[activeAccountDialog]}`} ref={accountDialog} role="dialog" aria-modal="true" aria-labelledby="account-dialog-title" onMouseDown={(event) => event.stopPropagation()}>
            <header className="account-modal-header">
              <h2 id="account-dialog-title">{accountDialogTitles[activeAccountDialog]}</h2>
              <button className="dialog-close" ref={closeButton} aria-label="关闭" type="button" onClick={closeAccountDialog} disabled={signingOut}><X aria-hidden="true" /></button>
            </header>

            {activeAccountDialog === "profile" && (
              <>
                {accountError && <p className="form-error" role="alert">{accountError}</p>}
                {account.avatar && (
                  <section className="sheet-section avatar-section" aria-labelledby="avatar-section-title">
                    <div className="section-heading">
                      <b id="avatar-section-title">头像</b>
                      <small>Beam 形象由随机种子生成，刷新和换设备后保持一致</small>
                    </div>
                    <div className="avatar-editor">
                      <UserAvatar avatar={account.avatar} size={96} label="当前头像预览" />
                      <div className="avatar-editor-controls">
                        <div className="avatar-palette-list" role="radiogroup" aria-label="头像配色">
                          {beamAvatarPalettes.map((palette, index) => (
                            <button
                              key={palette.name}
                              className="avatar-palette"
                              type="button"
                              role="radio"
                              aria-checked={account.avatar?.palette === index}
                              aria-label={palette.name}
                              title={palette.name}
                              disabled={avatarSaving}
                              onClick={() => void persistAvatar({ action: "set_palette", palette: index })}
                            >
                              {palette.colors.map((color) => <span key={color} style={{ backgroundColor: color }} />)}
                            </button>
                          ))}
                        </div>
                        <button
                          className="button-secondary avatar-randomize"
                          type="button"
                          disabled={avatarSaving}
                          onClick={() => void persistAvatar({ action: "randomize" })}
                        >
                          {avatarSaving ? "保存中" : "换一个形象"}
                        </button>
                      </div>
                    </div>
                    {avatarNotice && <p className="form-success avatar-notice" role="status">{avatarNotice}</p>}
                  </section>
                )}
                <section className="sheet-section birth-section">
                  <div className="section-heading"><b>出生资料</b><small>加密传输并保存到云端，用于此账号的所有对话</small></div>
                  <div className="default-chart-card" aria-label="当前默认星盘">
                    <div>
                      <span>当前默认星盘</span>
                      <strong>{profileDraft.name.trim() || "未命名"}</strong>
                      <small>角色：本人</small>
                    </div>
                    <button className="button-secondary" type="button" onClick={() => setChartLibraryOpen((current) => !current)}>管理星盘库</button>
                  </div>
                  {chartLibraryOpen && (
                    <div className="chart-library-panel" aria-label="星盘库">
                      <div className="chart-library-group">
                        <b>本人</b>
                        {chartLibrary.filter((record) => record.role === "self").map((record) => (
                          <article className="chart-library-item" key={record.id}>
                            <div>
                              <strong>{record.profile.name || "未命名"}</strong>
                              <small>{record.profile.date} {record.profile.time} · {profilePlaceLabel(record.profile)}</small>
                            </div>
                            <span>当前默认</span>
                          </article>
                        ))}
                      </div>
                      <div className="chart-library-group">
                        <b>其他</b>
                        {chartLibrary.filter((record) => record.role === "other").length === 0 && <p className="empty-library-copy">还没有其他星盘。</p>}
                        {chartLibrary.filter((record) => record.role === "other").map((record) => (
                          <article className="chart-library-item" key={record.id}>
                            <div>
                              <strong>{record.profile.name || "未命名"}</strong>
                              <small>{record.profile.date} {record.profile.time} · {profilePlaceLabel(record.profile)}</small>
                            </div>
                            <div className="chart-library-actions">
                              <select aria-label="关系类型" value={synastryRelationshipType} onChange={(event) => setSynastryRelationshipType(event.target.value as SynastryRelationshipType)} disabled={synastryPendingId !== null}>
                                <option value="romance">婚恋</option>
                                <option value="business">商业合作</option>
                                <option value="family">亲友/家庭</option>
                                <option value="general">其他关系</option>
                              </select>
                              <button className="button-secondary" type="button" onClick={() => void draftSynastryQuestionFromChart(record, synastryRelationshipType)} disabled={synastryPendingId !== null}>{synastryPendingId === record.id ? "正在计算合盘..." : "用于合盘"}</button>
                              <button className="button-secondary" type="button" onClick={() => void makeDefaultChart(record)} disabled={profileSaving}>设为默认</button>
                              <button className="button-secondary danger-button" type="button" onClick={() => deleteOtherChart(record.id)}>删除</button>
                            </div>
                          </article>
                        ))}
                      </div>
                      {synastryReportCard && (
                        <article className="synastry-report-card" aria-label="合盘结果摘要">
                          <div>
                            <span>合盘结果摘要</span>
                            <strong>{synastryReportCard.partnerName}</strong>
                            <small>Ashtakoot {synastryReportCard.score ?? "?"}/{synastryReportCard.maxScore ?? "?"} · {synastryReportCard.assessment || synastryReportCard.scoreBand || "待解释"}</small>
                          </div>
                          {synastryReportCard.headline && <p>{synastryReportCard.headline}</p>}
                          <details>
                            <summary>查看证据</summary>
                            <ul>
                              {(synastryReportCard.strengths || []).map((item) => <li key={item}>{item}</li>)}
                              {(synastryReportCard.risks || []).map((item) => <li key={item}>{item}</li>)}
                            </ul>
                            <small>下一步证据：{(synastryReportCard.nextEvidence || []).join(" / ") || "双方 Dasha / UL-DK / D9 7宫"}</small>
                          </details>
                        </article>
                      )}
                      {synastryHistory.length > 0 && (
                        <div className="synastry-history-list" aria-label="合盘历史">
                          <b>合盘历史</b>
                          {synastryHistory.slice(0, 5).map((item) => (
                            <button key={item.id} type="button" className="synastry-history-item" onClick={() => setSynastryReportCard(item)}>
                              <span>{item.partnerName}</span>
                              <small>Ashtakoot {item.score ?? "?"}/{item.maxScore ?? "?"} · {item.assessment || item.scoreBand || "待解释"}</small>
                            </button>
                          ))}
                        </div>
                      )}
                      <form className="profile-form chart-library-form" onSubmit={saveOtherChart}>
                        <div className="section-heading"><b>添加其他星盘</b><small>用于合盘、亲友盘或客户盘。</small></div>
                        <ProfileFields value={otherProfileDraft} onChange={setOtherProfileDraft} nameInputId="other-profile-name" />
                        <button className="button-primary save-profile" type="submit" disabled={!account}>添加到星盘库</button>
                      </form>
                    </div>
                  )}
                </section>
                {profileNotice && <p className="form-success" role="status">{profileNotice}</p>}
                <form className="profile-form" onSubmit={saveProfile}>
                  <ProfileFields value={profileDraft} onChange={setProfileDraft} nameInputId="profile-name" />
                  <button className="button-primary save-profile" type="submit" disabled={profileSaving || !account}>{profileSaving ? "保存中" : "保存出生资料"}</button>
                </form>
              </>
            )}

            {activeAccountDialog === "redeem" && (
              <>
                <div className="redeem-balance"><span>{account.activeSubscription ? "当前会员" : "当前余额"}</span><strong>{account.activeSubscription ? `${account.activeSubscription.product?.name || account.activeSubscription.productCode} · ${new Date(account.activeSubscription.endsAt).toLocaleDateString("zh-CN")} 到期` : `${account.credits} 点`}</strong></div>
                <form className="redeem-form account-redeem-form" onSubmit={redeem}>
                  <label htmlFor="redeem-code">兑换码</label>
                  <div>
                    <input id="redeem-code" ref={redeemInput} autoComplete="off" value={redeemCode} onChange={(event) => { setRedeemCode(event.target.value); setRedeemError(""); setRedeemMessage(""); }} placeholder="输入完整兑换码" />
                    <button className="button-primary" type="submit" disabled={!redeemCode.trim() || redeeming}>{redeeming ? "兑换中" : "兑换"}</button>
                  </div>
                  {redeemError && <p className="form-error" role="alert">{redeemError}</p>}
                  {redeemMessage && <p className="form-success" role="status">{redeemMessage}</p>}
                </form>
                {paymentEnabled && <div className="payment-packages">
                  <h3>套餐与会员</h3>
                  {paymentPackages.map((item) => <div className="payment-package" key={item.id}><div><strong>{item.name}</strong><span>{item.description || (item.productType === "credit_pack" ? `${item.credits} 点` : "会员权益")}</span></div><b>¥{(item.priceCents / 100).toFixed(2)}</b><button className="button-secondary" type="button" onClick={() => void createPayment(item.id)} disabled={Boolean(payingPackageId)}>{payingPackageId === item.id ? "创建中" : "立即支付"}</button></div>)}
                  {paymentOrder && <div className="payment-status" role="status"><p>订单 {paymentOrder.orderNo}：{paymentOrder.status === "paid" ? "支付成功，权益已到账" : "等待支付"}</p></div>}
                </div>}
                {paymentError && <p className="form-error" role="alert">{paymentError}</p>}
              </>
            )}

            {activeAccountDialog === "logout" && (
              <>
                <p className="logout-copy">退出后，需要重新登录才能继续查看对话。</p>
                {accountError && <p className="form-error" role="alert">{accountError}</p>}
                <div className="dialog-actions">
                  <button className="button-secondary" type="button" onClick={closeAccountDialog} disabled={signingOut}>取消</button>
                  <button className="button-primary danger-primary" type="button" onClick={() => void signOut()} disabled={signingOut}>{signingOut ? "正在退出" : "确认退出"}</button>
                </div>
              </>
            )}
          </section>
        </div>
      )}
      </main>
    </SidebarProvider>
  );
}