Function reconcileToolsWithStoredMessages

packages/cli/src/pi-transcript.ts:344–389

(
  state: MakaPiTranscriptState,
  turnId: string,
  messages: readonly StoredMessage[],
)

 * live events without applying session-switch reset semantics.
 */
export function reconcileToolsWithStoredMessages(
  state: MakaPiTranscriptState,
  turnId: string,
  messages: readonly StoredMessage[],
): boolean {
  const turnMessages = messages.filter((message) => message.turnId === turnId);
  const durableTools = new Map(
    foldStoredShellRunChildren(
      materializeSession(turnMessages).items.flatMap(chatItemToTranscriptEntries),
    )
      .filter(
        (entry): entry is Extract<MakaPiTranscriptEntry, { kind: 'tool' }> => entry.kind === 'tool',
      )
      .map((entry) => [entry.toolUseId, entry]),
  );
  let changed = false;
  const reconciled: MakaPiTranscriptEntry[] = [];
  for (const entry of state.entries) {
    if (entry.kind !== 'tool' || entry.turnId !== turnId) {
      reconciled.push(entry);
      continue;
    }
    const durable = durableTools.get(entry.toolUseId);
    if (!durable) {
      if (!entryInLiveViewport(state, entry)) {
        entry.hidden = true;
        reconciled.push(entry);
      }
      changed = true;
      continue;
    }
    entry.toolName = durable.toolName;
    entry.title = durable.title;
    entry.input = structuredClone(durable.input);
    entry.result = durable.result ? structuredClone(durable.result) : undefined;
    entry.output = durable.output;
    entry.durationMs = durable.durationMs;
    entry.status = durable.status;
    entry.hidden = durable.hidden;
    entry.resultVersion += 1;
    changed = true;
    reconciled.push(entry);
  }
  state.entries = reconciled;
  return changed;
}

/**
 * True when the entry will render inside the live viewport, or has not been