Merge pull request #23 from MikiDi/immutable_quads

blank nodes skolemization now works with immutable quads

Author: MikiDi

app.ts

@@ -92,7 +92,7 @@ const consumerJob = new CronJob(CRON_PATTERN, async () => {
       consumer.listen(
         async (member) => {
           try {
-            convertBlankNodes(member.quads);
+            member.quads = convertBlankNodes(member.quads);
             await processMember(member, treeProperties);
           } catch (e) {
             console.error(

utils.ts

@@ -39,21 +39,25 @@ export function fromDate(date: Date): RDF.Literal {
 
 export function convertBlankNodes(quads: RDF.Quad[]) {
   const blankNodesMap = new Map<RDF.BlankNode, RDF.NamedNode>();
-  quads.forEach((quad) => {
+  return quads.map((quad) => {
     if (quad.subject.termType === "BlankNode") {
       if (!blankNodesMap.has(quad.subject)) {
         blankNodesMap.set(quad.subject, BLANK(uuidv4()));
       }
-      quad.subject = blankNodesMap.get(quad.subject)!;
     }
     if (quad.object.termType === "BlankNode") {
       if (!blankNodesMap.has(quad.object)) {
         blankNodesMap.set(quad.object, BLANK(uuidv4()));
       }
-      quad.object = blankNodesMap.get(quad.object)!;
+    }
+    if (quad.subject.termType === "BlankNode" || quad.object.termType === "BlankNode") {
+      const newSubject = blankNodesMap.get(quad.subject) || quad.subject;
+      const newObject = blankNodesMap.get(quad.object) || quad.object;
+      return DataFactory.quad(newSubject, quad.predicate, newObject, quad.graph);
+    } else {
+      return quad;
     }
   });
-  return quads;
 }
 
 export function extractVersionTimestamp (member: Member, treeProperties: TreeProperties) : Date | null {