Function deleteSubscription

apps/sim/lib/webhooks/providers/rootly.ts:236–285

(ctx: DeleteSubscriptionContext)

  },

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

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

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

      const response = await fetch(`https://api.rootly.com/v1/webhooks/endpoints/${externalId}`, {
        method: 'DELETE',
        headers: {
          Authorization: `Bearer ${apiKey}`,
          Accept: 'application/vnd.api+json',
        },
      })

      if (response.ok || response.status === 404) {
        await response.body?.cancel()
        logger.info(
          `[${ctx.requestId}] Deleted Rootly webhook endpoint ${externalId} (status ${response.status})`
        )
      } else {
        const responseBody = await response.json().catch(() => ({}))
        logger.warn(
          `[${ctx.requestId}] Failed to delete Rootly webhook endpoint (non-fatal): ${response.status}`,
          { response: responseBody }
        )
        if (ctx.strict) {
          throw new Error(`Failed to delete Rootly webhook endpoint: ${response.status}`)
        }
      }
    } catch (error) {
      logger.warn(`[${ctx.requestId}] Error deleting Rootly webhook (non-fatal)`, error)
      if (ctx.strict) throw error
    }
  },
}