Function pollWebhook

apps/sim/lib/webhooks/polling/google-calendar.ts:97–182

(ctx: PollWebhookContext)

  label: 'Google Calendar',

  async pollWebhook(ctx: PollWebhookContext): Promise<'success' | 'failure'> {
    const { webhookData, workflowData, requestId, logger } = ctx
    const webhookId = webhookData.id

    try {
      const accessToken = await resolveOAuthCredential(
        webhookData,
        'google-calendar',
        requestId,
        logger
      )

      const config = getProviderConfig<GoogleCalendarWebhookConfig>(webhookData.providerConfig)
      // Canonical key `calendarId` first; `manualCalendarId` is a transitional basic-first
      // fallback. Defaults to the user's primary calendar when none is set.
      const calendarId =
        readCanonicalTriggerValue(config.calendarId, config.manualCalendarId) || 'primary'

      // First poll: seed timestamp, emit nothing
      if (!config.lastCheckedTimestamp) {
        await updateWebhookProviderConfig(
          webhookId,
          { lastCheckedTimestamp: new Date(Date.now() - 30_000).toISOString() },
          logger
        )
        await markWebhookSuccess(webhookId, logger)
        logger.info(`[${requestId}] First poll for webhook ${webhookId}, seeded timestamp`)
        return 'success'
      }

      // Fetch changed events since last poll
      const events = await fetchChangedEvents(accessToken, calendarId, config, requestId, logger)

      if (!events.length) {
        await markWebhookSuccess(webhookId, logger)
        logger.info(`[${requestId}] No changed events for webhook ${webhookId}`)
        return 'success'
      }

      logger.info(`[${requestId}] Found ${events.length} changed events for webhook ${webhookId}`)

      const { processedCount, failedCount, latestUpdated } = await processEvents(
        events,
        calendarId,
        config.eventTypeFilter,
        webhookData,
        workflowData,
        requestId,
        logger
      )

      // Advance cursor to latestUpdated - 5s for clock-skew overlap, but never regress
      // below the previous cursor — this prevents an infinite re-fetch loop when all
      // returned events are filtered client-side and latestUpdated is within 5s of the cursor.
      const newTimestamp =
        failedCount > 0
          ? config.lastCheckedTimestamp
          : latestUpdated