123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
import { map, switchMap, tap, share, BehaviorSubject } from "../rxjs.ts";
import type { Graph, Iri, Quad } from "../rdf.ts";import { bindingsQuery, quadsQuery, updateQuery } from "../engine.ts";import { type Context, resolveContext } from "../context.ts";import {  type Schema,  type SchemaPrototype,  type SchemaInterface,  type SchemaInterfaceIdentity,  expandSchema,} from "../schema/mod.ts";import { decode } from "../decoder.ts";
import { QueryBuilder } from "./query_builder.ts";import type { Entity } from "./types.ts";
export const createResource = <T extends SchemaPrototype>(  spec: T,  context?: Context) => new Resource(spec, context);
export class Resource<S extends SchemaPrototype, I = SchemaInterface<S>> {  private readonly schema: Schema;  private readonly context: Context;  private readonly queryBuilder: QueryBuilder;  private readonly $trigger = new BehaviorSubject(null);
  constructor(schema: S, context?: Context) {    this.schema = expandSchema(schema);    this.context = resolveContext(context);    this.queryBuilder = new QueryBuilder(this.schema, this.context);  }
  private decode(graph: Graph) {    return decode(graph, this.schema, this.context) as unknown as I[];  }
  count() {    const q = this.queryBuilder.countQuery();    console.log(q);    return this.$trigger.pipe(      switchMap(() => bindingsQuery(q, this.context)),      map((bindings) => {        console.warn("BINDINGS", bindings);        return parseInt(bindings[0].get("count")!.value);      })    );  }
  //exists(entity: Identity) {}
  query(sparqlConstructQuery: string) {    console.log(sparqlConstructQuery);    return quadsQuery(sparqlConstructQuery, this.context).pipe(      map((graph) => {        return this.decode(graph);      })    );  }
  find(where?: string | Quad[], limit?: number) {    const q = this.queryBuilder.getQuery(where, limit);    console.log(q);    return this.$trigger.pipe(      switchMap(() => quadsQuery(q, this.context)),      map((graph) => {        return this.decode(graph);      })    );  }
  findByIri(iri: Iri) {    return this.findByIris([iri]).pipe(      map((result) => (result.length > 0 ? result[0] : undefined))    );  }
  findByIris(iris: Iri[]) {    const q = this.queryBuilder.getByIrisQuery(iris);    console.log(q);    return this.$trigger.pipe(      switchMap(() => quadsQuery(q, this.context)),      map((graph) => {        return this.decode(graph);      })    );  }
  private updateQuery(query: string) {    console.log(query);
    const result = updateQuery(query, this.context).pipe(      tap(() => this.$trigger.next(null)),      share()    );    result.subscribe();    return result;  }
  insert(...entities: Entity<I>[]) {    const q = this.queryBuilder.insertQuery(entities);
    return this.updateQuery(q);  }
  insertData(...quads: Quad[]) {    const q = this.queryBuilder.insertDataQuery(quads);
    return this.updateQuery(q);  }
  update(...entities: Entity<I>[]) {    const q = this.queryBuilder.updateQuery(entities);
    return this.updateQuery(q);  }
  delete(...identities: SchemaInterfaceIdentity[] | Iri[]) {    const iris = identities.map((identity) => {      return typeof identity === "string" ? identity : identity.$id;    });
    const q = this.queryBuilder.deleteQuery(iris);
    return this.updateQuery(q);  }
  deleteData(...quads: Quad[]) {    const q = this.queryBuilder.deleteDataQuery(quads);
    return this.updateQuery(q);  }}