Update app.js

app.js

@@ -36,6 +36,21 @@ app.post('/internal/notify', (req, res) => {
     res.json({ success: false });
 });
 
+// NEW: Internal MCP Query Webhook (Routes AI requests down to the local daemon)
+app.post('/internal/mcp_query', (req, res) => {
+    const { user_id, lead_id, payload } = req.body;
+    if (clients.has(user_id)) {
+        clients.get(user_id).forEach(ws => {
+            if (ws.readyState === WebSocket.OPEN) {
+                // Forward the exact payload to the daemon
+                ws.send(JSON.stringify({ type: 'mcp_query', payload }));
+            }
+        });
+        return res.json({ success: true });
+    }
+    res.json({ success: false, message: "User daemon not connected" });
+});
+
 // Verify JWT against DB Secret
 async function verifyThrustToken(token) {
     const decoded = jwt.decode(token);
@@ -195,12 +210,12 @@ wss.on('connection', (ws, req, userId) => {
                 ws.send(JSON.stringify({ type: 'response', text: result.text, should_reload: result.should_reload, usage: result.usage }));
             }
 
-            // 2. BACKGROUND 3-MINUTE CONTEXT SYNC
+            // 2. BACKGROUND CONTEXT SYNC (SMART DEBOUNCED)
             if (data.type === 'context_sync') {
                 const payloadData = data.data;
                 const currentTime = new Date().toLocaleString(); // Anchor time for the AI
                 
-                const formattedPrompt = `[WORKSPACE UPDATE - CURRENT TIME: ${currentTime}]\n\nActivity Log (Past 3 Minutes):\n${payloadData.buffer}\n\nGit Diffs (Modified Files):\n${payloadData.diffs}\n\nNew Untracked Files:\n${payloadData.new_files}`;
+                const formattedPrompt = `[WORKSPACE UPDATE - CURRENT TIME: ${currentTime}]\n\nActivity Log (Recent Activity):\n${payloadData.buffer}\n\nGit Diffs (Modified Files):\n${payloadData.diffs}\n\nNew Untracked Files:\n${payloadData.new_files}`;
                 
                 await fetch(`${CORE_URL}/process`, {
                     method: 'POST', headers: { 'Content-Type': 'application/json' },