Incremunica user tools

A collection of functions to help use incremunica.

Install

$ yarn add @comunica/user-tools
Copy

Usage

BindingsTools

The isAddition function checks if a binding is an addition. It returns true if the passed bindings are an addition, false otherwise.

import { isAddition } from '@comunica/user-tools';
import { KeysBindings } from '@incremunica/context-entries';
import { BindingsFactory } from '@comunica/utils-bindings-factory';

export const BF = new BindingsFactory();

const bindings1 = BF.fromRecord({
  s: DF.namedNode('http://ex.org/s'),
});
const bindings2 = BF.fromRecord({
  s: DF.namedNode('http://ex.org/s'),
}).getContextEntry(KeysBindings.isAddition, true);
const bindings3 = BF.fromRecord({
  s: DF.namedNode('http://ex.org/s'),
}).getContextEntry(KeysBindings.isAddition, false);

console.log(isAddition(bindings1)); // true
console.log(isAddition(bindings2)); // true
console.log(isAddition(bindings3)); // false
Copy

DeferredEvaluationTools

The DeferredEvaluation class can be used to trigger a deferred evaluation of a query engine.

import {DeferredEvaluation} from '@comunica/user-tools';
import {QueryEngine} from "@incremunica/query-sparql-incremental";

const deferredEvaluation = new DeferredEvaluation();
const queryEngine = new QueryEngine();
const bindingsStream = queryEngine.queryBindings("SELECT * WHERE { ?s ?p ?o }", {
    sources: [ "https://www.rubensworks.net/" ],
    deferredEvaluationTrigger: deferredEvaluation.events
});

// Trigger the deferred evaluation
deferredEvaluation.triggerUpdate();
Copy

SourcesTools

createSourcesStreamFromBindingsStream can be used to create a sources stream from a bindings stream.

import {createSourcesStreamFromBindingsStream} from '@comunica/user-tools';
import {QueryEngine} from "@incremunica/query-sparql-incremental";

const queryEngine = new QueryEngine();
const bindingsStream1 = queryEngine.queryBindings("SELECT * WHERE { ?s ?p ?o }", {
    sources: [ "https://www.rubensworks.net/" ],
});
const bindingsStream2 = queryEngine.queryBindings("SELECT * WHERE { ?s ?p ?o }", {
  sources: [ createSourcesStreamFromBindingsStream(bindingsStream1, ["s"]) ],
});
Copy

QuerySourceIterator is a helper class to help build a query sources stream from different locations to pass to the query engine.

import {QuerySourceIterator} from '@comunica/user-tools';
import {QueryEngine} from "@incremunica/query-sparql-incremental";

const querySourceIterator = new QuerySourceIterator({
  seedSources: ["https://www.rubensworks.net/"],
  distinct: true
});
const queryEngine = new QueryEngine();
const bindingsStream = queryEngine.queryBindings("SELECT * WHERE { ?s ?p ?o }", {
  sources: [querySourceIterator],
});

querySourceIterator.addSource("https://ruben.verborgh.org/profile/"); // Add a source
querySourceIterator.removeSource("https://www.rubensworks.net/"); // Remove a source
querySourceIterator.addBindingsStream(anotherBindingsStream); // Add a bindings stream
querySourceIterator.addBindingsStream(bindingsStream, ["s"]); // Add results from the same bindingsStream
Copy