Function makeClient

scripts/agent-eval/repro-daemon-clients.mjs:39–70

(id)

];

function makeClient(id) {
  const child = spawn('node', [CLI, 'serve', '--mcp', '--path', repo], {
    env: { ...process.env, CODEGRAPH_TELEMETRY: '0', DO_NOT_TRACK: '1', CODEGRAPH_MCP_LOG_ATTACH: '0' },
    stdio: ['pipe', 'pipe', 'inherit'],
  });
  let buf = '';
  const waiters = new Map(); // id -> resolve
  child.stdout.setEncoding('utf8');
  child.stdout.on('data', (chunk) => {
    buf += chunk;
    let idx;
    while ((idx = buf.indexOf('\n')) !== -1) {
      const line = buf.slice(0, idx).trim();
      buf = buf.slice(idx + 1);
      if (!line) continue;
      let msg; try { msg = JSON.parse(line); } catch { continue; }
      if (msg.id !== undefined && waiters.has(msg.id)) {
        waiters.get(msg.id)(msg);
        waiters.delete(msg.id);
      }
    }
  });
  const send = (obj) => child.stdin.write(JSON.stringify(obj) + '\n');
  const request = (method, params, rpcId, timeoutMs) =>
    new Promise((res) => {
      let timer;
      if (timeoutMs) timer = setTimeout(() => { waiters.delete(rpcId); res({ __timeout: true }); }, timeoutMs);
      waiters.set(rpcId, (m) => { if (timer) clearTimeout(timer); res(m); });
      send({ jsonrpc: '2.0', id: rpcId, method, params });
    });
  return { id, child, send, request };
}

const sleep = (ms) => new Promise((r) => setTimeout(r, ms));