fix(core): remove all hardcoded port 3000 from server routes to use config.port …

…to prevent EADDRINUSE

fix(core): remove all hardcoded port 3000 from server routes to use config.port …
…to prevent EADDRINUSE
yibo
1 parent fab59a81
Showing 3 changed files with 10 additions and 8 deletions
server/agent-server.js
server/routes/agent-chat.js
server/services/company-heartbeat-service.js
@@ -9,7 +9,8 @@ const cors = require(&#39;cors&#39;);
 const agentChatRoute = require('./routes/agent-chat');
 const app = express();
-const PORT = 3000;
+const config = require('./config');
+const PORT = process.env.PORT || config.port || 3010;
 app.use(cors({ origin: ['http://localhost:5173'], credentials: true }));
@@ -1472,7 +1472,7 @@ router.post(&#39;/task/dispatch&#39;, async (req, res) =&gt; {
           const http = require('http');
           const postData = JSON.stringify({ message: taskMessage, conversationId: executionConvId });
           const options = {
-            hostname: 'localhost', port: 3000,
+            hostname: 'localhost', port: systemConfig.port,
             path: `/api/agent/${to}/chat`,
             method: 'POST',
             headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
@@ -1645,7 +1645,7 @@ router.post(&#39;/task/report&#39;, (req, res) =&gt; {
           const http = require('http');
           const postData = JSON.stringify({ message: callbackMessage, conversationId: callbackConvId });
           const options = {
-            hostname: 'localhost', port: 3000,
+            hostname: 'localhost', port: systemConfig.port,
             path: `/api/agent/${to}/chat`,
             method: 'POST',
             headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
@@ -1727,7 +1727,7 @@ router.post(&#39;/:agentId/task/transition&#39;, (req, res) =&gt; {
                const http = require('http');
                const postData = JSON.stringify({ message: masterMsg, conversationId: `approval-${taskId}` });
                const options = {
-                   hostname: 'localhost', port: 3000,
+                   hostname: 'localhost', port: systemConfig.port,
                    path: `/api/agent/master/chat`,
                    method: 'POST',
                    headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
@@ -1816,7 +1816,7 @@ ${artifactContent ? `è¿™æ˜¯ä¸Šä¸€é˜¶æ®µä½ æˆ–ä½ çš„å‰ç½®èŠ‚ç‚¹ç•™ä¸‹çš„äº¤ä»˜ç‰
         const http = require('http');
         const postData = JSON.stringify({ message: "è¯·ç¡®è®¤ä½ å·²æ”¶åˆ°ç³»ç»Ÿçš„æ–°é˜¶æ®µæŒ‚è½½æŒ‡ä»¤ï¼Œå¹¶ç«‹å³æ‰§è¡Œä½ å½“å‰é˜¶æ®µæœ¬åˆ†çš„ä»»åŠ¡ï¼", conversationId: activeConvId });
         const options = {
-          hostname: 'localhost', port: 3000,
+          hostname: 'localhost', port: systemConfig.port,
           path: `/api/agent/${agentId}/chat`,
           method: 'POST',
           headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
@@ -1881,7 +1881,7 @@ router.post(&#39;/task/reject&#39;, (req, res) =&gt; {
         const http = require('http');
         const postData = JSON.stringify({ message: rejectMessage, conversationId: `redo-${runId}-step-${stepIndex}` });
         const options = {
-          hostname: 'localhost', port: 3000,
+          hostname: 'localhost', port: systemConfig.port,
           path: `/api/agent/${agentId}/chat`,
           method: 'POST',
           headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
@@ -1967,7 +1967,7 @@ router.post(&#39;/human-request&#39;, (req, res) =&gt; {
       const http = require('http');
       const postData = JSON.stringify({ message: masterMsg, conversationId: `human-req-${Date.now().toString(36)}` });
       const options = {
-        hostname: 'localhost', port: 3000,
+        hostname: 'localhost', port: systemConfig.port,
         path: `/api/agent/master/chat`,
         method: 'POST',
         headers: { 'Content-Type': 'application/json', 'Content-Length': Buffer.byteLength(postData) },
@@ -14,6 +14,7 @@
 const fs = require('fs');
 const path = require('path');
 const http = require('http');
+const config = require('../config');
 const { CompanyService } = require('./company-service');
 const { PipelineService } = require('./pipeline-service');
 const { ScheduleService } = require('./schedule-service');
@@ -26,7 +27,7 @@ class CompanyHeartbeatService {
     this.timers = new Map();      // companyId → NodeJS.Timeout
     this.companyService = new CompanyService();
     this.scheduleService = new ScheduleService();
-    this.port = 3000;
+    this.port = config.port || 3010;
     this._started = false;
   }