Class DaemonHttpClient

apps/kimi-web/src/api/daemon/http.ts:91–399

}

export class DaemonHttpClient {
  constructor(
    private readonly origin: string,
    private readonly identity?: DaemonHttpClientIdentity,
  ) {}

  async get<T>(path: string, query?: Record<string, string | number | boolean | undefined>): Promise<T> {
    return this.request<T>('GET', path, undefined, query);
  }

  /** Authenticated raw-binary GET (no envelope). Used for file downloads that
   *  must carry the Bearer token — e.g. <video>/<img> src, which the browser
   *  fetches natively and cannot authorize on its own. Returns the body as a
   *  Blob on 2xx; otherwise parses the daemon envelope and throws. */
  async getBlob(path: string): Promise<Blob> {
    const url = buildRestUrl(this.origin, path);
    const requestId = createRequestId();
    const headers: Record<string, string> = { 'X-Request-Id': requestId };
    this.addClientHeaders(headers);
    const startedAt = Date.now();
    traceRestRequest({ method: 'GET', path, url, requestId });
    let response: Response;
    try {
      response = await fetch(url, { method: 'GET', headers, signal: timeoutSignal() });
    } catch (err) {
      traceRestFailure({
        method: 'GET',
        path,
        requestId,
        phase: 'fetch',
        durationMs: Date.now() - startedAt,
        error: err,
      });
      throw new DaemonNetworkError({
        message: `Network error calling GET ${path}`,
        cause: err,
        method: 'GET',
        path,
        url,
        requestId,
        phase: 'fetch',
        timeoutMs: REQUEST_TIMEOUT_MS,
        timestamp: Date.now(),
        durationMs: Date.now() - startedAt,
      });
    }
    if (response.ok) {
      traceRestResponse({
        method: 'GET',
        path,
        requestId,
        status: response.status,
        durationMs: Date.now() - startedAt,
        code: 0,
        msg: '',
      });
      return response.blob();
    }