Update app.js

app.js

@@ -78,6 +78,26 @@ const callAI = async (history, input, contextData, systemPrompt, projectContext,
     } catch (e) { return { text: "<notification>AI Unreachable</notification>", usage: {} }; }
 };
 
+// --- THRUST CLEANUP HELPER ---
+async function clearPreviousThrusts(projectId) {
+    try {
+        // Deleting the thrust automatically deletes all its tasks 
+        // because of the 'on delete cascade' rule in Supabase.
+        const { error } = await supabase
+            .from('thrusts')
+            .delete()
+            .eq('lead_id', projectId);
+        
+        if (error) {
+            console.error(`[DB Error] Failed to clear old thrusts for ${projectId}:`, error.message);
+        } else {
+            console.log(`🧹 Cleared previous thrusts for project ${projectId}`);
+        }
+    } catch (e) {
+        console.error("Error in clearPreviousThrusts:", e.message);
+    }
+}
+
 function extractCommands(text) {
     const commands = [];
     const parse = (regex, type, isJson = true) => {
@@ -123,7 +143,10 @@ async function executeCommands(userId, projectId, commands) {
     for (const cmd of commands) {
         try {
             if (cmd.type === 'create_thrust') {
-                const { data: thrust } = await supabase.from('thrusts').insert({ lead_id: projectId, title: cmd.payload.title, markdown_content: cmd.payload.markdown_content, status: 'active' }).select().single();
+               // 👉 ADD THIS LINE: Wipe out the old thrust and tasks first
+            await clearPreviousThrusts(projectId);
+              
+              const { data: thrust } = await supabase.from('thrusts').insert({ lead_id: projectId, title: cmd.payload.title, markdown_content: cmd.payload.markdown_content, status: 'active' }).select().single();
                 if (thrust && cmd.payload.tasks && cmd.payload.tasks.length > 0) {
                     const tasks = cmd.payload.tasks.map(t => ({ thrust_id: thrust.id, title: t }));
                     await supabase.from('thrust_tasks').insert(tasks);