IPC debouncing, resource cleanup, and native module rebuild scripts

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: Danny Bannister

main/ipc-handlers.ts

@@ -503,23 +503,49 @@ export function setupIpcHandlers(): void {
       fileWatchers.set(resolvedPath, abortController);
 
       // Use fs.watch if available, otherwise fallback to polling
+      const IGNORED_DIRS = new Set([
+        'node_modules', '.git', 'dist', 'build', '.next', '.cache',
+        '.turbo', '.nuxt', '.output', '__pycache__', '.venv', 'venv',
+        '.expo', '.parcel-cache', 'coverage', '.svelte-kit',
+      ]);
+
       const { watch } = await import('node:fs');
+
+      // Debounce file change notifications to avoid IPC flooding
+      let pendingChanges = new Map<string, string>();
+      let debounceTimer: ReturnType<typeof setTimeout> | null = null;
+
+      const flushChanges = () => {
+        const changes = Array.from(pendingChanges.entries());
+        pendingChanges = new Map();
+        debounceTimer = null;
+        BrowserWindow.getAllWindows().forEach(window => {
+          for (const [fullPath, type] of changes) {
+            window.webContents.send('file:change', { type, path: fullPath });
+          }
+        });
+      };
+
       const watcher = watch(resolvedPath, { recursive: true }, (eventType, filename) => {
         if (!filename) return;
-        
+
+        // Skip ignored directories
+        const parts = filename.split(path.sep);
+        if (parts.some(p => IGNORED_DIRS.has(p))) return;
+
         const fullPath = path.join(resolvedPath, filename);
-        
-        // Send to all windows
-        BrowserWindow.getAllWindows().forEach(window => {
-          window.webContents.send('file:change', {
-            type: eventType === 'rename' ? 'unlink' : 'change',
-            path: fullPath,
-          });
-        });
+        const type = eventType === 'rename' ? 'unlink' : 'change';
+
+        pendingChanges.set(fullPath, type);
+        if (!debounceTimer) {
+          debounceTimer = setTimeout(flushChanges, 300);
+        }
       });
 
       // Store watcher reference
       abortController.signal.addEventListener('abort', () => {
+        if (debounceTimer) clearTimeout(debounceTimer);
+        pendingChanges.clear();
         watcher.close();
       });
 
@@ -1253,12 +1279,22 @@ export function setupIpcHandlers(): void {
 
   // --- Git IPC Handlers ---
   console.log('[IPC:git] Registering git handlers...');
+  const GIT_MANAGER_CACHE_MAX = 10;
   const gitManagerCache = new Map<string, GitManager>();
   function getGitManager(cwd: string): GitManager {
     let mgr = gitManagerCache.get(cwd);
-    if (!mgr) {
-      mgr = new GitManager(cwd);
+    if (mgr) {
+      // Move to end (most recently used)
+      gitManagerCache.delete(cwd);
       gitManagerCache.set(cwd, mgr);
+      return mgr;
+    }
+    mgr = new GitManager(cwd);
+    gitManagerCache.set(cwd, mgr);
+    // Evict oldest entry if cache exceeds limit
+    if (gitManagerCache.size > GIT_MANAGER_CACHE_MAX) {
+      const oldest = gitManagerCache.keys().next().value;
+      if (oldest) gitManagerCache.delete(oldest);
     }
     return mgr;
   }

package.json

@@ -12,7 +12,9 @@
   },
   "scripts": {
     "build": "tsup",
-    "dev": "tsx src/index.ts",
+    "dev": "npm run rebuild:node && tsx src/index.ts",
+    "rebuild:node": "npm rebuild better-sqlite3",
+    "rebuild:electron": "npx electron-rebuild -m . -o better-sqlite3",
     "test": "vitest",
     "lint": "eslint src/",
     "typecheck": "tsc --noEmit",

renderer/stores/appStore.ts

@@ -937,7 +937,11 @@ export const useAppStore = create<AppState>((set, get) => ({
     }
   },
 
-  setIndexingPollInterval: (interval) => set({ indexingPollInterval: interval }),
+  setIndexingPollInterval: (interval) => {
+    const existing = get().indexingPollInterval;
+    if (existing) clearInterval(existing);
+    set({ indexingPollInterval: interval });
+  },
 
   // Multi-Conversation Actions
   createConversation: (options) => {
@@ -1823,6 +1827,12 @@ export const useAppStore = create<AppState>((set, get) => ({
         projectPath: state.projectPath || dirPath,
       }));
 
+      // Unwatch previous directory before watching new one
+      const prevPath = get().projectPath;
+      if (prevPath && prevPath !== dirPath) {
+        await window.electronAPI.file.unwatch(prevPath).catch(() => {});
+      }
+
       // Start watching the directory
       await window.electronAPI.file.watch(dirPath);
 

scripts/electron-dev.mjs

@@ -1,4 +1,4 @@
-import { spawn } from 'node:child_process';
+import { spawn, execSync } from 'node:child_process';
 import { watchFile, unwatchFile } from 'node:fs';
 import { access } from 'node:fs/promises';
 import path from 'node:path';
@@ -85,7 +85,7 @@ async function restartElectron() {
     await waitForFile(electronEntry);
     await waitForRenderer(viteUrl);
     await stopElectron();
-    electronProcess = spawnProcess(electronBinary, ['.'], 'electron', {
+    electronProcess = spawnProcess(electronBinary, ['--max-old-space-size=8192', '.'], 'electron', {
       NODE_ENV: 'development',
       ELECTRON_RUN_AS_NODE: '',
     });
@@ -94,6 +94,18 @@ async function restartElectron() {
   }
 }
 
+// Rebuild native modules for Electron before launching
+console.log('[electron-dev] Rebuilding native modules for Electron...');
+try {
+  execSync('npx electron-rebuild -m . -o better-sqlite3', {
+    cwd: projectRoot,
+    stdio: 'inherit',
+  });
+  console.log('[electron-dev] Native modules rebuilt for Electron.');
+} catch (e) {
+  console.error('[electron-dev] Warning: electron-rebuild failed:', e.message);
+}
+
 const viteProcess = spawnProcess('npm', ['run', 'dev:vite'], 'vite', {
   NODE_ENV: 'development',
 });