Function deleteSubscription

apps/sim/lib/webhooks/providers/lemlist.ts:123–232

(ctx: DeleteSubscriptionContext)

  },

  async deleteSubscription(ctx: DeleteSubscriptionContext): Promise<void> {
    const { webhook, requestId } = ctx
    try {
      const config = getProviderConfig(webhook)
      const apiKey = config.apiKey as string | undefined
      const externalId = config.externalId as string | undefined

      if (!apiKey) {
        logger.warn(
          `[${requestId}] Missing apiKey for Lemlist webhook deletion ${webhook.id}, skipping cleanup`
        )
        if (ctx.strict) throw new Error('Missing Lemlist apiKey for webhook deletion')
        return
      }

      const authString = Buffer.from(`:${apiKey}`).toString('base64')

      const deleteById = async (id: string) => {
        const validation = validateAlphanumericId(id, 'Lemlist hook ID', 50)
        if (!validation.isValid) {
          logger.warn(`[${requestId}] Invalid Lemlist hook ID format, skipping deletion`, {
            id: id.substring(0, 30),
          })
          if (ctx.strict) throw new Error('Invalid Lemlist hook ID for deletion')
          return
        }

        const lemlistApiUrl = `https://api.lemlist.com/api/hooks/${id}`
        const lemlistResponse = await fetch(lemlistApiUrl, {
          method: 'DELETE',
          headers: {
            Authorization: `Basic ${authString}`,
          },
        })

        if (!lemlistResponse.ok && lemlistResponse.status !== 404) {
          const responseBody = await lemlistResponse.json().catch(() => ({}))
          logger.warn(
            `[${requestId}] Failed to delete Lemlist webhook (non-fatal): ${lemlistResponse.status}`,
            { response: responseBody }
          )
          if (ctx.strict) {
            throw new Error(`Failed to delete Lemlist webhook: ${lemlistResponse.status}`)
          }
        } else {
          logger.info(`[${requestId}] Successfully deleted Lemlist webhook ${id}`)
        }
      }

      if (externalId) {
        await deleteById(externalId)
        return
      }

      if (ctx.strict) {
        logger.warn(
          `[${requestId}] Missing Lemlist externalId during strict cleanup; skipping unsafe URL-based remote deletion`,
          { webhookId: webhook.id }