Function createSubscription

apps/sim/lib/webhooks/providers/rootly.ts:138–234

(ctx: SubscriptionContext)

  },

  async createSubscription(ctx: SubscriptionContext): Promise<SubscriptionResult | undefined> {
    try {
      const providerConfig = getProviderConfig(ctx.webhook)
      const { apiKey, triggerId } = providerConfig as {
        apiKey?: string
        triggerId?: string
      }

      if (!apiKey) {
        throw new Error(
          'Rootly API key is required. Please provide your Rootly API key in the trigger configuration.'
        )
      }

      const { rootlyEventTypesForTrigger } = await import('@/triggers/rootly/utils')
      const eventTypes = rootlyEventTypesForTrigger(triggerId)
      const notificationUrl = getNotificationUrl(ctx.webhook)

      const signingSecret = generateId()

      logger.info(`[${ctx.requestId}] Creating Rootly webhook endpoint`, {
        triggerId,
        eventTypes,
        webhookId: ctx.webhook.id,
      })

      const requestBody = {
        data: {
          type: 'webhooks_endpoints',
          attributes: {
            name: `Sim (${triggerId || 'rootly'})`,
            url: notificationUrl,
            secret: signingSecret,
            event_types: eventTypes,
            enabled: true,
          },
        },
      }

      const response = await fetch('https://api.rootly.com/v1/webhooks/endpoints', {
        method: 'POST',
        headers: {
          Authorization: `Bearer ${apiKey}`,
          'Content-Type': 'application/vnd.api+json',
          Accept: 'application/vnd.api+json',
        },
        body: JSON.stringify(requestBody),
      })

      const responseBody = (await response.json().catch(() => ({}))) as Record<string, unknown>

      if (!response.ok) {
        const errors = responseBody.errors as Array<Record<string, unknown>> | undefined
        const errorDetail =
          (errors?.[0]?.detail as string | undefined) ||
          (errors?.[0]?.title as string | undefined) ||
          (responseBody.error as string | undefined)