Function listObjectsPage

apps/sim/connectors/s3/s3.ts:461–491

* Performs a single ListObjectsV2 page request and returns the parsed result.

(
  ctx: S3Context,
  prefix: string,
  continuationToken: string | undefined,
  retryOptions?: Parameters<typeof secureFetchWithRetry>[2],
  maxKeys: number = LIST_MAX_KEYS
)

 * Performs a single ListObjectsV2 page request and returns the parsed result.
 */
async function listObjectsPage(
  ctx: S3Context,
  prefix: string,
  continuationToken: string | undefined,
  retryOptions?: Parameters<typeof secureFetchWithRetry>[2],
  maxKeys: number = LIST_MAX_KEYS
): Promise<{ objects: S3ObjectEntry[]; isTruncated: boolean; nextContinuationToken?: string }> {
  const queryParams: Record<string, string> = {
    'list-type': '2',
    'encoding-type': 'url',
    'max-keys': String(maxKeys),
  }
  if (prefix) queryParams.prefix = prefix
  if (continuationToken) queryParams['continuation-token'] = continuationToken

  const canonicalQueryString = buildListQueryString(queryParams)
  const bucketPath = buildBucketPath(ctx)
  const headers = buildSignedHeaders(ctx, 'GET', bucketPath, canonicalQueryString)

  const url = buildUrl(ctx, bucketPath, canonicalQueryString)

  const response = await secureFetchWithRetry(url, { method: 'GET', headers }, retryOptions)

  if (!response.ok) {
    const errorText = await response.text()
    throw new Error(`S3 ListObjectsV2 failed: ${response.status} ${errorText}`)
  }

  const xml = await response.text()
  return parseListResponse(xml)
}

export const s3Connector: ConnectorConfig = {
  ...s3ConnectorMeta,