Update app.js

app.js

@@ -21,6 +21,49 @@ app.use(bodyParser.json({ limit: '50mb' }));
 const MIN_BASIC_REQUIRED = 50; 
 const MIN_DIAMOND_REQUIRED = 50; 
 
+// --- STATUS PHASES ---
+const WORKER_PHASES = [
+    "Worker: Analyzing Request...",
+    "Worker: Reading Context...",
+    "Worker: Checking Hierarchy...",
+    "Worker: Planning Logic...",
+    "Worker: Preparing Environment...",
+    "Worker: Thinking..." // Settles here
+];
+
+const PM_PHASES = [
+    "Manager: Reviewing Request...",
+    "Manager: Analyzing Project Structure...",
+    "Manager: Consulting Guidelines...",
+    "Manager: Formulating Strategy...",
+    "Manager: Delegating Tasks...",
+    "Manager: Thinking..." // Settles here
+];
+
+// --- HELPERS ---
+
+// Starts cycling status messages in the background. Returns a stop() function.
+function startStatusLoop(projectId, type = 'worker') {
+    const phases = type === 'pm' ? PM_PHASES : WORKER_PHASES;
+    let index = 0;
+    
+    // Set initial status immediately
+    StateManager.setStatus(projectId, phases[0]);
+
+    const interval = setInterval(() => {
+        index++;
+        if (index < phases.length) {
+            StateManager.setStatus(projectId, phases[index]);
+        } else {
+            // Stop incrementing, but keep the interval running (or clear it)
+            // We just let it sit on the last message
+            clearInterval(interval);
+        }
+    }, 1500); // Change status every 1.5 seconds
+
+    return () => clearInterval(interval);
+}
+
 async function checkMinimumCredits(userId, type = 'basic') {
     if (!supabase) return; 
 
@@ -105,6 +148,8 @@ function formatContext({ hierarchyContext, scriptContext, logContext }) {
     return out;
 }
 
+// --- CORE BACKGROUND LOGIC ---
+
 async function runBackgroundInitialization(projectId, userId, description) {
     if (StateManager.isLocked(projectId)) {
         console.log(`[Init Guard] Project ${projectId} is already initializing. Skipping.`);
@@ -128,11 +173,14 @@ async function runBackgroundInitialization(projectId, userId, description) {
 
         const pmHistory = [];
         
-        StateManager.setStatus(projectId, "Project Manager: Writing Design Doc...");
+        // Start PM Status Loop
+        let stopStatus = startStatusLoop(projectId, 'pm');
         
         const gddPrompt = `Create a comprehensive Game Design Document (GDD) for: ${description}`;
         const gddResult = await AIEngine.callPM(pmHistory, gddPrompt);
         
+        stopStatus(); // Stop loop when done
+        
         if (!gddResult?.text) throw new Error("PM failed to generate GDD");
         
         const gddText = gddResult.text;
@@ -144,10 +192,14 @@ async function runBackgroundInitialization(projectId, userId, description) {
         pmHistory.push({ role: 'user', parts: [{ text: gddPrompt }] });
         pmHistory.push({ role: 'model', parts: [{ text: gddText }] });
 
-        StateManager.setStatus(projectId, "Project Manager: Planning Tasks...");
+        // Start PM Status Loop again for next task
+        stopStatus = startStatusLoop(projectId, 'pm');
+
         const taskPrompt = "Based on the GDD, generate the first technical milestone.\nOutput format:\nTASK_NAME: <Name>\nWORKER_PROMPT: <Specific, isolated instructions for the worker>";
         const taskResult = await AIEngine.callPM(pmHistory, taskPrompt);
         
+        stopStatus();
+
         if (!taskResult?.text) throw new Error("PM failed to generate Task");
 
         const taskText = taskResult.text;
@@ -159,7 +211,8 @@ async function runBackgroundInitialization(projectId, userId, description) {
         const initialWorkerInstruction = extractWorkerPrompt(taskText) || `Initialize structure for: ${description}`;
         const initialWorkerPrompt = `CONTEXT: New Project. \nINSTRUCTION: ${initialWorkerInstruction}`;
         
-        StateManager.setStatus(projectId, "Worker: Initializing...");
+        // Start Worker Loop
+        stopStatus = startStatusLoop(projectId, 'worker');
         
         let workerTextAccumulated = "";
 
@@ -167,10 +220,12 @@ async function runBackgroundInitialization(projectId, userId, description) {
             [], 
             initialWorkerPrompt, 
             (thought) => {
+                stopStatus(); // Stop fake loop, switch to real thought
                 StateManager.setStatus(projectId, "Worker: Thinking...");
                 StateManager.appendSnapshotOnly(projectId, thought);
             },
             (chunk) => {
+                stopStatus(); // Stop fake loop
                 StateManager.setStatus(projectId, "Worker: Coding...");
                 workerTextAccumulated += chunk;
                 StateManager.appendStream(projectId, chunk);
@@ -211,35 +266,41 @@ async function runAsyncFeedback(projectId, userId, fullInput) {
         
         // 1. Clear previous ghost text
         StateManager.clearSnapshot(projectId);
-        StateManager.setStatus(projectId, "Worker: Starting...");
         
-        let responseText = ""; // The actual code
-        let thoughtText = "";  // The reasoning (optional to save, we generally discard)
+        // 2. Start Status Loop (Worker)
+        let stopStatus = startStatusLoop(projectId, 'worker');
+        
+        let responseText = ""; 
+        let thoughtText = "";  
         
-        // 2. Call Worker
+        // 3. Call Worker
         await AIEngine.callWorkerStream(
             project.workerHistory, 
             fullInput, 
             (thought) => {
+                stopStatus(); // Stop cycling
                 thoughtText += thought;
                 StateManager.setStatus(projectId, "Worker: Thinking...");
                 StateManager.appendSnapshotOnly(projectId, thought);
             },
             (chunk) => {
+                stopStatus(); // Stop cycling
                 responseText += chunk;
                 StateManager.setStatus(projectId, "Worker: Coding...");
                 StateManager.appendStream(projectId, chunk);
             }
         );
 
-        // 3. Interceptors
+        // 4. Interceptors
         const routeTask = extractRouteToPM(responseText);
         const pmQuestion = extractPMQuestion(responseText);
 
         if (routeTask) {
             console.log(`[${projectId}] Routing task to PM...`);
             StateManager.clearSnapshot(projectId); 
-            StateManager.setStatus(projectId, "Project Manager: Reviewing...");
+            
+            // Start PM Loop
+            stopStatus = startStatusLoop(projectId, 'pm');
             
             const pmPrompt = `[ROUTED TASK]: ${routeTask}\nWrite the backend/logic. Then use WORKER_PROMPT: <task> to delegate.`;
             
@@ -249,11 +310,13 @@ async function runAsyncFeedback(projectId, userId, fullInput) {
                 project.pmHistory,
                 pmPrompt,
                 (thought) => {
-                    StateManager.setStatus(projectId, "Project Manager: Thinking...");
+                    stopStatus();
+                    StateManager.setStatus(projectId, "Manager: Thinking...");
                     StateManager.appendSnapshotOnly(projectId, thought);
                 },
                 (chunk) => {
-                    StateManager.setStatus(projectId, "Project Manager: Planning...");
+                    stopStatus();
+                    StateManager.setStatus(projectId, "Manager: Planning...");
                     pmResponseText += chunk;
                     StateManager.appendSnapshotOnly(projectId, chunk); 
                 }
@@ -267,17 +330,21 @@ async function runAsyncFeedback(projectId, userId, fullInput) {
             const nextInstruction = extractWorkerPrompt(pmResponseText);
             if (nextInstruction) {
                 StateManager.clearSnapshot(projectId);
-                StateManager.setStatus(projectId, "Worker: Applying Changes...");
+                
+                // Back to Worker Loop
+                stopStatus = startStatusLoop(projectId, 'worker');
                 
                 let subResponse = "";
                 await AIEngine.callWorkerStream(
                     project.workerHistory, 
                     `[PM DELEGATION]: ${nextInstruction}`,
                     (thought) => {
+                        stopStatus();
                         StateManager.setStatus(projectId, "Worker: Thinking...");
                         StateManager.appendSnapshotOnly(projectId, thought);
                     },
                     (chunk) => {
+                        stopStatus();
                         StateManager.setStatus(projectId, "Worker: Coding...");
                         subResponse += chunk;
                         StateManager.appendStream(projectId, chunk); 
@@ -288,18 +355,22 @@ async function runAsyncFeedback(projectId, userId, fullInput) {
         } else if (pmQuestion) {
             console.log(`[${projectId}] Worker consulting PM...`);
             StateManager.clearSnapshot(projectId);
-            StateManager.setStatus(projectId, "Project Manager: Consulting...");
+            
+            // Start PM Loop
+            stopStatus = startStatusLoop(projectId, 'pm');
 
             let pmResponseText = "";
             await AIEngine.callPMStream(
                 project.pmHistory,
                 pmQuestion,
                 (thought) => {
-                    StateManager.setStatus(projectId, "Project Manager: Thinking...");
+                    stopStatus();
+                    StateManager.setStatus(projectId, "Manager: Thinking...");
                     StateManager.appendSnapshotOnly(projectId, thought);
                 },
                 (chunk) => {
-                    StateManager.setStatus(projectId, "Project Manager: Advising...");
+                    stopStatus();
+                    StateManager.setStatus(projectId, "Manager: Advising...");
                     pmResponseText += chunk;
                     StateManager.appendSnapshotOnly(projectId, chunk);
                 }
@@ -311,17 +382,21 @@ async function runAsyncFeedback(projectId, userId, fullInput) {
             await StateManager.addHistory(projectId, 'pm', 'model', pmResponseText);
 
             StateManager.clearSnapshot(projectId);
-            StateManager.setStatus(projectId, "Worker: Implementing Answer...");
+            
+            // Back to Worker Loop
+            stopStatus = startStatusLoop(projectId, 'worker');
             
             let subResponse = "";
             await AIEngine.callWorkerStream(
                 project.workerHistory, 
                 `[PM ANSWER]: ${pmResponseText}`,
                 (thought) => {
+                    stopStatus();
                     StateManager.setStatus(projectId, "Worker: Thinking...");
                     StateManager.appendSnapshotOnly(projectId, thought);
                 },
                 (chunk) => {
+                    stopStatus();
                     StateManager.setStatus(projectId, "Worker: Coding...");
                     subResponse += chunk;
                     StateManager.appendStream(projectId, chunk);
@@ -332,15 +407,13 @@ async function runAsyncFeedback(projectId, userId, fullInput) {
 
         StateManager.setStatus(projectId, "Finalizing...");
         
-        // 4. PERSISTENCE (CRITICAL: Wait for this before IDLE)
+        // 5. PERSISTENCE (Wait for DB)
         await StateManager.addHistory(projectId, 'worker', 'user', fullInput);
-        
-        // Save the FINAL accumulated text (responseText), not a stream fragment
         await StateManager.addHistory(projectId, 'worker', 'model', responseText);
         
         await processAndQueueResponse(projectId, responseText, userId);
 
-        // 5. FINISH
+        // 6. FINISH
         await StateManager.updateProject(projectId, { status: "idle" });
 
         if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
@@ -513,15 +586,18 @@ app.post('/human/override', validateRequest, async (req, res) => {
         const overrideMsg = `[SYSTEM OVERRIDE]: ${instruction}`;
         
         let overrideText = "";
+        let stopStatus = startStatusLoop(projectId, 'worker');
 
         AIEngine.callWorkerStream(
             project.workerHistory, 
             overrideMsg,
             (thought) => {
+                stopStatus();
                 StateManager.setStatus(projectId, "Worker: Thinking...");
                 StateManager.appendSnapshotOnly(projectId, thought);
             },
             (chunk) => {
+                stopStatus();
                 StateManager.setStatus(projectId, "Worker: Coding...");
                 overrideText += chunk;
                 StateManager.appendStream(projectId, chunk);