handler-fetch: upgrade oxigraph to 0.4.0-rc.1

zazuko · Aug 27, 2024 · 7d6a17a · 7d6a17a
1 parent 21d81bc
commit 7d6a17a
Show file tree

Hide file tree

Showing 6 changed files with 28 additions and 11 deletions.
diff --git a/.changeset/lazy-glasses-attend.md b/.changeset/lazy-glasses-attend.md
@@ -0,0 +1,5 @@
+---
+"trifid-handler-fetch": patch
+---
+
+Upgrade Oxigraph to 0.4.0-rc.1.
diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/handler-fetch/lib/query.js b/packages/handler-fetch/lib/query.js
@@ -19,19 +19,31 @@ export const performOxigraphQuery = async (store, query) => {
 
   try {
     if (isConstructQuery) {
-      contentType = 'application/n-quads'
-      results = store.query(query, {
+      const queryResults = store.query(query, {
         use_default_graph_as_union: true,
-      }).map((quad) => quad.toString()).join('.\n')
-      if (results) {
-        results = `${results}.\n`
+      })
+      if (Array.isArray(queryResults)) {
+        contentType = 'application/n-quads'
+        results = queryResults.map((quad) => quad.toString()).join('.\n')
+        if (results) {
+          results = `${results}.\n`
+        }
+      } else {
+        contentType = 'text/plain'
+        results = 'Something went wrong while getting the query results (expected array).'
       }
     } else {
-      contentType = 'application/sparql-results+json'
-      results = store.query(query, {
+      const queryResults = store.query(query, {
         use_default_graph_as_union: true,
         results_format: 'json',
       })
+      if (typeof queryResults === 'string') {
+        contentType = 'application/sparql-results+json'
+        results = queryResults
+      } else {
+        contentType = 'text/plain'
+        results = 'Something went wrong while getting the query results (expected string).'
+      }
     }
   } catch (error) {
     contentType = 'text/plain'

diff --git a/packages/handler-fetch/lib/worker.js b/packages/handler-fetch/lib/worker.js
@@ -70,7 +70,7 @@ const handleConfig = async (config) => {
   store.load(data, {
     format: contentType,
     base_iri: baseIri,
-    to_named_graph: graphNameIri,
+    to_graph_name: graphNameIri,
   })
   parentPort.postMessage({
     type: 'log',

diff --git a/packages/handler-fetch/package.json b/packages/handler-fetch/package.json
@@ -28,7 +28,7 @@
     "prepack": "npm run build"
   },
   "dependencies": {
-    "oxigraph": "^0.4.0-alpha.7",
+    "oxigraph": "^0.4.0-rc.1",
     "uuid": "^10.0.0"
   },
   "devDependencies": {

diff --git a/packages/handler-fetch/test/handler-fetch.test.js b/packages/handler-fetch/test/handler-fetch.test.js
@@ -37,7 +37,7 @@ describe('trifid-handler-fetch', () => {
     `, {
       format: 'text/turtle',
       base_iri: 'http://example.org/',
-      to_named_graph: oxigraph.defaultGraph(),
+      to_graph_name: oxigraph.defaultGraph(),
     })
   })