Function hydrateConsoleStore

apps/sim/stores/terminal/console/store.ts:720–790

* Hydrates the console store from IndexedDB on startup. * Applies the same normalization and trimming as the old persist merge.

()

 * Applies the same normalization and trimming as the old persist merge.
 */
async function hydrateConsoleStore(): Promise<void> {
  try {
    const data = await loadConsoleData()

    if (!data) {
      useTerminalConsoleStore.setState({ _hasHydrated: true })
      return
    }

    const oneHourAgo = Date.now() - 60 * 60 * 1000

    const workflowEntries = Object.fromEntries(
      Object.entries(data.workflowEntries).map(([workflowId, entries]) => [
        workflowId,
        trimWorkflowConsoleEntries(
          entries.map((entry, index) => {
            let updated = entry
            if (entry.executionOrder === undefined) {
              updated = { ...updated, executionOrder: index + 1 }
            }
            if (
              entry.isRunning &&
              entry.startedAt &&
              new Date(entry.startedAt).getTime() < oneHourAgo
            ) {
              updated = { ...updated, isRunning: false }
            }
            updated = {
              ...updated,
              input: normalizeConsoleInput(updated.input),
              output: normalizeConsoleOutput(updated.output),
              error: normalizeConsoleError(updated.error),
              warning:
                typeof updated.warning === 'string'
                  ? (normalizeConsoleError(updated.warning) ?? undefined)
                  : updated.warning,
            }
            return updated
          })
        ),
      ])
    )

    const currentState = useTerminalConsoleStore.getState()
    const mergedWorkflowEntries = { ...workflowEntries }

    for (const [wfId, currentEntries] of Object.entries(currentState.workflowEntries)) {
      if (currentEntries.length > 0) {
        const persistedEntries = mergedWorkflowEntries[wfId] ?? []
        const persistedIds = new Set(persistedEntries.map((e) => e.id))
        const newEntries = currentEntries.filter((e) => !persistedIds.has(e.id))
        if (newEntries.length > 0) {
          mergedWorkflowEntries[wfId] = trimWorkflowConsoleEntries([
            ...newEntries,
            ...persistedEntries,
          ])
        }
      }