Function trimWorkflowConsoleEntries

apps/sim/stores/terminal/console/utils.ts:247–295

(entries: ConsoleEntry[])

 * Returns a workflow's entries trimmed to the configured cap.
 */
export function trimWorkflowConsoleEntries(entries: ConsoleEntry[]): ConsoleEntry[] {
  if (entries.length <= TERMINAL_CONSOLE_LIMITS.MAX_ENTRIES_PER_WORKFLOW) {
    return entries
  }

  const executionGroups = new Map<string, ConsoleEntry[]>()

  for (const entry of entries) {
    const executionId = entry.executionId ?? entry.id
    const group = executionGroups.get(executionId)
    if (group) {
      group.push(entry)
    } else {
      executionGroups.set(executionId, [entry])
    }
  }

  const executionIds = [...executionGroups.keys()]
  const newestExecutionId = executionIds[0]

  if (!newestExecutionId) {
    return entries.slice(0, TERMINAL_CONSOLE_LIMITS.MAX_ENTRIES_PER_WORKFLOW)
  }

  const keptEntryIds = new Set<string>()
  let remainingSlots = TERMINAL_CONSOLE_LIMITS.MAX_ENTRIES_PER_WORKFLOW

  const newestExecutionEntries = executionGroups.get(newestExecutionId) ?? []
  const newestExecutionToKeep = newestExecutionEntries.slice(0, remainingSlots)
  newestExecutionToKeep.forEach((entry) => keptEntryIds.add(entry.id))
  remainingSlots -= newestExecutionToKeep.length

  for (const executionId of executionIds.slice(1)) {
    const executionEntries = executionGroups.get(executionId) ?? []

    if (executionEntries.length > remainingSlots) {
      continue
    }

    executionEntries.forEach((entry) => keptEntryIds.add(entry.id))
    remainingSlots -= executionEntries.length

    if (remainingSlots === 0) {
      break
    }
  }

  return entries.filter((entry) => keptEntryIds.has(entry.id))
}

/**
 * Applies workflow-level trimming while preserving newest-first order.