import { type LoaderFunctionArgs } from "@remix-run/server-runtime";
import { prisma } from "~/db.server";
import { redirectWithSuccessMessage } from "~/models/message.server";
import { OrgIntegrationRepository } from "~/models/orgIntegration.server";
import { findProjectBySlug } from "~/models/project.server";
import { requireUserId } from "~/services/session.server";
import {
  EnvironmentParamSchema,
  v3NewProjectAlertPath,
  v3NewProjectAlertPathConnectToSlackPath,
} from "~/utils/pathBuilder";

export async function loader({ request, params }: LoaderFunctionArgs) {
  const userId = await requireUserId(request);
  const { organizationSlug, projectParam, envParam } = EnvironmentParamSchema.parse(params);

  const url = new URL(request.url);
  const shouldReinstall = url.searchParams.get("reinstall") === "true";

  const project = await findProjectBySlug(organizationSlug, projectParam, userId);

  if (!project) {
    throw new Response("Project not found", { status: 404 });
  }

  // Find an integration for Slack for this org
  const integration = await prisma.organizationIntegration.findFirst({
    where: {
      service: "SLACK",
      organizationId: project.organizationId,
      deletedAt: null,
    },
  });

  // If integration exists and we're not reinstalling, redirect back to alerts
  if (integration && !shouldReinstall) {
    return redirectWithSuccessMessage(
      `${v3NewProjectAlertPath({ slug: organizationSlug }, project, {
        slug: envParam,
      })}?option=slack`,
      request,
      "Successfully connected your Slack workspace"
    );
  }

  // Redirect to Slack for new installation or reinstallation
  return await OrgIntegrationRepository.redirectToAuthService(
    "SLACK",
    project.organizationId,
    request,
    v3NewProjectAlertPathConnectToSlackPath({ slug: organizationSlug }, project, {
      slug: envParam,
    })
  );
}