Function createSubscription

apps/sim/lib/webhooks/providers/calendly.ts:27–165

(ctx: SubscriptionContext)

  },

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

      if (!apiKey) {
        logger.warn(`[${ctx.requestId}] Missing apiKey for Calendly webhook creation.`, {
          webhookId: ctx.webhook.id,
        })
        throw new Error(
          'Personal Access Token is required to create Calendly webhook. Please provide your Calendly Personal Access Token.'
        )
      }

      if (!organization) {
        logger.warn(`[${ctx.requestId}] Missing organization URI for Calendly webhook creation.`, {
          webhookId: ctx.webhook.id,
        })
        throw new Error(
          'Organization URI is required to create Calendly webhook. Please provide your Organization URI from the "Get Current User" operation.'
        )
      }

      if (!triggerId) {
        logger.warn(`[${ctx.requestId}] Missing triggerId for Calendly webhook creation.`, {
          webhookId: ctx.webhook.id,
        })
        throw new Error('Trigger ID is required to create Calendly webhook')
      }

      const notificationUrl = getNotificationUrl(ctx.webhook)

      const eventTypeMap: Record<string, string[]> = {
        calendly_invitee_created: ['invitee.created'],
        calendly_invitee_canceled: ['invitee.canceled'],
        calendly_routing_form_submitted: ['routing_form_submission.created'],
        calendly_webhook: [
          'invitee.created',
          'invitee.canceled',
          'routing_form_submission.created',
        ],
      }

      const events = eventTypeMap[triggerId] || ['invitee.created']

      const calendlyApiUrl = 'https://api.calendly.com/webhook_subscriptions'

      const requestBody = {
        url: notificationUrl,
        events,
        organization,
        scope: 'organization',
      }