Function downloadFileFromStorage

apps/sim/lib/uploads/utils/file-utils.server.ts:266–304

(
  userFile: UserFile,
  requestId: string,
  logger: Logger,
  options: { maxBytes?: number } = {}
)

 * @returns Buffer containing file data
 */
export async function downloadFileFromStorage(
  userFile: UserFile,
  requestId: string,
  logger: Logger,
  options: { maxBytes?: number } = {}
): Promise<Buffer> {
  let buffer: Buffer
  if (options.maxBytes !== undefined && userFile.size > options.maxBytes) {
    assertKnownSizeWithinLimit(userFile.size, options.maxBytes, 'storage file download')
  }

  if (isExecutionFile(userFile)) {
    logger.info(`[${requestId}] Downloading from execution storage: ${userFile.key}`)
    const { downloadExecutionFile } = await import(
      '@/lib/uploads/contexts/execution/execution-file-manager'
    )
    buffer = await downloadExecutionFile(userFile, { maxBytes: options.maxBytes })
  } else if (userFile.key) {
    const context = (userFile.context as StorageContext) || inferContextFromKey(userFile.key)
    logger.info(
      `[${requestId}] Downloading from ${context} storage (${userFile.context ? 'explicit' : 'inferred'}): ${userFile.key}`
    )

    const { downloadFile } = await import('@/lib/uploads/core/storage-service')
    buffer = await downloadFile({
      key: userFile.key,
      context,
      maxBytes: options.maxBytes,
    })
  } else {
    throw new Error('File has no key - cannot download')
  }

  if (options.maxBytes !== undefined) {
    assertKnownSizeWithinLimit(buffer.length, options.maxBytes, 'storage file download')
  }

  return buffer
}

/**
 * Result of {@link downloadServableFileFromStorage}: the bytes a consumer should