recipe_tool/app/api/update/execute/route.ts

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

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

  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 {
        const result = await executeUpdate(sendLog);

        // 发送最终结果
        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 : "未知错误";
        controller.enqueue(
          encoder.encode(
            `data: ${JSON.stringify({ done: true, success: false, message: errMsg })}\n\n`
          )
        );
      } finally {
        controller.close();
      }
    },
  });

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