import { prisma } from "~/db.server";

export const getIntegrationAccount = async (
  integrationDefinitionId: string,
  userId: string,
) => {
  return await prisma.integrationAccount.findFirst({
    where: {
      integrationDefinitionId: integrationDefinitionId,
      integratedById: userId,
      isActive: true,
    },
    include: {
      integrationDefinition: true,
    },
  });
};

export const getIntegrationAccountForId = async (id: string) => {
  return await prisma.integrationAccount.findUnique({
    where: {
      id,
    },
  });
};

export const getIntegrationAccounts = async (userId: string) => {
  return prisma.integrationAccount.findMany({
    where: {
      integratedById: userId,
      isActive: true,
    },
    include: {
      integrationDefinition: true,
    },
  });
};

export const getIntegrationAccountForSlug = async (slug: string) => {
  return await prisma.integrationAccount.findFirst({
    where: {
      integrationDefinition: {
        slug,
      },
    },
  });
};