Update app.js

app.js

@@ -113,44 +113,77 @@ app.post('/onboarding/create', validateRequest, async (req, res) => {
         let thumbnailBase64 = null;
 
         if (isFailure) {
-            console.log(`[Onboarding] ❌ Project Failed Grading (${grading.rating}). Skipping Image.`);
+            console.log(`[Onboarding] ❌ Project Failed Grading. Skipping Image.`);
         } else {
             console.log(`[Onboarding] ✅ Passed. Generating Thumbnail...`);
             const imagePrompt = `Game Title: ${grading.title}. Core Concept: ${description}`;
             thumbnailBase64 = await AIEngine.generateImage(imagePrompt);
         }
 
-        const projectData = {
+        const timestamp = Date.now();
+        const status = isFailure ? "rejected" : "initialized";
+
+        // 1. Prepare Memory Object (Flat for easy internal usage)
+        const memoryObject = {
             id: projectId,
             userId,
             title: grading.title || "Untitled Project",
             description,
             answers,
             stats: grading,
-            thumbnail: thumbnailBase64,// ? `data:image/png;base64,${thumbnailBase64}` : null,
-            createdAt: Date.now(),
-            status: isFailure ? "rejected" : "initialized"
+            thumbnail: thumbnailBase64, // ? `data:image/png;base64,${thumbnailBase64}` : null,
+            createdAt: timestamp,
+            status,
+            workerHistory: [],
+            pmHistory: [],
+            commandQueue: [],
+            failureCount: 0
         };
 
-        // Initialize in StateManager (handles Memory + DB write)
-        if (!isFailure) {
-            await StateManager.updateProject(projectId, {
-                ...projectData,
+        // 2. Prepare Database Object (Nested for performance)
+        if (db) {
+            const updates = {};
+            
+            // Bucket 1: Info (Lightweight)
+            updates[`projects/${projectId}/info`] = {
+                id: projectId,
+                userId,
+                title: grading.title || "Untitled Project",
+                description,
+                answers,
+                stats: grading,
+                createdAt: timestamp,
+                status
+            };
+
+            // Bucket 2: Thumbnail (Heavy - Isolated)
+            if (thumbnailBase64) {
+                updates[`projects/${projectId}/thumbnail`] = thumbnailBase64;
+            }
+
+            // Bucket 3: State (History)
+            updates[`projects/${projectId}/state`] = {
                 workerHistory: [],
                 pmHistory: [],
+                commandQueue: [],
                 failureCount: 0
-            });
-        } else if (db) {
-             // If failed, just write to DB for records, don't load to active memory
-             await db.ref(`projects/${projectId}`).set(projectData);
+            };
+
+            // Atomic multi-path update
+            await db.ref().update(updates);
+        }
+        
+        // 3. Update Memory
+        if (!isFailure) {
+            await StateManager.updateProject(projectId, memoryObject);
         }
 
         res.json({ 
             success: !isFailure, 
             projectId, 
             stats: grading, 
-            title: projectData.title,
-            thumbnail: projectData.thumbnail 
+            title: grading.title || "Untitled Project",
+            thumbnail: memoryObject.thumbnail 
         });
 
     } catch (err) {