Update base comunica to work with changes in link traversal

Author: RubenEschauzier

packages/actor-context-preprocess-set-persistent-cache-manager/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@comunica/actor-context-preprocess-set-persistent-cache-manager",
-  "version": "5.1.3",
+  "version": "5.2.0",
   "description": "A set-persistent-cache-manager context-preprocess actor",
   "lsd:module": true,
   "license": "MIT",

packages/actor-init-query/lib/HttpServiceSparqlEndpoint.ts

@@ -335,7 +335,6 @@ export class HttpServiceSparqlEndpoint {
             try {
               const executionPromises = Array.from(this.timeoutFinalizeResponseCallbacks.entries())
                 .flatMap(([res, cbArr]) => cbArr.map((cb) => cb(res)));
-              console.log(executionPromises)
               await Promise.all(executionPromises);
             } catch (error: unknown) {
               stderr.write(`Error during timeout callbacks: ${(<Error>error).message}\n`);

packages/actor-query-result-serialize-sparql-json/lib/ActorQueryResultSerializeSparqlJson.ts

@@ -124,17 +124,12 @@ export class ActorQueryResultSerializeSparqlJson extends ActorQueryResultSeriali
 
       const finalizeCbs: (((res: ServerResponse) => Promise<void>)[]) | undefined
         = context.get(KeysInitQuery.timeoutFinalizeResponseCallbacks);
-      console.log(finalizeCbs);
       if (finalizeCbs) {
         finalizeCbs.push(async (res: ServerResponse) => {
-          console.log("TEST")
           if (!metadataEmitted) {
-            console.log("Start push")
             data.push(finalize());
-            console.log("Pushed")
             resultStream.destroy();
           }
-          console.log("END TEST")
         })
       }
 

packages/actor-rdf-join-inner-multi-stems/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@comunica/actor-rdf-join-inner-multi-stems",
-  "version": "5.1.3",
+  "version": "5.2.0",
   "description": "A inner-multi-stems rdf-join actor",
   "lsd:module": true,
   "license": "MIT",

packages/cache-manager-entries/lib/ViewKeys.ts

@@ -1,4 +1,4 @@
-import type { BindingsStream, IActionContext, ISourceState, ISourceStateBloomFilter } from '@comunica/types';
+import type { BindingsStream, IActionContext, ILink, ISourceState, ISourceStateBloomFilter } from '@comunica/types';
 import { ViewKey } from './ViewKey';
 import { Algebra } from '@comunica/utils-algebra';
 import { AsyncIterator } from 'asynciterator';
@@ -20,33 +20,29 @@ export const CacheSourceStateViews = {
       }, 
       ISourceState
     >('@comunica/persistent-cache-manager:sourceStateView'),
-
-  cacheQueryView:
+  /**
+   * 
+   */
+  indexedCacheGetView:
     new ViewKey<
       ISourceState,
       { url: string, mode: 'get', action: IActionQuerySourceDereferenceLink },
       BindingsStream | AsyncIterator<RDF.Quad> | ISourceState
     >('@comunica/persistent-cache-manager:cacheQuery'),
 
-  cacheQueryViewBloomFilter:
-    new ViewKey<
-      ISourceStateBloomFilter,
-      { url: string, mode: 'get', action: IActionQuerySourceDereferenceLink } | { mode: 'queryBindings' | 'queryQuads', operation: Algebra.Operation},
-      AsyncIterator<BindingsStream> | AsyncIterator<AsyncIterator<RDF.Quad>> | ISourceState
-    >('@comunica/persistent-cache-manager:cacheQueryBloomFilter'),
-  
-  cacheCountView:
+  indexedCacheCountView:
     new ViewKey<
       ISourceState,
-      { operation: Algebra.Operation, documents: string[] },
+      { operation: Algebra.Operation },
       number
     >('@comunica/persistent-cache-manager:cacheCount'),
-  cacheCountBloomFilterView:
+
+  indexedCacheCountViewOfflineTraversal:
     new ViewKey<
-      ISourceStateBloomFilter,
-      { operation: Algebra.Operation, documents: string[] },
+      ISourceState,
+      { operation: Algebra.Operation, seeds: ILink[], query: Algebra.BaseOperation },
       number
-    >('@comunica/persistent-cache-manager:cacheCountBloomFilter'),
+    >('@comunica/persistent-cache-manager:cacheCount'),
 
 };
 

packages/cache-manager-entries/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@comunica/cache-manager-entries",
-  "version": "5.1.3",
+  "version": "5.2.0",
   "description": "A collection of reusable Comunica cache-manager-entries key definitions.",
   "license": "MIT",
   "funding": {

yarn.lock

@@ -5083,6 +5083,11 @@ csv-parse@^4.16.0:
   resolved "https://registry.npmjs.org/csv-parse/-/csv-parse-4.16.3.tgz"
   integrity sha512-cO1I/zmz4w2dcKHVvpCr7JVRu8/FymG5OEpmvsZYlccYolPBLoVGKUHgNoc4ZGkFeFlWGEDmMyBM+TTqRdW/wg==
 
+cuint@^0.2.2:
+  version "0.2.2"
+  resolved "https://registry.yarnpkg.com/cuint/-/cuint-0.2.2.tgz#408086d409550c2631155619e9fa7bcadc3b991b"
+  integrity sha512-d4ZVpCW31eWwCMe1YT3ur7mUDnTXbgwyzaL320DrcRT45rfjYxkt5QWLrmOJ+/UEAI2+fQgKe/fCjR8l4TpRgw==
+
 dargs@^7.0.0:
   version "7.0.0"
   resolved "https://registry.npmjs.org/dargs/-/dargs-7.0.0.tgz"
@@ -10830,19 +10835,6 @@ rdfa-streaming-parser@^3.0.2:
     readable-stream "^4.0.0"
     relative-to-absolute-iri "^1.0.2"
 
-rdfxml-streaming-parser@3.2.0:
-  version "3.2.0"
-  resolved "https://registry.yarnpkg.com/rdfxml-streaming-parser/-/rdfxml-streaming-parser-3.2.0.tgz#4775bbca68301b0c0eac306d8f7d8ea0a00a5051"
-  integrity sha512-SgQGK0EkbXd0jQ1PZk7dEpfDxf4CZpezkO6cTuGWesa9twdWaaW5elMoNBcbMT+2tOZC1EYZjs0JaXx0HnifcQ==
-  dependencies:
-    "@rubensworks/saxes" "^6.0.1"
-    "@types/readable-stream" "^4.0.18"
-    buffer "^6.0.3"
-    rdf-data-factory "^2.0.2"
-    readable-stream "^4.4.2"
-    relative-to-absolute-iri "^1.0.0"
-    validate-iri "^1.0.0"
-
 rdfxml-streaming-parser@^2.2.3:
   version "2.4.0"
   resolved "https://registry.npmjs.org/rdfxml-streaming-parser/-/rdfxml-streaming-parser-2.4.0.tgz"