import type { DurableMemoryCategory } from "./memory-schema.js";
import { inferPreferenceSlot } from "./preference-slots.js";

export const MEMORY_LAYERS = [
  "canonical",
  "durable",
  "session",
  "evidence",
] as const;

export const MEMORY_AUTHORITIES = [
  "manual-document",
  "structured-memory",
  "document-ingest",
  "transcript-ingest",
  "session-checkpoint",
  "distillation",
] as const;

export const MEMORY_CONFLICT_POLICIES = [
  "latest-wins",
  "append-only",
  "manual-review",
] as const;

export type MemoryLayer = (typeof MEMORY_LAYERS)[number];
export type MemoryAuthority = (typeof MEMORY_AUTHORITIES)[number];
export type MemoryConflictPolicy = (typeof MEMORY_CONFLICT_POLICIES)[number];

export interface MemoryBoundaryMetadata {
  layer: MemoryLayer;
  authority: MemoryAuthority;
  conflictPolicy: MemoryConflictPolicy;
  originalCategory?: DurableMemoryCategory;
  downgradedFrom?: DurableMemoryCategory;
  note?: string;
}

export interface PromotedFromMetadata {
  memoryId: string;
  scope?: string;
  category?: string;
  source?: string;
  boundary?: MemoryBoundaryMetadata | null;
}

export interface ProvenanceHistoryMetadata extends PromotedFromMetadata {
  observedAt?: string;
}

export interface MemoryProvenance {
  boundary: MemoryBoundaryMetadata | null;
  canonicalKey: string | null;
  promotedFrom: PromotedFromMetadata | null;
  provenanceHistory: ProvenanceHistoryMetadata[];
  provenanceHistoryCount: number;
}

export interface IngestBoundaryResolution {
  category: DurableMemoryCategory;
  boundary: MemoryBoundaryMetadata;
}

// 在栈各端的 transcript 来源与 scope 前缀。
// ⚠️ 接入新的 AI 端时必须同步这两处 —— 漏掉的端不会被认成 evidence 层，
// 其会话碎片既不会被降权，也会被 layer admission 当成 durable 结论放行。
// （kimi / antigravity 就漏了：kimi 2026-07-19 进栈、antigravity 07-29 进栈，
//   直到 08-01 才发现库里的 `kimi:` scope 一直被当结论对待。）
//
// minis（2026-08-12 加，iPhone 上的 Minis agent，经 iCloud 文件信箱回流对话记录）：
// 这一次是**接入前先补**，不是事后发现——补的动机值得记下来，因为 Minis 比前面几端更危险。
// 它的 CLI 把 agent 自己的工具调用回传也标成 `type:"user"` / `role:"user"`（实测一场对话
// 137 条里 69 条 user，其中仅 11 条是真人发言，另外 58 条是 `[Tool result: ...]`）。
// 所以漏掉它不只是"碎片被当结论"，而是**把 shell 输出提炼成用户说过的话**——
// 例如 `ssh: connect to host ... timed out` 会变成一条"用户说过"的记忆。
// 导出侧已在上游过滤（只导真人对话），这里是第二道闸：即使某次导出没过滤干净，
// 走 ingest 的内容也会被正确降权到 evidence 层，而不是当成 durable 结论。
const TRANSCRIPT_SOURCES = new Set(["cc", "codex", "gemini", "kimi", "antigravity", "minis"]);
const TRANSCRIPT_SCOPE_PREFIXES = [
  "cc:",
  "codex:",
  "gemini:",
  "kimi:",
  "antigravity:",
  "minis:",
];

export function getConflictPolicyForCategory(category: DurableMemoryCategory): MemoryConflictPolicy {
  return category === "events" || category === "cases"
    ? "append-only"
    : "latest-wins";
}

export function isTranscriptIngestSource(source: string): boolean {
  return TRANSCRIPT_SOURCES.has(source);
}

export function isTranscriptScope(scope: string): boolean {
  return TRANSCRIPT_SCOPE_PREFIXES.some((prefix) => scope.startsWith(prefix));
}

export function isDurableMemoryScope(scope: string): boolean {
  return scope.startsWith("memory:") || scope.startsWith("asset:");
}

export function buildStructuredMemoryBoundary(
  category: DurableMemoryCategory,
): MemoryBoundaryMetadata {
  return {
    layer: "durable",
    authority: "structured-memory",
    conflictPolicy: getConflictPolicyForCategory(category),
    originalCategory: category,
    note: "Structured memory writes are the durable source inside RecallNest.",
  };
}

export function buildDistillationBoundary(
  category: DurableMemoryCategory,
): MemoryBoundaryMetadata {
  return {
    layer: "durable",
    authority: "distillation",
    conflictPolicy: getConflictPolicyForCategory(category),
    originalCategory: category,
  };
}

export function normalizeCanonicalKey(value: string): string {
  return value
    .trim()
    .toLowerCase()
    .replace(/['"`]/g, "")
    .replace(/[^a-z0-9\p{Script=Han}]+/gu, "-")
    .replace(/^-+|-+$/g, "")
    .replace(/-{2,}/g, "-")
    .slice(0, 120);
}

function collapseKeyText(value: string): string {
  return value
    .replace(/\s+/g, " ")
    .trim();
}

export function buildDefaultCanonicalKey(params: {
  category: DurableMemoryCategory;
  text?: string;
  title?: string;
}): string {
  if (params.category === "preferences") {
    const slot = inferPreferenceSlot(params.text || params.title || "");
    if (slot) {
      return truncateCanonicalKey(
        slot.type === "brand-item"
          ? [params.category, slot.type, slot.brand, slot.item]
          : slot.type === "reply-style"
            ? [params.category, slot.type, ...slot.traits]
            : slot.type === "implicit-usage"
              ? [params.category, slot.type, slot.subject]
              : [params.category, slot.type, slot.preferredTool, "over", slot.avoidedTool],
      );
    }
  }

  const base = collapseKeyText(params.title || params.text || "");
  const normalizedBase = normalizeCanonicalKey(base);
  return normalizedBase
    ? `${params.category}:${normalizedBase}`
    : `${params.category}:memory`;
}

function truncateCanonicalKey(segments: string[]): string {
  return segments
    .filter(Boolean)
    .join(":")
    .slice(0, 120)
    .replace(/[:\-]+$/u, "");
}

export function resolveIngestBoundary(params: {
  source: string;
  scope: string;
  category: DurableMemoryCategory;
}): IngestBoundaryResolution {
  const { source, scope, category } = params;

  if (isTranscriptIngestSource(source)) {
    if (category === "profile" || category === "preferences") {
      return {
        category: "events",
        boundary: {
          layer: "evidence",
          authority: "transcript-ingest",
          conflictPolicy: "append-only",
          originalCategory: category,
          downgradedFrom: category,
          note: "Transcript-derived stable facts stay as evidence until explicitly promoted.",
        },
      };
    }

    return {
      category,
      boundary: {
        layer: "evidence",
        authority: "transcript-ingest",
        conflictPolicy: getConflictPolicyForCategory(category),
        originalCategory: category,
        note: "Transcript-derived memories are evidence and should not override curated memory.",
      },
    };
  }

  if (isDurableMemoryScope(scope) || scope === "memory") {
    return {
      category,
      boundary: {
        layer: "durable",
        authority: "document-ingest",
        conflictPolicy: getConflictPolicyForCategory(category),
        originalCategory: category,
        note: "Curated memory documents can mirror durable memory, but they are not session authority.",
      },
    };
  }

  return {
    category,
    boundary: {
      layer: "evidence",
      authority: "document-ingest",
      conflictPolicy: getConflictPolicyForCategory(category),
      originalCategory: category,
      note: "Unstructured ingest stays evidence until explicitly promoted.",
    },
  };
}

export function parseMetadataObject(metadata?: string): Record<string, unknown> | null {
  if (!metadata) return null;
  try {
    const parsed = JSON.parse(metadata);
    return parsed && typeof parsed === "object" ? parsed as Record<string, unknown> : null;
  } catch {
    return null;
  }
}

function coerceBoundaryMetadata(candidate: unknown): MemoryBoundaryMetadata | null {
  if (!candidate || typeof candidate !== "object") return null;

  const record = candidate as Record<string, unknown>;
  const layer = typeof record.layer === "string" ? record.layer : "";
  const authority = typeof record.authority === "string" ? record.authority : "";
  const conflictPolicy = typeof record.conflictPolicy === "string" ? record.conflictPolicy : "";

  if (
    !MEMORY_LAYERS.includes(layer as MemoryLayer) ||
    !MEMORY_AUTHORITIES.includes(authority as MemoryAuthority) ||
    !MEMORY_CONFLICT_POLICIES.includes(conflictPolicy as MemoryConflictPolicy)
  ) {
    return null;
  }

  return {
    layer: layer as MemoryLayer,
    authority: authority as MemoryAuthority,
    conflictPolicy: conflictPolicy as MemoryConflictPolicy,
    ...(typeof record.originalCategory === "string"
      ? { originalCategory: record.originalCategory as DurableMemoryCategory }
      : {}),
    ...(typeof record.downgradedFrom === "string"
      ? { downgradedFrom: record.downgradedFrom as DurableMemoryCategory }
      : {}),
    ...(typeof record.note === "string" ? { note: record.note } : {}),
  };
}

export function extractBoundaryMetadata(metadata?: string): MemoryBoundaryMetadata | null {
  const parsed = parseMetadataObject(metadata);
  return coerceBoundaryMetadata(parsed?.boundary);
}

function coercePromotedFromMetadata(candidate: unknown): PromotedFromMetadata | null {
  if (!candidate || typeof candidate !== "object") return null;

  const record = candidate as Record<string, unknown>;
  const memoryId = typeof record.memoryId === "string" ? record.memoryId.trim() : "";
  if (!memoryId) return null;

  return {
    memoryId,
    ...(typeof record.scope === "string" ? { scope: record.scope } : {}),
    ...(typeof record.category === "string" ? { category: record.category } : {}),
    ...(typeof record.source === "string" ? { source: record.source } : {}),
    boundary: coerceBoundaryMetadata(record.boundary),
  };
}

function coerceProvenanceHistoryMetadata(candidate: unknown): ProvenanceHistoryMetadata | null {
  const promotedFrom = coercePromotedFromMetadata(candidate);
  if (!promotedFrom || typeof candidate !== "object") return null;

  const record = candidate as Record<string, unknown>;
  return {
    ...promotedFrom,
    ...(typeof record.observedAt === "string" ? { observedAt: record.observedAt } : {}),
  };
}

export function extractPromotedFrom(metadata?: string): PromotedFromMetadata | null {
  const parsed = parseMetadataObject(metadata);
  return coercePromotedFromMetadata(parsed?.promotedFrom);
}

export function extractProvenanceHistory(metadata?: string): ProvenanceHistoryMetadata[] {
  const parsed = parseMetadataObject(metadata);
  const rawHistory = Array.isArray(parsed?.provenanceHistory) ? parsed.provenanceHistory : [];
  const history = rawHistory
    .map((candidate) => coerceProvenanceHistoryMetadata(candidate))
    .filter((candidate): candidate is ProvenanceHistoryMetadata => Boolean(candidate));

  if (history.length > 0) {
    return history;
  }

  const promotedFrom = coerceProvenanceHistoryMetadata(parsed?.promotedFrom);
  return promotedFrom ? [promotedFrom] : [];
}

export function extractProvenanceHistoryCount(metadata?: string): number {
  const parsed = parseMetadataObject(metadata);
  const candidate = parsed?.provenanceHistoryCount;
  if (typeof candidate === "number" && Number.isFinite(candidate) && candidate >= 0) {
    return Math.floor(candidate);
  }
  return extractProvenanceHistory(metadata).length;
}

export function extractMemoryProvenance(params: {
  scope: string;
  metadata?: string;
}): MemoryProvenance {
  return {
    boundary: extractBoundaryMetadata(params.metadata),
    canonicalKey: extractCanonicalKey(params.metadata),
    promotedFrom: extractPromotedFrom(params.metadata),
    provenanceHistory: extractProvenanceHistory(params.metadata),
    provenanceHistoryCount: extractProvenanceHistoryCount(params.metadata),
  };
}

export function extractCanonicalKey(metadata?: string): string | null {
  const parsed = parseMetadataObject(metadata);
  const canonicalKey = parsed?.canonicalKey;
  return typeof canonicalKey === "string" && canonicalKey.trim().length > 0
    ? canonicalKey
    : null;
}

export function shouldUseStableMemoryResult(params: {
  category: "profile" | "preferences" | "entities";
  scope: string;
  metadata?: string;
}): boolean {
  if (isTranscriptScope(params.scope)) {
    return false;
  }

  const boundary = extractBoundaryMetadata(params.metadata);
  if (!boundary) {
    return true;
  }

  return boundary.layer !== "evidence";
}