123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283
import { assert, assertEquals, equal } from "./test_deps.ts";
import {  createStore,  createStoreContext,  emptyStore,  ttl,  x,} from "./test_utils.ts";
import { createResource } from "../library/resource/mod.ts";import { rdf, xsd } from "../library/namespaces/mod.ts";import { DataFactory } from "../library/rdf.ts";
import { QueryEngine as Comunica } from "https://esm.sh/@comunica/query-sparql-rdfjs@2.4.3";
const assertContainsEqual = (haystack: unknown[], needle: unknown) => {  let found = false;  for (const item of haystack) {    if (equal(item, needle)) {      found = true;      break;    }  }  assert(found);};
const Instant = {  "@type": x.Instant,  date: {    "@id": x.inXSDDate,    "@type": xsd.date,  },} as const;
const Director = {  "@type": x.Director,  name: x.name,} as const;
const Movie = {  "@type": x.Movie,  name: x.name,  director: {    "@id": x.director,    "@context": Director,  },  released: {    "@id": x.released,    "@context": Instant,    "@optional": true,  },} as const;
const defaultStoreContent = ttl(`  x:StanleyKubrick    a x:Director ;    x:name "Stanley Kubrick" .  x:QuentinTarantino    a x:Director ;    x:name "Quentin Tarantino" .  x:FullMetalJacket    a x:Movie;    x:name "Full Metal Jacket" ;    x:director x:StanleyKubrick .  x:Shining    a x:Movie;    x:name "Shining" ;    x:director x:StanleyKubrick .  x:PulpFiction    a x:Movie;    x:name "Pulp Fiction" ;    x:director x:QuentinTarantino .`);
const createDirector = ($id: string, name: string) => ({  $id: x[$id],  $type: [x.Director],  name,});
const Tarantino = createDirector("QuentinTarantino", "Quentin Tarantino");const Kubrick = createDirector("StanleyKubrick", "Stanley Kubrick");
const engine = new Comunica();const _ = new DataFactory();
const init = () => {  const store = createStore();  store.addQuads(defaultStoreContent);  const context = createStoreContext(store, {    sources: [{ type: "rdfjsSource", value: store }],  });  const directors = createResource(Director, context, engine);  const movies = createResource(Movie, context, engine);  const assertStore = (turtle: string) => {    const storeQuads = store.getQuads(null, null, null, null);    const expectedQuads = ttl(turtle);    assertEquals(storeQuads, expectedQuads);  };  const empty = async () => {    await emptyStore(store);  };  return { directors, movies, assertStore, empty };};
Deno.test("Resource / Get many resources", async () => {  const { directors } = init();  const result = await directors.find();
  assertEquals(result.length, 2);  assertContainsEqual(result, Tarantino);  assertContainsEqual(result, Kubrick);});
Deno.test("Resource / Get resource by IRI", async () => {  const { directors } = init();  const result = await directors.findByIri(Tarantino.$id);
  assertEquals(result, Tarantino);});
Deno.test("Resource / Get multiple resources by IRI", async () => {  const { directors } = init();  const result = await directors.findByIris([Tarantino.$id, Kubrick.$id]);
  assertContainsEqual(result, Tarantino);  assertContainsEqual(result, Kubrick);});
Deno.test("Resource / Get resource by string condition", async () => {  const { directors } = init();  const condition = `?iri <${x.name}> "Quentin Tarantino" .`;  const result = await directors.find(condition);
  assertEquals(result.length, 1);  assertEquals(result[0], Tarantino);});
Deno.test("Resource / Get resource by quad condition", async () => {  const { directors } = init();  const condition = _.quad(    _.variable("iri"),    _.namedNode(x.name),    _.literal("Quentin Tarantino"),  );  const result = await directors.find([condition]);
  assertEquals(result.length, 1);  assertEquals(result[0], Tarantino);});
Deno.test("Resource / Count resources", async () => {  const { directors } = init();  const count = await directors.count();  assertEquals(count, 2);});
Deno.test("Resource / Insert multiple resources", async () => {  const { directors, empty, assertStore } = init();  await empty();  await directors.insert(Kubrick, Tarantino);
  assertStore(`      x:StanleyKubrick        a x:Director ;        x:name "Stanley Kubrick" .      x:QuentinTarantino        a x:Director ;        x:name "Quentin Tarantino" .    `);});
Deno.test("Resource / Insert complex resource", async () => {  const { movies } = init();  await movies.insert({    $id: x.IngloriousBasterds,    name: "Inglorious Basterds",    director: { $id: x.QuentinTarantino },    released: { date: new Date("2008-01-01") },  });  const result = await movies.findByIri(x.IngloriousBasterds);
  assertEquals(result?.name, "Inglorious Basterds");  assertEquals(result?.director, Tarantino);  assertEquals(result?.released?.date, new Date("2008-01-01"));});
Deno.test("Resource / Update multiple resources", async () => {  const { directors } = init();  await directors.update(    {      $id: Kubrick.$id,      name: "Kubrick Stanley",    },    {      $id: Tarantino.$id,      name: "Tarantino Quentin",    },  );  const result = await directors.find();
  assertContainsEqual(result, { ...Tarantino, name: "Tarantino Quentin" });  assertContainsEqual(result, { ...Kubrick, name: "Kubrick Stanley" });});
/*  test.skip("Update nested property in resource", async () => {    const result = await run(      movies.update({        $id: x.PulpFiction,        released: {          date: new Date("1994-01-01"),        },      }),      movies.findByIri(x.PulpFiction)    );
    expect(result!.released?.date).toEqual(new Date("1994-01-01"));  }); */
Deno.test("Resource / Delete multiple resources", async () => {  const { directors } = init();  await directors.delete(Tarantino, Kubrick);  const dirs = await directors.find();  assertEquals(dirs.length, 0);});
Deno.test("Resource / Insert data", async () => {  const { directors } = init();  await directors.insert({    $id: x.ChristopherNolan,  });  await directors.insertData(    _.quad(      _.namedNode(x.ChristopherNolan),      _.namedNode(x.name),      _.literal("Christopher Nolan"),    ),  );  const result = await directors.findByIri(x.ChristopherNolan);  assertEquals(result, {    $id: x.ChristopherNolan,    $type: [x.Director],    name: "Christopher Nolan",  });});
Deno.test("Resource / Delete data", async () => {  const { directors } = init();  await directors.insert({    $id: x.ChristopherNolan,    $type: [x.Director, x.CustomType],    name: "Christopher Nolan",  });  await directors.deleteData(    _.quad(      _.namedNode(x.ChristopherNolan),      _.namedNode(rdf.type),      _.namedNode(x.CustomType),    ),  );  const result = await directors.findByIri(x.ChristopherNolan);  assertEquals(result, {    $id: x.ChristopherNolan,    $type: [x.Director],    name: "Christopher Nolan",  });});
Deno.test("Resource / Support for custom types", async () => {  const { movies } = init();  await movies.insert({    $id: x.KillBill,    $type: [x.TarantinoMovie],    name: "Kill Bill",    director: { $id: x.QuentinTarantino },  });  const result = await movies.findByIri(x.KillBill);
  assertEquals(result?.$type, [x.Movie, x.TarantinoMovie]);});