Class MainThreadLbugEngine

ui/src/store/lbugEngine.ts:67–134

}

class MainThreadLbugEngine implements LbugEngine {
  private db: Database | null = null;
  private conn: Connection | null = null;
  private closed = false;

  async init(): Promise<void> {
    lbug.setWorkerPath('/lbug_wasm_worker.js');
    await lbug.init();
    // Buffer pool size note: lbug accepts a `bufferPoolSize` argument here,
    // but in WASM the linear memory is a single shared heap — reserving more
    // for the page cache leaves less for everything else (CSV temp files,
    // query state, parser tables). An explicit 512 MB reservation broke ingest
    // even for small repos, so we let the engine's auto-sizing decide. To
    // genuinely fit larger graphs the right move is to reduce extraction depth
    // or use server mode rather than push this number up.
    this.db = new lbug.Database(':memory:');
    await this.db.init();
    this.conn = new lbug.Connection(this.db);
    await this.conn.init();
    this.closed = false;
  }

  async query(cypher: string): Promise<Record<string, unknown>[]> {
    if (!this.conn) throw new Error('LbugEngine.query before init()');
    const result = await this.conn.query(cypher);
    try {
      return await result.getAllObjects();
    } finally {
      await result.close();
    }
  }

  async exec(cypher: string): Promise<void> {
    if (!this.conn) throw new Error('LbugEngine.exec before init()');
    const result = await this.conn.query(cypher);
    await result.close();
  }

  async fsWrite(path: string, data: Uint8Array): Promise<void> {
    await lbug.FS.writeFile(path, data);
  }

  async fsUnlink(path: string): Promise<void> {
    await lbug.FS.unlink(path);
  }

  async close(): Promise<void> {
    if (this.closed) return;
    this.closed = true;
    try {
      await this.conn?.close();
    } catch {
      /* ignore */
    }
    try {
      await this.db?.close();
    } catch {
      /* ignore */