Function deleteSubscription

apps/sim/lib/webhooks/providers/monday.ts:179–281

* Delete a Monday.com webhook subscription via their GraphQL API. * Errors are logged but not thrown (non-fatal cleanup).

(ctx: DeleteSubscriptionContext)

   * Errors are logged but not thrown (non-fatal cleanup).
   */
  async deleteSubscription(ctx: DeleteSubscriptionContext): Promise<void> {
    const config = getProviderConfig(ctx.webhook)
    const externalId = config.externalId as string | undefined

    if (!externalId) {
      if (ctx.strict) throw new Error('Missing Monday externalId for webhook deletion')
      return
    }

    const externalIdValidation = validateMondayNumericId(externalId, 'webhookId')
    if (!externalIdValidation.isValid) {
      logger.warn(
        `[${ctx.requestId}] Invalid externalId format for Monday webhook deletion: ${externalId}`
      )
      if (ctx.strict) throw new Error('Invalid Monday externalId for webhook deletion')
      return
    }

    let accessToken: string | null = null
    try {
      const credentialId = config.credentialId as string | undefined
      if (credentialId) {
        const credentialOwner = await getCredentialOwner(credentialId, ctx.requestId)
        if (credentialOwner) {
          accessToken = await refreshAccessTokenIfNeeded(
            credentialOwner.accountId,
            credentialOwner.userId,
            ctx.requestId
          )
        }
      }
    } catch (error) {
      logger.warn(
        `[${ctx.requestId}] Could not resolve credentials for Monday webhook deletion (non-fatal)`,
        { error: toError(error).message }
      )
      if (ctx.strict) throw error
    }

    if (!accessToken) {
      logger.warn(
        `[${ctx.requestId}] No access token available for Monday webhook deletion ${externalId} (non-fatal)`
      )
      if (ctx.strict) throw new Error('Missing Monday access token for webhook deletion')
      return
    }

    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 { delete_webhook(id: ${externalIdValidation.sanitized}) { id board_id } }`,
        }),