Method _proxyVertex

src/proxy/index.js:1083–1121

(reqPath, body, opts = {})

  // auth. The access token comes from EVOMAP_VERTEX_ACCESS_TOKEN (provisioned/refreshed by the daemon via
  // `gcloud auth print-access-token` or a token sidecar); SA-key auto-minting is a follow-up. No translation.
  async _proxyVertex(reqPath, body, opts = {}) {
    const baseUrl = String(opts.baseUrl || '').replace(/\/+$/, '');
    if (!baseUrl) { const e = new Error('vertex base url required'); e.statusCode = 500; throw e; }
    const token = process.env.EVOMAP_VERTEX_ACCESS_TOKEN || '';
    if (!token) { const e = new Error('vertex access token required'); e.statusCode = 401; throw e; }
    const timeoutMs = opts.timeoutMs || 60_000;
    const fwd = { 'content-type': 'application/json', authorization: `Bearer ${token}` };

    const endpoint = `${baseUrl}${reqPath}`;
    const abortController = new AbortController();
    const timeoutErr = new Error('vertex upstream timed out');
    timeoutErr.name = 'TimeoutError';
    const abortTimer = setTimeout(() => abortController.abort(timeoutErr), timeoutMs);
    abortTimer.unref?.();
    let res;
    try {
      res = await fetch(endpoint, { method: 'POST', headers: fwd, body: JSON.stringify(body || {}), signal: abortController.signal });
    } catch (err) {
      clearTimeout(abortTimer);
      throw makeVertexGatewayError(err);
    }

    const headers = Object.fromEntries(res.headers.entries());
    const contentType = (headers['content-type'] || '').toLowerCase();
    const isStream = contentType.includes('text/event-stream') || /:streamGenerateContent(\b|\?|$)/.test(reqPath);
    if (isStream) clearTimeout(abortTimer);

    const readText = async () => {
      try { return await res.text(); } catch (err) { throw makeVertexGatewayError(err); } finally { clearTimeout(abortTimer); }
    };

    return {
      status: res.status,
      headers,
      stream: isStream ? res.body : null,
      json: isStream ? null : async () => JSON.parse(await readText()),
      text: isStream ? null : readText,
    };
  }

  // Bedrock upstream mode: same return contract as _proxyAnthropic so
  // messages_route.js and ProxyHttpServer._streamResponse don't change.