Restore CWD symlink normalization in VcsStatusBroadcaster

The old GitStatusBroadcasterLive resolved symlinks via realpathSync.native
before using the path as a cache key or PubSub filter. The new
VcsStatusBroadcaster omitted this normalization, causing symlinked workspace
paths to create duplicate cache entries and streamStatus event filtering to
miss updates published under the resolved real path.

Restore the normalizeCwd helper and call it in getStatus, refreshLocalStatus,
refreshStatus, and streamStatus to match the old behavior.

Author: cursoragent

apps/server/src/vcs/VcsStatusBroadcaster.ts

@@ -1,3 +1,5 @@
+import { realpathSync } from "node:fs";
+
 import {
   Duration,
   Effect,
@@ -63,6 +65,14 @@ export class VcsStatusBroadcaster extends Context.Service<
   VcsStatusBroadcasterShape
 >()("t3/vcs/VcsStatusBroadcaster") {}
 
+function normalizeCwd(cwd: string): string {
+  try {
+    return realpathSync.native(cwd);
+  } catch {
+    return cwd;
+  }
+}
+
 function fingerprintStatusPart(status: unknown): string {
   return JSON.stringify(status);
 }
@@ -188,16 +198,18 @@ export const layer = Layer.effect(
     const getStatus: VcsStatusBroadcasterShape["getStatus"] = Effect.fn(
       "VcsStatusBroadcaster.getStatus",
     )(function* (input) {
+      const cwd = normalizeCwd(input.cwd);
       const [local, remote] = yield* Effect.all([
-        getOrLoadLocalStatus(input.cwd),
-        getOrLoadRemoteStatus(input.cwd),
+        getOrLoadLocalStatus(cwd),
+        getOrLoadRemoteStatus(cwd),
       ]);
       return mergeGitStatusParts(local, remote);
     });
 
     const refreshLocalStatus: VcsStatusBroadcasterShape["refreshLocalStatus"] = Effect.fn(
       "VcsStatusBroadcaster.refreshLocalStatus",
-    )(function* (cwd) {
+    )(function* (rawCwd) {
+      const cwd = normalizeCwd(rawCwd);
       yield* workflow.invalidateLocalStatus(cwd);
       const local = yield* workflow.localStatus({ cwd });
       return yield* updateCachedLocalStatus(cwd, local, { publish: true });
@@ -213,7 +225,8 @@ export const layer = Layer.effect(
 
     const refreshStatus: VcsStatusBroadcasterShape["refreshStatus"] = Effect.fn(
       "VcsStatusBroadcaster.refreshStatus",
-    )(function* (cwd) {
+    )(function* (rawCwd) {
+      const cwd = normalizeCwd(rawCwd);
       const [local, remote] = yield* Effect.all([
         refreshLocalStatus(cwd),
         refreshRemoteStatus(cwd),
@@ -299,12 +312,13 @@ export const layer = Layer.effect(
     const streamStatus: VcsStatusBroadcasterShape["streamStatus"] = (input) =>
       Stream.unwrap(
         Effect.gen(function* () {
+          const cwd = normalizeCwd(input.cwd);
           const subscription = yield* PubSub.subscribe(changesPubSub);
-          const initialLocal = yield* getOrLoadLocalStatus(input.cwd);
-          const initialRemote = (yield* getCachedStatus(input.cwd))?.remote?.value ?? null;
-          yield* retainRemotePoller(input.cwd);
+          const initialLocal = yield* getOrLoadLocalStatus(cwd);
+          const initialRemote = (yield* getCachedStatus(cwd))?.remote?.value ?? null;
+          yield* retainRemotePoller(cwd);
 
-          const release = releaseRemotePoller(input.cwd).pipe(Effect.ignore, Effect.asVoid);
+          const release = releaseRemotePoller(cwd).pipe(Effect.ignore, Effect.asVoid);
 
           return Stream.concat(
             Stream.make({
@@ -313,7 +327,7 @@ export const layer = Layer.effect(
               remote: initialRemote,
             }),
             Stream.fromSubscription(subscription).pipe(
-              Stream.filter((event) => event.cwd === input.cwd),
+              Stream.filter((event) => event.cwd === cwd),
               Stream.map((event) => event.event),
             ),
           ).pipe(Stream.ensuring(release));