Function startCodeGraphMCP

bin/mcp_bridge.js:13–63

()

let mcpRequestId = 1;

function startCodeGraphMCP() {
  const possiblePaths = [
    path.join(__dirname, '..', '..', 'code-graph-mcp', 'dist', 'index.js'),
    path.join(__dirname, '..', 'node_modules', 'budget-aware-mcp', 'dist', 'index.js'),
    path.join(__dirname, '..', 'node_modules', '.package-lock.json'),
  ];

  let mcpPath = null;
  for (const p of possiblePaths) {
    if (fs.existsSync(p)) { mcpPath = p; break; }
  }

  if (!mcpPath) {
    const linkedPath = path.join(__dirname, '..', 'node_modules', 'budget-aware-mcp');
    if (fs.existsSync(linkedPath)) {
      const realPath = fs.realpathSync(linkedPath);
      const candidate = path.join(realPath, 'dist', 'index.js');
      if (fs.existsSync(candidate)) mcpPath = candidate;
    }
  }

  if (!mcpPath) {
    try {
      const { execSync } = require('child_process');
      const globalPath = execSync('npm root -g', { encoding: 'utf-8' }).trim();
      const gp = path.join(globalPath, 'budget-aware-mcp', 'dist', 'index.js');
      if (fs.existsSync(gp)) mcpPath = gp;
    } catch {}
  }

  if (!mcpPath) return null;

  const child = spawn('node', [mcpPath], {
    stdio: ['pipe', 'pipe', 'pipe'],
    cwd: process.cwd(),
    shell: false,
  });

  child.on('error', () => {});
  child.on('exit', () => {
    mcpProcess = null;
    if (mcpDemuxer) { try { mcpDemuxer.close(); } catch {} mcpDemuxer = null; }
  });

  mcpProcess = child;
  // Single shared line demuxer — replaces the per-request 'data' listener
  // pattern that leaked listeners and could resolve a request with another
  // request's response bytes under load.
  mcpDemuxer = createLineDemuxer(child.stdout);
  return child;
}

async function mcpCall(method, params = {}) {
  if (!mcpProcess) return null;