fix(core): normalize file watcher paths to forward slashes

LHMQ878 · cursoragent · LHMQ878 · commit fe29ec7fb2df · 2026-08-08T16:54:11.000+08:00
Parcel watcher emits backslash paths on Windows while the rest of the
codebase compares paths with forward slashes. Normalize watcher events on
win32 before publishing.

Co-authored-by: Cursor &lt;cursoragent@cursor.com&gt;
diff --git a/packages/core/src/filesystem/watcher.ts b/packages/core/src/filesystem/watcher.ts
@@ -41,6 +41,10 @@ function getBackend() {
   if (process.platform === "linux") return "inotify"
 }
 
+export function normalizeEventPath(file: string): string {
+  return process.platform === "win32" ? file.replaceAll("\\", "/") : file
+}
+
 function protecteds(dir: string) {
   return Protected.paths().filter((item) => {
     const relative = path.relative(dir, item)
@@ -85,9 +89,10 @@ const layer = Layer.effect(
 
     const callback: ParcelWatcher.SubscribeCallback = (_error, updates) => {
       for (const update of updates) {
-        if (update.type === "create") runFork(events.publish(Event.Updated, { file: update.path, event: "add" }))
-        if (update.type === "update") runFork(events.publish(Event.Updated, { file: update.path, event: "change" }))
-        if (update.type === "delete") runFork(events.publish(Event.Updated, { file: update.path, event: "unlink" }))
+        const file = normalizeEventPath(update.path)
+        if (update.type === "create") runFork(events.publish(Event.Updated, { file, event: "add" }))
+        if (update.type === "update") runFork(events.publish(Event.Updated, { file, event: "change" }))
+        if (update.type === "delete") runFork(events.publish(Event.Updated, { file, event: "unlink" }))
       }
     }
 
diff --git a/packages/core/test/filesystem/watcher.test.ts b/packages/core/test/filesystem/watcher.test.ts
@@ -1,5 +1,5 @@
 import { $ } from "bun"
-import { describe, expect } from "bun:test"
+import { describe, expect, test } from "bun:test"
 import fs from "fs/promises"
 import path from "path"
 import { ConfigProvider, Deferred, Duration, Effect, Fiber, Layer, Option, Stream } from "effect"
@@ -17,6 +17,14 @@ import { testEffect } from "../lib/effect"
 
 const describeWatcher = Watcher.hasNativeBinding() && !process.env.CI ? describe : describe.skip
 
+test("normalizeEventPath converts backslashes on Windows", () => {
+  if (process.platform !== "win32") {
+    expect(Watcher.normalizeEventPath("foo/bar")).toBe("foo/bar")
+    return
+  }
+  expect(Watcher.normalizeEventPath("foo\\bar\\baz.txt")).toBe("foo/bar/baz.txt")
+})
+
 type WatcherEvent = { file: string; event: "add" | "change" | "unlink" }
 
 const it = testEffect(AppNodeBuilder.build(LayerNode.group([FSUtil.node, EventV2.node])))
