test_runner: accept testOnly in run

PR-URL: #49753Fixes: #49733 Reviewed-By: Chemi Atlow <[email protected]> Reviewed-By: Benjamin Gruenbaum <[email protected]> Reviewed-By: Raz Luvaton <[email protected]>

Author: MoLow

doc/api/test.md

@@ -906,6 +906,8 @@ changes:
  number. If a nullish value is provided, each process gets its own port,
  incremented from the primary's `process.debugPort`.
 **Default:**`undefined`.
+*`only`:{boolean} If truthy, the test context will only run tests that
+ have the `only` option set
 *`setup`{Function} A function that accepts the `TestsStream` instance
  and can be used to setup listeners before any tests are run.
 **Default:**`undefined`.

lib/internal/test_runner/runner.js

@@ -154,14 +154,17 @@ function filterExecArgv(arg, i, arr){
 !ArrayPrototypeSome(kFilterArgValues,(p)=>arg===p||(i>0&&arr[i-1]===p)||StringPrototypeStartsWith(arg,`${p}=`));
 }
 
-functiongetRunArgs({path, inspectPort, testNamePatterns }){
+functiongetRunArgs(path,{inspectPort, testNamePatterns, only}){
 constargv=ArrayPrototypeFilter(process.execArgv,filterExecArgv);
 if(isUsingInspector()){
 ArrayPrototypePush(argv,`--inspect-port=${getInspectPort(inspectPort)}`);
 }
-if(testNamePatterns){
+if(testNamePatterns!=null){
 ArrayPrototypeForEach(testNamePatterns,(pattern)=>ArrayPrototypePush(argv,`--test-name-pattern=${pattern}`));
 }
+if(only===true){
+ArrayPrototypePush(argv,'--test-only');
+}
 ArrayPrototypePush(argv,path);
 
 returnargv;
@@ -345,17 +348,17 @@ class FileTest extends Test{
 }
 }
 
-functionrunTestFile(path,root,inspectPort,filesWatcher,testNamePatterns){
+functionrunTestFile(path,filesWatcher,opts){
 constwatchMode=filesWatcher!=null;
-constsubtest=root.createSubtest(FileTest,path,async(t)=>{
-constargs=getRunArgs({__proto__: null,path,inspectPort, testNamePatterns });
+constsubtest=opts.root.createSubtest(FileTest,path,async(t)=>{
+constargs=getRunArgs(path,opts);
 conststdio=['pipe','pipe','pipe'];
 constenv={__proto__: null, ...process.env,NODE_TEST_CONTEXT: 'child-v8'};
 if(watchMode){
 stdio.push('ipc');
 env.WATCH_REPORT_DEPENDENCIES='1';
 }
-if(root.harness.shouldColorizeTestFiles){
+if(opts.root.harness.shouldColorizeTestFiles){
 env.FORCE_COLOR='1';
 }
 
@@ -402,7 +405,7 @@ function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns){
 filesWatcher.runningProcesses.delete(path);
 filesWatcher.runningSubtests.delete(path);
 if(filesWatcher.runningSubtests.size===0){
-root.reporter[kEmitMessage]('test:watch:drained');
+opts.root.reporter[kEmitMessage]('test:watch:drained');
 }
 }
 
@@ -425,10 +428,10 @@ function runTestFile(path, root, inspectPort, filesWatcher, testNamePatterns){
 returnsubtest.start();
 }
 
-functionwatchFiles(testFiles,root,inspectPort,signal,testNamePatterns){
+functionwatchFiles(testFiles,opts){
 construnningProcesses=newSafeMap();
 construnningSubtests=newSafeMap();
-constwatcher=newFilesWatcher({__proto__: null,debounce: 200,mode: 'filter', signal });
+constwatcher=newFilesWatcher({__proto__: null,debounce: 200,mode: 'filter',signal: opts.signal});
 constfilesWatcher={__proto__: null, watcher, runningProcesses, runningSubtests };
 
 watcher.on('changed',({ owners })=>{
@@ -444,19 +447,19 @@ function watchFiles(testFiles, root, inspectPort, signal, testNamePatterns){
 }
 if(!runningSubtests.size){
 // Reset the topLevel counter
-root.harness.counters.topLevel=0;
+opts.root.harness.counters.topLevel=0;
 }
 awaitrunningSubtests.get(file);
-runningSubtests.set(file,runTestFile(file,root,inspectPort,filesWatcher,testNamePatterns));
+runningSubtests.set(file,runTestFile(file,filesWatcher,opts));
 },undefined,(error)=>{
 triggerUncaughtException(error,true/* fromPromise */);
 }));
 });
-if(signal){
+if(opts.signal){
 kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
-signal.addEventListener(
+opts.signal.addEventListener(
 'abort',
-()=>root.postRun(),
+()=>opts.root.postRun(),
 {__proto__: null,once: true,[kResistStopPropagation]: true},
 );
 }
@@ -469,14 +472,17 @@ function run(options){
 options=kEmptyObject;
 }
 let{ testNamePatterns, shard }=options;
-const{ concurrency, timeout, signal, files, inspectPort, watch, setup }=options;
+const{ concurrency, timeout, signal, files, inspectPort, watch, setup, only}=options;
 
 if(files!=null){
 validateArray(files,'options.files');
 }
 if(watch!=null){
 validateBoolean(watch,'options.watch');
 }
+if(only!=null){
+validateBoolean(only,'options.only');
+}
 if(shard!=null){
 validateObject(shard,'options.shard');
 // Avoid re-evaluating the shard object in case it's a getter
@@ -522,14 +528,15 @@ function run(options){
 
 letpostRun=()=>root.postRun();
 letfilesWatcher;
+constopts={__proto__: null, root, signal, inspectPort, testNamePatterns, only };
 if(watch){
-filesWatcher=watchFiles(testFiles,root,inspectPort,signal,testNamePatterns);
+filesWatcher=watchFiles(testFiles,opts);
 postRun=undefined;
 }
 construnFiles=()=>{
 root.harness.bootstrapComplete=true;
 returnSafePromiseAllSettledReturnVoid(testFiles,(path)=>{
-constsubtest=runTestFile(path,root,inspectPort,filesWatcher,testNamePatterns);
+constsubtest=runTestFile(path,filesWatcher,opts);
 filesWatcher?.runningSubtests.set(path,subtest);
 returnsubtest;
 });

test/fixtures/test-runner/test_only.js

@@ -0,0 +1,5 @@
+'use strict';
+consttest=require('node:test');
+
+test('this should be skipped');
+test.only('this should be executed');

test/parallel/test-runner-run.mjs

@@ -148,6 +148,18 @@ describe('require(\'node:test\').run',{concurrency: true }, () =>{
 assert.strictEqual(result[5],'ok 2 - this should be executed\n');
 });
 
+it('should pass only to children',async()=>{
+constresult=awaitrun({
+files: [join(testFixtures,'test_only.js')],
+only: true
+})
+.compose(tap)
+.toArray();
+
+assert.strictEqual(result[2],'ok 1 - this should be skipped # SKIP \'only\' option not set\n');
+assert.strictEqual(result[5],'ok 2 - this should be executed\n');
+});
+
 it('should emit "test:watch:drained" event on watch mode',async()=>{
 constcontroller=newAbortController();
 awaitrun({