Update app.js

app.js

@@ -23,7 +23,7 @@ const {
     SUPABASE_URL,
     SUPABASE_SERVICE_ROLE_KEY,
     EXTERNAL_SERVER_URL = 'http://localhost:7860',
-    STORAGE_BUCKET = 'project-assets', 
+    STORAGE_BUCKET = 'project-assets', // Default bucket name
     PORT = 7860
 } = process.env;
 
@@ -223,7 +223,6 @@ app.post('/feedback', async (req, res) => {
             ...pluginPayload           
         });
 
-        // We expect the AI Server to return success immediately while working in background
         return res.json({ success: true, externalResponse: response.data });
 
     } catch (err) {
@@ -235,6 +234,33 @@ app.post('/feedback', async (req, res) => {
     }
 });
 
+// --- RETAINED FEEDBACK2 ENDPOINT ---
+app.post('/feedback2', verifySupabaseUser, async (req, res) => {
+    const { projectId, prompt, images, ...otherPayload } = req.body; 
+    const userId = req.user.id;
+
+    if (!projectId || !prompt) {
+        return res.status(400).json({ error: 'Missing projectId or prompt' });
+    }
+
+    const targetUrl = EXTERNAL_SERVER_URL.replace(/\/$/, '') + '/project/feedback';
+
+    try {
+        const response = await axios.post(targetUrl, {
+            userId: userId,
+            projectId: projectId,
+            prompt: prompt,
+            images: images || [], 
+            ...otherPayload
+        });
+
+        return res.json({ success: true, externalResponse: response.data });
+    } catch (err) {
+        console.error("Forward Error:", err.message);
+        return res.status(502).json({ error: 'Failed to forward' });
+    }
+});
+
 app.post('/poll', async (req, res) => {
     const { token } = req.body;
 
@@ -260,6 +286,7 @@ app.post('/poll', async (req, res) => {
         const targetUrl = EXTERNAL_SERVER_URL.replace(/\/$/, '') + '/project/ping'; 
       
         try {
+            // Forward ping to get commands AND stream
             const response = await axios.post(targetUrl, {
               projectId: verifiedData.projectId,
               userId: verifiedData.uid
@@ -288,6 +315,7 @@ app.post('/project/delete', verifySupabaseUser, async (req, res) => {
     console.log(`🗑️ Deleting Project: ${projectId} requested by ${userId}`);
 
     try {
+        // 1. Verify Ownership
         const { data: project, error: fetchError } = await supabase
             .from('projects')
             .select('user_id')
@@ -298,6 +326,7 @@ app.post('/project/delete', verifySupabaseUser, async (req, res) => {
             return res.status(403).json({ error: "Unauthorized" });
         }
 
+        // 2. Explicitly Delete Message Chunks
         const { error: chunkError } = await supabase
             .from('message_chunks')
             .delete()
@@ -307,6 +336,7 @@ app.post('/project/delete', verifySupabaseUser, async (req, res) => {
             console.warn(`Warning: Failed to delete message chunks: ${chunkError.message}`);
         }
 
+        // 3. Delete Project
         const { error: dbError } = await supabase
             .from('projects')
             .delete()
@@ -314,14 +344,17 @@ app.post('/project/delete', verifySupabaseUser, async (req, res) => {
         
         if (dbError) throw dbError;
 
+        // 4. Delete from Supabase Storage
         if (STORAGE_BUCKET) {
             const { data: files } = await supabase.storage.from(STORAGE_BUCKET).list(projectId);
+            
             if (files && files.length > 0) {
                 const filesToRemove = files.map(f => `${projectId}/${f.name}`);
                 await supabase.storage.from(STORAGE_BUCKET).remove(filesToRemove);
             }
         }
 
+        // 5. Clear from Memory
         activeSessions.delete(`${userId}:${projectId}`);
         for (const [key, val] of tempKeys.entries()) {
             if (val.projectId === projectId) tempKeys.delete(key);