Function hydrateUserFile

apps/sim/lib/uploads/utils/user-file-base64.server.ts:431–472

(
  file: UserFile,
  options: Base64HydrationOptions,
  state: HydrationState,
  logger: Logger
)

}

async function hydrateUserFile(
  file: UserFile,
  options: Base64HydrationOptions,
  state: HydrationState,
  logger: Logger
): Promise<UserFile> {
  if (!file.base64) {
    try {
      await assertUserFileContentAccess(file, {
        requestId: options.requestId,
        workspaceId: options.workspaceId,
        workflowId: options.workflowId,
        executionId: options.executionId,
        largeValueExecutionIds: options.largeValueExecutionIds,
        fileKeys: options.fileKeys,
        allowLargeValueWorkflowScope: options.allowLargeValueWorkflowScope,
        userId: options.userId,
        logger,
      })
    } catch (error) {
      logger.warn(`[${options.requestId ?? 'unknown'}] Skipping unauthorized file base64`, error)
      return stripBase64(file)
    }
  }

  const cached = await state.cache.get(file)
  if (cached) {
    const maxBytes = options.maxBytes ?? DEFAULT_MAX_BASE64_BYTES
    if (Buffer.byteLength(cached, 'base64') > maxBytes) {
      return stripBase64(file)
    }
    return { ...file, base64: cached }
  }

  const base64 = await resolveBase64(file, options, logger)
  if (!base64) {
    return stripBase64(file)
  }

  await state.cache.set(file, base64, state.cacheTtlSeconds)
  return { ...file, base64 }
}

async function hydrateValue(
  value: unknown,