utils.ts

import fs from "fs";
import path from "path";

function kstNow(): Date {
  return new Date(Date.now() + 9 * 60 * 60 * 1000);
}

function toMysqlDatetime(date: Date): string {
  return date.toISOString().slice(0, 19).replace("T", " ");
}

// YYYY-MM-DD (출석 날짜 비교용)
function toKSTDateStr(date: Date): string {
  return new Date(date.getTime() + 9 * 60 * 60 * 1000).toISOString().slice(0, 10);
}

// YYYYMMDD (NEIS API 파라미터용)
function toNeisDateStr(kstDate: Date): string {
  const y = kstDate.getUTCFullYear();
  const m = String(kstDate.getUTCMonth() + 1).padStart(2, "0");
  const d = String(kstDate.getUTCDate()).padStart(2, "0");
  return `${y}${m}${d}`;
}

const NEIS_KEY = process.env.NEIS_API_KEY ?? "";
const ATPT_CODE = "F10";
// 2026년 전남광주통합특별시교육청 개편으로 NEIS 학교코드가 7380292 -> 7140392로 변경됨
const SCHOOL_CODE = "7140392";

async function fetchWithRetry<T>(fn: () => Promise<T>, maxRetries = 2): Promise<T> {
  let lastErr: unknown;
  for (let attempt = 1; attempt <= maxRetries + 1; attempt++) {
    try {
      return await fn();
    } catch (err) {
      lastErr = err;
      if (attempt <= maxRetries) {
        console.warn(`[NEIS] 재시도 ${attempt}/${maxRetries} — ${(err as Error).message}`);
        await new Promise((r) => setTimeout(r, 300));
      }
    }
  }
  throw lastErr;
}

// 전역 fetch(undici)는 연결을 재사용(keep-alive)해서, 매 요청마다 TLS 핸드셰이크를 새로 하던
// https.get보다 연속 요청이 빠르다.
async function fetchJson<T = any>(url: string, timeoutMs = 4000): Promise<T> {
  let res: Response;
  try {
    res = await fetch(url, { signal: AbortSignal.timeout(timeoutMs) });
  } catch (err) {
    if ((err as Error).name === "TimeoutError") throw new Error("요청 시간 초과");
    throw err;
  }
  if (!res.ok) {
    await res.body?.cancel();
    throw new Error(`HTTP ${res.status}`);
  }
  return (await res.json()) as T;
}

// NEIS Open API 공통 호출 — 학교 코드와 인증키는 여기서 채운다
function fetchNeis<T = any>(
  service: string,
  params: Record<string, string | number>,
  timeoutMs?: number,
): Promise<T> {
  const query = new URLSearchParams({
    KEY: NEIS_KEY,
    Type: "json",
    ATPT_OFCDC_SC_CODE: ATPT_CODE,
    SD_SCHUL_CODE: SCHOOL_CODE,
  });
  for (const [k, v] of Object.entries(params)) query.set(k, String(v));
  return fetchJson<T>(`https://open.neis.go.kr/hub/${service}?${query}`, timeoutMs);
}

// KST 기준 분이 바뀔 때마다 한 번씩 콜백을 부른다 (30초 폴링이라 같은 분에 두 번 불리지 않게 막는다)
function onEveryKstMinute(cb: (kst: Date) => void | Promise<void>): void {
  let lastFiredMinute = -1;
  setInterval(() => {
    const kst = kstNow();
    const minuteKey = kst.getUTCHours() * 60 + kst.getUTCMinutes();
    if (minuteKey === lastFiredMinute) return;
    lastFiredMinute = minuteKey;
    Promise.resolve()
      .then(() => cb(kst))
      .catch((err) => console.error("[Timer]", (err as Error).message));
  }, 30 * 1000);
}

const fallbackFileCache = new Map<string, unknown>();
const fallbackMtimeCache = new Map<string, number>();

// 매 요청마다 동기 readFileSync로 이벤트 루프를 막지 않도록, 파일이 안 바뀐 동안은 캐시를 재사용
function readFallbackFile<T>(filename: string, empty: T): T {
  const filePath = path.join(process.cwd(), "fallback", filename);
  try {
    const mtime = fs.statSync(filePath).mtimeMs;
    if (fallbackMtimeCache.get(filename) !== mtime) {
      fallbackFileCache.set(filename, JSON.parse(fs.readFileSync(filePath, "utf8")));
      fallbackMtimeCache.set(filename, mtime);
    }
    return fallbackFileCache.get(filename) as T;
  } catch {
    return empty;
  }
}

interface FallbackMeal {
  menu: string;
  cal: string;
}

// NEIS API 점검/장애 시 fallback/meal.json에 수동 등록한 급식 정보를 대신 사용
function getFallbackMeal(dateStr: string, mealType: number): FallbackMeal | null {
  const data = readFallbackFile<Record<string, Record<string, FallbackMeal>>>("meal.json", {});
  return data[dateStr]?.[String(mealType)] ?? null;
}

interface FallbackScheduleRow {
  day: number;
  event: string;
}

// NEIS API 점검/장애 시 fallback/academic.json에 수동 등록한 학사일정을 대신 사용
function getFallbackSchedule(year: number, month: number): FallbackScheduleRow[] {
  const key = `${year}-${String(month).padStart(2, "0")}`;
  const data = readFallbackFile<Record<string, FallbackScheduleRow[]>>("academic.json", {});
  return data[key] ?? [];
}

export {
  kstNow,
  toMysqlDatetime,
  toKSTDateStr,
  toNeisDateStr,
  fetchWithRetry,
  fetchJson,
  fetchNeis,
  onEveryKstMinute,
  getFallbackMeal,
  getFallbackSchedule,
  NEIS_KEY,
  ATPT_CODE,
  SCHOOL_CODE,
};