Update app.js

app.js

@@ -106,8 +106,10 @@ server.on('upgrade', async (request, socket, head) => {
 });
 
 // WS Logic
+
+
+
 wss.on('connection', (ws, req, user) => {
-    // Note: 'uid' is what we encoded into the JWT in the Auth Proxy
     const userId = user.uid; 
     
     if (!clients.has(userId)) clients.set(userId, new Set());
@@ -120,182 +122,39 @@ wss.on('connection', (ws, req, user) => {
         try {
             const data = JSON.parse(message.toString());
 
+            // 1. CHAT PROMPTS
             if (data.type === 'prompt') {
                 ws.send(JSON.stringify({ type: 'status', status: 'thinking' }));
-
                 const response = await fetch(`${CORE_URL}/process`, {
-                    method: 'POST',
-                    headers: { 'Content-Type': 'application/json' },
-                    body: JSON.stringify({
-                        userId: userId,
-                        projectId: data.projectId,
-                        prompt: data.content,
-                        context: data.context,
-                        task_type: 'chat' 
-                    })
+                    method: 'POST', headers: { 'Content-Type': 'application/json' },
+                    body: JSON.stringify({ userId, projectId: data.projectId, prompt: data.content, context: data.context, task_type: 'chat' })
                 });
-
                 if (!response.ok) throw new Error("Core API Failed");
                 const result = await response.json();
-
                 ws.send(JSON.stringify({ type: 'response', text: result.text, should_reload: result.should_reload, usage: result.usage }));
             }
-        } catch (e) {
-            console.error("WS Error", e);
-            ws.send(JSON.stringify({ type: 'error', message: "Processing Error" }));
-        }
-    });
-
-    ws.on('close', () => {
-        if (clients.has(userId)) clients.get(userId).delete(ws);
-    });
-});
-
-setInterval(() => {
-    wss.clients.forEach((ws) => {
-        if (ws.isAlive === false) return ws.terminate();
-        ws.isAlive = false;
-        ws.ping();
-    });
-}, 30000);
-
-server.listen(PORT, () => console.log(`🚀 Gateway on ${PORT}`));
 
-/* import express from 'express';
-import { createServer } from 'http';
-import { WebSocketServer, WebSocket } from 'ws';
-import cors from 'cors';
-import jwt from 'jsonwebtoken';
-import { v4 as uuidv4 } from 'uuid';
-import { createClient } from '@supabase/supabase-js';
-
-const PORT = 7860;
-const SUPABASE_URL = process.env.SUPABASE_URL;
-const SUPABASE_KEY = process.env.SUPABASE_SERVICE_KEY;
-const CORE_URL = process.env.CORE_URL || "http://localhost:7862"; // Point to Core
-
-if (!SUPABASE_URL) { console.error("❌ Config Missing"); process.exit(1); }
-
-const app = express();
-const server = createServer(app);
-const wss = new WebSocketServer({ noServer: true });
-const supabase = createClient(SUPABASE_URL, SUPABASE_KEY);
-
-const clients = new Map(); // UserId -> Set<WebSocket>
-
-app.use(cors());
-app.use(express.json({ limit: '50mb' }));
-
-app.get('/', (req, res) => res.send('Gateway Active'));
-
-// Internal Notification Webhook (Called by Core)
-app.post('/internal/notify', (req, res) => {
-    const { user_id, type, message } = req.body;
-    if (clients.has(user_id)) {
-        clients.get(user_id).forEach(ws => {
-            if (ws.readyState === WebSocket.OPEN) ws.send(JSON.stringify({ type, message }));
-        });
-        return res.json({ success: true });
-    }
-    res.json({ success: false });
-});
-
-// Inside Gateway WebSocket upgrade or API middleware
-async function verifyThrustToken(token) {
-    const decoded = jwt.decode(token);
-    if (!decoded || !decoded.sid) return null;
-
-    // 1. Fetch the secret and verify existence in one go
-    const { data: session } = await supabase
-        .from('user_sessions')
-        .select('session_secret')
-        .eq('id', decoded.sid)
-        .single();
-
-    if (!session) return null; // Session was deleted/revoked
-
-    try {
-        // 2. Verify signature against the stored secret
-        return jwt.verify(token, session.session_secret);
-    } catch (e) {
-        return null;
-    }
-}
-
-// WS Upgrade
-
-server.on('upgrade', async (request, socket, head) => {
-    const url = new URL(request.url, `http://${request.headers.host}`);
-    const token = url.searchParams.get('token');
-
-    if (!token) { 
-        socket.write('HTTP/1.1 401 Unauthorized\r\n\r\n'); 
-        socket.destroy(); 
-        return; 
-    }
-
-    // 1. You MUST await the async function
-    const decodedData = await verifyThrustToken(token);
-
-    // 2. Logic: If decodedData is null, verification failed
-    if (!decodedData) { 
-        socket.write('HTTP/1.1 403 Forbidden\r\n\r\n'); 
-        socket.destroy(); 
-        return; 
-    }
-  
-    // 3. Handle the upgrade and pass the decoded data (user info)
-    wss.handleUpgrade(request, socket, head, (ws) => {
-        // decodedData now contains your 'sid' and whatever else was in the JWT
-        wss.emit('connection', ws, request, decodedData);
-    });
-});
-
-// WS Logic
-wss.on('connection', (ws, req, user) => {
-    const userId = user.id || user.sub;
-    if (!clients.has(userId)) clients.set(userId, new Set());
-    
-    clients.get(userId).add(ws);
-
-    ws.isAlive = true;
-    ws.on('pong', () => { ws.isAlive = true; });
-
-    ws.on('message', async (message) => {
-        try {
-            const data = JSON.parse(message.toString());
-
-            if (data.type === 'prompt') {
-                ws.send(JSON.stringify({ type: 'status', status: 'thinking' }));
-
-                // Call Core
-                const response = await fetch(`${CORE_URL}/process`, {
-                    method: 'POST',
-                    headers: { 'Content-Type': 'application/json' },
+            // 2. BACKGROUND 3-MINUTE CONTEXT SYNC
+            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}`;
+                
+                await fetch(`${CORE_URL}/process`, {
+                    method: 'POST', headers: { 'Content-Type': 'application/json' },
                     body: JSON.stringify({
                         userId: userId,
                         projectId: data.projectId,
-                        prompt: data.content,
-                        context: data.context,
-                        task_type: 'chat' // Default to chat for WS
+                        prompt: formattedPrompt,
+                        images: payloadData.images, 
+                        task_type: 'log_ingestion'
                     })
                 });
-
-                if (!response.ok) throw new Error("Core API Failed");
-
-                const result = await response.json();
-
-                // Send to Client
-                ws.send(JSON.stringify({
-                    type: 'response',
-                    text: result.text,
-                    should_reload: result.should_reload,
-                    usage: result.usage
-                }));
             }
+
         } catch (e) {
             console.error("WS Error", e);
-            ws.send(JSON.stringify({ type: 'error', message: "Processing Error" }));
         }
     });
 
@@ -304,7 +163,8 @@ wss.on('connection', (ws, req, user) => {
     });
 });
 
-// Keep Alive
+
+
 setInterval(() => {
     wss.clients.forEach((ws) => {
         if (ws.isAlive === false) return ws.terminate();
@@ -314,4 +174,4 @@ setInterval(() => {
 }, 30000);
 
 server.listen(PORT, () => console.log(`🚀 Gateway on ${PORT}`));
-*/
+