Update app.js

app.js

@@ -180,7 +180,7 @@ app.post('/onboarding/analyze', validateRequest, async (req, res) => {
 
     try {
         // Analyst uses BASIC models (Flash)
-        await checkMinimumCredits(userId, 'basic');
+        // await checkMinimumCredits(userId, 'basic');
 
         console.log(`[Onboarding] Analyzing idea...`);
         
@@ -189,7 +189,7 @@ app.post('/onboarding/analyze', validateRequest, async (req, res) => {
         const usage = result.usage?.totalTokenCount || 0;
 
         // Bill Basic
-        if (usage > 0) await deductUserCredits(userId, usage, 'basic');
+        // if (usage > 0) await deductUserCredits(userId, usage, 'basic');
 
         if (result.status === "REJECTED") {
             return res.json({ 
@@ -214,7 +214,7 @@ app.post('/onboarding/create', validateRequest, async (req, res) => {
 
     try {
         // Pre-flight check
-        await checkMinimumCredits(userId, 'basic');
+        // await checkMinimumCredits(userId, 'basic');
 
         const randomHex = (n = 6) => crypto.randomBytes(Math.ceil(n/2)).toString("hex").slice(0, n);
         const projectId = `proj_${Date.now()}_${randomHex(7)}`;
@@ -314,8 +314,9 @@ app.post('/onboarding/create', validateRequest, async (req, res) => {
         }
 
         // Deduct Basic Credits
-        if (basicTokens > 0) await deductUserCredits(userId, basicTokens, 'basic');
-       console.log("sending");
+        //if (basicTokens > 0) await deductUserCredits(userId, basicTokens, 'basic');
+      
+      console.log("sending");
         res.json({ 
           status: 200,
             success: !isFailure, 
@@ -399,8 +400,8 @@ async function runBackgroundInitialization(projectId, userId, description) {
         });
         
         // 7. Deduct Accumulated Credits
-        if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
-        if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
+        // if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
+        // if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
         
         console.log(`[Background] Init complete. Diamond: ${diamondUsage}, Basic: ${basicUsage}`);
 
@@ -415,8 +416,8 @@ app.post('/new/project', validateRequest, async (req, res) => {
     
     try {
         // Init requires BOTH types to be safe
-        await checkMinimumCredits(userId, 'diamond');
-        await checkMinimumCredits(userId, 'basic');
+        // await checkMinimumCredits(userId, 'diamond');
+        // await checkMinimumCredits(userId, 'basic');
 
         if(db) db.ref(`projects/${projectId}/info/status`).set("initializing");
         
@@ -447,7 +448,7 @@ app.post('/project/feedback', async (req, res) => {
         if (project.userId !== userId) return res.status(403).json({ error: "Unauthorized" });
 
         // Basic Check (most interaction is worker)
-        await checkMinimumCredits(userId, 'basic');
+        // await checkMinimumCredits(userId, 'basic');
         
         if(db) await db.ref(`projects/${projectId}/info/status`).set("working");
           
@@ -497,9 +498,11 @@ app.post('/project/feedback', async (req, res) => {
             if(db) await db.ref(`projects/${projectId}/info`).update({ status: "working", lastUpdated: Date.now() });
 
             // Final Bill
+            /*
             if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
             if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
-
+             */
+          
             return res.json({ success: true, message: "Next Task Assigned" });
         }
 
@@ -528,9 +531,9 @@ app.post('/project/feedback', async (req, res) => {
                 StateManager.queueCommand(projectId, { type: "EXECUTE", payload: "print('SYSTEM: Worker Reset')" });
                 await processAndQueueResponse(projectId, workerResult.text, userId);
                 
-                if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
+               /* if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
                 if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
-                return res.json({ success: true, message: "Worker Terminated." });
+                */ return res.json({ success: true, message: "Worker Terminated." });
             } else {
                 const injection = `[PM GUIDANCE]: ${pmVerdict} \n\nApply this fix now.`;
                 
@@ -544,9 +547,9 @@ app.post('/project/feedback', async (req, res) => {
                 await StateManager.updateProject(projectId, { workerHistory: project.workerHistory, failureCount: 1 });
                 await processAndQueueResponse(projectId, workerResult.text, userId);
                 
-                if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
+               /* if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
                 if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
-                return res.json({ success: true, message: "PM Guidance Applied." });
+               */ return res.json({ success: true, message: "PM Guidance Applied." });
             }
         }
 
@@ -596,9 +599,9 @@ app.post('/project/feedback', async (req, res) => {
         if(db) await db.ref(`projects/${projectId}/info`).update({ status: "idle", lastUpdated: Date.now() });
       
         // Final Billing
-        if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
+        /* if (diamondUsage > 0) await deductUserCredits(userId, diamondUsage, 'diamond');
         if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
-
+         */
         res.json({ success: true });
 
     } catch (err) {
@@ -640,7 +643,7 @@ app.post('/human/override', validateRequest, async (req, res) => {
     let basicUsage = 0;
 
     try {
-        await checkMinimumCredits(userId, 'basic');
+        // await checkMinimumCredits(userId, 'basic');
 
         const project = await StateManager.getProject(projectId);
         const overrideMsg = `[SYSTEM OVERRIDE]: ${instruction}`;
@@ -660,7 +663,7 @@ app.post('/human/override', validateRequest, async (req, res) => {
         await StateManager.updateProject(projectId, { workerHistory: project.workerHistory });
         await processAndQueueResponse(projectId, workerResult.text, userId);
         
-        if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
+        // if (basicUsage > 0) await deductUserCredits(userId, basicUsage, 'basic');
         
         res.json({ success: true });
     } catch (err) {
@@ -685,9 +688,9 @@ async function processAndQueueResponse(projectId, rawResponse, userId) {
             const imgTokens = imgResult.usage?.totalTokenCount || 0;
             const totalCost = imgTokens; // imgTokens + IMAGE_COST_BASIC;
             
-            if (userId && totalCost > 0) {
+            /* if (userId && totalCost > 0) {
                 await deductUserCredits(userId, totalCost, 'basic');
-            }
+            } */
 
             // 3. Queue creation command
             await StateManager.queueCommand(projectId, { type: "CREATE_ASSET", payload: imgResult.image });