Class DaemonKimiWebApi

apps/kimi-web/src/api/daemon/client.ts:243–1378

// ---------------------------------------------------------------------------

export class DaemonKimiWebApi implements KimiWebApi {
  private readonly http: DaemonHttpClient;
  private readonly config: KimiApiConfig;

  constructor(config: KimiApiConfig) {
    this.config = config;
    this.http = new DaemonHttpClient(config.serverHttpUrl, {
      clientId: config.clientId,
      clientName: config.clientName,
      clientVersion: config.clientVersion,
      clientUiMode: config.clientUiMode,
    });
  }

  // -------------------------------------------------------------------------
  // Health / Meta
  // -------------------------------------------------------------------------

  async getHealth(): Promise<{ status: 'ok'; uptimeSec: number }> {
    // Real daemon returns { ok: true }; the older shape was { status, uptime_sec }.
    const data = await this.http.get<Partial<WireHealth>>('/healthz');
    return { status: 'ok', uptimeSec: data.uptime_sec ?? 0 };
  }

  async getMeta(): Promise<{
    serverVersion: string;
    serverId: string;
    startedAt: string;
    capabilities: Record<string, boolean>;
    openInApps: string[];
  }> {
    const data = await this.http.get<WireMeta>('/meta');
    return {
      serverVersion: data.server_version,
      serverId: data.server_id,
      startedAt: data.started_at,
      capabilities: data.capabilities,
      openInApps: Array.isArray(data.open_in_apps) ? data.open_in_apps : [],
    };
  }

  // -------------------------------------------------------------------------
  // Sessions
  // -------------------------------------------------------------------------

  async listSessions(
    input?: PageRequest & {
      status?: AppSessionStatus;
      workspaceId?: string;
      includeArchive?: boolean;
      excludeEmpty?: boolean;
    },
  ): Promise<Page<AppSession>> {
    const query: Record<string, string | number | boolean | undefined> = {
      before_id: input?.beforeId,
      after_id: input?.afterId,
      page_size: input?.pageSize,
      status: input?.status ? toWireSessionStatus(input.status) : undefined,