frontend-admin / Daocheng-Yading

  import type {
    GuideOverrides,
    KnowledgeEntry,
    KioskServerBundle,
    VideoSourceConfig,
    WelcomeMessages,

  } from "../kioskStorage";

  import { applyServerBundle } from "../kioskStorage";

  /**
   * API 根地址。
   * - 若设置 `VITE_API_BASE_URL`（非空）：开发与生产均使用该地址（浏览器直连该主机，需后端 CORS 正确）。
   * - 生产构建且未设置：空字符串 → 同域 `/api/...`，由 Nginx 反代到 PHP。
   * - 开发且未设置：空字符串 → 与 Vite 同源（默认 9999），由 `vite.config.ts` 把 `/api`、`/uploads` 代理到后端，避免 9999→9901 跨域导致 Failed to fetch。
   */

  export function apiBase(): string {

    const raw = import.meta.env.VITE_API_BASE_URL;
    if (typeof raw === "string" && raw.trim() !== "") {
      return raw.replace(/\/$/, "");
    }
    return "";

  }
  
  export function apiUrl(path: string): string {
    const p = path.startsWith("/") ? path : `/${path}`;
    return `${apiBase()}${p}`;
  }
  
  export type ApiResult<T> = { code: number; data?: T; msg?: string };
  

  export type KioskBundle = KioskServerBundle;
  
  /** 避免 ThinkPHP APP_DEBUG 下 trace 在 JSON 后追加脚本导致整段无法 parse */
  function parseJsonTextLoose(text: string): unknown {
    const trimmed = text.trim();
    if (!trimmed) return {};

    try {

      return JSON.parse(trimmed);

    } catch {

      const s = trimmed.indexOf("{");
      const e = trimmed.lastIndexOf("}");
      if (s >= 0 && e > s) {
        try {
          return JSON.parse(trimmed.slice(s, e + 1));
        } catch {
          return {};
        }
      }

      return {};
    }
  }
  

  async function parseBody(res: Response): Promise<unknown> {
    const t = await res.text();
    return parseJsonTextLoose(t);
  }
  
  export function apiCodeOk(code: unknown): boolean {
    return code === 0 || code === "0";
  }
  
  function formatSyncError(e: unknown): string {
    return e instanceof Error ? e.message : String(e);
  }
  

  export async function kioskGet<T>(path: string): Promise<ApiResult<T>> {
    const res = await fetch(apiUrl(path), {
      method: "GET",

      headers: {
        Accept: "application/json",
        "X-Requested-With": "XMLHttpRequest",
      },

    });
    const body = (await parseBody(res)) as ApiResult<T>;
    if (!res.ok && body.code === undefined) {
      return { code: res.status, msg: res.statusText };
    }
    return body;
  }
  

  export type DataDisplayPayload = {
    realtimeImages: Array<{
      id: number;
      name: string;
      time: string;
      telescope: string;
      exposure: string;
      image: string;
    }>;
    status: {
      weather: string;
      seeing: string;
      transparency: string;
      moonPhase: string;
    };
    historicalData: Array<{
      date: string;
      observations: number;
      quality: string;
      weather: string;
    }>;
  };
  
  export type ObservatoryHistoryPayload = {
    items: Array<{
      id: number;
      kind: string;
      title: string;
      summary: string;
      date: string;
      thumb: string;
    }>;
  };
  

  /** 从后端拉取 bundle 并写入内存（不写 localStorage） */

  export async function fetchAndApplyKioskBundle(): Promise<boolean> {
    const res = await kioskGet<KioskBundle>("/api/kiosk/bundle");

    if (!apiCodeOk(res.code) || !res.data) {

      return false;
    }

    applyServerBundle(res.data);

    return true;
  }
  
  export async function fetchDataDisplay(): Promise<DataDisplayPayload | null> {
    const res = await kioskGet<DataDisplayPayload>("/api/kiosk/data-display");

    if (!apiCodeOk(res.code) || !res.data) return null;

    return res.data;
  }
  
  export async function fetchObservatoryHistory(): Promise<ObservatoryHistoryPayload["items"] | null> {
    const res = await kioskGet<ObservatoryHistoryPayload>("/api/kiosk/observatory-history");

    if (!apiCodeOk(res.code) || !res.data?.items) return null;

    return res.data.items;
  }
  
  function adminHeaders(): HeadersInit {
    const token = import.meta.env.VITE_ADMIN_API_TOKEN ?? "";

    const h: Record<string, string> = {
      "Content-Type": "application/json",
      Accept: "application/json",
      "X-Requested-With": "XMLHttpRequest",
    };
    if (token) h["X-Admin-Token"] = token;
    return h;
  }
  
  /** multipart 上传勿带 Content-Type，由浏览器自动带 boundary */
  function adminHeadersMultipart(): HeadersInit {
    const token = import.meta.env.VITE_ADMIN_API_TOKEN ?? "";
    const h: Record<string, string> = {
      Accept: "application/json",
      "X-Requested-With": "XMLHttpRequest",
    };

    if (token) h["X-Admin-Token"] = token;
    return h;
  }
  

  /** 知识库 image / videoUrl：data URL、绝对 URL 原样返回；否则拼 API 根（开发直连后端、生产同域相对路径） */
  export function resolveKioskMediaUrl(stored: string | undefined | null): string {
    if (stored == null) return "";
    const s = stored.trim();
    if (s === "") return "";
    if (s.startsWith("data:") || s.startsWith("http://") || s.startsWith("https://")) return s;
    const base = apiBase();
    if (s.startsWith("/")) return base ? `${base}${s}` : s;
    return base ? `${base}/${s}` : `/${s}`;
  }
  
  /** 上传封面或视频，成功返回 `/uploads/knowledge/...`；失败 throw（含服务器 msg） */
  export async function uploadKnowledgeMediaFile(file: File): Promise<string> {
    const fd = new FormData();
    fd.append("file", file);
    let res: Response;
    try {
      res = await fetch(apiUrl("/api/admin/knowledge/upload-media"), {
        method: "POST",
        headers: adminHeadersMultipart(),
        body: fd,
      });
    } catch (e) {
      throw new Error(
        `无法连接上传接口（${formatSyncError(e)}）。请确认后端已启动且可访问 ${apiUrl("/api/admin/knowledge/upload-media")}。`
      );
    }
    const body = (await parseBody(res)) as ApiResult<{ url?: string }> & { url?: unknown };
    const fromData = body.data?.url;
    const fromTop = body.url;
    const url =
      typeof fromData === "string" && fromData
        ? fromData
        : typeof fromTop === "string" && fromTop
          ? fromTop
          : "";
    if (!res.ok || !apiCodeOk(body.code) || !url) {
      const detail =
        typeof body.msg === "string" && body.msg.trim() !== ""
          ? body.msg
          : `HTTP ${res.status} · ${JSON.stringify(body).slice(0, 400)}`;
      throw new Error(`上传失败：${detail}`);
    }
    return url;

  }
  
  export async function pushHomeBackgroundsToServer(urls: string[]): Promise<boolean> {
    const res = await fetch(apiUrl("/api/admin/kiosk/home-backgrounds"), {
      method: "POST",
      headers: adminHeaders(),
      body: JSON.stringify({ urls }),
    });
    const body = (await parseBody(res)) as ApiResult<unknown>;

    return res.ok && apiCodeOk(body.code);

  }
  
  export async function pushWelcomeToServer(w: WelcomeMessages): Promise<boolean> {
    const res = await fetch(apiUrl("/api/admin/kiosk/welcome"), {
      method: "POST",
      headers: adminHeaders(),
      body: JSON.stringify(w),
    });
    const body = (await parseBody(res)) as ApiResult<unknown>;

    return res.ok && apiCodeOk(body.code);

  }
  
  export async function pushGuideToServer(guide: GuideOverrides): Promise<boolean> {
    const res = await fetch(apiUrl("/api/admin/kiosk/guide"), {
      method: "POST",
      headers: adminHeaders(),
      body: JSON.stringify({ guide }),
    });
    const body = (await parseBody(res)) as ApiResult<unknown>;

    return res.ok && apiCodeOk(body.code);

  }
  

  /**
   * 全量同步知识库。成功时 resolve；失败时 throw（网络、序列化、或接口返回错误），便于展示具体原因。
   */
  export async function pushKnowledgeToServer(entries: KnowledgeEntry[]): Promise<void> {
    let body: string;
    try {
      body = JSON.stringify({ entries });
    } catch (e) {
      throw new Error(
        `知识库 JSON 序列化失败（常见原因：库里仍有旧版写入的超大 base64 图片/视频，整表一起提交时超出浏览器限制）：${formatSyncError(e)}`
      );
    }
    const approxMb = Math.round(body.length / (1024 * 1024));
    if (body.length > 60 * 1024 * 1024) {
      throw new Error(
        `本次同步请求体约 ${approxMb}MB，过大。请删除或编辑仍含「data:image/…」「data:video/…」大内联媒体的条目后重试，或调大 PHP post_max_size / Nginx client_max_body_size。`
      );
    }
  
    let res: Response;
    try {
      res = await fetch(apiUrl("/api/admin/knowledge/sync"), {
        method: "POST",
        headers: adminHeaders(),
        body,
      });
    } catch (e) {
      throw new Error(
        `无法连接保存接口（${formatSyncError(e)}）。说明：页面在 ${typeof window !== "undefined" ? window.location.origin : ""}，接口在 ${apiUrl("/api/admin/knowledge/sync")}；本机开发请运行 daocheng-api（composer run dev 或 php think run -p 9901），并与 .env.development 中 VITE_DEV_PROXY_TARGET 端口一致。`
      );
    }
  
    const parsed = (await parseBody(res)) as ApiResult<unknown>;
    if (!res.ok || !apiCodeOk(parsed.code)) {
      const detail =
        typeof parsed.msg === "string" && parsed.msg.trim() !== ""
          ? parsed.msg
          : `${res.status} ${res.statusText}`.trim();
      throw new Error(`服务器拒绝保存：${detail}`);
    }
  }
  
  export async function pushVideoSourceToServer(cfg: VideoSourceConfig): Promise<boolean> {
    const res = await fetch(apiUrl("/api/admin/kiosk/video-source"), {

      method: "POST",
      headers: adminHeaders(),

      body: JSON.stringify({
        protocol: cfg.protocol,
        url: cfg.url,
        note: cfg.note,
      }),
    });
    const body = (await parseBody(res)) as ApiResult<unknown>;
    return res.ok && apiCodeOk(body.code);
  }
  
  export async function pushCarouselBackgroundsToServer(urls: string[]): Promise<boolean> {
    const res = await fetch(apiUrl("/api/admin/kiosk/carousel-backgrounds"), {
      method: "POST",
      headers: adminHeaders(),
      body: JSON.stringify({ urls }),

    });
    const body = (await parseBody(res)) as ApiResult<unknown>;

    return res.ok && apiCodeOk(body.code);

  }