Function request

src/client/http.ts:21–79

(config: Config, opts: RequestOpts)

}

export async function request(config: Config, opts: RequestOpts): Promise<Response> {
  const isFormData = typeof FormData !== 'undefined' && opts.body instanceof FormData;

  const headers: Record<string, string> = {
    'User-Agent': `mmx-cli/${CLI_VERSION}`,
    ...opts.headers,
  };

  if (!isFormData && !headers['Content-Type']) {
    headers['Content-Type'] = 'application/json';
  }

  if (!opts.noAuth) {
    const credential = await resolveCredential(config);

    if (opts.authStyle === 'x-api-key') {
      headers['x-api-key'] = credential.token;
    } else {
      headers['Authorization'] = `Bearer ${credential.token}`;
    }

    if (config.verbose) {
      process.stderr.write(`> ${opts.method ?? 'GET'} ${opts.url}\n`);
      process.stderr.write(`> Auth: ${credential.token.slice(0, 8)}...\n`);
    }

    const model =
      opts.body && typeof opts.body === 'object' && 'model' in opts.body
        ? String((opts.body as Record<string, unknown>).model)
        : undefined;

    maybeShowStatusBar(config, credential.token, model);
  }

  const timeoutMs = (opts.timeout ?? config.timeout) * 1000;

  const res = await fetch(opts.url, {
    method: opts.method ?? 'GET',
    headers,
    body: opts.body
      ? isFormData
        ? (opts.body as FormData)
        : JSON.stringify(opts.body)
      : undefined,
    signal: opts.stream ? undefined : AbortSignal.timeout(timeoutMs),
  });

  if (config.verbose) {
    process.stderr.write(`< ${res.status} ${res.statusText}\n`);
  }

  if (!res.ok) {
    let body: ApiErrorBody = {};
    try { body = (await res.json()) as ApiErrorBody; } catch { /* non-JSON */ }
    throw mapApiError(res.status, body, opts.url);
  }

  return res;