Function configurePolling

apps/sim/lib/webhooks/providers/outlook.ts:24–112

({ webhook: webhookData, requestId }: PollingConfigContext)

  },

  async configurePolling({ webhook: webhookData, requestId }: PollingConfigContext) {
    logger.info(`[${requestId}] Setting up Outlook polling for webhook ${webhookData.id}`)

    try {
      const providerConfig = (webhookData.providerConfig as Record<string, unknown>) || {}
      const credentialId = providerConfig.credentialId as string | undefined

      if (!credentialId) {
        logger.error(`[${requestId}] Missing credentialId for Outlook webhook ${webhookData.id}`)
        return false
      }

      const resolvedOutlook = await resolveOAuthAccountId(credentialId)
      if (!resolvedOutlook) {
        logger.error(
          `[${requestId}] Could not resolve credential ${credentialId} for Outlook webhook ${webhookData.id}`
        )
        return false
      }

      const rows = await db
        .select()
        .from(account)
        .where(eq(account.id, resolvedOutlook.accountId))
        .limit(1)
      if (rows.length === 0) {
        logger.error(
          `[${requestId}] Credential ${credentialId} not found for Outlook webhook ${webhookData.id}`
        )
        return false
      }

      const effectiveUserId = rows[0].userId

      const accessToken = await refreshAccessTokenIfNeeded(
        resolvedOutlook.accountId,
        effectiveUserId,
        requestId
      )
      if (!accessToken) {
        logger.error(
          `[${requestId}] Failed to refresh/access Outlook token for credential ${credentialId}`
        )
        return false
      }

      const now = new Date()

      await db
        .update(webhook)
        .set({
          providerConfig: {
            ...providerConfig,
            userId: effectiveUserId,
            credentialId,
            maxEmailsPerPoll:
              typeof providerConfig.maxEmailsPerPoll === 'string'
                ? Number.parseInt(providerConfig.maxEmailsPerPoll, 10) || 25