Function getStartPageToken

apps/sim/lib/webhooks/polling/google-drive.ts:214–245

(
  accessToken: string,
  config: GoogleDriveWebhookConfig,
  requestId: string,
  logger: Logger
)

}

async function getStartPageToken(
  accessToken: string,
  config: GoogleDriveWebhookConfig,
  requestId: string,
  logger: Logger
): Promise<string> {
  const params = new URLSearchParams()
  if (config.includeSharedDrives) {
    params.set('supportsAllDrives', 'true')
  }

  const url = `${DRIVE_API_BASE}/changes/startPageToken?${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 === 429 || isDriveRateLimitError(status, errorData)) {
      const err = new Error(`Drive API rate limit (${status}): ${JSON.stringify(errorData)}`)
      err.name = 'DriveRateLimitError'
      throw err
    }
    throw new Error(
      `Failed to get Drive start page token: ${status} - ${JSON.stringify(errorData)}`
    )
  }

  const data = await response.json()
  return data.startPageToken as string
}

async function fetchChanges(
  accessToken: string,