fix: advance the transcript per committed event so running timers stop resetting

apps/desktop/renderer-architecture.json

@@ -610,7 +610,7 @@
           "@maka/ui": 1
         },
         "importSpecifiers": 7,
-        "nonTriviaTokens": 2725
+        "nonTriviaTokens": 2687
       },
       "src/renderer/app-shell-session-start-actions.ts": {
         "importDeclarations": 2,

apps/desktop/src/main/__tests__/runtime-host-client.test.ts

@@ -151,12 +151,7 @@ function subscription(
     hostEpoch: 'host-1',
     subscriptionId: `subscription-${sessionId}`,
     activeAssistantStreams: [],
-    transcriptBootstrap: {
-      throughSequence: null,
-      overlayMessageCount: 0,
-      durable: emptyTranscriptPage(sessionId, 'durable'),
-      overlay: emptyTranscriptPage(sessionId, 'overlay'),
-    },
+    transcriptBootstrap: { durable: emptyTranscriptPage(sessionId) },
     snapshot: {
       schemaVersion: SESSION_CONTINUITY_SCHEMA_VERSION,
       session: {
@@ -176,25 +171,26 @@ function subscription(
       lifecycle.push(`${sessionId}:transcript`);
       return [] as T[];
     },
-    loadTranscriptOverlay: async <T>(_decodeMessage: (value: unknown) => T) => [] as T[],
     decodeTranscriptPage: async () => {
       throw new Error('Fake subscription does not expose transcript pages');
     },
     loadTranscriptPage: async () => {
       throw new Error('Fake subscription does not expose transcript pages');
     },
+    ready: async () => {
+      lifecycle.push(`${sessionId}:ready`);
+    },
     close: async () => {
       lifecycle.push(`${sessionId}:close`);
     },
     [Symbol.asyncIterator]: async function* (): AsyncIterator<SubscriptionFrame> {},
   };
 }
 
-function emptyTranscriptPage(sessionId: string, source: 'durable' | 'overlay') {
+function emptyTranscriptPage(sessionId: string) {
   return {
     kind: 'page' as const,
     sessionId,
-    source,
     direction: 'older' as const,
     throughSequence: null,
     rawBytes: 0,

apps/desktop/src/main/__tests__/runtime-host-desktop-candidate.test.ts

@@ -1442,12 +1442,23 @@ function connectionHarness(
       if (options.subscriptionError) throw options.subscriptionError;
       const subscriptionFrames = new AsyncFrameQueue();
       activeSubscriptionFrames = subscriptionFrames;
-      const closeSubscription = () => { subscriptionFrames.end(); ptyListeners.clear(); };
+      // The Host holds a subscription's frames until the subscriber calls
+      // ready(), so handing them over earlier would let an ordering bug pass.
+      let releaseFrames = (): void => undefined;
+      const readyGate = new Promise<void>((resolve) => {
+        releaseFrames = resolve;
+      });
+      let closed = false;
+      const closeSubscription = () => {
+        closed = true;
+        subscriptionFrames.end();
+        ptyListeners.clear();
+        releaseFrames();
+      };
       closeSubscriptions.add(closeSubscription);
       const emptyPage = {
         kind: 'page' as const,
         sessionId,
-        source: 'durable' as const,
         direction: 'older' as const,
         throughSequence: null,
         rawBytes: 0,
@@ -1468,15 +1479,17 @@ function connectionHarness(
         activeAssistantStreams: options.activeAssistantStreams ?? [],
         transcriptBootstrap: {
           throughSequence: null,
-          overlayMessageCount: 0,
           durable: emptyPage,
-          overlay: { ...emptyPage, source: 'overlay' },
         },
         loadTranscript: async () => [],
-        loadTranscriptOverlay: async () => [],
         decodeTranscriptPage: async () => ({ messages: [], nextCursor: null }),
         loadTranscriptPage: async () => emptyPage,
-        [Symbol.asyncIterator]: () => subscriptionFrames[Symbol.asyncIterator](),
+        [Symbol.asyncIterator]: async function* () {
+          await readyGate;
+          if (closed) return;
+          yield* subscriptionFrames;
+        },
+        ready: async () => releaseFrames(),
         close: async () => closeSubscription(),
       };
     },