worker: add eval ts input

marco-ippolito · aduh95 · commit c658a8afdfb2 · 2025-02-06T01:15:06.000+01:00
PR-URL: #56394 Backport-PR-URL: #56912 Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Paolo Insogna <paolo@cowtech.it> Reviewed-By: Pietro Marchini <pietro.marchini94@gmail.com>
diff --git a/lib/internal/main/worker_thread.js b/lib/internal/main/worker_thread.js
@@ -49,7 +49,10 @@ const { setupMainThreadPort } = require('internal/worker/messaging');
 const {
   onGlobalUncaughtException,
   evalScript,
+  evalTypeScript,
   evalModuleEntryPoint,
+  parseAndEvalCommonjsTypeScript,
+  parseAndEvalModuleTypeScript,
 } = require('internal/process/execution');
 
 let debug = require('internal/util/debuglog').debuglog('worker', (fn) => {
@@ -166,7 +169,29 @@ port.on('message', (message) => {
           value: filename,
         });
         ArrayPrototypeSplice(process.argv, 1, 0, name);
-        evalScript(name, filename);
+        const tsEnabled = getOptionValue('--experimental-strip-types');
+        const inputType = getOptionValue('--input-type');
+
+        if (inputType === 'module-typescript' && tsEnabled) {
+          // This is a special case where we want to parse and eval the
+          // TypeScript code as a module
+          parseAndEvalModuleTypeScript(filename, false);
+          break;
+        }
+
+        let evalFunction;
+        if (inputType === 'commonjs') {
+          evalFunction = evalScript;
+        } else if (inputType === 'commonjs-typescript' && tsEnabled) {
+          evalFunction = parseAndEvalCommonjsTypeScript;
+        } else if (tsEnabled) {
+          evalFunction = evalTypeScript;
+        } else {
+          // Default to commonjs.
+          evalFunction = evalScript;
+        }
+
+        evalFunction(name, filename);
         break;
       }
 
diff --git a/test/parallel/test-worker-eval-typescript.js b/test/parallel/test-worker-eval-typescript.js
@@ -0,0 +1,67 @@
+'use strict';
+require('../common');
+const assert = require('assert');
+const { Worker } = require('worker_threads');
+const { test } = require('node:test');
+const { once } = require('events');
+
+const esmHelloWorld = `
+    import worker from 'worker_threads';
+    const foo: string = 'Hello, World!';
+    worker.parentPort.postMessage(foo);
+`;
+
+const cjsHelloWorld = `
+    const { parentPort } = require('worker_threads');
+    const foo: string = 'Hello, World!';
+    parentPort.postMessage(foo);
+`;
+
+const flags = ['--experimental-strip-types', '--disable-warning=ExperimentalWarning'];
+
+test('Worker eval module typescript without input-type', async () => {
+  const w = new Worker(esmHelloWorld, { eval: true, execArgv: [...flags] });
+  assert.deepStrictEqual(await once(w, 'message'), ['Hello, World!']);
+});
+
+test('Worker eval module typescript with --input-type=module-typescript', async () => {
+  const w = new Worker(esmHelloWorld, { eval: true, execArgv: ['--input-type=module-typescript',
+                                                               ...flags] });
+  assert.deepStrictEqual(await once(w, 'message'), ['Hello, World!']);
+});
+
+test('Worker eval module typescript with --input-type=commonjs-typescript', async () => {
+  const w = new Worker(esmHelloWorld, { eval: true, execArgv: ['--input-type=commonjs-typescript',
+                                                               ...flags] });
+
+  const [err] = await once(w, 'error');
+  assert.strictEqual(err.name, 'SyntaxError');
+  assert.match(err.message, /Cannot use import statement outside a module/);
+});
+
+test('Worker eval module typescript with --input-type=module', async () => {
+  const w = new Worker(esmHelloWorld, { eval: true, execArgv: ['--input-type=module',
+                                                               ...flags] });
+  const [err] = await once(w, 'error');
+  assert.strictEqual(err.name, 'SyntaxError');
+  assert.match(err.message, /Missing initializer in const declaration/);
+});
+
+test('Worker eval commonjs typescript without input-type', async () => {
+  const w = new Worker(cjsHelloWorld, { eval: true, execArgv: [...flags] });
+  assert.deepStrictEqual(await once(w, 'message'), ['Hello, World!']);
+});
+
+test('Worker eval commonjs typescript with --input-type=commonjs-typescript', async () => {
+  const w = new Worker(cjsHelloWorld, { eval: true, execArgv: ['--input-type=commonjs-typescript',
+                                                               ...flags] });
+  assert.deepStrictEqual(await once(w, 'message'), ['Hello, World!']);
+});
+
+test('Worker eval commonjs typescript with --input-type=module-typescript', async () => {
+  const w = new Worker(cjsHelloWorld, { eval: true, execArgv: ['--input-type=module-typescript',
+                                                               ...flags] });
+  const [err] = await once(w, 'error');
+  assert.strictEqual(err.name, 'ReferenceError');
+  assert.match(err.message, /require is not defined in ES module scope, you can use import instead/);
+});
