Function createSubscription

apps/sim/lib/webhooks/providers/monday.ts:77–173

* Create a Monday.com webhook subscription via their GraphQL API. * Monday.com webhooks are board-scoped and event-type-specific.

(ctx: SubscriptionContext)

   * Monday.com webhooks are board-scoped and event-type-specific.
   */
  async createSubscription(ctx: SubscriptionContext): Promise<SubscriptionResult | undefined> {
    const config = getProviderConfig(ctx.webhook)
    const triggerId = config.triggerId as string | undefined
    const boardId = config.boardId as string | undefined

    if (!triggerId) {
      logger.warn(`[${ctx.requestId}] Missing triggerId for Monday webhook ${ctx.webhook.id}`)
      throw new Error('Trigger type is required for Monday.com webhook creation.')
    }

    if (!boardId) {
      logger.warn(`[${ctx.requestId}] Missing boardId for Monday webhook ${ctx.webhook.id}`)
      throw new Error(
        'Board ID is required. Please provide a valid Monday.com board ID in the trigger configuration.'
      )
    }

    const boardIdValidation = validateMondayNumericId(boardId, 'boardId')
    if (!boardIdValidation.isValid) {
      throw new Error(boardIdValidation.error!)
    }

    const { MONDAY_EVENT_TYPE_MAP } = await import('@/triggers/monday/utils')
    const eventType = MONDAY_EVENT_TYPE_MAP[triggerId]
    if (!eventType) {
      logger.warn(`[${ctx.requestId}] Unknown Monday trigger ID: ${triggerId}`)
      throw new Error(`Unknown Monday.com trigger type: ${triggerId}`)
    }

    const accessToken = await resolveAccessToken(config, ctx.userId, ctx.requestId)
    const notificationUrl = getNotificationUrl(ctx.webhook)

    try {
      const response = await fetch(MONDAY_API_URL, {
        method: 'POST',
        headers: {
          'Content-Type': 'application/json',
          'API-Version': '2024-10',
          Authorization: accessToken,
        },
        body: JSON.stringify({
          query: `mutation { create_webhook(board_id: ${boardIdValidation.sanitized}, url: ${JSON.stringify(notificationUrl)}, event: ${eventType}) { id board_id } }`,
        }),
      })

      if (!response.ok) {
        throw new Error(
          `Monday.com API returned HTTP ${response.status}. Please verify your account connection and try again.`
        )
      }

      const data = await response.json()
      const errors = data.errors as Array<{ message: string }> | undefined

      if (errors && errors.length > 0) {
        const errorMsg = errors.map((e) => e.message).join(', ')
        logger.error(`[${ctx.requestId}] Failed to create Monday webhook`, {
          errors: errorMsg,