yadnyeshkolte commited on
Commit
f33252d
·
1 Parent(s): 713027e
Dockerfile CHANGED
@@ -44,4 +44,4 @@ RUN echo '#!/bin/bash' > start.sh && \
44
  echo 'PORT=7860 pm2-runtime start /app/backend/dist/index.js --name "backend"' >> start.sh && \
45
  chmod +x start.sh
46
 
47
- CMD ["./start.sh"]
 
44
  echo 'PORT=7860 pm2-runtime start /app/backend/dist/index.js --name "backend"' >> start.sh && \
45
  chmod +x start.sh
46
 
47
+ CMD ["./start.sh"]
backend/package.json CHANGED
@@ -25,4 +25,4 @@
25
  "ts-node-dev": "^2.0.0",
26
  "typescript": "^5.3.0"
27
  }
28
- }
 
25
  "ts-node-dev": "^2.0.0",
26
  "typescript": "^5.3.0"
27
  }
28
+ }
backend/src/index.ts CHANGED
@@ -15,13 +15,13 @@ app.get('/api/health', (req, res) => {
15
 
16
  // Proxy routes for MCP Agents
17
  // These allow Archestra to talk to the agents through the single public port 7860
18
- app.use('/mcp/analyzer', createProxyMiddleware({ target: 'http://localhost:3002', pathRewrite: { '^/mcp/analyzer': '' }, changeOrigin: true }));
19
- app.use('/mcp/reader', createProxyMiddleware({ target: 'http://localhost:3003', pathRewrite: { '^/mcp/reader': '' }, changeOrigin: true }));
20
- app.use('/mcp/generator', createProxyMiddleware({ target: 'http://localhost:3004', pathRewrite: { '^/mcp/generator': '' }, changeOrigin: true }));
21
 
22
  app.use(express.json());
23
  app.use('/api/generate', generateRouter);
24
 
25
  app.listen(PORT, () => {
26
  console.log(`Backend running on port ${PORT}`);
27
- });
 
15
 
16
  // Proxy routes for MCP Agents
17
  // These allow Archestra to talk to the agents through the single public port 7860
18
+ app.use('/mcp/analyzer', createProxyMiddleware({ target: 'http://localhost:3002', changeOrigin: true }));
19
+ app.use('/mcp/reader', createProxyMiddleware({ target: 'http://localhost:3003', changeOrigin: true }));
20
+ app.use('/mcp/generator', createProxyMiddleware({ target: 'http://localhost:3004', changeOrigin: true }));
21
 
22
  app.use(express.json());
23
  app.use('/api/generate', generateRouter);
24
 
25
  app.listen(PORT, () => {
26
  console.log(`Backend running on port ${PORT}`);
27
+ });
mcp-servers/code-reader/package.json CHANGED
@@ -19,4 +19,4 @@
19
  "@types/node": "^20.0.0",
20
  "typescript": "^5.3.0"
21
  }
22
- }
 
19
  "@types/node": "^20.0.0",
20
  "typescript": "^5.3.0"
21
  }
22
+ }
mcp-servers/code-reader/src/index.mts CHANGED
@@ -217,7 +217,7 @@ if (process.env.PORT) {
217
  let transport: SSEServerTransport;
218
 
219
  app.get("/sse", async (req, res) => {
220
- transport = new SSEServerTransport("/messages", res);
221
  await server.connect(transport);
222
  });
223
 
@@ -234,4 +234,4 @@ if (process.env.PORT) {
234
  } else {
235
  const transport = new StdioServerTransport();
236
  await server.connect(transport);
237
- }
 
217
  let transport: SSEServerTransport;
218
 
219
  app.get("/sse", async (req, res) => {
220
+ transport = new SSEServerTransport("/mcp/reader/messages", res);
221
  await server.connect(transport);
222
  });
223
 
 
234
  } else {
235
  const transport = new StdioServerTransport();
236
  await server.connect(transport);
237
+ }
mcp-servers/doc-generator/package.json CHANGED
@@ -19,4 +19,4 @@
19
  "@types/node": "^20.0.0",
20
  "typescript": "^5.3.0"
21
  }
22
- }
 
19
  "@types/node": "^20.0.0",
20
  "typescript": "^5.3.0"
21
  }
22
+ }
mcp-servers/doc-generator/src/index.mts CHANGED
@@ -184,7 +184,7 @@ if (process.env.PORT) {
184
  let transport: SSEServerTransport;
185
 
186
  app.get("/sse", async (req, res) => {
187
- transport = new SSEServerTransport("/messages", res);
188
  await server.connect(transport);
189
  });
190
 
@@ -201,4 +201,4 @@ if (process.env.PORT) {
201
  } else {
202
  const transport = new StdioServerTransport();
203
  await server.connect(transport);
204
- }
 
184
  let transport: SSEServerTransport;
185
 
186
  app.get("/sse", async (req, res) => {
187
+ transport = new SSEServerTransport("/mcp/generator/messages", res);
188
  await server.connect(transport);
189
  });
190
 
 
201
  } else {
202
  const transport = new StdioServerTransport();
203
  await server.connect(transport);
204
+ }
mcp-servers/repo-analyzer/package.json CHANGED
@@ -19,4 +19,4 @@
19
  "@types/node": "^20.0.0",
20
  "typescript": "^5.3.0"
21
  }
22
- }
 
19
  "@types/node": "^20.0.0",
20
  "typescript": "^5.3.0"
21
  }
22
+ }
mcp-servers/repo-analyzer/src/index.mts CHANGED
@@ -284,7 +284,7 @@ if (process.env.PORT) {
284
  let transport: SSEServerTransport;
285
 
286
  app.get("/sse", async (req, res) => {
287
- transport = new SSEServerTransport("/messages", res);
288
  await server.connect(transport);
289
  });
290
 
@@ -301,4 +301,4 @@ if (process.env.PORT) {
301
  } else {
302
  const transport = new StdioServerTransport();
303
  await server.connect(transport);
304
- }
 
284
  let transport: SSEServerTransport;
285
 
286
  app.get("/sse", async (req, res) => {
287
+ transport = new SSEServerTransport("/mcp/analyzer/messages", res);
288
  await server.connect(transport);
289
  });
290
 
 
301
  } else {
302
  const transport = new StdioServerTransport();
303
  await server.connect(transport);
304
+ }