Move Watcher Scan/Reconcile To Worker Thread And Fix Startup/Telemetry Races

package.json

@@ -11,7 +11,7 @@
     "setup": "node src/setup-gui.js",
     "watcher": "node src/watcher/watcher-client.js",
     "bridge": "node src/bridge/mcp-bridge.js",
-    "test": "node --test --test-timeout 30000 src/*.test.js",
+    "test": "node --test --test-timeout 30000 src/*.test.js src/watcher/*.test.js",
     "stress-test": "node --test src/stress-test.js"
   },
   "keywords": [

src/watcher/exclude-patterns.js

@@ -0,0 +1,34 @@
+function escapeRegexLiteral(value) {
+  return value.replace(/[.+?^${}()|[\]\\]/g, '\\$&');
+}
+
+export function buildExcludeRegex(pattern) {
+  const normalizedPattern = String(pattern || '').trim().replace(/\\/g, '/');
+  if (!normalizedPattern) return null;
+
+  const escaped = escapeRegexLiteral(normalizedPattern);
+  const wildcardPattern = escaped
+    .replace(/\*\*/g, '___DOUBLE_STAR___')
+    .replace(/\*/g, '[^/]*')
+    .replace(/___DOUBLE_STAR___/g, '.*');
+
+  // Match on path-segment boundaries anywhere in the path.
+  return new RegExp(`(^|.*/)${wildcardPattern}($|/.*)`);
+}
+
+export function compileExcludePatterns(excludePatterns = []) {
+  const compiled = [];
+  for (const pattern of excludePatterns) {
+    const regex = buildExcludeRegex(pattern);
+    if (regex) compiled.push(regex);
+  }
+  return compiled;
+}
+
+export function shouldExcludePath(filePath, compiledExcludePatterns = []) {
+  const normalizedPath = String(filePath || '').replace(/\\/g, '/');
+  for (const regex of compiledExcludePatterns) {
+    if (regex.test(normalizedPath)) return true;
+  }
+  return false;
+}

src/watcher/scan-telemetry.js

@@ -0,0 +1,28 @@
+export function mergeScanTelemetrySnapshot(current, telemetry) {
+  if (!telemetry) return { ...current };
+  return {
+    filesIngested: (current.filesIngested || 0) + (telemetry.filesIngested || 0),
+    assetsIngested: (current.assetsIngested || 0) + (telemetry.assetsIngested || 0),
+    deletesProcessed: (current.deletesProcessed || 0) + (telemetry.deletesProcessed || 0),
+    errorsCount: (current.errorsCount || 0) + (telemetry.errorsCount || 0),
+    lastIngestAt: telemetry.lastIngestAt || current.lastIngestAt || null
+  };
+}
+
+export function reconcileFinalTelemetry({ streamedTelemetry, streamedTotals, finalTelemetry }) {
+  if (!streamedTelemetry) return finalTelemetry || null;
+  if (!finalTelemetry) return null;
+
+  return {
+    filesIngested: Math.max(0, (finalTelemetry.filesIngested || 0) - (streamedTotals?.filesIngested || 0)),
+    assetsIngested: Math.max(0, (finalTelemetry.assetsIngested || 0) - (streamedTotals?.assetsIngested || 0)),
+    deletesProcessed: Math.max(0, (finalTelemetry.deletesProcessed || 0) - (streamedTotals?.deletesProcessed || 0)),
+    errorsCount: Math.max(0, (finalTelemetry.errorsCount || 0) - (streamedTotals?.errorsCount || 0)),
+    lastIngestAt: finalTelemetry.lastIngestAt || null
+  };
+}
+
+export function getConfigReloadAction(projectsChanged, hasActiveWatcher) {
+  if (!projectsChanged) return 'none';
+  return hasActiveWatcher ? 'restart' : 'defer';
+}