Adds nodejs smoketest

Author: benjamind

package.json

@@ -9,9 +9,10 @@
   "scripts": {
     "build": "rollup -c",
     "test:unit": "karma start",
+    "test:node": "mocha ./tests/node/main.mjs",
     "test:types": "tsc -p ./tests/tsconfig.json",
     "test:types:watch": "npm run test:types -- --watch",
-    "test": "npm run fmt_test && npm run build && npm run test:types && npm run test:unit",
+    "test": "npm run fmt_test && npm run build && npm run test:types && npm run test:unit && npm run test:node",
     "fmt": "prettier --write './*.{mjs,js,ts,md,json,html}' './{src,docs,tests}/{,**/}*.{mjs,js,ts,md,json,html}'",
     "fmt_test": "test $(prettier -l './*.{mjs,js,ts,md,json,html}' './{src,docs,tests}/{**/,}*.{mjs,js,ts,md,json,html}' | wc -l) -eq 0",
     "watchtest": "CHROME_ONLY=1 karma start --no-single-run"
@@ -28,7 +29,7 @@
   "devDependencies": {
     "@rollup/plugin-terser": "0.4.0",
     "@rollup/plugin-typescript": "11.0.0",
-    "chai": "4.3.7",
+    "chai": "^4.3.7",
     "conditional-type-checks": "1.0.6",
     "husky": "8.0.3",
     "karma": "6.4.1",

tests/node/main.mjs

@@ -0,0 +1,28 @@
+import { Worker } from "worker_threads";
+import * as Comlink from "../../dist/esm/comlink.mjs";
+import nodeEndpoint from "../../dist/esm/node-adapter.mjs";
+import { expect } from "chai";
+
+describe("node", () => {
+  describe("Comlink across workers", function () {
+    beforeEach(function () {
+      this.worker = new Worker("./tests/node/worker.mjs");
+    });
+
+    afterEach(function () {
+      this.worker.terminate();
+    });
+
+    it("can communicate", async function () {
+      const proxy = Comlink.wrap(nodeEndpoint(this.worker));
+      expect(await proxy(1, 3)).to.equal(4);
+    });
+
+    it("can tunnels a new endpoint with createEndpoint", async function () {
+      const proxy = Comlink.wrap(nodeEndpoint(this.worker));
+      const otherEp = await proxy[Comlink.createEndpoint]();
+      const otherProxy = Comlink.wrap(otherEp);
+      expect(await otherProxy(20, 1)).to.equal(21);
+    });
+  });
+});

tests/node/worker.mjs

@@ -0,0 +1,5 @@
+import { parentPort } from "worker_threads";
+import * as Comlink from "../../dist/esm/comlink.mjs";
+import nodeEndpoint from "../../dist/esm/node-adapter.mjs";
+
+Comlink.expose((a, b) => a + b, nodeEndpoint(parentPort));