test: add basic tests for worker

test/parallel/test-worker-cleanup-handles.js

@@ -0,0 +1,24 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, isMainThread, postMessage } = require('worker');
+const { Server } = require('net');
+const fs = require('fs');
+
+if (isMainThread) {
+  const w = new Worker(__filename);
+  let fd = null;
+  w.on('message', common.mustCall((fd_) => {
+    assert.strictEqual(typeof fd_, 'number');
+    fd = fd_;
+  }));
+  w.on('exit', common.mustCall((code) => {
+    assert.throws(() => fs.fstatSync(fd),
+                  common.expectsError({ code: 'EBADF' }));
+  }));
+} else {
+  const server = new Server();
+  server.listen(0);
+  postMessage(server._handle.fd);
+  server.unref();
+}

test/parallel/test-worker-dns-terminate.js

@@ -0,0 +1,14 @@
+'use strict';
+const common = require('../common');
+const { Worker } = require('worker');
+
+const w = new Worker(`
+const dns = require('dns');
+dns.lookup('nonexistent.org', () => {});
+require('worker').postMessage('0');
+`, { eval: true });
+
+w.on('message', common.mustCall(() => {
+  // This should not crash the worker during a DNS request.
+  w.terminate(common.mustCall());
+}));

test/parallel/test-worker-uncaught-exception-async.js

@@ -0,0 +1,17 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, isMainThread } = require('worker');
+
+if (isMainThread) {
+  const w = new Worker(__filename);
+  w.on('message', common.mustNotCall());
+  w.on('error', common.mustCall((err) => {
+    // TODO(addaleax): be more specific here
+    assert(/foo/.test(err));
+  }));
+} else {
+  setImmediate(() => {
+    throw new Error('foo');
+  });
+}

test/parallel/test-worker-uncaught-exception.js

@@ -0,0 +1,15 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, isMainThread } = require('worker');
+
+if (isMainThread) {
+  const w = new Worker(__filename);
+  w.on('message', common.mustNotCall());
+  w.on('error', common.mustCall((err) => {
+    // TODO(addaleax): be more specific here
+    assert(/foo/.test(err));
+  }));
+} else {
+  throw new Error('foo');
+}

test/parallel/test-worker.js

@@ -0,0 +1,17 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const { Worker, isMainThread, postMessage } = require('worker');
+
+if (isMainThread) {
+  const w = new Worker(__filename);
+  w.on('message', common.mustCall((message) => {
+    assert.strictEqual(message, 'Hello, world!');
+  }));
+} else {
+  setImmediate(() => {
+    process.nextTick(() => {
+      postMessage('Hello, world!');
+    });
+  });
+}