Class ServerGraphStore

ui/src/store/serverStore.ts:71–366

}

export class ServerGraphStore implements GraphStore {
  private readonly baseUrl: string;
  private _hasData = false;

  // Visualization caps threaded into /api/graph as ?maxNodes=&maxEdges=.
  // Defaults match LadybugStore and SettingsDrawer's DEFAULT_MAX_*. The
  // agent caps the response server-side (see serve.py:fetch_graph).
  private maxVisNodes = 20000;
  private maxVisEdges = 20000;

  constructor(baseUrl: string) {
    // Strip trailing slash for consistent URL building
    this.baseUrl = baseUrl.replace(/\/+$/, '');

    // Apply persisted visualization limits so the first fetch uses them
    // without waiting for the user to open Settings and click Update.
    // Mirrors LadybugStore's behavior in ensureReady().
    try {
      const savedNodes = localStorage.getItem('ot:maxVisNodes');
      const savedEdges = localStorage.getItem('ot:maxVisEdges');
      const n = savedNodes != null ? Number(savedNodes) : NaN;
      const e = savedEdges != null ? Number(savedEdges) : NaN;
      // Integers only — the /api/graph contract rejects non-integer caps,
      // so a persisted decimal would make every fetch 400.
      if (Number.isInteger(n) && n > 0) this.maxVisNodes = n;
      if (Number.isInteger(e) && e > 0) this.maxVisEdges = e;
    } catch {
      /* localStorage unavailable (SSR, restricted browser) — keep defaults */
    }
  }

  // ---- Helpers --------------------------------------------------------

  private async get<T>(
    path: string,
    params?: Record<string, string>,
  ): Promise<T> {
    const base = this.baseUrl.endsWith('/') ? this.baseUrl : this.baseUrl + '/';
    const url = new URL(path.startsWith('/') ? path.slice(1) : path, base);
    if (params) {
      for (const [k, v] of Object.entries(params)) {
        if (v !== undefined && v !== '') url.searchParams.set(k, v);
      }
    }
    const res = await fetch(url.toString());
    if (!res.ok) {
      const body = await res.text().catch(() => '');
      throw new Error(`Server error ${res.status}: ${body}`);
    }
    return res.json() as Promise<T>;
  }

  private async post<T>(path: string, body: unknown): Promise<T> {
    const base = this.baseUrl.endsWith('/') ? this.baseUrl : this.baseUrl + '/';
    const url = new URL(path.startsWith('/') ? path.slice(1) : path, base);
    const res = await fetch(url.toString(), {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },