const API_TAG = "SSE-API";
function apiLog(msg: string) {
  const t = new Date().toISOString().slice(0, 19).replace("T", " ");
  console.log(`[${t}] [${API_TAG}] ${msg}`);
}
function apiErr(msg: string) {
  const t = new Date().toISOString().slice(0, 19).replace("T", " ");
  console.error(`[${t}] [${API_TAG}] ${msg}`);
}

import { executeUpdate } from "@/lib/update";

// POST /api/update/execute - 执行容器更新（SSE 流式输出日志）
export async function POST() {
  const encoder = new TextEncoder();

  apiLog("收到更新请求，创建 SSE 流");

  const stream = new ReadableStream({
    async start(controller) {
      // 发送日志的辅助函数
      const sendLog = (message: string) => {
        const data = JSON.stringify({ log: message });
        controller.enqueue(encoder.encode(`data: ${data}\n\n`));
      };

      try {
        apiLog("开始执行 executeUpdate...");
        const result = await executeUpdate(sendLog);

        apiLog(`executeUpdate 完成: success=${result.success}, message="${result.message}"`);

        // 发送最终结果
        const finalData = JSON.stringify({
          done: true,
          success: result.success,
          message: result.message,
        });
        controller.enqueue(encoder.encode(`data: ${finalData}\n\n`));
      } catch (error) {
        const errMsg =
          error instanceof Error ? error.message : "未知错误";
        apiErr(`SSE 流异常: ${errMsg}`);
        controller.enqueue(
          encoder.encode(
            `data: ${JSON.stringify({ done: true, success: false, message: errMsg })}\n\n`
          )
        );
      } finally {
        apiLog("关闭 SSE 流");
        controller.close();
      }
    },
  });

  return new Response(stream, {
    headers: {
      "Content-Type": "text/event-stream",
      "Cache-Control": "no-cache",
      Connection: "keep-alive",
    },
  });
}