Method request

apps/kimi-web/src/api/daemon/http.ts:265–377

(
    method: string,
    path: string,
    body?: unknown,
    query?: Record<string, string | number | boolean | undefined>,
    allowCodes: number[] = [],
  )

  }

  private async request<T>(
    method: string,
    path: string,
    body?: unknown,
    query?: Record<string, string | number | boolean | undefined>,
    allowCodes: number[] = [],
  ): Promise<T> {
    // Build URL, appending query string (omit undefined values)
    let url = buildRestUrl(this.origin, path);
    if (query) {
      const params = new URLSearchParams();
      for (const [key, value] of Object.entries(query)) {
        if (value !== undefined) {
          params.set(key, String(value));
        }
      }
      const qs = params.toString();
      if (qs) url = `${url}?${qs}`;
    }

    // Build headers
    const requestId = createRequestId();
    const headers: Record<string, string> = {
      'X-Request-Id': requestId,
    };
    this.addClientHeaders(headers);
    if (body !== undefined) {
      headers['Content-Type'] = 'application/json; charset=utf-8';
    }

    const startedAt = Date.now();
    traceRestRequest({ method, path, url, requestId, body });

    // Execute fetch
    let response: Response;
    try {
      response = await fetch(url, {
        method,
        headers,
        body: body !== undefined ? JSON.stringify(body) : undefined,
        signal: timeoutSignal(),
      });
    } catch (err) {
      traceRestFailure({ method, path, requestId, phase: 'fetch', durationMs: Date.now() - startedAt, error: err });
      throw new DaemonNetworkError({
        message: `Network error calling ${method} ${path}`,
        cause: err,
        method,
        path,
        url,
        requestId,
        phase: 'fetch',
        timeoutMs: REQUEST_TIMEOUT_MS,
        timestamp: Date.now(),
        durationMs: Date.now() - startedAt,
      });
    }