Update app.js

app.js

@@ -106,15 +106,37 @@ function extractCommands(text) {
     return commands;
 }
 
+// --- BULLETPROOF CRON MATH ---
 async function registerMorningCron(projectId, offset) {
     const now = new Date();
     const target = new Date(now);
-    target.setUTCHours(6 - offset, 0, 0, 0); 
+    
+    // We want exactly 6:00 AM local time.
+    // So we calculate the target UTC minutes needed.
+    // E.g., Local 6 AM in EST (-5) = 11 AM UTC (660 mins).
+    // E.g., Local 6 AM in IST (+5.5) = 12:30 AM UTC (30 mins).
+    const targetUtcMinutes = (6 * 60) - (offset * 60); 
+
+    // setUTCHours natively handles fractional minutes and negative hour rollovers!
+    target.setUTCHours(0, targetUtcMinutes, 0, 0); 
+    
+    // If 6 AM today has already passed, schedule for tomorrow
     if (target <= now) target.setDate(target.getDate() + 1); 
+
     const delayMs = target.getTime() - now.getTime();
+    console.log(`⏰ Briefing Scheduled for ${projectId}. Local 6AM occurs in ${(delayMs/1000/60/60).toFixed(2)} hours.`);
+
     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 } })
+        body: JSON.stringify({ 
+            secret: CRON_SECRET, 
+            jobId: `briefing_${projectId}`, 
+            intervalMs: 86400000, // 24 hours
+            initialDelay: delayMs, 
+            webhookUrl: `https://everydaytok-thrust-core-server.hf.space/automated-briefing`, 
+            leadId: projectId, 
+            payload: { projectId, timezoneOffset: offset } 
+        })
     }).catch(()=>{});
 }
 
@@ -175,8 +197,40 @@ async function executeCommands(userId, projectId, commands) {
         } catch (e) {}
     }
     return flags;
-}
+};
+
+app.post('/init-project', async (req, res) => {
+    // 1. Receive timezoneOffset from frontend
+    const { userId, name, description, localPath, timezoneOffset = 0 } = req.body;
+    
+    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 });
+
+    setImmediate(async () => {
+        try {
+            // 2. Inject the explicit timezone offset into the initialization prompt
+            const initInput = `PROJECT: ${name}\nDESC: ${description}\nUSER TIMEZONE OFFSET: ${timezoneOffset}\nTask: Init PRD, First Thrust, Schedule Morning Briefing.`;
+            
+            const aiResult = await callAI([], initInput, {}, [], prompts.init_system_prompt, "", SMART_MODEL_ID);
+            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);
+            const flags = await executeCommands(userId, lead.id, cmds);
+
+            if (flags.newThrustId) {
+                await dispatchEmail(userId, lead.id, lead.name, flags.newThrustId, flags.newThrustMarkdown);
+            }
+        } catch (err) {}
+    });
+});
 
+/*
 app.post('/init-project', async (req, res) => {
     const { userId, name, description, localPath } = req.body;
     const { data: lead } = await supabase.from('leads').insert({ user_id: userId, name, description, local_path: localPath, status: 'active', requirements_doc: "Init..." }).select().single();
@@ -194,6 +248,7 @@ app.post('/init-project', async (req, res) => {
         } catch (err) {}
     });
 });
+*/
 
 app.post('/process', async (req, res) => {
     const { userId, projectId, prompt, context, images, task_type = 'chat' } = req.body;