Update stateManager.js

stateManager.js

@@ -4,9 +4,10 @@ let supabase = null;
 const activeProjects = new Map();
 const initializationLocks = new Set(); 
 
-const streamBuffers = new Map(); // Destructive (For Plugin)
-const statusBuffers = new Map(); // Granular Status (For Frontend)
-const snapshotBuffers = new Map(); // Non-Destructive (For Frontend Visualization)
+// --- REALTIME BUFFERS ---
+const streamBuffers = new Map(); // Destructive (For Plugin - Code Execution)
+const statusBuffers = new Map(); // Granular Status (For Frontend - "Worker is typing...")
+const snapshotBuffers = new Map(); // Non-Destructive (For Frontend - Ghost Text)
 
 export const initDB = () => {
     if (!process.env.SUPABASE_URL || !process.env.SUPABASE_SERVICE_ROLE_KEY) {
@@ -113,6 +114,9 @@ export const StateManager = {
         return statusBuffers.get(projectId) || "Working...";
     },
 
+    // --- STREAMING HELPERS ---
+    
+    // Use this for WORKER (Goes to Plugin AND Frontend)
     appendStream: (projectId, chunk) => {
         const currentDestructive = streamBuffers.get(projectId) || "";
         streamBuffers.set(projectId, currentDestructive + chunk);
@@ -121,6 +125,12 @@ export const StateManager = {
         snapshotBuffers.set(projectId, currentSnapshot + chunk);
     },
 
+    // Use this for PM (Goes to Frontend ONLY - User sees thinking, Plugin ignores)
+    appendSnapshotOnly: (projectId, chunk) => {
+        const currentSnapshot = snapshotBuffers.get(projectId) || "";
+        snapshotBuffers.set(projectId, currentSnapshot + chunk);
+    },
+
     popStream: (projectId) => {
         const content = streamBuffers.get(projectId) || "";
         streamBuffers.set(projectId, "");