Deploy from GitHub Actions 2025-12-16_04-55-23

apps/backend/src/index.ts

@@ -171,7 +171,6 @@ async function startServer() {
     // Cloud defaults like 7860 break the internal reflex arc.
     const PORT = 3001;
 
-    // Start server IMMEDIATELY
     server.listen(PORT, '0.0.0.0', () => {
       console.log(`🚀 Backend server running on http://0.0.0.0:${PORT}`);
       console.log(`📡 MCP WebSocket available at ws://0.0.0.0:${PORT}/mcp/ws`);
@@ -1227,21 +1226,29 @@ async function startServer() {
      * GET /api/evolution/graph/stats
      * Get Neo4j graph statistics for 3D visualization
      * 🔗 NEURAL LINK ENDPOINT
+     *
+     * OPTIMIZED: Uses separate lightweight queries to avoid memory overflow
+     * on Neo4j AuraDB free tier (824 MiB limit)
      */
     app.get('/api/evolution/graph/stats', async (_req, res) => {
       try {
         const { neo4jService } = await import('./database/Neo4jService.js');
 
-        // 1. Fetch Stats
-        const statsQuery = `
-          MATCH (n) 
-          OPTIONAL MATCH ()-[r]->() 
-          RETURN count(DISTINCT n) as nodes, count(DISTINCT r) as relationships
-        `;
-        const statsResult = await neo4jService.runQuery(statsQuery);
+        // 1. Fetch Stats using memory-efficient separate queries
+        // Note: The original MATCH (n) OPTIONAL MATCH ()-[r]->() creates a cross-product
+        // that exceeds Neo4j AuraDB's memory limits on large graphs (150K+ nodes)
+        const nodeCountQuery = `MATCH (n) RETURN count(n) as nodes`;
+        const relCountQuery = `MATCH ()-[r]->() RETURN count(r) as relationships`;
+
+        // Run queries in parallel for better performance
+        const [nodeResult, relResult] = await Promise.all([
+          neo4jService.runQuery(nodeCountQuery),
+          neo4jService.runQuery(relCountQuery)
+        ]);
+
         const stats = {
-          nodes: statsResult[0]?.nodes?.toNumber ? statsResult[0].nodes.toNumber() : (statsResult[0]?.nodes || 0),
-          relationships: statsResult[0]?.relationships?.toNumber ? statsResult[0].relationships.toNumber() : (statsResult[0]?.relationships || 0)
+          nodes: nodeResult[0]?.nodes?.toNumber ? nodeResult[0].nodes.toNumber() : (nodeResult[0]?.nodes || 0),
+          relationships: relResult[0]?.relationships?.toNumber ? relResult[0].relationships.toNumber() : (relResult[0]?.relationships || 0)
         };
 
         // 2. Fetch Sample Nodes for Visualization

apps/backend/src/mcp/servers/NeuralBridgeServer.ts

@@ -1471,7 +1471,8 @@ class NeuralBridgeServer {
                     break;
 
                 case 'backend':
-                    const backendResponse = await fetch('http://localhost:3001/api/health', {
+                    const backendPort = process.env.PORT || 7860;
+                    const backendResponse = await fetch(`http://localhost:${backendPort}/api/health`, {
                         signal: AbortSignal.timeout(5000)
                     });
                     success = backendResponse.ok;

apps/backend/src/services/CognitiveErrorIntelligence.ts

@@ -33,6 +33,9 @@ import { logger } from '../utils/logger.js';
 
 const log = logger.child({ module: 'CognitiveErrorIntelligence' });
 
+// Dynamic base URL for self-healing API calls
+const getBaseUrl = () => `http://localhost:${process.env.PORT || 7860}`;
+
 // ═══════════════════════════════════════════════════════════════════════════
 // TYPES
 // ═══════════════════════════════════════════════════════════════════════════
@@ -558,8 +561,11 @@ export class CognitiveErrorIntelligence extends EventEmitter {
             });
           });
         } else if (action.apiCall) {
-          // Execute API call
-          const response = await fetch(action.apiCall.endpoint, {
+          // Execute API call - prepend base URL to relative paths
+          const endpoint = action.apiCall.endpoint.startsWith('/')
+            ? `${getBaseUrl()}${action.apiCall.endpoint}`
+            : action.apiCall.endpoint;
+          const response = await fetch(endpoint, {
             method: action.apiCall.method,
             headers: { 'Content-Type': 'application/json' },
             body: action.apiCall.body ? JSON.stringify(action.apiCall.body) : undefined
@@ -709,7 +715,7 @@ export class CognitiveErrorIntelligence extends EventEmitter {
         name: 'Restart Redis Connection',
         description: 'Reconnect to Redis when connection is lost',
         errorPatterns: ['ECONNREFUSED', 'redis', 'connection refused'],
-        apiCall: { endpoint: 'http://localhost:3001/api/healing/service/redis', method: 'POST' },
+        apiCall: { endpoint: '/api/healing/service/redis', method: 'POST' },
         requiresApproval: false,
         riskLevel: 'low',
         successRate: 0.85,
@@ -720,7 +726,7 @@ export class CognitiveErrorIntelligence extends EventEmitter {
         name: 'Clear Memory Cache',
         description: 'Clear in-memory caches when memory is low',
         errorPatterns: ['heap', 'memory', 'OOM'],
-        apiCall: { endpoint: 'http://localhost:3001/api/system/clear-cache', method: 'POST' },
+        apiCall: { endpoint: '/api/system/clear-cache', method: 'POST' },
         requiresApproval: false,
         riskLevel: 'low',
         successRate: 0.9,
@@ -731,7 +737,7 @@ export class CognitiveErrorIntelligence extends EventEmitter {
         name: 'Retry Database Connection',
         description: 'Attempt to reconnect to database',
         errorPatterns: ['database', 'postgres', 'neo4j', 'SQLSTATE'],
-        apiCall: { endpoint: 'http://localhost:3001/api/healing/service/database', method: 'POST' },
+        apiCall: { endpoint: '/api/healing/service/database', method: 'POST' },
         requiresApproval: false,
         riskLevel: 'medium',
         successRate: 0.75,

apps/backend/src/services/NudgeService.ts

@@ -249,17 +249,15 @@ class NudgeService {
 
     try {
       if (this.neo4jAdapter) {
-        // Get current graph stats
-        const statsResult = await this.neo4jAdapter.runQuery(`
-          MATCH (n) 
-          WITH count(n) as nodeCount
-          MATCH ()-[r]->()
-          RETURN nodeCount, count(r) as relCount
-        `);
-
-        const stats = statsResult?.[0];
-        const nodeCount = stats?.nodeCount || 0;
-        const relCount = stats?.relCount || 0;
+        // Get current graph stats - use separate queries to avoid memory overflow
+        // on Neo4j AuraDB free tier (824 MiB limit with 150K+ nodes)
+        const [nodeResult, relResult] = await Promise.all([
+          this.neo4jAdapter.runQuery(`MATCH (n) RETURN count(n) as nodeCount`),
+          this.neo4jAdapter.runQuery(`MATCH ()-[r]->() RETURN count(r) as relCount`)
+        ]);
+
+        const nodeCount = nodeResult?.[0]?.nodeCount || 0;
+        const relCount = relResult?.[0]?.relCount || 0;
 
         // Create evolution event node
         await this.neo4jAdapter.runQuery(`
@@ -332,7 +330,7 @@ class NudgeService {
 
     try {
       // Trigger compilation via HTTP to self
-      const port = process.env.PORT || 3001;
+      const port = process.env.PORT || 7860;
       const response = await fetch(`http://localhost:${port}/api/knowledge/compile`, {
         method: 'POST',
         headers: { 'Content-Type': 'application/json' }

apps/backend/src/services/agent/HansPedderAgentController.ts

@@ -99,6 +99,13 @@ export class HansPedderAgentController {
 
     eventBus.on('threat:detected', () => {
       this.healthMetrics.lastIngestion = new Date();
+      this.healthMetrics.dataflowOk = true;
+    });
+
+    // Also track threat feed broadcasts (from OpenPhish etc.)
+    eventBus.on('threats:broadcast', () => {
+      this.healthMetrics.lastIngestion = new Date();
+      this.healthMetrics.dataflowOk = true;
     });
 
     eventBus.on('system:heartbeat', (data: any) => {
@@ -240,7 +247,8 @@ export class HansPedderAgentController {
 
     try {
       // Check if MCP tools endpoint responds (indicates server is ready)
-      const port = process.env.PORT || 3001;
+      // Default to 7860 which is the standard port for WidgeTDC backend (both local and HuggingFace)
+      const port = process.env.PORT || 7860;
       const baseUrl = process.env.API_BASE_URL || `http://localhost:${port}`;
       const response = await fetch(`${baseUrl}/api/mcp/tools`, {
         method: 'GET',
@@ -275,8 +283,8 @@ export class HansPedderAgentController {
     const name = 'apiEndpoints';
 
     try {
-      // Test key API endpoints (use port 3001 where backend runs)
-      const port = process.env.PORT || 3001;
+      // Test key API endpoints - default to 7860 which is standard for WidgeTDC
+      const port = process.env.PORT || 7860;
       const baseUrl = process.env.API_BASE_URL || `http://localhost:${port}`;
       const endpoints = [
         { url: `${baseUrl}/health`, method: 'GET' },
@@ -405,7 +413,7 @@ export class HansPedderAgentController {
           logger.info('   → API endpoints unreachable - checking backend status...');
           fixAction = 'Health check on correct backend port';
           try {
-            const backendPort = process.env.PORT || '3001';
+            const backendPort = process.env.PORT || '7860';
             const testUrl = `http://localhost:${backendPort}/health`;
             const response = await fetch(testUrl, { signal: AbortSignal.timeout(3000) });
             if (response.ok) {