Function _proxyRequest

src/atp/hubClient.js:28–70

(method, path, body, timeoutMs)

}

function _proxyRequest(method, path, body, timeoutMs) {
  const proxyUrl = getProxyUrl();
  if (!proxyUrl) return Promise.resolve({ ok: false, error: 'proxy_not_running' });

  const url = new URL(path, proxyUrl);
  const timeout = timeoutMs || require('../config').HTTP_TRANSPORT_TIMEOUT_MS;

  return new Promise(function (resolve) {
    const payload = body ? JSON.stringify(body) : '';
    const headers = { 'Content-Type': 'application/json' };
    if (payload) headers['Content-Length'] = Buffer.byteLength(payload);
    const proxyToken = getProxyToken();
    if (proxyToken) headers['Authorization'] = 'Bearer ' + proxyToken;

    const req = http.request(
      {
        hostname: url.hostname,
        port: url.port,
        path: url.pathname + (url.search || ''),
        method: method,
        headers: headers,
        timeout: timeout,
      },
      function (res) {
        const chunks = [];
        res.on('data', function (c) { chunks.push(c); });
        res.on('end', function () {
          const raw = Buffer.concat(chunks).toString();
          if (res.statusCode >= 200 && res.statusCode < 300) {
            try { resolve({ ok: true, data: JSON.parse(raw) }); }
            catch (_) { resolve({ ok: true, data: { raw: raw } }); }
          } else {
            resolve({ ok: false, status: res.statusCode, error: raw.slice(0, 400) });
          }
        });
      }
    );
    req.on('error', function (err) { resolve({ ok: false, error: err.message }); });
    req.on('timeout', function () { req.destroy(); resolve({ ok: false, error: 'proxy_timeout' }); });
    if (payload) req.write(payload);
    req.end();
  });
}

// Route through hubFetch() rather than the global `fetch()` for two
// reasons (both flagged by Cursor reviewers on PR #160):