Class HttpClient

src/lib/http.ts:162–649

}

export class HttpClient {
  private readonly baseUrl: string;
  private readonly apiKey?: string;
  private readonly fetchImpl: FetchImpl;
  private readonly sleep: (ms: number) => Promise<void>;
  private readonly random: () => number;
  private readonly onDebug?: (event: DebugEvent) => void;
  private readonly onTransition?: (msg: string) => void;
  private readonly requestTimeoutMs: number;

  constructor(options: HttpClientOptions) {
    this.baseUrl = trimTrailingSlash(options.baseUrl);
    this.apiKey = options.apiKey;
    this.fetchImpl = options.fetchImpl ?? globalThis.fetch.bind(globalThis);
    this.sleep = options.sleep ?? defaultSleep;
    this.random = options.random ?? Math.random;
    this.onDebug = options.onDebug;
    this.onTransition = options.onTransition;
    this.requestTimeoutMs = options.requestTimeoutMs ?? REQUEST_TIMEOUT_DEFAULT_MS;
  }

  async get<T>(path: string, options: RequestOptions = {}): Promise<T> {
    return this.requestWithMeta<T>('GET', path, options).then(r => r.body);
  }

  async post<T>(path: string, options: RequestOptions = {}): Promise<T> {
    return this.requestWithMeta<T>('POST', path, options).then(r => r.body);
  }

  async put<T>(path: string, options: RequestOptions = {}): Promise<T> {
    return this.requestWithMeta<T>('PUT', path, options).then(r => r.body);
  }

  async patch<T>(path: string, options: RequestOptions = {}): Promise<T> {
    return this.requestWithMeta<T>('PATCH', path, options).then(r => r.body);
  }

  async delete<T>(path: string, options: RequestOptions = {}): Promise<T> {
    return this.requestWithMeta<T>('DELETE', path, options).then(r => r.body);
  }

  /**
   * Like `get` / `post` / etc. but returns the full `RequestResult` including
   * `requestId` and `status`, so callers can surface the requestId in
   * happy-path output (dogfood item 1).
   */
  async getWithMeta<T>(path: string, options: RequestOptions = {}): Promise<RequestResult<T>> {
    return this.requestWithMeta<T>('GET', path, options);
  }

  async postWithMeta<T>(path: string, options: RequestOptions = {}): Promise<RequestResult<T>> {
    return this.requestWithMeta<T>('POST', path, options);
  }

  async putWithMeta<T>(path: string, options: RequestOptions = {}): Promise<RequestResult<T>> {
    return this.requestWithMeta<T>('PUT', path, options);
  }