Function doltFetch

packages/wl-sdk/src/dolthub/api.ts:91–129

(opts: DoltFetchOptions)

 * decide whether a non-2xx response is an error.
 */
export async function doltFetch(opts: DoltFetchOptions): Promise<DoltFetchResult> {
  const fetchImpl = opts.fetch ?? globalThis.fetch;
  const url = buildDoltUrl(opts.path, opts.query);

  const headers: Record<string, string> = {
    // Bypass Cloudflare's subrequest cache. DoltHub returns stale
    // reads otherwise, which surfaces as ghost branches / merged PRs
    // not appearing immediately. The DOM `cache: 'no-store'` init is
    // rejected by workerd; the cache-control header is what
    // propagates.
    'cache-control': 'no-cache',
    ...buildAuthHeader(opts.auth),
  };

  const init: RequestInit = { method: opts.method, headers };
  if (opts.body !== undefined) {
    headers['content-type'] = 'application/json';
    init.body = JSON.stringify(opts.body);
  }

  opts.hooks?.onRequest?.({ method: opts.method, url });

  const res = await fetchImpl(url, init);
  const text = await res.text();
  let json: unknown;
  if (text.length > 0) {
    try {
      json = JSON.parse(text);
    } catch {
      json = undefined;
    }
  }

  if (!res.ok) {
    opts.hooks?.onError?.({ method: opts.method, url, status: res.status, body: json ?? text });
  }

  return { status: res.status, headers: res.headers, text, json };
}

/**
 * Convenience: throw `WlDoltHubError` if the response is non-2xx.