Function upsertProjectServiceConnection

lib/services/project-services.ts:45–75

(
  projectId: string,
  provider: string,
  serviceData: Record<string, unknown>
)

}

export async function upsertProjectServiceConnection(
  projectId: string,
  provider: string,
  serviceData: Record<string, unknown>
) {
  const existing = await prisma.projectServiceConnection.findFirst({
    where: { projectId, provider },
  });

  if (existing) {
    const updated = await prisma.projectServiceConnection.update({
      where: { id: existing.id },
      data: {
        serviceData: serializeServiceData(serviceData),
        status: 'connected',
      },
    });
    return deserializeServiceData(updated);
  }

  const created = await prisma.projectServiceConnection.create({
    data: {
      projectId,
      provider,
      status: 'connected',
      serviceData: serializeServiceData(serviceData),
    },
  });

  return deserializeServiceData(created);
}

export async function deleteProjectService(serviceId: string): Promise<boolean> {
  try {