watch: check parent and child path properly

co-authored-by: Jake Yuesong Li <[email protected]>

Author: jazelly

lib/internal/watch_mode/files_watcher.js

@@ -7,7 +7,7 @@ const {
   SafeMap,
   SafeSet,
   SafeWeakMap,
-  StringPrototypeStartsWith,
+  StringPrototypeStartsWith
 } = primordials;
 
 const { validateNumber, validateOneOf } = require('internal/validators');
@@ -18,7 +18,7 @@ const EventEmitter = require('events');
 const { addAbortListener } = require('internal/events/abort_listener');
 const { watch } = require('fs');
 const { fileURLToPath } = require('internal/url');
-const { resolve, dirname } = require('path');
+const { resolve, dirname, sep } = require('path');
 const { setTimeout, clearTimeout } = require('timers');
 
 const supportsRecursiveWatching = process.platform === 'win32' ||
@@ -52,13 +52,20 @@ class FilesWatcher extends EventEmitter {
     }
   }
 
+  #isParentPath(parentCandidate, childCandidate) {
+    const parent = resolve(parentCandidate);
+    const child = resolve(childCandidate);
+    const normalizedParent = parent.endsWith(sep) ? parent : parent + sep;
+    return StringPrototypeStartsWith(child, normalizedParent);
+  }
+
   #isPathWatched(path) {
     if (this.#watchers.has(path)) {
       return true;
     }
 
     for (const { 0: watchedPath, 1: watcher } of this.#watchers.entries()) {
-      if (watcher.recursive && StringPrototypeStartsWith(path, watchedPath)) {
+      if (watcher.recursive && this.#isParentPath(watchedPath, path)) {
         return true;
       }
     }
@@ -68,7 +75,7 @@ class FilesWatcher extends EventEmitter {
 
   #removeWatchedChildren(path) {
     for (const { 0: watchedPath, 1: watcher } of this.#watchers.entries()) {
-      if (path !== watchedPath && StringPrototypeStartsWith(watchedPath, path)) {
+      if (path !== watchedPath && this.#isParentPath(path, watchedPath)) {
         this.#unwatch(watcher);
         this.#watchers.delete(watchedPath);
       }

test/parallel/test-watch-mode-files_watcher.mjs

@@ -6,7 +6,7 @@ import path from 'node:path';
 import assert from 'node:assert';
 import process from 'node:process';
 import { describe, it, beforeEach, afterEach } from 'node:test';
-import { writeFileSync, mkdirSync } from 'node:fs';
+import { writeFileSync, mkdirSync, appendFileSync } from 'node:fs';
 import { setTimeout } from 'node:timers/promises';
 import { once } from 'node:events';
 import { spawn } from 'node:child_process';
@@ -51,6 +51,38 @@ describe('watch mode file watcher', () => {
     assert.strictEqual(changesCount, 1);
   });
 
+  it('should watch changed files with same prefix path string', async () => {
+    const ran1 = Promise.withResolvers();
+    mkdirSync(tmpdir.resolve('subdir'));
+    mkdirSync(tmpdir.resolve('sub'));
+    const file1 = tmpdir.resolve('subdir', 'file1.mjs');
+    const file2 = tmpdir.resolve('sub', 'file2.mjs');
+    writeFileSync(file2, 'export const hello = () => { return "hello world"; };');
+    writeFileSync(file1, 'import { hello } from "../sub/file2.mjs"; console.log(hello());');
+
+    let stdout = '';
+    const child = spawn(process.execPath,
+                        ['--watch', file1],
+                        { encoding: 'utf8', stdio: 'pipe' });
+    let completeCount = 0;
+    child.stdout.on('data', async (data) => {
+      stdout += data.toString();
+      if (stdout.match(/Complete/g)) {
+        completeCount++;
+      }
+      if (completeCount === 1) {
+        ran1.resolve();
+      }
+      // The file is reloaded due to file watching
+      if (completeCount === 2) {
+        child.kill();
+        await once(child, 'exit');
+      }
+    });
+    await ran1.promise;
+    appendFileSync(file1, '\n // append 1');
+  });
+
   it('should debounce changes', async () => {
     const file = tmpdir.resolve('file2');
     writeFileSync(file, 'written');