test: debug

nodejs · Sep 26, 2024 · 558b2c7 · 558b2c7
1 parent 2f4389c
commit 558b2c7
Showing 1 changed file with 66 additions and 6 deletions.
diff --git a/test/parallel/test-runner-run.mjs b/test/parallel/test-runner-run.mjs
@@ -591,52 +591,112 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
 
   it('should run with different cwd while in watch mode', async () => {
     const controller = new AbortController();
+    let passed = 0;
+    let failedBeforeAbort = 0;
+    let failedAferAbort = 0;
+    let aborted = false;
     const stream = run({
       cwd: fixtures.path('test-runner', 'cwd'),
       watch: true,
       signal: controller.signal,
     }).on('data', function({ type }) {
       if (type === 'test:watch:drained') {
+        aborted = true;
         controller.abort();
       }
     });
 
-    stream.on('test:fail', common.mustNotCall());
-    stream.on('test:pass', common.mustCall(1));
+    stream.on('test:fail', (data) => {
+      if (!aborted) {
+        failedBeforeAbort++;
+      } else {
+        failedAferAbort++;
+      }
+    });
+    stream.on('test:pass', () => {
+      passed++;
+    });
+
+    // eslint-disable-next-line no-unused-vars
+    for await (const _ of stream);
+
+    assert.strictEqual(failedBeforeAbort, 0);
+    assert.strictEqual(failedAferAbort, 0);
+    assert.strictEqual(passed, 1);
   });
 
   it('should run with different cwd while in watch mode and isolation "none"', async () => {
     const controller = new AbortController();
+    let passed = 0;
+    let failedBeforeAbort = 0;
+    let failedAferAbort = 0;
+    let aborted = false;
     const stream = run({
       cwd: fixtures.path('test-runner', 'cwd'),
       watch: true,
       signal: controller.signal,
       isolation: 'none',
     }).on('data', function({ type }) {
       if (type === 'test:watch:drained') {
+        aborted = true;
         controller.abort();
       }
     });
 
-    stream.on('test:fail', common.mustNotCall());
-    stream.on('test:pass', common.mustCall(1));
+    stream.on('test:fail', (data) => {
+      if (!aborted) {
+        failedBeforeAbort++;
+      } else {
+        failedAferAbort++;
+      }
+    });
+    stream.on('test:pass', () => {
+      passed++;
+    });
+
+    // eslint-disable-next-line no-unused-vars
+    for await (const _ of stream);
+
+    assert.strictEqual(failedBeforeAbort, 0);
+    assert.strictEqual(failedAferAbort, 0);
+    assert.strictEqual(passed, 1);
   });
 
   it('should run with different cwd while in watch mode and isolation "process"', async () => {
     const controller = new AbortController();
+    let passed = 0;
+    let failedBeforeAbort = 0;
+    let failedAferAbort = 0;
+    let aborted = false;
     const stream = run({
       cwd: fixtures.path('test-runner', 'cwd'),
       watch: true,
       signal: controller.signal,
       isolation: 'process',
     }).on('data', function({ type }) {
       if (type === 'test:watch:drained') {
+        aborted = true;
         controller.abort();
       }
     });
 
-    stream.on('test:fail', common.mustNotCall());
-    stream.on('test:pass', common.mustCall(1));
+    stream.on('test:fail', (data) => {
+      if (!aborted) {
+        failedBeforeAbort++;
+      } else {
+        failedAferAbort++;
+      }
+    });
+    stream.on('test:pass', () => {
+      passed++;
+    });
+
+    // eslint-disable-next-line no-unused-vars
+    for await (const _ of stream);
+
+    assert.strictEqual(failedBeforeAbort, 0);
+    assert.strictEqual(failedAferAbort, 0);
+    assert.strictEqual(passed, 1);
   });
 });