fix(resume): cap history hydrate to the newest retained rows

Resume paints only the newest MAX_RETAINED_STREAM_ROWS rows, so an
oversized history never trips per-append retention eviction during the
hydrate loop. streamLogBase stays 0: no dropped-rows marker on resume.

Author: TheGreatAxios

src/tui/product-host.test.ts

@@ -19,6 +19,7 @@ import {
   type ProductHostConfig,
 } from "./product-host.js";
 import { buildModelsFirstCatalog, modelOptionId } from "./model-catalog.js";
+import { MAX_RETAINED_STREAM_ROWS } from "./long-log.js";
 
 function makeFakeSessionPort(): {
   readonly sends: string[];
@@ -136,6 +137,56 @@ describe("mountProductHost", () => {
     }
   });
 
+  test("history.hydrate caps oversized history at the newest retained rows (CL-9008)", async () => {
+    const { host, emitter } = await mountHeadless();
+    try {
+      const total = MAX_RETAINED_STREAM_ROWS + 200;
+      const blocks = Array.from({ length: total }, (_, i) => ({
+        type: "text",
+        content: `row-${i}`,
+      }));
+      emitter.emit("history.hydrate", blocks);
+      expect(host.shell.streamLog.length).toBe(MAX_RETAINED_STREAM_ROWS);
+      expect(host.shell.streamLog[0]).toEqual({
+        role: "assistant",
+        text: `row-${total - MAX_RETAINED_STREAM_ROWS}`,
+      });
+      expect(host.shell.streamLog[MAX_RETAINED_STREAM_ROWS - 1]).toEqual({
+        role: "assistant",
+        text: `row-${total - 1}`,
+      });
+      // Pre-sliced to the cap, so the append loop never trips retention
+      // eviction: no churn, no dropped-rows marker on resume.
+      expect(host.shell.streamLogBase).toBe(0);
+    } finally {
+      host.dispose();
+    }
+  });
+
+  test("history.hydrate below the cap paints every row (CL-9008)", async () => {
+    const { host, emitter } = await mountHeadless();
+    try {
+      const total = MAX_RETAINED_STREAM_ROWS - 100;
+      const blocks = Array.from({ length: total }, (_, i) => ({
+        type: "text",
+        content: `small-${i}`,
+      }));
+      emitter.emit("history.hydrate", blocks);
+      expect(host.shell.streamLog.length).toBe(total);
+      expect(host.shell.streamLog[0]).toEqual({
+        role: "assistant",
+        text: "small-0",
+      });
+      expect(host.shell.streamLog[total - 1]).toEqual({
+        role: "assistant",
+        text: `small-${total - 1}`,
+      });
+      expect(host.shell.streamLogBase).toBe(0);
+    } finally {
+      host.dispose();
+    }
+  });
+
   test("session.title updates the shell header", async () => {
     const { host, emitter } = await mountHeadless();
     try {

src/tui/product-host.ts

@@ -67,6 +67,7 @@ import {
 import { surfaceSystemNotice } from "./shell/prompt.js";
 import type { DeliverySettle, QueueKind } from "./delivery-queue.js";
 import { hydrateHistoryRows } from "./history-hydrate.js";
+import { MAX_RETAINED_STREAM_ROWS } from "./long-log.js";
 import type { StreamRow } from "./stream.js";
 
 import type { PendingImageAttachment } from "./image-attachments.js";
@@ -557,7 +558,9 @@ export async function mountProductHost(
 
   function onHistory(blocks: unknown): void {
     if (disposed) return;
-    for (const row of hydrateHistoryRows(blocks)) {
+    const rows = hydrateHistoryRows(blocks);
+    const tail = rows.slice(-MAX_RETAINED_STREAM_ROWS);
+    for (const row of tail) {
       appendStreamRow(shell, row);
     }
   }