Function downloadFromS3

apps/sim/lib/uploads/providers/s3/client.ts:191–219

(
  key: string,
  customConfig?: S3Config,
  maxBytes?: number
)

): Promise<Buffer>

export async function downloadFromS3(
  key: string,
  customConfig?: S3Config,
  maxBytes?: number
): Promise<Buffer> {
  const config = customConfig || { bucket: S3_CONFIG.bucket, region: S3_CONFIG.region }

  const command = new GetObjectCommand({
    Bucket: config.bucket,
    Key: key,
  })

  const response = await getS3Client().send(command)
  if (maxBytes !== undefined && response.ContentLength !== undefined) {
    try {
      assertKnownSizeWithinLimit(response.ContentLength, maxBytes, 'storage download')
    } catch (error) {
      const body = response.Body as { destroy?: (error?: Error) => void } | undefined
      body?.destroy?.(error instanceof Error ? error : undefined)
      throw error
    }
  }

  const stream = response.Body as NodeJS.ReadableStream
  return readNodeStreamToBufferWithLimit(stream, {
    maxBytes: maxBytes ?? Number.MAX_SAFE_INTEGER,
    label: 'storage download',
  })
}

/**
 * Stream an object out of S3 without buffering it. The caller MUST fully consume or