Aislo/B06_Section/B06_Section_Api_Culvert_Options.ts

/* =============================================================================
 * B06_Section_Api_Culvert_Options.ts
 * B06 조정창에서 만진 **배수관 세트 구간값**(기슭막이·집수정 길이·전/후)을
 * 원천인 `pipe_points.json`에 되돌려 쓴다(2026-08-24 사용자).
 *
 * 값을 B06 정본(design)에 따로 담지 않는 이유: 같은 숫자가 B05 배수관 카드에도
 * 있어서 두 곳이 갈리면 어느 쪽이 참인지 알 수 없다. 원천은 하나여야 한다.
 *
 * 조작분은 **세션에만** 쌓고 영구저장은 [저장]·[확정]에서만 한다(CLAUDE.md 5장
 * 조작·데이터 흐름 정책, 2026-08-29 사용자 확정). 종전 800ms 디바운스 자동 PUT은
 * 폐지했다 — 저장을 누르지 않았는데 영구저장소가 바뀌면 [초기화]의 기준선이 흐려진다.
 * 세션에 담는 이유는 B06에서 만진 값을 B05 [저장]으로도 내보내야 하기 때문이다.
 * ========================================================================== */

import {
  fetchDetailPipePoints,
  saveDetailPipePoints,
} from "../B04_PreProcess/B04_PreProcess_Api_Fetch";
import type { DetailPipeInput } from "../B04_PreProcess/B04_PreProcess_Api_Fetch";

/** 측점 하나에 얹을 옵션 조각 — 키는 `pipe_points` 옵션 키 그대로.
 *  값은 수치가 대부분이나 날개벽 설치("있음"/"없음")처럼 문자열도 있다. */
export type CulvertOptionPatch = Record<string, number | string>;

/** 세션에 쌓인 조각 — 측점(누가거리 2자리 문자열) → 옵션 조각. */
type PendingMap = Record<string, CulvertOptionPatch>;

export interface CulvertOptionWriter {
  /** 측점 옵션을 세션에 예약한다. 같은 측점의 앞선 예약과는 합쳐진다. */
  queue: (chainageM: number, patch: CulvertOptionPatch) => void;
  /** 예약분을 즉시 내보낸다([저장]·[확정]에서만 부른다). */
  flush: () => Promise<void>;
}

const keyOf = (chainageM: number): string => chainageM.toFixed(2);

function readPending(sessionKey: string | null): PendingMap {
  if (!sessionKey) return {};
  try {
    const raw = window.sessionStorage.getItem(sessionKey);
    return raw ? (JSON.parse(raw) as PendingMap) : {};
  } catch {
    return {};
  }
}

function writePending(sessionKey: string | null, pending: PendingMap): void {
  if (!sessionKey) return;
  try {
    if (Object.keys(pending).length === 0) window.sessionStorage.removeItem(sessionKey);
    else window.sessionStorage.setItem(sessionKey, JSON.stringify(pending));
  } catch {
    /* 세션 저장 실패는 무시 — 값은 화면 캐시에 남아 있다. */
  }
}

/**
 * 세션에 쌓인 구간값을 `pipe_points.json`에 한 번에 쓴다. 예약분이 없으면 아무것도
 * 하지 않는다. 성공하면 세션을 비우고, 실패하면 **그대로 두어** 다음 [저장]에서
 * 다시 시도한다 — 조용히 잃으면 화면과 저장분이 갈린다.
 */
export async function flushCulvertOptions(
  projectId: string | null,
  sessionKey: string | null,
): Promise<void> {
  const pending = readPending(sessionKey);
  const entries = Object.entries(pending);
  if (!projectId || entries.length === 0) return;
  const current = await fetchDetailPipePoints(projectId);
  let touched = false;
  const points: DetailPipeInput[] = current.pipe_points.map((point) => {
    // 좌표는 서버가 다시 계산하므로 싣지 않는다(DetailPipeInput 규약).
    const { lonlat: _lonlat, ...input } = point;
    const patch = pending[keyOf(point.chainage_m)];
    if (!patch) return input;
    touched = true;
    return { ...input, options: { ...(input.options ?? {}), ...patch } };
  });
  if (touched) await saveDetailPipePoints(projectId, points);
  writePending(sessionKey, {});
}

/**
 * 저장기 하나를 만든다. `projectId`·`sessionKey`가 없으면 예약만 메모리에 남는다
 * (조회 전용 상태). `onError`는 [저장] 시점 실패를 화면에 알리는 쪽이 구현한다.
 */
export function createCulvertOptionWriter(
  projectId: () => string | null,
  sessionKey: () => string | null,
  onError?: (message: string) => void,
): CulvertOptionWriter {
  return {
    queue(chainageM, patch) {
      const key = sessionKey();
      const pending = readPending(key);
      pending[keyOf(chainageM)] = { ...(pending[keyOf(chainageM)] ?? {}), ...patch };
      writePending(key, pending);
    },
    async flush() {
      try {
        await flushCulvertOptions(projectId(), sessionKey());
      } catch (error) {
        onError?.(error instanceof Error ? error.message : "배수관 구간값 저장 실패");
        throw error;
      }
    },
  };
}