Function downloadFile

apps/sim/lib/uploads/core/storage-service.ts:366–402

(options: DownloadFileOptions)

 * Download a file from the configured storage provider
 */
export async function downloadFile(options: DownloadFileOptions): Promise<Buffer> {
  const { key, context, maxBytes } = options

  if (context) {
    const config = getStorageConfig(context)

    if (USE_BLOB_STORAGE) {
      const { downloadFromBlob } = await import('@/lib/uploads/providers/blob/client')
      const blobConfig = createBlobConfig(config)
      return maxBytes === undefined
        ? downloadFromBlob(key, blobConfig)
        : downloadFromBlob(key, blobConfig, maxBytes)
    }

    if (USE_S3_STORAGE) {
      const { downloadFromS3 } = await import('@/lib/uploads/providers/s3/client')
      const s3Config = createS3Config(config)
      return maxBytes === undefined
        ? downloadFromS3(key, s3Config)
        : downloadFromS3(key, s3Config, maxBytes)
    }
  }

  const { readFile, stat } = await import('fs/promises')
  const { join } = await import('path')
  const { UPLOAD_DIR_SERVER } = await import('./setup.server')

  const safeKey = sanitizeFileKey(key)
  const filePath = join(UPLOAD_DIR_SERVER, safeKey)

  if (maxBytes !== undefined) {
    const fileStats = await stat(filePath)
    assertKnownSizeWithinLimit(fileStats.size, maxBytes, 'storage download')
  }

  return readFile(filePath)
}

/**
 * Stream a file out of the configured storage provider without buffering it in memory.