Method _sendRequest

src/tools/mcp_client.js:273–310

(server, method, params)

  }

  _sendRequest(server, method, params) {
    return new Promise((resolve) => {
      if (!server.process || !server.process.stdin || !server.demuxer) {
        resolve(null);
        return;
      }

      const id = this._requestId++;
      const request = JSON.stringify({ jsonrpc: '2.0', id, method, params }) + '\n';

      let timer = null;
      const finish = (val) => {
        if (timer) clearTimeout(timer);
        server.demuxer.unregister(id);
        resolve(val);
      };

      server.demuxer.register(id, (line) => {
        try {
          const resp = JSON.parse(line);
          if (resp.id === id) {
            finish(resp.result || null);
          }
        } catch { /* not our line; demuxer keeps trying others */ }
      });

      try {
        server.process.stdin.write(request);
      } catch {
        finish(null);
        return;
      }

      // Timeout after 10s. Note: we resolve null rather than reject so
      // callers don't blow up — MCP errors are operational, not fatal.
      timer = setTimeout(() => finish(null), 10000);
    });
  }

  _sendNotification(server, method, params) {
    if (!server.process || !server.process.stdin) return;