Function createSubscription

apps/sim/lib/webhooks/providers/resend.ts:153–260

(ctx: SubscriptionContext)

  },

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

      if (!apiKey) {
        logger.warn(`[${requestId}] Missing apiKey for Resend webhook creation.`, {
          webhookId: webhook.id,
        })
        throw new Error(
          'Resend API Key is required. Please provide your Resend API Key in the trigger configuration.'
        )
      }

      const events =
        triggerId === 'resend_webhook'
          ? RESEND_ALL_WEBHOOK_EVENT_TYPES
          : triggerId && RESEND_TRIGGER_TO_EVENT_TYPE[triggerId]
            ? [RESEND_TRIGGER_TO_EVENT_TYPE[triggerId]]
            : null

      if (!events?.length) {
        throw new Error(`Unknown or unsupported Resend trigger type: ${triggerId ?? '(missing)'}`)
      }

      const notificationUrl = getNotificationUrl(webhook)

      logger.info(`[${requestId}] Creating Resend webhook`, {
        triggerId,
        events,
        webhookId: webhook.id,
      })

      const resendResponse = await fetch('https://api.resend.com/webhooks', {
        method: 'POST',
        headers: {
          Authorization: `Bearer ${apiKey}`,
          'Content-Type': 'application/json',
        },
        body: JSON.stringify({
          endpoint: notificationUrl,
          events,
        }),
      })

      const responseBody = (await resendResponse.json()) as Record<string, unknown>

      if (!resendResponse.ok) {
        const errorMessage =
          (responseBody.message as string) ||
          (responseBody.name as string) ||
          'Unknown Resend API error'
        logger.error(
          `[${requestId}] Failed to create webhook in Resend for webhook ${webhook.id}. Status: ${resendResponse.status}`,
          { message: errorMessage, response: responseBody }
        )