jsonld.canonize workers implementation (#3419)

* jsonld.canonize workers implementation

* refactor worker code structure

src/service/data-service.js

@@ -1,4 +1,5 @@
 import jsonld from 'jsonld';
+import toNQuadsWorker from '../workers/data-service-toNQuads-worker.js';
 import {
     SCHEMA_CONTEXT,
     MEDIA_TYPES,
@@ -19,14 +20,10 @@ class DataService {
             algorithm: ALGORITHM,
             format: MEDIA_TYPES.N_QUADS,
         };
-
         if (inputFormat) {
             options.inputFormat = inputFormat;
         }
-
-        const canonized = await jsonld.canonize(content, options);
-
-        return canonized.split('\n').filter((x) => x !== '');
+        return toNQuadsWorker(content, options);
     }
 
     async compact(content) {

src/workers/data-service-toNQuads-worker.js

@@ -0,0 +1,24 @@
+import { Worker, isMainThread, parentPort, workerData } from 'node:worker_threads';
+
+import jsonld from 'jsonld';
+import { fileURLToPath } from 'url';
+
+if (!isMainThread) {
+    const { content, options } = workerData;
+    const canonized = await jsonld.canonize(content, options);
+    parentPort.postMessage(canonized.split('\n').filter((x) => x !== ''));
+}
+
+export default function toNQuadsWorker(content, options) {
+    return new Promise((resolve, reject) => {
+        const worker = new Worker(fileURLToPath(import.meta.url), {
+            workerData: { content, options },
+        });
+        worker.on('message', resolve);
+        worker.on('error', reject);
+        worker.on('exit', (code) => {
+            if (code !== 0)
+                reject(new Error(`Worker stopped with exit code ${code}`));
+        });
+    });
+};