Let clean checkouts reset diff stats and steady preview browsing

- Rebase thread diff totals after clean checkout observations
- Improve preview approvals, URL defaults, tab favicons, and tab scrolling
- Prevent snapshot/live event gaps and retry failed subscriptions

Author: badcuban

apps/desktop/src/preview/PreviewAutomation.ts

@@ -262,6 +262,10 @@ export const make = Effect.sync(function PreviewAutomationMake() {
       webContentsId: contents.id,
       host: blockedHost,
       url,
+      // Who was navigating. The agent's own navigations are refused in the
+      // renderer before they start, so anything blocked here came from a page
+      // -- a redirect or a link -- and the prompt should say which one.
+      fromHost: navigationHost(contents.getURL()),
     };
     const embedder = contents.hostWebContents;
     if (embedder !== null && !embedder.isDestroyed()) {

apps/server/integration/OrchestrationEngineHarness.integration.ts

@@ -61,6 +61,7 @@ import {
   type OrchestrationEngineShape,
 } from "../src/orchestration/Services/OrchestrationEngine.ts";
 import { ThreadDeletionReactor } from "../src/orchestration/Services/ThreadDeletionReactor.ts";
+import { ThreadDiffStatBaselineReactor } from "../src/orchestration/Services/ThreadDiffStatBaselineReactor.ts";
 import { OrchestrationReactor } from "../src/orchestration/Services/OrchestrationReactor.ts";
 import { ProjectionSnapshotQuery } from "../src/orchestration/Services/ProjectionSnapshotQuery.ts";
 import {
@@ -348,6 +349,7 @@ export const makeOrchestrationIntegrationHarness = (
             }),
           refreshStatus: () => Effect.die("refreshStatus should not be called in this test"),
           streamStatus: () => Stream.empty,
+          observeLocalStatus: () => Stream.empty,
         }),
       ),
       Layer.provideMerge(
@@ -370,6 +372,12 @@ export const makeOrchestrationIntegrationHarness = (
           drain: Effect.void,
         }),
       ),
+      Layer.provideMerge(
+        Layer.succeed(ThreadDiffStatBaselineReactor, {
+          start: () => Effect.void,
+          drain: Effect.void,
+        }),
+      ),
     );
     const layer = Layer.empty.pipe(
       Layer.provideMerge(runtimeServicesLayer),

apps/server/src/checkpointing/Layers/CheckpointDiffQuery.test.ts

@@ -107,6 +107,7 @@ describe("CheckpointDiffQueryLive", () => {
                 toCheckpointRef,
               });
             }),
+          listThreadDiffStatBaselines: () => Effect.die("unused"),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),
@@ -194,6 +195,7 @@ describe("CheckpointDiffQueryLive", () => {
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
           getFullThreadDiffContext: () => Effect.die("unused"),
+          listThreadDiffStatBaselines: () => Effect.die("unused"),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),
@@ -308,6 +310,7 @@ describe("CheckpointDiffQueryLive", () => {
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
           getFullThreadDiffContext: () => Effect.die("unused"),
+          listThreadDiffStatBaselines: () => Effect.die("unused"),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),
@@ -380,6 +383,7 @@ describe("CheckpointDiffQueryLive", () => {
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
           getFullThreadDiffContext: () => Effect.die("unused"),
+          listThreadDiffStatBaselines: () => Effect.die("unused"),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),
@@ -448,6 +452,7 @@ describe("CheckpointDiffQueryLive", () => {
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
           getFullThreadDiffContext: () => Effect.die("unused"),
+          listThreadDiffStatBaselines: () => Effect.die("unused"),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),
@@ -499,6 +504,7 @@ describe("CheckpointDiffQueryLive", () => {
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getThreadCheckpointContext: () => Effect.succeed(Option.none()),
           getFullThreadDiffContext: () => Effect.succeed(Option.none()),
+          listThreadDiffStatBaselines: () => Effect.die("unused"),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),

apps/server/src/orchestration/Layers/CheckpointReactor.test.ts

@@ -399,6 +399,7 @@ describe("CheckpointReactor", () => {
         ),
       refreshStatus: () => Effect.die("refreshStatus should not be called in this test"),
       streamStatus: () => Stream.empty,
+      observeLocalStatus: () => Stream.empty,
     });
 
     const layer = CheckpointReactorLive.pipe(

apps/server/src/orchestration/Layers/OrchestrationEngine.test.ts

@@ -155,6 +155,7 @@ describe("OrchestrationEngine", () => {
           proposedPlans: [],
           activities: [],
           checkpoints: [],
+          diffStatBaselineTurnCount: 0,
           session: null,
         },
       ],
@@ -202,6 +203,7 @@ describe("OrchestrationEngine", () => {
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getThreadCheckpointContext: () => Effect.succeed(Option.none()),
           getFullThreadDiffContext: () => Effect.succeed(Option.none()),
+          listThreadDiffStatBaselines: () => Effect.succeed([]),
           getThreadShellById: () => Effect.succeed(Option.none()),
           getThreadDetailById: () => Effect.succeed(Option.none()),
         }),

apps/server/src/orchestration/Layers/OrchestrationEngine.ts

@@ -316,6 +316,7 @@ const makeOrchestrationEngine = Effect.gen(function* () {
     get streamDomainEvents(): OrchestrationEngineShape["streamDomainEvents"] {
       return Stream.fromPubSub(eventPubSub);
     },
+    subscribeDomainEvents: Effect.map(PubSub.subscribe(eventPubSub), Stream.fromSubscription),
   } satisfies OrchestrationEngineShape;
 });
 

apps/server/src/orchestration/Layers/OrchestrationReactor.test.ts

@@ -9,6 +9,7 @@ import { CheckpointReactor } from "../Services/CheckpointReactor.ts";
 import { ProviderCommandReactor } from "../Services/ProviderCommandReactor.ts";
 import { ProviderRuntimeIngestionService } from "../Services/ProviderRuntimeIngestion.ts";
 import { ThreadDeletionReactor } from "../Services/ThreadDeletionReactor.ts";
+import { ThreadDiffStatBaselineReactor } from "../Services/ThreadDiffStatBaselineReactor.ts";
 import { OrchestrationReactor } from "../Services/OrchestrationReactor.ts";
 import { makeOrchestrationReactor } from "./OrchestrationReactor.ts";
 
@@ -22,7 +23,7 @@ describe("OrchestrationReactor", () => {
     runtime = null;
   });
 
-  it("starts provider ingestion, provider command, checkpoint, and thread deletion reactors", async () => {
+  it("starts provider ingestion, provider command, checkpoint, thread deletion, and diff-stat baseline reactors", async () => {
     const started: string[] = [];
 
     runtime = ManagedRuntime.make(
@@ -63,6 +64,15 @@ describe("OrchestrationReactor", () => {
             drain: Effect.void,
           }),
         ),
+        Layer.provideMerge(
+          Layer.succeed(ThreadDiffStatBaselineReactor, {
+            start: () => {
+              started.push("thread-diffstat-baseline-reactor");
+              return Effect.void;
+            },
+            drain: Effect.void,
+          }),
+        ),
       ),
     );
 
@@ -75,6 +85,7 @@ describe("OrchestrationReactor", () => {
       "provider-command-reactor",
       "checkpoint-reactor",
       "thread-deletion-reactor",
+      "thread-diffstat-baseline-reactor",
     ]);
 
     await Effect.runPromise(Scope.close(scope, Exit.void));

apps/server/src/orchestration/Layers/OrchestrationReactor.ts

@@ -9,18 +9,21 @@ import { CheckpointReactor } from "../Services/CheckpointReactor.ts";
 import { ProviderCommandReactor } from "../Services/ProviderCommandReactor.ts";
 import { ProviderRuntimeIngestionService } from "../Services/ProviderRuntimeIngestion.ts";
 import { ThreadDeletionReactor } from "../Services/ThreadDeletionReactor.ts";
+import { ThreadDiffStatBaselineReactor } from "../Services/ThreadDiffStatBaselineReactor.ts";
 
 export const makeOrchestrationReactor = Effect.gen(function* () {
   const providerRuntimeIngestion = yield* ProviderRuntimeIngestionService;
   const providerCommandReactor = yield* ProviderCommandReactor;
   const checkpointReactor = yield* CheckpointReactor;
   const threadDeletionReactor = yield* ThreadDeletionReactor;
+  const threadDiffStatBaselineReactor = yield* ThreadDiffStatBaselineReactor;
 
   const start: OrchestrationReactorShape["start"] = Effect.fn("start")(function* () {
     yield* providerRuntimeIngestion.start();
     yield* providerCommandReactor.start();
     yield* checkpointReactor.start();
     yield* threadDeletionReactor.start();
+    yield* threadDiffStatBaselineReactor.start();
   });
 
   return {

apps/server/src/orchestration/Layers/ProjectionPipeline.ts

@@ -559,6 +559,7 @@ const makeOrchestrationProjectionPipeline = Effect.fn("makeOrchestrationProjecti
             effectiveCwd: null,
             goal: null,
             voiceActive: 0,
+            diffStatBaselineTurnCount: 0,
             latestTurnId: null,
             createdAt: event.payload.createdAt,
             updatedAt: event.payload.updatedAt,
@@ -820,6 +821,27 @@ const makeOrchestrationProjectionPipeline = Effect.fn("makeOrchestrationProjecti
           return;
         }
 
+        case "thread.diffstat-rebased": {
+          const existingRow = yield* projectionThreadRepository.getById({
+            threadId: event.payload.threadId,
+          });
+          if (Option.isNone(existingRow)) {
+            return;
+          }
+          // The decider only emits this event when the baseline moves forward,
+          // but replay order is the projector's problem alone -- clamp so a
+          // re-applied event can never walk the rollup backwards.
+          yield* projectionThreadRepository.upsert({
+            ...existingRow.value,
+            diffStatBaselineTurnCount: Math.max(
+              existingRow.value.diffStatBaselineTurnCount ?? 0,
+              event.payload.baselineTurnCount,
+            ),
+            updatedAt: event.payload.occurredAt,
+          });
+          return;
+        }
+
         case "thread.reverted": {
           const existingRow = yield* projectionThreadRepository.getById({
             threadId: event.payload.threadId,