import { NextRequest, NextResponse } from "next/server";
import { prisma } from "@/lib/prisma";
import {
  badRequestResponse,
  getCurrentUser,
  getRequestIp,
  notFoundResponse,
  unauthorizedResponse,
} from "@/lib/server-auth";
import { canCompleteMonitorInstance } from "@/lib/monitor/access";
import { buildMonitorOperator } from "@/lib/monitor/audit";
import { reopenMonitorInstance } from "@/lib/monitor/instance-actions";
import { parseJsonObject } from "@/lib/monitor/utils";

function getId(params: { id: string }) {
  const id = Number(params.id);
  return Number.isInteger(id) && id > 0 ? id : null;
}

export async function POST(
  req: NextRequest,
  { params }: { params: { id: string } }
) {
  const currentUser = await getCurrentUser(req);
  if (!currentUser) {
    return unauthorizedResponse();
  }

  const id = getId(params);
  if (!id) {
    return badRequestResponse("实例 ID 不合法");
  }

  const instance = await prisma.monitorInstance.findUnique({
    where: { id },
    include: {
      plan: true,
      item: {
        include: {
          itemUsers: true,
        },
      },
    },
  });

  if (!instance) {
    return notFoundResponse("实例不存在");
  }

  const ownerUserIds = instance.item.itemUsers
    .filter((entry) => entry.roleType === "OWNER" && entry.isEnabled)
    .map((entry) => entry.userId);

  if (!canCompleteMonitorInstance(currentUser, instance.plan.ownerDeptId, ownerUserIds)) {
    return NextResponse.json({ message: "无权限重开该实例" }, { status: 403 });
  }

  const body = await req.json().catch(() => ({}));
  const payload = parseJsonObject(body);
  const reason =
    typeof payload?.reason === "string" ? payload.reason.trim() : "";

  try {
    const updated = await reopenMonitorInstance({
      instanceId: instance.id,
      operator: buildMonitorOperator(currentUser, getRequestIp(req)),
      reason,
    });

    return NextResponse.json({ instance: updated });
  } catch (error) {
    const message =
      error instanceof Error ? error.message : "重开实例失败";

    if (message === "INSTANCE_NOT_FOUND") {
      return notFoundResponse("实例不存在");
    }
    if (message === "INSTANCE_NOT_COMPLETED") {
      return badRequestResponse("仅已完成实例支持重开");
    }

    throw error;
  }
}