Function fetchChangedEvents

apps/sim/lib/webhooks/polling/google-calendar.ts:185–247

(
  accessToken: string,
  calendarId: string,
  config: GoogleCalendarWebhookConfig,
  requestId: string,
  logger: Logger
)

}

async function fetchChangedEvents(
  accessToken: string,
  calendarId: string,
  config: GoogleCalendarWebhookConfig,
  requestId: string,
  logger: Logger
): Promise<CalendarEvent[]> {
  const allEvents: CalendarEvent[] = []
  const maxEvents = config.maxEventsPerPoll || MAX_EVENTS_PER_POLL
  let pageToken: string | undefined
  let pages = 0

  do {
    pages++
    const params = new URLSearchParams({
      updatedMin: config.lastCheckedTimestamp!,
      singleEvents: 'true',
      showDeleted: 'true',
      maxResults: String(Math.min(maxEvents, 250)),
    })

    if (pageToken) {
      params.set('pageToken', pageToken)
    }

    if (config.searchTerm) {
      params.set('q', config.searchTerm)
    }

    const encodedCalendarId = encodeURIComponent(calendarId)
    const url = `${CALENDAR_API_BASE}/calendars/${encodedCalendarId}/events?${params.toString()}`

    const response = await fetch(url, {
      headers: { Authorization: `Bearer ${accessToken}` },
    })

    if (!response.ok) {
      const status = response.status
      const errorData = await response.json().catch(() => ({}))

      if (status === 403 || status === 429) {
        throw new Error(
          `Calendar API rate limit (${status}) — skipping to retry next poll cycle: ${JSON.stringify(errorData)}`
        )
      }

      throw new Error(`Failed to fetch calendar events: ${status} - ${JSON.stringify(errorData)}`)
    }

    const data = await response.json()
    const events = (data.items || []) as CalendarEvent[]
    allEvents.push(...events)

    pageToken = data.nextPageToken as string | undefined

    // Stop if we have enough events or hit the page limit
    if (allEvents.length >= maxEvents || pages >= MAX_PAGES) {
      break