Function processEvents

apps/sim/lib/webhooks/polling/google-calendar.ts:288–363

(
  events: CalendarEvent[],
  calendarId: string,
  eventTypeFilter: CalendarEventTypeFilter | undefined,
  webhookData: PollWebhookContext['webhookData'],
  workflowData: PollWebhookContext['workflowData'],
  requestId: string,
  logger: Logger
)

}

async function processEvents(
  events: CalendarEvent[],
  calendarId: string,
  eventTypeFilter: CalendarEventTypeFilter | undefined,
  webhookData: PollWebhookContext['webhookData'],
  workflowData: PollWebhookContext['workflowData'],
  requestId: string,
  logger: Logger
): Promise<{ processedCount: number; failedCount: number; latestUpdated: string | null }> {
  let processedCount = 0
  let failedCount = 0
  let latestUpdated: string | null = null

  for (const event of events) {
    // Track the latest `updated` timestamp for clock-skew-free state tracking
    if (event.updated) {
      if (!latestUpdated || event.updated > latestUpdated) {
        latestUpdated = event.updated
      }
    }

    // Client-side event type filter — skip before idempotency so filtered events aren't cached
    const computedEventType = determineEventType(event)
    if (eventTypeFilter && computedEventType !== eventTypeFilter) {
      continue
    }

    try {
      // Idempotency key includes `updated` so re-edits of the same event re-trigger
      const idempotencyKey = `${webhookData.id}:${event.id}:${event.updated || event.created || ''}`

      await pollingIdempotency.executeWithIdempotency(
        'google-calendar',
        idempotencyKey,
        async () => {
          const simplified = simplifyEvent(event, computedEventType)

          const payload: GoogleCalendarWebhookPayload = {
            event: simplified,
            calendarId,
            timestamp: new Date().toISOString(),
          }

          const result = await processPolledWebhookEvent(
            webhookData,
            workflowData,
            payload,
            requestId
          )

          if (!result.success) {
            logger.error(
              `[${requestId}] Failed to process webhook for event ${event.id}:`,
              result.statusCode,
              result.error
            )
            throw new Error(`Webhook processing failed (${result.statusCode}): ${result.error}`)
          }