Function downloadFileStream

apps/sim/lib/uploads/core/storage-service.ts:409–430

(options: {
  key: string
  context: StorageContext
})

 * import worker so a multi-hundred-MB file is never held resident.
 */
export async function downloadFileStream(options: {
  key: string
  context: StorageContext
}): Promise<Readable> {
  const { key, context } = options
  const config = getStorageConfig(context)

  if (USE_BLOB_STORAGE) {
    const { downloadFromBlobStream } = await import('@/lib/uploads/providers/blob/client')
    return downloadFromBlobStream(key, createBlobConfig(config))
  }

  if (USE_S3_STORAGE) {
    const { downloadFromS3Stream } = await import('@/lib/uploads/providers/s3/client')
    return downloadFromS3Stream(key, createS3Config(config))
  }

  const { createReadStream } = await import('fs')
  const { join } = await import('path')
  const { UPLOAD_DIR_SERVER } = await import('./setup.server')
  return createReadStream(join(UPLOAD_DIR_SERVER, sanitizeFileKey(key)))
}

/**
 * Delete a file from the configured storage provider