Update app.js

app.js

@@ -54,6 +54,11 @@ const StateManager = {
     setFrozen: async (projectId, status) => {
         if (activeProjects.has(projectId)) activeProjects.get(projectId).isFrozen = status;
         await supabase.from('leads').update({ is_frozen: status }).eq('id', projectId);
+    },
+    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;
     }
 };
 
@@ -95,8 +100,6 @@ 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;
@@ -142,7 +145,6 @@ async function executeCommands(userId, projectId, commands) {
                 await registerMorningCron(projectId, cmd.payload.timezone_offset || 0);
             }
 
-            // 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) {
@@ -151,7 +153,6 @@ async function executeCommands(userId, projectId, commands) {
                 }
             }
 
-            // NEW: AI marks thrust as complete, we delete all its tasks
             if (cmd.type === 'thrust_complete') {
                 const { data: active } = await supabase.from('thrusts').select('id').eq('lead_id', projectId).eq('status', 'active').single();
                 if (active) {
@@ -161,6 +162,11 @@ async function executeCommands(userId, projectId, commands) {
                 }
             }
 
+            if (cmd.type === 'freeze_project') {
+                const isFrozen = cmd.payload === 'true';
+                await StateManager.setFrozen(projectId, isFrozen);
+            }
+
             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(() => {});
             }
@@ -207,7 +213,6 @@ app.post('/process', async (req, res) => {
         let cmds = extractCommands(aiResult.text);
         let flags = await executeCommands(userId, projectId, cmds);
 
-        // Escalation: If fast model marks thrust complete, ask smart model for next thrust immediately
         if (flags.thrustComplete && task_type === 'log_ingestion') {
             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);
@@ -224,5 +229,40 @@ app.post('/process', async (req, res) => {
     } catch (e) { res.status(500).json({ error: "Processing Error" }); }
 });
 
+// --- AUTOMATED MORNING BRIEFING ---
+app.post('/automated-briefing', async (req, res) => {
+    const { projectId } = req.body;
+
+    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" });
+
+        // TONE DIRECTIVE INJECTED INTO PROMPT
+        const prompt = "It is morning. Generate today's Morning Briefing (New Thrust). Look at the RECENT TIMELINE to see what was accomplished yesterday. Adopt a highly conversational, proactive tone in the markdown (e.g., 'Morning! You finished X yesterday. Today, the priority is Y.'). If the project has been idle for days, use <freeze_project>true</freeze_project>.";
+        
+        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[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) { 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}`));