test_runner: add __proto__ null

PR-URL: #48663
Reviewed-By: Antoine du Hamel <[email protected]>
Reviewed-By: Chemi Atlow <[email protected]>

Author: rluvaton

.eslintrc.js

@@ -111,6 +111,14 @@ module.exports = {
         },
       ] },
     },
+    {
+      files: [
+        'lib/internal/test_runner/**/*.js',
+      ],
+      rules: {
+        'node-core/set-proto-to-null-in-object': 'error',
+      },
+    },
   ],
   rules: {
     // ESLint built-in rules

lib/internal/test_runner/coverage.js

@@ -250,7 +250,7 @@ class TestCoverage {
     let dir;
 
     try {
-      mkdirSync(this.originalCoverageDirectory, { recursive: true });
+      mkdirSync(this.originalCoverageDirectory, { __proto__: null, recursive: true });
       dir = opendirSync(this.coverageDirectory);
 
       for (let entry; (entry = dir.readSync()) !== null;) {

lib/internal/test_runner/harness.js

@@ -116,6 +116,7 @@ function setup(root) {
   const globalOptions = parseCommandLine();
 
   const hook = createHook({
+    __proto__: null,
     init(asyncId, type, triggerAsyncId, resource) {
       if (resource instanceof Test) {
         testResources.set(asyncId, resource);
@@ -216,7 +217,7 @@ function runInParentContext(Factory) {
 
   const test = (name, options, fn) => run(name, options, fn);
   ArrayPrototypeForEach(['skip', 'todo', 'only'], (keyword) => {
-    test[keyword] = (name, options, fn) => run(name, options, fn, { [keyword]: true });
+    test[keyword] = (name, options, fn) => run(name, options, fn, { __proto__: null, [keyword]: true });
   });
   return test;
 }

lib/internal/test_runner/mock/mock.js

@@ -133,7 +133,7 @@ class MockTracker {
     validateObject(options, 'options');
     const { times = Infinity } = options;
     validateTimes(times, 'options.times');
-    const ctx = new MockFunctionContext(implementation, { original }, times);
+    const ctx = new MockFunctionContext(implementation, { __proto__: null, original }, times);
     return this.#setupMock(ctx, original);
   }
 
@@ -189,7 +189,7 @@ class MockTracker {
       );
     }
 
-    const restore = { descriptor, object: objectOrFunction, methodName };
+    const restore = { __proto__: null, descriptor, object: objectOrFunction, methodName };
     const impl = implementation === kDefaultFunction ?
       original : implementation;
     const ctx = new MockFunctionContext(impl, restore, times);
@@ -238,6 +238,7 @@ class MockTracker {
     }
 
     return this.method(object, methodName, implementation, {
+      __proto__: null,
       ...options,
       getter,
     });
@@ -265,6 +266,7 @@ class MockTracker {
     }
 
     return this.method(object, methodName, implementation, {
+      __proto__: null,
       ...options,
       setter,
     });
@@ -297,6 +299,7 @@ class MockTracker {
           throw err;
         } finally {
           FunctionPrototypeCall(trackCall, ctx, {
+            __proto__: null,
             arguments: argList,
             error,
             result,
@@ -321,6 +324,7 @@ class MockTracker {
           throw err;
         } finally {
           FunctionPrototypeCall(trackCall, ctx, {
+            __proto__: null,
             arguments: argList,
             error,
             result,

lib/internal/test_runner/mock/mock_timers.js

@@ -45,7 +45,7 @@ function setPosition(node, pos) {
 }
 
 function abortIt(signal) {
-  return new AbortError(undefined, { cause: signal.reason });
+  return new AbortError(undefined, { __proto__: null, cause: signal.reason });
 }
 
 const SUPPORTED_TIMERS = ['setTimeout', 'setInterval'];
@@ -194,7 +194,9 @@ class MockTimers {
 
   #toggleEnableTimers(activate) {
     const options = {
+      __proto__: null,
       toFake: {
+        __proto__: null,
         setTimeout: () => {
           this.#realSetTimeout = globalThis.setTimeout;
           this.#realClearTimeout = globalThis.clearTimeout;
@@ -233,6 +235,7 @@ class MockTimers {
         },
       },
       toReal: {
+        __proto__: null,
         setTimeout: () => {
           globalThis.setTimeout = this.#realSetTimeout;
           globalThis.clearTimeout = this.#realClearTimeout;

lib/internal/test_runner/reporter/spec.js

@@ -42,7 +42,7 @@ class SpecReporter extends Transform {
   #failedTests = [];
 
   constructor() {
-    super({ writableObjectMode: true });
+    super({ __proto__: null, writableObjectMode: true });
   }
 
   #indent(nesting) {
@@ -127,7 +127,7 @@ class SpecReporter extends Transform {
     }
   }
   _transform({ type, data }, encoding, callback) {
-    callback(null, this.#handleEvent({ type, data }));
+    callback(null, this.#handleEvent({ __proto__: null, type, data }));
   }
   _flush(callback) {
     if (this.#failedTests.length === 0) {

lib/internal/test_runner/reporter/tap.js

@@ -18,7 +18,7 @@ const kDefaultIndent = '    '; // 4 spaces
 const kFrameStartRegExp = /^ {4}at /;
 const kLineBreakRegExp = /\n|\r\n/;
 const kDefaultTAPVersion = 13;
-const inspectOptions = { colors: false, breakLength: Infinity };
+const inspectOptions = { __proto__: null, colors: false, breakLength: Infinity };
 let testModule; // Lazy loaded due to circular dependency.
 
 function lazyLoadTest() {

lib/internal/test_runner/runner.js

@@ -135,7 +135,7 @@ function createTestFileList() {
     for (let i = 0; i < testPaths.length; i++) {
       const absolutePath = resolve(testPaths[i]);
 
-      processPath(absolutePath, testFiles, { userSupplied: true });
+      processPath(absolutePath, testFiles, { __proto__: null, userSupplied: true });
     }
   } catch (err) {
     if (err?.code === 'ENOENT') {
@@ -348,9 +348,9 @@ class FileTest extends Test {
 function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns) {
   const watchMode = filesWatcher != null;
   const subtest = root.createSubtest(FileTest, path, async (t) => {
-    const args = getRunArgs({ path, inspectPort, testNamePatterns });
+    const args = getRunArgs({ __proto__: null, path, inspectPort, testNamePatterns });
     const stdio = ['pipe', 'pipe', 'pipe'];
-    const env = { ...process.env, NODE_TEST_CONTEXT: 'child-v8' };
+    const env = { __proto__: null, ...process.env, NODE_TEST_CONTEXT: 'child-v8' };
     if (watchMode) {
       stdio.push('ipc');
       env.WATCH_REPORT_DEPENDENCIES = '1';
@@ -359,7 +359,7 @@ function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns) {
       env.FORCE_COLOR = '1';
     }
 
-    const child = spawn(process.execPath, args, { signal: t.signal, encoding: 'utf8', env, stdio });
+    const child = spawn(process.execPath, args, { __proto__: null, signal: t.signal, encoding: 'utf8', env, stdio });
     if (watchMode) {
       filesWatcher.runningProcesses.set(path, child);
       filesWatcher.watcher.watchChildProcessModules(child, path);
@@ -376,7 +376,7 @@ function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns) {
       subtest.parseMessage(data);
     });
 
-    const rl = createInterface({ input: child.stderr });
+    const rl = createInterface({ __proto__: null, input: child.stderr });
     rl.on('line', (line) => {
       if (isInspectorMessage(line)) {
         process.stderr.write(line + '\n');
@@ -394,8 +394,8 @@ function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns) {
     });
 
     const { 0: { 0: code, 1: signal } } = await SafePromiseAll([
-      once(child, 'exit', { signal: t.signal }),
-      finished(child.stdout, { signal: t.signal }),
+      once(child, 'exit', { __proto__: null, signal: t.signal }),
+      finished(child.stdout, { __proto__: null, signal: t.signal }),
     ]);
 
     if (watchMode) {
@@ -428,7 +428,7 @@ function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns) {
 function watchFiles(testFiles, root, inspectPort, signal, testNamePatterns) {
   const runningProcesses = new SafeMap();
   const runningSubtests = new SafeMap();
-  const watcher = new FilesWatcher({ debounce: 200, mode: 'filter', signal });
+  const watcher = new FilesWatcher({ __proto__: null, debounce: 200, mode: 'filter', signal });
   const filesWatcher = { __proto__: null, watcher, runningProcesses, runningSubtests };
 
   watcher.on('changed', ({ owners }) => {
@@ -513,7 +513,7 @@ function run(options) {
     });
   }
 
-  const root = createTestTree({ concurrency, timeout, signal });
+  const root = createTestTree({ __proto__: null, concurrency, timeout, signal });
   let testFiles = files ?? createTestFileList();
 
   if (shard) {

lib/internal/test_runner/test.js

@@ -79,7 +79,7 @@ function stopTest(timeout, signal) {
   if (timeout === kDefaultTimeout) {
     return once(signal, 'abort');
   }
-  return PromisePrototypeThen(setTimeout(timeout, null, { ref: false, signal }), () => {
+  return PromisePrototypeThen(setTimeout(timeout, null, { __proto__: null, ref: false, signal }), () => {
     throw new ERR_TEST_FAILURE(
       `test timed out after ${timeout}ms`,
       kTestTimeoutFailure,
@@ -506,7 +506,7 @@ class Test extends AsyncResource {
 
   getRunArgs() {
     const ctx = new TestContext(this);
-    return { ctx, args: [ctx] };
+    return { __proto__: null, ctx, args: [ctx] };
   }
 
   async runHook(hook, args) {
@@ -540,12 +540,12 @@ class Test extends AsyncResource {
     const { args, ctx } = this.getRunArgs();
     const after = async () => {
       if (this.hooks.after.length > 0) {
-        await this.runHook('after', { args, ctx });
+        await this.runHook('after', { __proto__: null, args, ctx });
       }
     };
     const afterEach = runOnce(async () => {
       if (this.parent?.hooks.afterEach.length > 0) {
-        await this.parent.runHook('afterEach', { args, ctx });
+        await this.parent.runHook('afterEach', { __proto__: null, args, ctx });
       }
     });
 
@@ -554,7 +554,7 @@ class Test extends AsyncResource {
         await this.parent.runHook('before', this.parent.getRunArgs());
       }
       if (this.parent?.hooks.beforeEach.length > 0) {
-        await this.parent.runHook('beforeEach', { args, ctx });
+        await this.parent.runHook('beforeEach', { __proto__: null, args, ctx });
       }
       const stopPromise = stopTest(this.timeout, this.signal);
       const runArgs = ArrayPrototypeSlice(args);
@@ -811,7 +811,7 @@ class Suite extends Test {
 
   getRunArgs() {
     const ctx = new SuiteContext(this);
-    return { ctx, args: [ctx] };
+    return { __proto__: null, ctx, args: [ctx] };
   }
 
   async run() {

lib/internal/test_runner/tests_stream.js

@@ -12,7 +12,7 @@ class TestsStream extends Readable {
   #canPush;
 
   constructor() {
-    super({ objectMode: true });
+    super({ __proto__: null, objectMode: true });
     this.#buffer = [];
     this.#canPush = true;
   }
@@ -83,6 +83,8 @@ class TestsStream extends Readable {
 
   [kEmitMessage](type, data) {
     this.emit(type, data);
+    // Disabling as this going to the user-land
+    // eslint-disable-next-line node-core/set-proto-to-null-in-object
     this.#tryPush({ type, data });
   }
 

lib/internal/test_runner/utils.js

@@ -81,7 +81,7 @@ function createDeferredCallback() {
     resolve();
   };
 
-  return { promise, cb };
+  return { __proto__: null, promise, cb };
 }
 
 function isTestFailureError(err) {