Update stateManager.js

stateManager.js

@@ -5,9 +5,9 @@ const activeProjects = new Map();
 const initializationLocks = new Set(); 
 
 // --- 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)
+const streamBuffers = new Map(); // Destructive (Plugin)
+const statusBuffers = new Map(); // Status (Frontend)
+const snapshotBuffers = new Map(); // Non-Destructive (Frontend)
 
 export const initDB = () => {
     if (!process.env.SUPABASE_URL || !process.env.SUPABASE_SERVICE_ROLE_KEY) {
@@ -58,7 +58,6 @@ export const StateManager = {
 
     addHistory: async (projectId, type, role, text) => {
         const newMessage = { role, parts: [{ text }] };
-        
         const project = activeProjects.get(projectId);
         if (project) {
             const historyKey = type === 'pm' ? 'pmHistory' : 'workerHistory';
@@ -81,10 +80,9 @@ export const StateManager = {
 
             const latest = chunks?.[0];
             const currentPayload = (latest && Array.isArray(latest.payload)) ? latest.payload : [];
-            const currentSize = currentPayload.length;
             const latestIndex = (latest && typeof latest.chunk_index === 'number') ? latest.chunk_index : -1;
 
-            if (latest && currentSize < 20) {
+            if (latest && currentPayload.length < 20) {
                 const updatedPayload = [...currentPayload, newMessage];
                 const { error: updateError } = await supabase.from('message_chunks')
                     .update({ payload: updatedPayload })
@@ -114,9 +112,6 @@ 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);
@@ -125,7 +120,6 @@ 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);