Merge pull request #510 from perrin4869/chore/nodejs/test-worker-threads

tdewolff · web-flow · commit 2eed2f639ec2 · 2022-07-10T12:33:43.000-04:00
Node.JS bindings Worker threads segfault reproduction
diff --git a/bindings/js/package.json b/bindings/js/package.json
@@ -28,7 +28,7 @@
   ],
   "scripts": {
     "install": "node-gyp-build",
-    "test": "node test.js",
+    "test": "node test/index.js && node test/worker.js",
     "prebuildify": "prebuildify --napi --strip"
   },
   "homepage": "https://github.com/tdewolff/minify#readme",
diff --git a/bindings/js/test/index.js b/bindings/js/test/index.js
diff --git a/bindings/js/test/worker.js b/bindings/js/test/worker.js
@@ -0,0 +1,26 @@
+import { Worker, isMainThread, workerData, parentPort } from 'node:worker_threads';
+
+if (isMainThread) {
+    let input = "<html><span style=\"color:#ff0000;\">A  phrase</span>";
+    const worker = new Worker(new URL(import.meta.url), {
+        workerData: input,
+    });
+
+    let expected = "<html><span style=color:red>A phrase</span>";
+    let output = await new Promise((resolve, reject) => {
+        worker.on('message', resolve);
+        worker.on('error', reject);
+        worker.on('exit', (code) => {
+            if (code !== 0)
+            reject(new Error(`Worker stopped with exit code ${code}`));
+        });
+    })
+    if (output != expected) {
+        throw "unexpected output using worker threads: '"+output+"' instead of '"+expected+"'";
+    }
+    await worker.terminate();
+} else {
+    const { config, string } = await import('@tdewolff/minify');
+    config({'html-keep-document-tags': true})
+    parentPort.postMessage(string("text/html", workerData));
+}
