Update app.js

app.js

@@ -7,7 +7,7 @@ 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; 
+const CORE_URL = process.env.CORE_URL || "http://localhost:7862"; // Point to Core
 
 if (!SUPABASE_URL) { console.error("❌ Config Missing"); process.exit(1); }
 
@@ -23,7 +23,7 @@ app.use(express.json({ limit: '50mb' }));
 
 app.get('/', (req, res) => res.send('Gateway Active'));
 
-// Internal Notification Webhook
+// Internal Notification Webhook (Called by Core)
 app.post('/internal/notify', (req, res) => {
     const { user_id, type, message } = req.body;
     if (clients.has(user_id)) {
@@ -67,7 +67,6 @@ wss.on('connection', (ws, req, user) => {
                 ws.send(JSON.stringify({ type: 'status', status: 'thinking' }));
 
                 // Call Core
-              
                 const response = await fetch(`${CORE_URL}/process`, {
                     method: 'POST',
                     headers: { 'Content-Type': 'application/json' },
@@ -75,10 +74,12 @@ wss.on('connection', (ws, req, user) => {
                         userId: userId,
                         projectId: data.projectId,
                         prompt: data.content,
-                        context: data.context
+                        context: data.context,
+                        task_type: 'chat' // Default to chat for WS
                     })
                 });
-                
+
+                if (!response.ok) throw new Error("Core API Failed");
 
                 const result = await response.json();
 
@@ -86,7 +87,7 @@ wss.on('connection', (ws, req, user) => {
                 ws.send(JSON.stringify({
                     type: 'response',
                     text: result.text,
-                    should_reload: result.should_reload, // .NET app listens for this to refresh UI
+                    should_reload: result.should_reload,
                     usage: result.usage
                 }));
             }