/* =============================================================================
 * B06_Section_Section_Store.ts
 * 종횡단 상세(SectionDetailResponse)의 **프론트 공유 캐시** — B05·B06이 같은 객체를 본다.
 *
 * ── 왜 필요한가 (2026-08-03 사용자 확정) ─────────────────────────────
 * B05(노선·계획선)와 B06(종횡단 설계)은 같은 영구저장소 데이터의 두 창이다. 페이지마다
 * 따로 fetch해 제각각 들고 있으면, B06에서 지반유형·암 경계를 고친 뒤 B05로 넘어갔을 때
 * 횡단 기준 유토곡선이 옛 값으로 그려진다(사용자가 실제로 겪은 문제). 여기서 한 번 받아
 * **같은 객체 참조**를 두 페이지에 주면, B06이 측점 설계를 제자리 갱신하는 순간 B05가
 * 다음 그리기에서 그대로 본다 — 별도 동기화 코드가 필요 없다.
 *
 * ── 수명 규칙 ─────────────────────────────────────────────────────
 * 키는 `projectId:routeId`. SPA 모듈 싱글턴이라 페이지를 오가도 살아 있고, 새로고침이면
 * 사라져 영구저장소에서 다시 받는다(영구저장소가 항상 정본). 서버가 파일을 통째로 다시
 * 쓰는 조작(재생성·계획선 편집 저장·확정)은 그 응답/재조회로 `replace`·`invalidate`한다.
 * ========================================================================== */

import type { CrossSectionPatch, SectionDetailResponse } from "./B06_Section_Api_Fetch";
import { fetchSectionDetail, saveSections } from "./B06_Section_Api_Fetch";

const cache = new Map<string, SectionDetailResponse>();
const pending = new Map<string, Promise<SectionDetailResponse>>();

function keyOf(projectId: string, routeId: number): string {
  return `${projectId}:${routeId}`;
}

/**
 * 상세를 가져온다 — 캐시가 있으면 **같은 객체**를 즉시 돌려주고, 없으면 한 번만 fetch한다
 * (동시 호출은 같은 Promise를 공유). `force`면 캐시를 버리고 다시 받는다.
 */
export async function loadSectionDetail(
  projectId: string,
  routeId: number,
  options?: { force?: boolean },
): Promise<SectionDetailResponse> {
  const key = keyOf(projectId, routeId);
  if (!options?.force) {
    const cached = cache.get(key);
    if (cached) return cached;
    const inFlight = pending.get(key);
    if (inFlight) return inFlight;
  }
  const request = fetchSectionDetail(projectId, routeId)
    .then((detail) => {
      cache.set(key, detail);
      return detail;
    })
    .finally(() => {
      pending.delete(key);
    });
  pending.set(key, request);
  return request;
}

/** 서버가 새 상세를 통째로 돌려준 조작(재생성 등) 뒤 캐시를 그 값으로 바꾼다. */
export function replaceSectionDetail(
  projectId: string,
  routeId: number,
  detail: SectionDetailResponse,
): void {
  cache.set(keyOf(projectId, routeId), detail);
}

/**
 * 캐시를 비운다. routeId를 생략하면 그 프로젝트 전부 —
 * 서버 쪽 정본이 바뀌었는데 새 상세를 손에 못 쥔 조작(계획선 편집 저장 등) 뒤에 쓴다.
 */
export function invalidateSectionDetail(projectId: string, routeId?: number): void {
  if (routeId !== undefined) {
    cache.delete(keyOf(projectId, routeId));
    return;
  }
  const prefix = `${projectId}:`;
  for (const key of [...cache.keys()]) {
    if (key.startsWith(prefix)) cache.delete(key);
  }
}

/**
 * 캐시에 얹힌 **사용자 수정분**을 저장 payload로 뽑는다(2026-08-24 사용자 확정 흐름).
 *
 * 초기 계산값은 원복용으로 서버에 그대로 있고, 사용자가 만진 값은 이 캐시 한 세트가
 * 최종본이다. B05 [임시저장]도 이 세트를 함께 보내야 B06에서 만진 구조물 조정이
 * 영구저장소에 남는다 — 안 보내면 캐시만 비워져 편집이 사라진다.
 *
 * 초기 계산값에는 없는 키(사용자가 만져야 생기는 키)만 싣는다.
 */
export function crossPatchesFromCache(detail: SectionDetailResponse): CrossSectionPatch[] {
  const patches: CrossSectionPatch[] = [];
  for (const section of detail.cross_sections) {
    const design = section.design;
    if (!design) continue;
    const patch: CrossSectionPatch = { chainage_m: section.chainage_m };
    let touched = false;
    const put = <K extends keyof CrossSectionPatch>(key: K, value: CrossSectionPatch[K]): void => {
      if (value === undefined || value === null) return;
      patch[key] = value;
      touched = true;
    };
    put("display_half_width_m", design.display_half_width_m);
    put("inlet_structure", design.inlet_structure);
    put("basin_adjust", design.basin_adjust);
    put("revet_adjust", design.revet_adjust);
    put("ford_adjust", design.ford_adjust);
    put("box_adjust", design.box_adjust);
    put("extra_wall_counts", design.extra_wall_counts);
    put("extra_spans", design.extra_spans);
    put("revet_link_detached", design.revet_link_detached);
    put("revet_follow_grade", design.revet_follow_grade);
    if (touched) patches.push(patch);
  }
  return patches;
}

/**
 * 캐시에 얹힌 사용자 수정분을 영구저장소에 남긴다(임시저장용). 캐시가 없거나 수정분이
 * 없으면 아무것도 보내지 않는다. 저장 실패는 호출자가 처리한다.
 */
export async function saveCachedCrossPatches(projectId: string, routeId: number): Promise<number> {
  const detail = cache.get(keyOf(projectId, routeId));
  if (!detail) return 0;
  const patches = crossPatchesFromCache(detail);
  if (!patches.length) return 0;
  await saveSections(projectId, routeId, undefined, patches);
  return patches.length;
}