test_runner: fix diagnostics channel context tracking

Signed-off-by: Moshe Atlow <moshe@atlow.co.il>
PR-URL: #63283
Reviewed-By: Chemi Atlow <chemi@atlow.co.il>
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
Reviewed-By: Gürgün Dayıoğlu <hey@gurgun.day>

Author: MoLow

lib/internal/test_runner/test.js

@@ -1259,6 +1259,9 @@ class Test extends AsyncResource {
 
     let stopPromise;
 
+    let publishEnd = () => testChannel.end.publish(channelContext);
+    let publishError = (err) => testChannel.error.publish({ __proto__: null, ...channelContext, error: err });
+
     try {
       if (this.parent?.hooks.before.length > 0) {
         // This hook usually runs immediately, we need to wait for it to finish
@@ -1277,9 +1280,11 @@ class Test extends AsyncResource {
       // not the runInAsyncScope call itself, to maintain AsyncLocalStorage bindings.
       let testFn = this.fn;
       if (channelContext !== null && testChannel.start.hasSubscribers) {
-        testFn = (...fnArgs) => testChannel.start.runStores(channelContext,
-                                                            () => ReflectApply(this.fn, this, fnArgs),
-        );
+        testFn = (...fnArgs) => testChannel.start.runStores(channelContext, () => {
+          publishEnd = AsyncResource.bind(publishEnd);
+          publishError = AsyncResource.bind(publishError);
+          return ReflectApply(this.fn, this, fnArgs);
+        });
       }
 
       ArrayPrototypeUnshift(runArgs, testFn, ctx);
@@ -1331,9 +1336,8 @@ class Test extends AsyncResource {
       await afterEach();
       await after();
     } catch (err) {
-      // Publish diagnostics_channel error event if the channel has subscribers
       if (channelContext !== null && testChannel.error.hasSubscribers) {
-        testChannel.error.publish({ __proto__: null, ...channelContext, error: err });
+        publishError(err);
       }
       if (isTestFailureError(err)) {
         if (err.failureType === kTestTimeoutFailure) {
@@ -1357,7 +1361,7 @@ class Test extends AsyncResource {
 
       // Publish diagnostics_channel end event if the channel has subscribers (in both success and error cases)
       if (channelContext !== null && testChannel.end.hasSubscribers) {
-        testChannel.end.publish(channelContext);
+        publishEnd();
       }
     }
 
@@ -1702,6 +1706,9 @@ class Suite extends Test {
       file: this.entryFile,
       type: this.reportedType,
     };
+    let publishEnd = () => testChannel.end.publish(channelContext);
+    let publishError = (err) => testChannel.error.publish({ __proto__: null, ...channelContext, error: err });
+
     try {
       const { ctx, args } = this.getRunArgs();
 
@@ -1713,9 +1720,11 @@ class Suite extends Test {
       let suiteFn = this.fn;
       if (testChannel.start.hasSubscribers) {
         const baseFn = this.fn;
-        suiteFn = (...fnArgs) => testChannel.start.runStores(channelContext,
-                                                             () => ReflectApply(baseFn, this, fnArgs),
-        );
+        suiteFn = (...fnArgs) => testChannel.start.runStores(channelContext, () => {
+          publishEnd = AsyncResource.bind(publishEnd);
+          publishError = AsyncResource.bind(publishError);
+          return ReflectApply(baseFn, this, fnArgs);
+        });
       }
 
       const runArgs = [suiteFn, ctx];
@@ -1724,12 +1733,12 @@ class Suite extends Test {
       await ReflectApply(this.runInAsyncScope, this, runArgs);
     } catch (err) {
       if (testChannel.error.hasSubscribers) {
-        testChannel.error.publish({ __proto__: null, ...channelContext, error: err });
+        publishError(err);
       }
       this.fail(new ERR_TEST_FAILURE(err, kTestCodeFailure));
     } finally {
       if (testChannel.end.hasSubscribers) {
-        testChannel.end.publish(channelContext);
+        publishEnd();
       }
     }
 

test/fixtures/test-runner/diagnostics-channel-bindstore-end.js

@@ -0,0 +1,27 @@
+'use strict';
+const dc = require('node:diagnostics_channel');
+const { AsyncLocalStorage } = require('node:async_hooks');
+const { test } = require('node:test');
+
+const als = new AsyncLocalStorage();
+const ch = dc.tracingChannel('node.test');
+
+ch.start.bindStore(als, (data) => data.name);
+
+const storeAtEnd = {};
+const storeAtError = {};
+
+ch.end.subscribe((data) => {
+  storeAtEnd[data.name] = als.getStore();
+});
+
+ch.error.subscribe((data) => {
+  storeAtError[data.name] = als.getStore();
+});
+
+test('passing test', () => {});
+test('failing test', () => { throw new Error('boom'); });
+
+process.on('exit', () => {
+  console.log(JSON.stringify({ storeAtEnd, storeAtError }));
+});

test/parallel/test-runner-diagnostics-channel.js

@@ -119,6 +119,26 @@ test('context is available in async operations within test', async () => {
   assert.strictEqual(valueInTimeout, testName);
 });
 
+test('bindStore propagates store to end and error subscribers', async () => {
+  // Spawn a fixture that records `als.getStore()` at end/error publish time so
+  // we can assert subscribers see the bound store, not undefined.
+  const fixturePath = join(__dirname, '../fixtures/test-runner/diagnostics-channel-bindstore-end.js');
+  const result = spawnSync(process.execPath, [fixturePath], { encoding: 'utf8' });
+  // The fixture contains an intentionally failing test, so exit is non-zero.
+  assert.notStrictEqual(result.status, 0);
+  const line = result.stdout.split('\n').find((l) => l.includes('storeAtEnd'));
+  assert.ok(line, `expected storeAtEnd line in stdout:\n${result.stdout}`);
+  const { storeAtEnd, storeAtError } = JSON.parse(line);
+  assert.deepStrictEqual(storeAtEnd, {
+    '<root>': '<root>',
+    'passing test': 'passing test',
+    'failing test': 'failing test',
+  });
+  assert.deepStrictEqual(storeAtError, {
+    'failing test': 'failing test',
+  });
+});
+
 test('error events fire for failing tests in fixture', async () => {
   // Run the fixture test that intentionally fails
   const fixturePath = join(__dirname, '../fixtures/test-runner/diagnostics-channel-error-test.js');