worker: add support for .cjs extension

PR-URL: #31662 Reviewed-By: Anna Henningsen <[email protected]> Reviewed-By: Rich Trott <[email protected]> Reviewed-By: James M Snell <[email protected]> Reviewed-By: Colin Ihrig <[email protected]> Reviewed-By: Ruben Bridgewater <[email protected]> Reviewed-By: David Carlier <[email protected]> Reviewed-By: Yuta Hiroto <[email protected]> Reviewed-By: Gus Caplan <[email protected]> Reviewed-By: Denys Otrishko <[email protected]>
nodejs · Feb 17, 2020 · 822f2ac · 822f2ac
1 parent b35f83e
commit 822f2ac
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 2 deletions.
diff --git a/lib/internal/errors.js b/lib/internal/errors.js
@@ -1367,7 +1367,7 @@ E('ERR_WORKER_PATH',
 E('ERR_WORKER_UNSERIALIZABLE_ERROR',
   'Serializing an uncaught exception failed', Error);
 E('ERR_WORKER_UNSUPPORTED_EXTENSION',
-  'The worker script extension must be ".js" or ".mjs". Received "%s"',
+  'The worker script extension must be ".js", ".mjs", or ".cjs". Received "%s"',
   TypeError);
 E('ERR_WORKER_UNSUPPORTED_OPERATION',
   '%s is not supported in workers', TypeError);

diff --git a/lib/internal/worker.js b/lib/internal/worker.js
@@ -104,7 +104,7 @@ class Worker extends EventEmitter {
       filename = path.resolve(filename);
 
       const ext = path.extname(filename);
-      if (ext !== '.js' && ext !== '.mjs') {
+      if (!/^\.[cm]?js$/.test(ext)) {
         throw new ERR_WORKER_UNSUPPORTED_EXTENSION(ext);
       }
     }

diff --git a/test/fixtures/worker-data.cjs b/test/fixtures/worker-data.cjs
@@ -0,0 +1,3 @@
+const { workerData, parentPort } = require('worker_threads');
+
+parentPort.postMessage(workerData);
diff --git a/test/parallel/test-worker-cjs-workerdata.js b/test/parallel/test-worker-cjs-workerdata.js
@@ -0,0 +1,15 @@
+'use strict';
+const common = require('../common');
+const fixtures = require('../common/fixtures');
+const assert = require('assert');
+const { Worker } = require('worker_threads');
+
+const workerData = 'Hello from main thread';
+
+const worker = new Worker(fixtures.path('worker-data.cjs'), {
+  workerData
+});
+
+worker.on('message', common.mustCall((message) => {
+  assert.strictEqual(message, workerData);
+}));
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		const { workerData, parentPort } = require('worker_threads');

		parentPort.postMessage(workerData);