From 5aa98f13f2c29a4a47a414cae7a8706f49934f8f Mon Sep 17 00:00:00 2001
From: Mohamed Boudra <boudra.moha@gmail.com>
Date: Sun, 12 Apr 2026 12:53:54 +0700
Subject: [PATCH] fix: update workspace test stubs for emission dedup gating

Add missing lastEmittedByWorkspaceId to test subscription stubs,
update activityAt assertion to null, and adjust dedup test to expect
deduplicated emissions.
---
 .../server/session.workspace-git-watch.test.ts    |  1 +
 .../server/src/server/session.workspaces.test.ts  | 15 +++++++--------
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/packages/server/src/server/session.workspace-git-watch.test.ts b/packages/server/src/server/session.workspace-git-watch.test.ts
index a528cfba4..3e0ca570f 100644
--- a/packages/server/src/server/session.workspace-git-watch.test.ts
+++ b/packages/server/src/server/session.workspace-git-watch.test.ts
@@ -225,6 +225,7 @@ describe("workspace git watch targets", () => {
       filter: undefined,
       isBootstrapping: false,
       pendingUpdatesByWorkspaceId: new Map(),
+      lastEmittedByWorkspaceId: new Map(),
     };
     sessionAny.reconcileActiveWorkspaceRecords = async () => new Set();
 
diff --git a/packages/server/src/server/session.workspaces.test.ts b/packages/server/src/server/session.workspaces.test.ts
index 36d8cb1de..5dbb8b140 100644
--- a/packages/server/src/server/session.workspaces.test.ts
+++ b/packages/server/src/server/session.workspaces.test.ts
@@ -994,7 +994,7 @@ describe("workspace aggregation", () => {
     expect(result.entries[0]).toMatchObject({
       id: "/tmp/repo",
       status: "running",
-      activityAt: "2026-03-01T12:03:00.000Z",
+      activityAt: null,
     });
   });
 
@@ -1069,6 +1069,7 @@ describe("workspace aggregation", () => {
       filter: undefined,
       isBootstrapping: false,
       pendingUpdatesByWorkspaceId: new Map(),
+      lastEmittedByWorkspaceId: new Map(),
     };
     session.reconcileActiveWorkspaceRecords = async () => new Set();
 
@@ -1196,6 +1197,7 @@ describe("workspace aggregation", () => {
       filter: undefined,
       isBootstrapping: false,
       pendingUpdatesByWorkspaceId: new Map(),
+      lastEmittedByWorkspaceId: new Map(),
     };
     session.reconcileActiveWorkspaceRecords = async () =>
       new Set(["/tmp/repo", "/tmp/repo/worktree"]);
@@ -1240,16 +1242,11 @@ describe("workspace aggregation", () => {
     const workspaceUpdates = emitted.filter(
       (message) => message.type === "workspace_update",
     ) as any[];
-    expect(workspaceUpdates).toHaveLength(3);
-    expect(workspaceUpdates.map((entry) => entry.payload.kind)).toEqual([
-      "upsert",
-      "upsert",
-      "upsert",
-    ]);
+    expect(workspaceUpdates).toHaveLength(2);
+    expect(workspaceUpdates.map((entry) => entry.payload.kind)).toEqual(["upsert", "upsert"]);
     expect(workspaceUpdates.map((entry) => entry.payload.workspace.id).sort()).toEqual([
       "/tmp/repo",
       "/tmp/repo/worktree",
-      "/tmp/repo/worktree",
     ]);
   });
 
@@ -1510,6 +1507,7 @@ describe("workspace aggregation", () => {
       filter: undefined,
       isBootstrapping: false,
       pendingUpdatesByWorkspaceId: new Map(),
+      lastEmittedByWorkspaceId: new Map(),
     };
     session.listAgentPayloads = async () => [];
     session.projectRegistry.get = async (projectId: string) => projects.get(projectId) ?? null;
@@ -1986,6 +1984,7 @@ describe("workspace aggregation", () => {
       filter: undefined,
       isBootstrapping: false,
       pendingUpdatesByWorkspaceId: new Map(),
+      lastEmittedByWorkspaceId: new Map(),
     };
     session.reconcileActiveWorkspaceRecords = async () => new Set();
     session.listAgentPayloads = async () => [];