import { useMutation, useQueryClient } from '@tanstack/react-query'
import { toast } from 'sonner'

import { handleError, post } from 'data/fetchers'
import { useIntegrationInstallationSnapshot } from 'state/integration-installation'
import type { ResponseError, UseCustomMutationOptions } from 'types'
import type { IntegrationConnectionsCreateVariables } from './integrations.types'
import { integrationKeys } from './keys'

export async function createIntegrationVercelConnections({
  organizationIntegrationId,
  connection,
}: IntegrationConnectionsCreateVariables) {
  const { data, error } = await post('/platform/integrations/vercel/connections', {
    body: {
      organization_integration_id: organizationIntegrationId,
      connection: {
        foreign_project_id: connection.foreign_project_id,
        supabase_project_ref: connection.supabase_project_ref,
        metadata: connection.metadata,
      },
    },
  })

  if (error) handleError(error)
  return data
}

export type IntegrationVercelConnectionsCreateData = Awaited<
  ReturnType<typeof createIntegrationVercelConnections>
>

export const useIntegrationVercelConnectionsCreateMutation = ({
  onSuccess,
  onError,
  ...options
}: Omit<
  UseCustomMutationOptions<
    IntegrationVercelConnectionsCreateData,
    ResponseError,
    IntegrationConnectionsCreateVariables
  >,
  'mutationFn'
> = {}) => {
  const queryClient = useQueryClient()
  const snapshot = useIntegrationInstallationSnapshot()
  return useMutation<
    IntegrationVercelConnectionsCreateData,
    ResponseError,
    IntegrationConnectionsCreateVariables
  >({
    mutationFn: (vars) => createIntegrationVercelConnections(vars),
    async onSuccess(data, variables, context) {
      await Promise.all([
        queryClient.invalidateQueries({ queryKey: integrationKeys.integrationsList() }),
        queryClient.invalidateQueries({
          queryKey: integrationKeys.integrationsListWithOrg(variables.orgSlug),
        }),
        queryClient.invalidateQueries({
          queryKey: integrationKeys.vercelProjectList(variables.organizationIntegrationId),
        }),
        queryClient.invalidateQueries({
          queryKey: integrationKeys.vercelConnectionsList(variables.organizationIntegrationId),
        }),
      ])
      await onSuccess?.(data, variables, context)
    },
    async onError(data, variables, context) {
      snapshot.setLoading(false)
      if (onError === undefined) {
        toast.error(`Failed to create connection: ${data.message}`)
      } else {
        onError(data, variables, context)
      }
    },
    ...options,
  })
}