Function cleanupBudgetEntry

apps/sim/lib/uploads/utils/user-file-base64.server.ts:338–366

(
  redis: NonNullable<ReturnType<typeof getRedisClient>>,
  executionId: string,
  fileKey: string,
  rawEntry: string,
  entry: Base64BudgetEntry
)

}

async function cleanupBudgetEntry(
  redis: NonNullable<ReturnType<typeof getRedisClient>>,
  executionId: string,
  fileKey: string,
  rawEntry: string,
  entry: Base64BudgetEntry
): Promise<{ claimed: boolean; deletedCount: number }> {
  const limits = getExecutionRedisBudgetLimits()
  const budgetReservation: ExecutionRedisBudgetReservation = {
    executionId,
    userId: entry.userId,
    category: 'base64_cache',
    operation: 'cleanup_base64_cache',
    bytes: entry.bytes,
  }
  const budgetKeys = getExecutionRedisBudgetKeys(budgetReservation)
  const result = (await redis.eval(
    CLEANUP_BASE64_CACHE_ENTRY_SCRIPT,
    2 + budgetKeys.length,
    getBudgetIndexKey(executionId),
    `${REDIS_KEY_PREFIX}exec:${executionId}:${fileKey}`,
    ...budgetKeys,
    fileKey,
    rawEntry,
    entry.bytes,
    limits.ttlSeconds
  )) as [number, number]
  return { claimed: Number(result[0]) === 1, deletedCount: Number(result[1] ?? 0) }
}

function stripBase64(file: UserFile): UserFile {
  const { base64: _base64, ...rest } = file