Function resolveBase64

apps/sim/lib/uploads/utils/user-file-base64.server.ts:373–429

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

}

async function resolveBase64(
  file: UserFile,
  options: Base64HydrationOptions,
  logger: Logger
): Promise<string | null> {
  const maxBytes = options.maxBytes ?? DEFAULT_MAX_BASE64_BYTES

  if (file.base64) {
    const base64Bytes = Buffer.byteLength(file.base64, 'base64')
    if (base64Bytes > maxBytes) {
      logger.warn(
        `[${options.requestId}] Skipping existing base64 for ${file.name} (decoded ${base64Bytes} exceeds ${maxBytes})`
      )
      return null
    }
    return file.base64
  }

  const allowUnknownSize = options.allowUnknownSize ?? false
  const hasStableStorageKey = Boolean(file.key)

  if (Number.isFinite(file.size) && file.size > maxBytes) {
    logger.warn(
      `[${options.requestId}] Skipping base64 for ${file.name} (size ${file.size} exceeds ${maxBytes})`
    )
    return null
  }

  if (
    (!Number.isFinite(file.size) || file.size <= 0) &&
    !allowUnknownSize &&
    !hasStableStorageKey
  ) {
    logger.warn(`[${options.requestId}] Skipping base64 for ${file.name} (unknown file size)`)
    return null
  }

  const requestId = options.requestId ?? 'unknown'
  try {
    return await readUserFileContent(file, {
      requestId,
      workspaceId: options.workspaceId,
      workflowId: options.workflowId,
      executionId: options.executionId,
      largeValueExecutionIds: options.largeValueExecutionIds,
      fileKeys: options.fileKeys,
      allowLargeValueWorkflowScope: options.allowLargeValueWorkflowScope,
      userId: options.userId,
      encoding: 'base64',
      maxBytes,
      maxSourceBytes: maxBytes,
    })
  } catch (error) {
    logger.warn(`[${requestId}] Failed to hydrate base64 for ${file.name}`, error)
    return null
  }
}