Function monkeyPatchFetch

src/util/fetch/monkeyPatchFetch.ts:155–230

(
  url: string | URL | Request,
  options?: FetchOptions,
)

 * Enhanced fetch wrapper that adds logging, authentication, error handling, and optional compression
 */
export async function monkeyPatchFetch(
  url: string | URL | Request,
  options?: FetchOptions,
): Promise<Response> {
  const NO_LOG_URLS = [R_ENDPOINT, CONSENT_ENDPOINT, EVENTS_ENDPOINT];
  const urlString = getRequestUrlString(url);
  const callerHeaders = getEffectiveHeaders(url, options?.headers);
  const isSilent = new Headers(callerHeaders).get('x-promptfoo-silent') === 'true';
  const logEnabled = !NO_LOG_URLS.some((logUrl) => matchesNoLogUrl(urlString, logUrl)) && !isSilent;

  const opts: RequestInit = {
    ...options,
  };

  const originalBody = opts.body;

  // Handle compression if requested
  if (options?.compress && opts.body && typeof opts.body === 'string') {
    try {
      const compressed = await gzipAsync(opts.body);
      opts.body = compressed as BodyInit;
      opts.headers = setHeader(getEffectiveHeaders(url, opts.headers), 'Content-Encoding', 'gzip');
    } catch (e) {
      logger.warn(`Failed to compress request body: ${e}`);
    }
  }

  // Attach the saved cloud credential only for cloud-bound requests, and never
  // override an Authorization header the caller set explicitly — token
  // validation/rotation sends the token being validated, not the saved one.
  const cloudAuth = getCloudBearerToken(url);
  const effectiveHeaders = getEffectiveHeaders(url, opts.headers);
  if (cloudAuth && !hasAuthorizationHeader(effectiveHeaders)) {
    opts.headers = setHeader(effectiveHeaders, 'Authorization', cloudAuth);
  }

  const cloudTaskTeamId = getCloudTaskTeamId(url);
  const headersWithAuth = getEffectiveHeaders(url, opts.headers);
  if (cloudTaskTeamId && !hasHeader(headersWithAuth, PROMPTFOO_TEAM_ID_HEADER)) {
    opts.headers = setHeader(headersWithAuth, PROMPTFOO_TEAM_ID_HEADER, cloudTaskTeamId);
  }
  try {
    // biome-ignore lint/style/noRestrictedGlobals: we need raw fetch here
    const response = await fetch(url, opts);

    if (logEnabled) {
      void logRequestResponse({
        url: urlString,
        requestBody: originalBody,
        requestMethod: opts.method || 'GET',
        response,
      });
    }

    return response;
  } catch (e) {
    if (logEnabled) {
      void logRequestResponse({