1234567891011121314151617181920212223242526272829303132333435363738394041
import { N3, quadsToGraph, type RDF } from "../rdf.ts";import { type AsyncIterator } from "../asynciterator.ts";
import type { IQueryEngine, QueryContext } from "./types.ts";
export class QueryEngineProxy {  private readonly engine: IQueryEngine;  private readonly context: QueryContext;
  constructor(engine: IQueryEngine, context: QueryContext) {    this.engine = engine;    this.context = context;  }
  queryBoolean(query: string) {    return this.engine.queryBoolean(query, this.context);  }
  async queryBindings(query: string) {    const bindingsStream = await this.engine.queryBindings(      query,      this.context,    ) as unknown as AsyncIterator<RDF.Bindings>;    return bindingsStream.toArray();  }
  async queryGraph(query: string) {    const quadStream = await this.engine.queryQuads(      query,      this.context,    ) as unknown as AsyncIterator<RDF.Quad>;    const quads = await (quadStream.toArray());    const store = new N3.Store(quads);    return quadsToGraph(store);  }
  queryVoid(query: string) {    return this.engine.queryVoid(query, this.context);  }}