Update app.js

app.js

@@ -4,9 +4,6 @@ import fs from 'fs';
 import path from 'path';
 import { createClient } from '@supabase/supabase-js';
 
-// ==========================================
-// 1. CONFIGURATION & SETUP
-// ==========================================
 const PORT = 7860;
 const SUPABASE_URL = process.env.SUPABASE_URL;
 const SUPABASE_KEY = process.env.SUPABASE_SERVICE_KEY;
@@ -15,14 +12,10 @@ const FRONT_URL = process.env.FRONT_URL;
 const CRON_REGISTRY_URL = process.env.CRON_REGISTRY_URL || "http://localhost:7861"; 
 const CRON_SECRET = process.env.CRON_SECRET || "default_secret";
 
-// --- MODEL CONFIGURATION ---
 const SMART_MODEL_ID = "claude"; 
 const FAST_MODEL_ID = "gpt-5-mini"; 
 
-if (!SUPABASE_URL || !SUPABASE_KEY) {
-    console.error("FATAL: Missing Supabase URL or Service Key.");
-    process.exit(1);
-}
+if (!SUPABASE_URL || !SUPABASE_KEY) process.exit(1);
 
 const app = express();
 const supabase = createClient(SUPABASE_URL, SUPABASE_KEY);
@@ -30,160 +23,67 @@ const supabase = createClient(SUPABASE_URL, SUPABASE_KEY);
 app.use(express.json({ limit: '50mb' }));
 app.use(cors());
 
-// ==========================================
-// 2. PROMPT MANAGEMENT
-// ==========================================
 let prompts = {}; 
 try {
-    const promptsPath = path.resolve('./prompts.json');
-    if (fs.existsSync(promptsPath)) {
-        prompts = JSON.parse(fs.readFileSync(promptsPath, 'utf8'));
-        console.log("✅ Prompts loaded.");
-    } else {
-        throw new Error("prompts.json not found");
-    }
-} catch (e) {
-    console.error("❌ Prompt Load Error:", e.message);
-    process.exit(1);
-}
+    prompts = JSON.parse(fs.readFileSync(path.resolve('./prompts.json'), 'utf8'));
+} catch (e) { process.exit(1); }
 
-// ==========================================
-// 3. STATE MANAGER
-// ==========================================
 const activeProjects = new Map();
 
 const StateManager = {
     getHistory: async (projectId) => {
-        if (activeProjects.has(projectId)) {
-            const cached = activeProjects.get(projectId);
-            cached.lastActive = Date.now();
-            return cached.history;
-        }
-
-        const { data: chunks, error } = await supabase
-            .from('message_chunks')
-            .select('*')
-            .eq('project_id', projectId)
-            .order('chunk_index', { ascending: false })
-            .limit(10);
-
-        if (error) return [];
+        if (activeProjects.has(projectId)) return activeProjects.get(projectId).history;
+        const { data: chunks } = await supabase.from('message_chunks').select('*').eq('project_id', projectId).order('chunk_index', { ascending: false }).limit(10);
         const fullHistory = (chunks || []).reverse().flatMap(c => c.payload || []);
-        
-        activeProjects.set(projectId, { history: fullHistory, lastActive: Date.now(), isFrozen: false });
+        activeProjects.set(projectId, { history: fullHistory, isFrozen: false });
         return fullHistory;
     },
-
     addHistory: async (projectId, role, text) => {
         const newMessage = { role, parts: [{ text }] };
-
-        if (activeProjects.has(projectId)) {
-            const project = activeProjects.get(projectId);
-            project.history.push(newMessage);
-            project.lastActive = Date.now();
-            if (role === 'user') project.isFrozen = false; 
-        }
-
+        if (activeProjects.has(projectId)) activeProjects.get(projectId).history.push(newMessage);
         try {
-            const { data: latestChunk } = await supabase
-                .from('message_chunks')
-                .select('id, chunk_index, payload')
-                .eq('project_id', projectId)
-                .order('chunk_index', { ascending: false })
-                .limit(1)
-                .single();
-
+            const { data: latestChunk } = await supabase.from('message_chunks').select('id, chunk_index, payload').eq('project_id', projectId).order('chunk_index', { ascending: false }).limit(1).single();
             const currentPayload = (latestChunk?.payload) || [];
-
             if (latestChunk && currentPayload.length < 20) {
-                await supabase.from('message_chunks').update({ 
-                    payload: [...currentPayload, newMessage] 
-                }).eq('id', latestChunk.id);
+                await supabase.from('message_chunks').update({ payload: [...currentPayload, newMessage] }).eq('id', latestChunk.id);
             } else {
-                await supabase.from('message_chunks').insert({
-                    project_id: projectId,
-                    lead_id: projectId,
-                    chunk_index: (latestChunk?.chunk_index ?? -1) + 1,
-                    payload: [newMessage]
-                });
+                await supabase.from('message_chunks').insert({ project_id: projectId, lead_id: projectId, chunk_index: (latestChunk?.chunk_index ?? -1) + 1, payload: [newMessage] });
             }
-
-            if (role === 'user') await supabase.from('leads').update({ is_frozen: false }).eq('id', projectId);
-        } catch (e) { console.error("History Sync Error", e); }
+        } catch (e) {}
     },
-    
-    isFrozen: async (projectId) => {
-        if (activeProjects.has(projectId)) return activeProjects.get(projectId).isFrozen;
-        const { data } = await supabase.from('leads').select('is_frozen').eq('id', projectId).single();
-        return data?.is_frozen || false;
-    },
-
     setFrozen: async (projectId, status) => {
         if (activeProjects.has(projectId)) activeProjects.get(projectId).isFrozen = status;
         await supabase.from('leads').update({ is_frozen: status }).eq('id', projectId);
     }
 };
 
-// ==========================================
-// 4. AI ENGINE
-// ==========================================
 const callAI = async (history, input, contextData, systemPrompt, projectContext, modelId) => {
     let contextStr = "";
     try { contextStr = JSON.stringify(contextData, null, 2); } catch {}
-
-    const recentHistory = history.slice(-10).map(m => 
-        `${m.role === 'model' ? 'Assistant' : 'User'}: ${m.parts?.[0]?.text || ""}`
-    ).join('\n');
-
+    const recentHistory = history.slice(-10).map(m => `${m.role === 'model' ? 'Assistant' : 'User'}: ${m.parts?.[0]?.text || ""}`).join('\n');
     const fullPrompt = `System: ${systemPrompt}\n\n${projectContext}\n\n[HISTORY]:\n${recentHistory}\n\n[CONTEXT]: ${contextStr}\n\nUser: ${input}\nAssistant:`;
 
     try {
         const response = await fetch(`${REMOTE_SERVER_URL}/api/generate`, {
-            method: 'POST',
-            headers: { 'Content-Type': 'application/json' },
+            method: 'POST', headers: { 'Content-Type': 'application/json' },
             body: JSON.stringify({ model: modelId, prompt: fullPrompt, system_prompt: systemPrompt })
         });
-
-        if (!response.ok) throw new Error("AI API Error");
         const result = await response.json();
         return { text: result.data || result.text || "", usage: result.usage };
-    } catch (e) {
-        return { text: "<notification>AI Unreachable</notification>", usage: {} };
-    }
+    } catch (e) { return { text: "<notification>AI Unreachable</notification>", usage: {} }; }
 };
 
-// ==========================================
-// 5. COMMAND & CRON LOGIC
-// ==========================================
 function extractCommands(text) {
     const commands = [];
     const parse = (regex, type, isJson = true) => {
         let match;
         regex.lastIndex = 0;
-        // Added 'gi' flags for case-insensitive and global multiline matching
         while ((match = regex.exec(text)) !== null) {
             let rawPayload = match[1].trim();
             try {
-                if (isJson) {
-                    commands.push({ type, payload: JSON.parse(rawPayload) });
-                } else {
-                    commands.push({ type, payload: rawPayload });
-                }
+                commands.push({ type, payload: isJson ? JSON.parse(rawPayload) : rawPayload });
             } catch (e) { 
-                console.error(`⚠️ Parse Error (${type}):`, e.message);
-                
-                // BULLETPROOF FALLBACK: If AI spits raw markdown instead of JSON, rescue it.
-                if (type === 'create_thrust') {
-                    console.log(`[FALLBACK] Rescuing invalid JSON as raw markdown...`);
-                    commands.push({ 
-                        type, 
-                        payload: { 
-                            title: "System Thrust", 
-                            markdown_content: rawPayload, 
-                            tasks: [] 
-                        } 
-                    });
-                }
+                if (type === 'create_thrust') commands.push({ type, payload: { title: "System Thrust", markdown_content: rawPayload, tasks: [] } });
             }
         }
     };
@@ -195,6 +95,9 @@ function extractCommands(text) {
     parse(/<schedule_briefing>([\s\S]*?)<\/schedule_briefing>/gi, 'schedule_briefing');
     parse(/<freeze_project>([\s\S]*?)<\/freeze_project>/gi, 'freeze_project', false); 
     parse(/<thrust_complete>([\s\S]*?)<\/thrust_complete>/gi, 'thrust_complete', false); 
+    
+    // NEW: Parse AI checking off tasks
+    parse(/<complete_task>([\s\S]*?)<\/complete_task>/gi, 'complete_task', false); 
 
     return commands;
 }
@@ -202,46 +105,22 @@ function extractCommands(text) {
 async function registerMorningCron(projectId, offset) {
     const now = new Date();
     const target = new Date(now);
-    const targetUtcHour = 6 - offset; 
-
-    target.setUTCHours(targetUtcHour, 0, 0, 0); 
+    target.setUTCHours(6 - offset, 0, 0, 0); 
     if (target <= now) target.setDate(target.getDate() + 1); 
-
     const delayMs = target.getTime() - now.getTime();
-    const intervalMs = 24 * 60 * 60 * 1000; 
-
-    console.log(`⏰ Scheduling Briefing for ${projectId}. Next run in ${(delayMs/1000/60).toFixed(1)} mins.`);
-
-    await fetch(`${CRON_REGISTRY_URL}/register`, {
-        method: 'POST',
-        headers: { 'Content-Type': 'application/json' },
-        body: JSON.stringify({
-            secret: CRON_SECRET,
-            jobId: `briefing_${projectId}`,
-            intervalMs: intervalMs, 
-            initialDelay: delayMs,
-            webhookUrl: `https://everydaytok-thrust-core-server.hf.space/automated-briefing`,
-            leadId: projectId, 
-            payload: { projectId, timezoneOffset: offset }
-        })
-    }).catch(e => console.error("Cron Reg Error", e));
+    fetch(`${CRON_REGISTRY_URL}/register`, {
+        method: 'POST', headers: { 'Content-Type': 'application/json' },
+        body: JSON.stringify({ secret: CRON_SECRET, jobId: `briefing_${projectId}`, intervalMs: 86400000, initialDelay: delayMs, webhookUrl: `https://everydaytok-thrust-core-server.hf.space/automated-briefing`, leadId: projectId, payload: { projectId, timezoneOffset: offset } })
+    }).catch(()=>{});
 }
 
 async function executeCommands(userId, projectId, commands) {
     let flags = { shouldReload: false, thrustComplete: false };
 
     for (const cmd of commands) {
-        console.log(`[CMD] ${cmd.type} -> Project: ${projectId}`);
-
         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();
-
+                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);
@@ -250,12 +129,7 @@ async function executeCommands(userId, projectId, commands) {
             }
 
             if (cmd.type === 'log_timeline') {
-                await supabase.from('timeline_events').insert({
-                    lead_id: projectId,
-                    title: cmd.payload.title,
-                    description: cmd.payload.description,
-                    type: (cmd.payload.type || 'system').toLowerCase(),
-                });
+                await supabase.from('timeline_events').insert({ lead_id: projectId, title: cmd.payload.title, description: cmd.payload.description, type: (cmd.payload.type || 'system').toLowerCase() });
                 flags.shouldReload = true;
             }
 
@@ -265,81 +139,57 @@ async function executeCommands(userId, projectId, commands) {
             }
 
             if (cmd.type === 'schedule_briefing') {
-                const offset = cmd.payload.timezone_offset || 0;
-                await registerMorningCron(projectId, offset);
+                await registerMorningCron(projectId, cmd.payload.timezone_offset || 0);
             }
 
-            if (cmd.type === 'freeze_project') {
-                const isFrozen = cmd.payload === 'true';
-                await StateManager.setFrozen(projectId, isFrozen);
-                console.log(`❄️ Project ${projectId} Frozen: ${isFrozen}`);
+            // NEW: AI checks off a specific task
+            if (cmd.type === 'complete_task') {
+                const { data: active } = await supabase.from('thrusts').select('id').eq('lead_id', projectId).eq('status', 'active').single();
+                if (active) {
+                    await supabase.from('thrust_tasks').update({ status: 'done' }).eq('thrust_id', active.id).ilike('title', `%${cmd.payload}%`);
+                    flags.shouldReload = true;
+                }
             }
 
+            // NEW: AI marks thrust as complete, we delete all its tasks
             if (cmd.type === 'thrust_complete') {
-                flags.thrustComplete = true; 
+                const { data: active } = await supabase.from('thrusts').select('id').eq('lead_id', projectId).eq('status', 'active').single();
+                if (active) {
+                    await supabase.from('thrusts').update({ status: 'completed' }).eq('id', active.id);
+                    await supabase.from('thrust_tasks').delete().eq('thrust_id', active.id);
+                    flags.thrustComplete = true;
+                }
             }
 
             if (cmd.type === 'notification' && FRONT_URL) {
-                fetch(`${FRONT_URL}/internal/notify`, {
-                    method: 'POST',
-                    headers: { 'Content-Type': 'application/json' },
-                    body: JSON.stringify({ user_id: userId, type: 'toast', message: cmd.payload })
-                }).catch(() => {});
+                fetch(`${FRONT_URL}/internal/notify`, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ user_id: userId, type: 'toast', message: cmd.payload }) }).catch(() => {});
             }
 
-        } catch (e) { console.error("Exec Error", e); }
+        } catch (e) {}
     }
     return flags;
 }
 
-// ==========================================
-// 6. ENDPOINTS
-// ==========================================
-
-// --- INIT ---
 app.post('/init-project', async (req, res) => {
     const { userId, name, description, localPath } = req.body;
-    
-    const { data: lead, error } = await supabase.from('leads').insert({
-        user_id: userId, name, description, local_path: localPath, status: 'active', requirements_doc: "Init..."
-    }).select().single();
-
-    if (error || !lead) return res.status(500).json({ error: "Failed to create project" });
-
+    const { data: lead } = await supabase.from('leads').insert({ user_id: userId, name, description, local_path: localPath, status: 'active', requirements_doc: "Init..." }).select().single();
     res.json({ success: true, leadId: lead.id });
 
-    // Run AI processing in background
     setImmediate(async () => {
         try {
             const initInput = `PROJECT: ${name}\nDESC: ${description}\nTask: Init PRD, First Thrust, Schedule Morning Briefing.`;
             const aiResult = await callAI([], initInput, {}, prompts.init_system_prompt, "", SMART_MODEL_ID);
-            
-            // Explicitly force a success notification command so the UI reacts
             aiResult.text += `\n<notification>Project '${name}' initialized successfully!</notification>`;
-            
             await StateManager.addHistory(lead.id, 'user', initInput);
             await StateManager.addHistory(lead.id, 'model', aiResult.text);
-            
             const cmds = extractCommands(aiResult.text);
             await executeCommands(userId, lead.id, cmds);
-        } catch (err) {
-            console.error("❌ Background Init Failed:", err);
-            // Notify frontend of failure
-            if (FRONT_URL) {
-                fetch(`${FRONT_URL}/internal/notify`, {
-                    method: 'POST',
-                    headers: { 'Content-Type': 'application/json' },
-                    body: JSON.stringify({ user_id: userId, type: 'toast', message: "Initialization AI Error." })
-                }).catch(() => {});
-            }
-        }
+        } catch (err) {}
     });
 });
 
-// --- MAIN PROCESS ---
 app.post('/process', async (req, res) => {
     const { userId, projectId, prompt, context, task_type = 'chat' } = req.body;
-
     if (task_type === 'chat') await StateManager.setFrozen(projectId, false);
 
     let selectedModel = (task_type === 'log_ingestion') ? FAST_MODEL_ID : SMART_MODEL_ID;
@@ -347,502 +197,23 @@ app.post('/process', async (req, res) => {
 
     try {
         const { data: lead } = await supabase.from('leads').select('requirements_doc').eq('id', projectId).single();
-        const { data: activeThrust } = await supabase.from('thrusts')
-            .select('title, tasks:thrust_tasks(title, status)')
-            .eq('lead_id', projectId)
-            .eq('status', 'active')
-            .order('created_at', { ascending: false })
-            .limit(1)
-            .single();
-        
-        const { data: timeline } = await supabase.from('timeline_events')
-            .select('title, type, description, created_at')
-            .eq('lead_id', projectId)
-            .order('created_at', { ascending: false })
-            .limit(10); 
-
-        const projectContext = `
-        [PRD]: ${lead?.requirements_doc?.substring(0, 3000)}...
-        
-        [CURRENT THRUST]: 
-        ${activeThrust ? JSON.stringify(activeThrust, null, 2) : "None"}
-
-        [RECENT TIMELINE]:
-        ${JSON.stringify(timeline || [], null, 2)}
-        `;
-
-        const history = await StateManager.getHistory(projectId);
-        if (task_type === 'chat') await StateManager.addHistory(projectId, 'user', prompt);
-
-        let aiResult = await callAI(history, prompt, context, sysPrompt, projectContext, selectedModel);
-        let cmds = extractCommands(aiResult.text);
-        let flags = await executeCommands(userId, projectId, cmds);
-
-        if (flags.thrustComplete && task_type === 'log_ingestion') {
-            console.log(`🚀 Thrust Complete detected by Analyst. Escalating to Director...`);
-            
-            const escalationPrompt = "The previous thrust is complete based on logs. Generate the next Thrust immediately to keep momentum.";
-            const smartResult = await callAI(history, escalationPrompt, context, prompts.director_system_prompt, projectContext, SMART_MODEL_ID);
-            
-            aiResult.text += `\n\n[DIRECTOR INTERVENTION]:\n${smartResult.text}`;
-            
-            const smartCmds = extractCommands(smartResult.text);
-            await executeCommands(userId, projectId, smartCmds);
-            
-            await StateManager.addHistory(projectId, 'model', aiResult.text);
-        } else {
-            await StateManager.addHistory(projectId, 'model', aiResult.text);
-        }
-
-        const cleanText = aiResult.text.replace(/<[^>]+>[\s\S]*?<\/[^>]+>/g, '').trim();
-        res.json({ text: cleanText, should_reload: flags.shouldReload });
-
-    } catch (e) {
-        console.error(e);
-        res.status(500).json({ error: "Processing Error" });
-    }
-});
-
-// --- AUTOMATED MORNING BRIEFING ---
-app.post('/automated-briefing', async (req, res) => {
-    const { projectId } = req.body;
-    console.log(`☀️ Morning Briefing Triggered: ${projectId}`);
-
-    try {
-        const isFrozen = await StateManager.isFrozen(projectId);
-        
-        const { data: lastThrust } = await supabase.from('thrusts')
-            .select('created_at')
-            .eq('lead_id', projectId)
-            .order('created_at', { ascending: false })
-            .limit(1)
-            .single();
-
-        const lastThrustDate = lastThrust ? new Date(lastThrust.created_at).getDate() : 0;
-        const todayDate = new Date().getDate();
-
-        if (isFrozen) return res.json({ status: "skipped_frozen" });
-        if (lastThrustDate === todayDate) return res.json({ status: "skipped_exists" });
-
-        const prompt = "It is 6 AM. Generate the Morning Briefing (New Thrust). If the project has been idle, use <freeze_project>true</freeze_project> after this.";
-        
-        const { data: lead } = await supabase.from('leads').select('*').eq('id', projectId).single();
-        const { data: timeline } = await supabase.from('timeline_events')
-            .select('*').eq('lead_id', projectId).order('created_at', { ascending: false }).limit(5);
+        const { data: activeThrust } = await supabase.from('thrusts').select('title, tasks:thrust_tasks(title, status)').eq('lead_id', projectId).eq('status', 'active').order('created_at', { ascending: false }).limit(1).single();
+        const { data: timeline } = await supabase.from('timeline_events').select('title, type, description, created_at').eq('lead_id', projectId).order('created_at', { ascending: false }).limit(10); 
 
-        const projectContext = `[PRD]: ${lead.requirements_doc}\n[TIMELINE]: ${JSON.stringify(timeline)}`;
+        const projectContext = `[PRD]: ${lead?.requirements_doc?.substring(0, 3000)}...\n[CURRENT THRUST]: ${activeThrust ? JSON.stringify(activeThrust) : "None"}\n[RECENT TIMELINE]: ${JSON.stringify(timeline || [])}`;
         const history = await StateManager.getHistory(projectId);
         
-        const aiResult = await callAI(history, prompt, {}, prompts.director_system_prompt, projectContext, SMART_MODEL_ID);
-        
-        await StateManager.addHistory(projectId, 'model', aiResult.text);
-        const cmds = extractCommands(aiResult.text);
-        await executeCommands(lead.user_id, projectId, cmds);
-
-        await StateManager.setFrozen(projectId, true); 
-
-        res.json({ success: true });
-
-    } catch (e) {
-        console.error("Morning Briefing Error", e);
-        res.status(500).json({ error: e.message });
-    }
-});
-
-app.get('/', async (req, res) => {
-   res.status(200).json({ status: "Alive" });
-});
-
-app.listen(PORT, () => {
-  console.log(`✅ Core Online: ${PORT} | Smart: ${SMART_MODEL_ID} | Fast: ${FAST_MODEL_ID}`);
-});
-
-/* import express from 'express';
-import cors from 'cors';
-import fs from 'fs';
-import path from 'path';
-import { createClient } from '@supabase/supabase-js';
-
-
-// ==========================================
-// 1. CONFIGURATION & SETUP
-// ==========================================
-const PORT = 7860;
-const SUPABASE_URL = process.env.SUPABASE_URL;
-const SUPABASE_KEY = process.env.SUPABASE_SERVICE_KEY;
-const REMOTE_SERVER_URL = process.env.REMOTE_AI_URL || "http://localhost:11434"; // Defaulting to local if env missing
-const FRONT_URL = process.env.FRONT_URL;
-const CRON_REGISTRY_URL = process.env.CRON_REGISTRY_URL || "http://localhost:7861"; 
-const CRON_SECRET = process.env.CRON_SECRET || "default_secret";
-
-// --- MODEL CONFIGURATION ---
-const SMART_MODEL_ID = "claude"; 
-const FAST_MODEL_ID = "gpt-5-mini"; 
-
-if (!SUPABASE_URL || !SUPABASE_KEY) {
-    console.error("FATAL: Missing Supabase URL or Service Key.");
-    process.exit(1);
-}
-
-const app = express();
-const supabase = createClient(SUPABASE_URL, SUPABASE_KEY);
-
-app.use(express.json({ limit: '50mb' }));
-app.use(cors());
-
-// ==========================================
-// 2. PROMPT MANAGEMENT
-// ==========================================
-let prompts = {}; 
-try {
-    const promptsPath = path.resolve('./prompts.json');
-    if (fs.existsSync(promptsPath)) {
-        const fileData = fs.readFileSync(promptsPath, 'utf8');
-        prompts = JSON.parse(fileData);
-        console.log("✅ Prompts loaded.");
-    } else {
-        throw new Error("prompts.json not found");
-    }
-} catch (e) {
-    console.error("❌ Prompt Load Error:", e.message);
-    process.exit(1);
-}
-
-// ==========================================
-// 3. STATE MANAGER
-// ==========================================
-const activeProjects = new Map();
-
-const StateManager = {
-    getHistory: async (projectId) => {
-        if (activeProjects.has(projectId)) {
-            const cached = activeProjects.get(projectId);
-            cached.lastActive = Date.now();
-            return cached.history;
-        }
-
-        const { data: chunks, error } = await supabase
-            .from('message_chunks')
-            .select('*')
-            .eq('project_id', projectId)
-            .order('chunk_index', { ascending: false })
-            .limit(10);
-
-        if (error) return [];
-        const fullHistory = (chunks || []).reverse().flatMap(c => c.payload || []);
-        
-        // Initialize Cache with default frozen state (false)
-        activeProjects.set(projectId, { history: fullHistory, lastActive: Date.now(), isFrozen: false });
-        return fullHistory;
-    },
-
-    addHistory: async (projectId, role, text) => {
-        const newMessage = { role, parts: [{ text }] };
-
-        // Cache update
-        if (activeProjects.has(projectId)) {
-            const project = activeProjects.get(projectId);
-            project.history.push(newMessage);
-            project.lastActive = Date.now();
-            // User activity unfreezes project automatically
-            if (role === 'user') project.isFrozen = false; 
-        }
-
-        // DB Sync (Chunking Logic)
-        try {
-            const { data: latestChunk } = await supabase
-                .from('message_chunks')
-                .select('id, chunk_index, payload')
-                .eq('project_id', projectId)
-                .order('chunk_index', { ascending: false })
-                .limit(1)
-                .single();
-
-            const currentPayload = (latestChunk?.payload) || [];
-
-            if (latestChunk && currentPayload.length < 20) {
-                await supabase.from('message_chunks').update({ 
-                    payload: [...currentPayload, newMessage] 
-                }).eq('id', latestChunk.id);
-            } else {
-                await supabase.from('message_chunks').insert({
-                    project_id: projectId,
-                    lead_id: projectId,
-                    chunk_index: (latestChunk?.chunk_index ?? -1) + 1,
-                    payload: [newMessage]
-                });
-            }
-
-            // If user spoke, unfreeze in DB
-            if (role === 'user') {
-                await supabase.from('leads').update({ is_frozen: false }).eq('id', projectId);
-            }
-
-        } catch (e) { console.error("History Sync Error", e); }
-    },
-    
-    isFrozen: async (projectId) => {
-        if (activeProjects.has(projectId)) return activeProjects.get(projectId).isFrozen;
-        const { data } = await supabase.from('leads').select('is_frozen').eq('id', projectId).single();
-        return data?.is_frozen || false;
-    },
-
-    setFrozen: async (projectId, status) => {
-        if (activeProjects.has(projectId)) activeProjects.get(projectId).isFrozen = status;
-        await supabase.from('leads').update({ is_frozen: status }).eq('id', projectId);
-    }
-};
-
-// ==========================================
-// 4. AI ENGINE
-// ==========================================
-
-const callAI = async (history, input, contextData, systemPrompt, projectContext, modelId) => {
-    let contextStr = "";
-    try { contextStr = JSON.stringify(contextData, null, 2); } catch {}
-
-    const recentHistory = history.slice(-10).map(m => 
-        `${m.role === 'model' ? 'Assistant' : 'User'}: ${m.parts?.[0]?.text || ""}`
-    ).join('\n');
-
-    const fullPrompt = `System: ${systemPrompt}\n\n${projectContext}\n\n[HISTORY]:\n${recentHistory}\n\n[CONTEXT]: ${contextStr}\n\nUser: ${input}\nAssistant:`;
-
-    try {
-        const response = await fetch(`${REMOTE_SERVER_URL}/api/generate`, {
-            method: 'POST',
-            headers: { 'Content-Type': 'application/json' },
-            body: JSON.stringify({ model: modelId, prompt: fullPrompt, system_prompt: systemPrompt })
-        });
-
-        if (!response.ok) throw new Error("AI API Error");
-        const result = await response.json();
-        return { text: result.data || result.text || "", usage: result.usage };
-    } catch (e) {
-        return { text: "<notification>AI Unreachable</notification>", usage: {} };
-    }
-};
-
-// ==========================================
-// 5. COMMAND & CRON LOGIC
-// ==========================================
-
-function extractCommands(text) {
-    const commands = [];
-    const parse = (regex, type, isJson = true) => {
-        let match;
-        regex.lastIndex = 0;
-        while ((match = regex.exec(text)) !== null) {
-            try {
-                commands.push({ type, payload: isJson ? JSON.parse(match[1]) : match[1].trim() });
-            } catch (e) { console.error(`Parse Error (${type})`, e); }
-        }
-    };
-
-    parse(/<thrust_create>([\s\S]*?)<\/thrust_create>/g, 'create_thrust');
-    parse(/<timeline_log>([\s\S]*?)<\/timeline_log>/g, 'log_timeline');
-    parse(/<notification>([\s\S]*?)<\/notification>/g, 'notification', false);
-    parse(/<update_requirements>([\s\S]*?)<\/update_requirements>/g, 'update_requirements', false);
-    parse(/<schedule_briefing>([\s\S]*?)<\/schedule_briefing>/g, 'schedule_briefing');
-    parse(/<freeze_project>([\s\S]*?)<\/freeze_project>/g, 'freeze_project', false); 
-    parse(/<thrust_complete>([\s\S]*?)<\/thrust_complete>/g, 'thrust_complete', false); 
-
-    return commands;
-}
-
-// Logic: Calculate delay until 6AM user time, register Cron with that initial delay
-async function registerMorningCron(projectId, offset) {
-    const now = new Date();
-    const target = new Date(now);
-    
-    // Logic: 6 AM relative to user offset.
-    // E.g., Offset -5 (EST). UTC is 11 AM when EST is 6 AM.
-    // Target UTC hour = 6 - offset.
-    const targetUtcHour = 6 - offset; 
-
-    target.setUTCHours(targetUtcHour, 0, 0, 0); 
-    
-    if (target <= now) {
-        target.setDate(target.getDate() + 1); // Move to tomorrow
-    }
-
-    const delayMs = target.getTime() - now.getTime();
-    const intervalMs = 24 * 60 * 60 * 1000; // 24 Hours
-
-    console.log(`⏰ Scheduling Briefing for ${projectId}. Next run in ${(delayMs/1000/60).toFixed(1)} mins.`);
-
-await fetch(`${CRON_REGISTRY_URL}/register`, {
-    method: 'POST',
-    headers: { 'Content-Type': 'application/json' },
-    body: JSON.stringify({
-        secret: CRON_SECRET,
-        jobId: `briefing_${projectId}`,
-        intervalMs: intervalMs, 
-        initialDelay: delayMs,
-        webhookUrl: `https://everydaytok-thrust-core-server.hf.space/automated-briefing`,
-        // ADD THIS LINE BELOW:
-        leadId: projectId, // <--- Passes the UUID to the Cron Registry
-        payload: { projectId, timezoneOffset: offset }
-    })
-}).catch(e => console.error("Cron Reg Error", e));
-
-  
-}
-
-async function executeCommands(userId, projectId, commands) {
-    let flags = { shouldReload: false, thrustComplete: false };
-
-    for (const cmd of commands) {
-        console.log(`[CMD] ${cmd.type} -> Project: ${projectId}`);
-
-        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();
-
-                if (thrust && cmd.payload.tasks) {
-                    const tasks = cmd.payload.tasks.map(t => ({ thrust_id: thrust.id, title: t }));
-                    await supabase.from('thrust_tasks').insert(tasks);
-                }
-                flags.shouldReload = true;
-            }
-
-            if (cmd.type === 'log_timeline') {
-                await supabase.from('timeline_events').insert({
-                    lead_id: projectId,
-                    title: cmd.payload.title,
-                    description: cmd.payload.description,
-                    type: (cmd.payload.type || 'system').toLowerCase(),
-                });
-                flags.shouldReload = true;
-            }
-
-            if (cmd.type === 'update_requirements') {
-                await supabase.from('leads').update({ requirements_doc: cmd.payload }).eq('id', projectId);
-                flags.shouldReload = true;
-            }
-
-            if (cmd.type === 'schedule_briefing') {
-                const offset = cmd.payload.timezone_offset || 0;
-                await registerMorningCron(projectId, offset);
-            }
-
-            if (cmd.type === 'freeze_project') {
-                const isFrozen = cmd.payload === 'true';
-                await StateManager.setFrozen(projectId, isFrozen);
-                console.log(`❄️ Project ${projectId} Frozen: ${isFrozen}`);
-            }
-
-            if (cmd.type === 'thrust_complete') {
-                flags.thrustComplete = true; // Signal for escalation
-            }
-
-            if (cmd.type === 'notification' && FRONT_URL) {
-                fetch(`${FRONT_URL}/internal/notify`, {
-                    method: 'POST',
-                    headers: { 'Content-Type': 'application/json' },
-                    body: JSON.stringify({ user_id: userId, type: 'toast', message: cmd.payload })
-                }).catch(() => {});
-            }
-
-        } catch (e) { console.error("Exec Error", e); }
-    }
-    return flags;
-}
-
-// ==========================================
-// 6. ENDPOINTS
-// ==========================================
-
-// --- INIT ---
-app.post('/init-project', async (req, res) => {
-    const { userId, name, description, localPath } = req.body;
-    
-    const { data: lead, error } = await supabase.from('leads').insert({
-        user_id: userId, name, description, local_path: localPath, status: 'active', requirements_doc: "Init..."
-    }).select().single();
-
-  console.log(lead);
-  console.log(error);
-
-    res.json({ success: true, leadId: lead.id });
-
-    setImmediate(async () => {
-        const initInput = `PROJECT: ${name}\nDESC: ${description}\nTask: Init PRD, First Thrust, Schedule Morning Briefing.`;
-        const aiResult = await callAI([], initInput, {}, prompts.init_system_prompt, "", SMART_MODEL_ID);
-        
-        await StateManager.addHistory(lead.id, 'user', initInput);
-        await StateManager.addHistory(lead.id, 'model', aiResult.text);
-        
-        const cmds = extractCommands(aiResult.text);
-        await executeCommands(userId, lead.id, cmds);
-    });
-});
-
-// --- MAIN PROCESS ---
-app.post('/process', async (req, res) => {
-    const { userId, projectId, prompt, context, task_type = 'chat' } = req.body;
-
-    // 1. Unfreeze if user interacts
-    if (task_type === 'chat') await StateManager.setFrozen(projectId, false);
-
-    // 2. Select Model (Log Ingestion = Fast, High Level = Smart)
-    let selectedModel = (task_type === 'log_ingestion') ? FAST_MODEL_ID : SMART_MODEL_ID;
-    let sysPrompt = (task_type === 'log_ingestion') ? prompts.log_analyst_prompt : prompts.director_system_prompt;
-
-    try {
-        // 3. Build Context (God View: PRD + Timeline + Active Thrust)
-        const { data: lead } = await supabase.from('leads').select('requirements_doc').eq('id', projectId).single();
-        const { data: activeThrust } = await supabase.from('thrusts')
-            .select('title, tasks:thrust_tasks(title, status)')
-            .eq('lead_id', projectId)
-            .eq('status', 'active')
-            .order('created_at', { ascending: false })
-            .limit(1)
-            .single();
-        
-        // FETCH TIMELINE (Restored functionality)
-        const { data: timeline } = await supabase.from('timeline_events')
-            .select('title, type, description, created_at')
-            .eq('lead_id', projectId)
-            .order('created_at', { ascending: false })
-            .limit(10); // Look at last 10 events for context
-
-        const projectContext = `
-        [PRD]: ${lead?.requirements_doc?.substring(0, 3000)}...
-        
-        [CURRENT THRUST]: 
-        ${activeThrust ? JSON.stringify(activeThrust, null, 2) : "None"}
-
-        [RECENT TIMELINE]:
-        ${JSON.stringify(timeline || [], null, 2)}
-        `;
-
-        const history = await StateManager.getHistory(projectId);
-        if (task_type === 'chat') await StateManager.addHistory(projectId, 'user', prompt);
-
-        // 4. AI Execution
         let aiResult = await callAI(history, prompt, context, sysPrompt, projectContext, selectedModel);
         let cmds = extractCommands(aiResult.text);
         let flags = await executeCommands(userId, projectId, cmds);
 
-        // 5. AUTO-ESCALATION (Fast -> Smart)
-        // Logic: Analyst determines thrust is done via logs -> Triggers Director to set new Aim.
+        // Escalation: If fast model marks thrust complete, ask smart model for next thrust immediately
         if (flags.thrustComplete && task_type === 'log_ingestion') {
-            console.log(`🚀 Thrust Complete detected by Analyst. Escalating to Director...`);
-            
             const escalationPrompt = "The previous thrust is complete based on logs. Generate the next Thrust immediately to keep momentum.";
-            // Call Smart Model
             const smartResult = await callAI(history, escalationPrompt, context, prompts.director_system_prompt, projectContext, SMART_MODEL_ID);
-            
             aiResult.text += `\n\n[DIRECTOR INTERVENTION]:\n${smartResult.text}`;
-            
             const smartCmds = extractCommands(smartResult.text);
             await executeCommands(userId, projectId, smartCmds);
-            
             await StateManager.addHistory(projectId, 'model', aiResult.text);
         } else {
             await StateManager.addHistory(projectId, 'model', aiResult.text);
@@ -850,82 +221,8 @@ app.post('/process', async (req, res) => {
 
         const cleanText = aiResult.text.replace(/<[^>]+>[\s\S]*?<\/[^>]+>/g, '').trim();
         res.json({ text: cleanText, should_reload: flags.shouldReload });
-
-    } catch (e) {
-        console.error(e);
-        res.status(500).json({ error: "Processing Error" });
-    }
+    } catch (e) { res.status(500).json({ error: "Processing Error" }); }
 });
 
-// --- AUTOMATED MORNING BRIEFING (Called by Cron) ---
-app.post('/automated-briefing', async (req, res) => {
-    const { projectId } = req.body;
-    console.log(`☀️ Morning Briefing Triggered: ${projectId}`);
-
-    try {
-        const isFrozen = await StateManager.isFrozen(projectId);
-        
-        const { data: lastThrust } = await supabase.from('thrusts')
-            .select('created_at')
-            .eq('lead_id', projectId)
-            .order('created_at', { ascending: false })
-            .limit(1)
-            .single();
-
-        const lastThrustDate = lastThrust ? new Date(lastThrust.created_at).getDate() : 0;
-        const todayDate = new Date().getDate();
-
-        // Prevent generating if project is dead (frozen) or if generated recently
-        if (isFrozen) {
-            console.log(`Skipping briefing: Project Frozen.`);
-            return res.json({ status: "skipped_frozen" });
-        }
-        if (lastThrustDate === todayDate) {
-            console.log(`Skipping briefing: Thrust already exists for today.`);
-            return res.json({ status: "skipped_exists" });
-        }
-
-        // Generate Briefing
-        const prompt = "It is 6 AM. Generate the Morning Briefing (New Thrust). If the project has been idle, use <freeze_project>true</freeze_project> after this.";
-        
-        // Manually build context context for the automated call
-        const { data: lead } = await supabase.from('leads').select('*').eq('id', projectId).single();
-        const { data: timeline } = await supabase.from('timeline_events')
-            .select('*').eq('lead_id', projectId).order('created_at', { ascending: false }).limit(5);
-
-        const projectContext = `[PRD]: ${lead.requirements_doc}\n[TIMELINE]: ${JSON.stringify(timeline)}`;
-        const history = await StateManager.getHistory(projectId);
-        
-        const aiResult = await callAI(history, prompt, {}, prompts.director_system_prompt, projectContext, SMART_MODEL_ID);
-        
-        await StateManager.addHistory(projectId, 'model', aiResult.text);
-        const cmds = extractCommands(aiResult.text);
-        await executeCommands(lead.user_id, projectId, cmds);
-
-        // Morning briefings set the project to Frozen state until user returns
-        // This prevents the AI from generating 30 briefings for an abandoned project
-        await StateManager.setFrozen(projectId, true); 
-
-        res.json({ success: true });
-
-    } catch (e) {
-        console.error("Morning Briefing Error", e);
-        res.status(500).json({ error: e.message });
-    }
-});
-app.get('/', async (req, res) => {
-   res.status(200).json({ status: "Alive" });
-});
-
-app.listen(PORT, () => {
-  console.log(`✅ Core Online: ${PORT} | Smart: ${SMART_MODEL_ID} | Fast: ${FAST_MODEL_ID}`);
-
-  console.log(`SUPABASE_URL ${SUPABASE_URL}`);
-  console.log(`SUPABASE_KEY ${SUPABASE_KEY}`);
-  console.log(`REMOTE_SERVER_URL ${REMOTE_SERVER_URL}`);
-  console.log(`FRONT_URL ${FRONT_URL}`);
-  console.log(`CRON_REGISTRY_URL ${CRON_REGISTRY_URL}`);
-  console.log(`CRON_SECRET ${CRON_SECRET}`);
-  
-});
-*/
+app.get('/', async (req, res) => res.status(200).json({ status: "Alive" }));
+app.listen(PORT, () => console.log(`✅ Core Online: ${PORT}`));