Class WorkerGraphStore

ui/src/store/workerStore.ts:75–412

}

export class WorkerGraphStore implements GraphStore {
  private worker: Worker;
  private pending = new Map<number, PendingRequest>();
  private nextSeq = 1;
  private embedder: Embedder | null = null;
  // The LadybugDB engine is owned here, on the main thread, so its internal
  // worker is a top-level worker rather than one nested inside storeWorker
  // (which broke on browsers without worker-in-worker support — Sentry
  // OSS-OPENTRACE-1G). storeWorker reaches it via `engine-request` messages.
  private engine: LbugEngine = createLbugEngine();
  private nodesImportedSinceClear = 0;

  constructor() {
    this.worker = new Worker(new URL('./storeWorker.ts', import.meta.url), {
      type: 'module',
    });
    this.worker.onmessage = (e: MessageEvent<InMessage>) =>
      this.onMessage(e.data);
    this.worker.onerror = (e) => {
      const err = new Error(e.message || 'store worker error');
      for (const req of this.pending.values()) req.reject(err);
      this.pending.clear();
    };
    // The inner store used to read these from localStorage during init, but
    // Workers don't expose localStorage. Read them here and push them in once.
    try {
      const savedNodes = localStorage.getItem('ot:maxVisNodes');
      const savedEdges = localStorage.getItem('ot:maxVisEdges');
      if (savedNodes || savedEdges) {
        const maxN = savedNodes ? Number(savedNodes) : 2000;
        const maxE = savedEdges ? Number(savedEdges) : 5000;
        if (Number.isFinite(maxN) && Number.isFinite(maxE)) {
          void this.setLimits(maxN, maxE);
        }
      }
    } catch {
      // localStorage may be unavailable (SSR, sandboxed iframe) — limits keep
      // their defaults in that case.
    }
  }

  // --- GraphStore interface ---

  hasData(): boolean {
    return this.nodesImportedSinceClear > 0;
  }

  ensureReady(): Promise<void> {
    return this.call<void>('ensureReady', []);
  }

  fetchGraph(query?: string, hops?: number): Promise<GraphData> {
    return this.call<GraphData>('fetchGraph', [query, hops]);
  }

  fetchStats(): Promise<GraphStats> {
    return this.call<GraphStats>('fetchStats', []);
  }