Function deleteSubscription

apps/sim/lib/webhooks/providers/airtable.ts:571–742

({
    webhook: webhookRecord,
    workflow,
    requestId,
    strict,
  }: DeleteSubscriptionContext)

  },

  async deleteSubscription({
    webhook: webhookRecord,
    workflow,
    requestId,
    strict,
  }: DeleteSubscriptionContext): Promise<void> {
    try {
      const config = getProviderConfig(webhookRecord)
      const { baseId, externalId } = config as {
        baseId?: string
        externalId?: string
      }

      if (!baseId) {
        logger.warn(`[${requestId}] Missing baseId for Airtable webhook deletion`, {
          webhookId: webhookRecord.id,
        })
        if (strict) throw new Error('Missing Airtable baseId for webhook deletion')
        return
      }

      const baseIdValidation = validateAirtableId(baseId, 'app', 'baseId')
      if (!baseIdValidation.isValid) {
        logger.warn(`[${requestId}] Invalid Airtable base ID format, skipping deletion`, {
          webhookId: webhookRecord.id,
          baseId: baseId.substring(0, 20),
        })
        if (strict) throw new Error('Invalid Airtable baseId for webhook deletion')
        return
      }

      const credentialId = config.credentialId as string | undefined
      if (!credentialId) {
        logger.warn(
          `[${requestId}] Missing credentialId for Airtable webhook deletion ${webhookRecord.id}`
        )
        if (strict) throw new Error('Missing Airtable credentialId for webhook deletion')
        return
      }

      const credentialOwner = await getCredentialOwner(credentialId, requestId)
      const accessToken = credentialOwner
        ? await refreshAccessTokenIfNeeded(
            credentialOwner.accountId,
            credentialOwner.userId,
            requestId
          )
        : null
      if (!accessToken) {
        const message = `[${requestId}] Could not retrieve Airtable access token. Cannot delete webhook in Airtable.`
        logger.warn(message, { webhookId: webhookRecord.id })
        if (strict) throw new Error(message)
        return
      }

      let resolvedExternalId: string | undefined = externalId
      let externalIdLookupFailed = false