n3 - npm Package Compare versions

Comparing version 1.9.0 to 1.10.0

lib/N3Store.js

@@ -227,3 +227,11 @@ "use strict";
   } // ## Public methods
-  // ### `addQuad` adds a new quad to the store.
+  // ### `add` adds the specified quad to the dataset.
+  // Returns the dataset instance it was called on.
+  // Existing quads, as defined in Quad.equals, will be ignored.
+
+
+  add(quad) {
+    this.addQuad(quad);
+    return this;
+  } // ### `addQuad` adds a new quad to the store.
   // Returns if the quad index has changed, if the quad did not already exist.
@@ -277,2 +285,16 @@
     for (let i = 0; i < quads.length; i++) this.addQuad(quads[i]);
+  } // ### `delete` removes the specified quad from the dataset.
+  // Returns the dataset instance it was called on.
+
+
+  delete(quad) {
+    this.removeQuad(quad);
+    return this;
+  } // ### `has` determines whether a dataset includes a certain quad.
+  // Returns true or false as appropriate.
+
+
+  has(quad) {
+    const quads = this.getQuads(quad.subject, quad.predicate, quad.object, quad.graph);
+    return quads.length !== 0;
   } // ### `import` adds a stream of quads to the store
@@ -334,3 +356,13 @@
   removeMatches(subject, predicate, object, graph) {
-    return this.remove(this.match(subject, predicate, object, graph));
+    const stream = new _readableStream.Readable({
+      objectMode: true
+    });
+
+    stream._read = () => {
+      for (const quad of this.getQuads(subject, predicate, object, graph)) stream.push(quad);
+
+      stream.push(null);
+    };
+
+    return this.remove(stream);
   } // ### `deleteGraph` removes all triples with the given graph from the store
@@ -376,18 +408,12 @@
     return quads;
-  } // ### `match` returns a stream of quads matching a pattern.
+  } // ### `match` returns a new dataset that is comprised of all quads in the current instance matching the given arguments.
+  // The logic described in Quad Matching is applied for each quad in this dataset to check if it should be included in the output dataset.
+  // Note: This method always returns a new DatasetCore, even if that dataset contains no quads.
+  // Note: Since a DatasetCore is an unordered set, the order of the quads within the returned sequence is arbitrary.
   // Setting any field to `undefined` or `null` indicates a wildcard.
+  // For backwards compatibility, the object return also implements the Readable stream interface.
 
 
   match(subject, predicate, object, graph) {
-    const stream = new _readableStream.Readable({
-      objectMode: true
-    }); // Initialize stream once it is being read
-
-    stream._read = () => {
-      for (const quad of this.getQuads(subject, predicate, object, graph)) stream.push(quad);
-
-      stream.push(null);
-    };
-
-    return stream;
+    return new DatasetCoreAndReadableStream(this, subject, predicate, object, graph);
   } // ### `countQuads` returns the number of quads matching a pattern.
@@ -747,2 +773,9 @@ // Setting any field to `undefined` or `null` indicates a wildcard.
     return lists;
+  } // ### Store is an iterable.
+  // Can be used where iterables are expected: for...of loops, array spread operator,
+  // `yield*`, and destructuring assignment (order is not guaranteed).
+
+
+  *[Symbol.iterator]() {
+    yield* this.getQuads();
   }
@@ -757,2 +790,66 @@
   return typeof s === 'string' || s instanceof String;
+}
+/**
+ * A class that implements both DatasetCore and Readable.
+ */
+
+
+class DatasetCoreAndReadableStream extends _readableStream.Readable {
+  constructor(n3Store, subject, predicate, object, graph) {
+    super({
+      objectMode: true
+    });
+    Object.assign(this, {
+      n3Store,
+      subject,
+      predicate,
+      object,
+      graph
+    });
+  }
+
+  get filtered() {
+    if (!this._filtered) {
+      const {
+        n3Store,
+        graph,
+        object,
+        predicate,
+        subject
+      } = this;
+      const quads = n3Store.getQuads(subject, predicate, object, graph);
+      this._filtered = new N3Store(quads, {
+        factory: n3Store._factory
+      });
+    }
+
+    return this._filtered;
+  }
+
+  _read() {
+    for (const quad of this.filtered.getQuads()) this.push(quad);
+
+    this.push(null);
+  }
+
+  add(quad) {
+    return this.filtered.add(quad);
+  }
+
+  delete(quad) {
+    return this.filtered.delete(quad);
+  }
+
+  has(quad) {
+    return this.filtered.has(quad);
+  }
+
+  match(subject, predicate, object, graph) {
+    return new DatasetCoreAndReadableStream(this.filtered, subject, predicate, object, graph);
+  }
+
+  *[Symbol.iterator]() {
+    yield* this.filtered.getQuads();
+  }
+
 }

package.json

 {
   "name": "n3",
-  "version": "1.9.0",
+  "version": "1.10.0",
   "description": "Lightning fast, asynchronous, streaming Turtle / N3 / RDF library.",
@@ -5,0 +5,0 @@ "author": "Ruben Verborgh <[e-mail]>",

src/N3Store.js

@@ -214,2 +214,10 @@ // **N3Store** objects store N3 quads by graph in memory.
 
+  // ### `add` adds the specified quad to the dataset.
+  // Returns the dataset instance it was called on.
+  // Existing quads, as defined in Quad.equals, will be ignored.
+  add(quad) {
+    this.addQuad(quad);
+    return this;
+  }
+
   // ### `addQuad` adds a new quad to the store.
@@ -263,2 +271,16 @@ // Returns if the quad index has changed, if the quad did not already exist.
 
+  // ### `delete` removes the specified quad from the dataset.
+  // Returns the dataset instance it was called on.
+  delete(quad) {
+    this.removeQuad(quad);
+    return this;
+  }
+
+  // ### `has` determines whether a dataset includes a certain quad.
+  // Returns true or false as appropriate.
+  has(quad) {
+    const quads = this.getQuads(quad.subject, quad.predicate, quad.object, quad.graph);
+    return quads.length !== 0;
+  }
+
   // ### `import` adds a stream of quads to the store
@@ -321,3 +343,11 @@ import(stream) {
   removeMatches(subject, predicate, object, graph) {
-    return this.remove(this.match(subject, predicate, object, graph));
+    const stream = new Readable({ objectMode: true });
+
+    stream._read = () => {
+      for (const quad of this.getQuads(subject, predicate, object, graph))
+        stream.push(quad);
+      stream.push(null);
+    };
+
+    return this.remove(stream);
   }
@@ -379,15 +409,10 @@
 
-  // ### `match` returns a stream of quads matching a pattern.
+  // ### `match` returns a new dataset that is comprised of all quads in the current instance matching the given arguments.
+  // The logic described in Quad Matching is applied for each quad in this dataset to check if it should be included in the output dataset.
+  // Note: This method always returns a new DatasetCore, even if that dataset contains no quads.
+  // Note: Since a DatasetCore is an unordered set, the order of the quads within the returned sequence is arbitrary.
   // Setting any field to `undefined` or `null` indicates a wildcard.
+  // For backwards compatibility, the object return also implements the Readable stream interface.
   match(subject, predicate, object, graph) {
-    const stream = new Readable({ objectMode: true });
-
-    // Initialize stream once it is being read
-    stream._read = () => {
-      for (const quad of this.getQuads(subject, predicate, object, graph))
-        stream.push(quad);
-      stream.push(null);
-    };
-
-    return stream;
+    return new DatasetCoreAndReadableStream(this, subject, predicate, object, graph);
   }
@@ -797,2 +822,9 @@
   }
+
+  // ### Store is an iterable.
+  // Can be used where iterables are expected: for...of loops, array spread operator,
+  // `yield*`, and destructuring assignment (order is not guaranteed).
+  *[Symbol.iterator]() {
+    yield* this.getQuads();
+  }
 }
@@ -804,1 +836,46 @@
 }
+
+/**
+ * A class that implements both DatasetCore and Readable.
+ */
+class DatasetCoreAndReadableStream extends Readable {
+  constructor(n3Store, subject, predicate, object, graph) {
+    super({ objectMode: true });
+    Object.assign(this, { n3Store, subject, predicate, object, graph });
+  }
+
+  get filtered() {
+    if (!this._filtered) {
+      const { n3Store, graph, object, predicate, subject } = this;
+      const quads = n3Store.getQuads(subject, predicate, object, graph);
+      this._filtered = new N3Store(quads, { factory: n3Store._factory });
+    }
+    return this._filtered;
+  }
+
+  _read() {
+    for (const quad of this.filtered.getQuads())
+      this.push(quad);
+    this.push(null);
+  }
+
+  add(quad) {
+    return this.filtered.add(quad);
+  }
+
+  delete(quad) {
+    return this.filtered.delete(quad);
+  }
+
+  has(quad) {
+    return this.filtered.has(quad);
+  }
+
+  match(subject, predicate, object, graph) {
+    return new DatasetCoreAndReadableStream(this.filtered, subject, predicate, object, graph);
+  }
+
+  *[Symbol.iterator]() {
+    yield* this.filtered.getQuads();
+  }
+}

No alert changes

Improved metrics

Total package byte prevSize

270405

increased by1.92%

Lines of code

5821

increased by2.5%

No dependency changes