Skip to content

test_runner: call abort on test finish #48827

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
nodejs-github-bot merged 12 commits into from
Jul 21, 2023
Merged

test_runner: call abort on test finish #48827

Changes from 1 commit
Commits
Show all changes
12 commits
Select commit Hold shift + click to select a range
21a9e6d
test_runner: call abort on test finish
rluvaton Jul 18, 2023
0ed4cb4
format
rluvaton Jul 18, 2023
c4710a8
format
rluvaton Jul 18, 2023
eeabcf5
do not recreate on each test
rluvaton Jul 18, 2023
f93f38e
cleanup
rluvaton Jul 18, 2023
5017fe5
cleanup
rluvaton Jul 18, 2023
58da4d2
cleanup
rluvaton Jul 18, 2023
f5f36b6
abort after all cleanup
rluvaton Jul 19, 2023
0c7c812
Update test/fixtures/test-runner/aborts/wait-for-abort-helper.js
rluvaton Jul 19, 2023
42f7308
Update lib/internal/test_runner/test.js
rluvaton Jul 20, 2023
976b24f
trigger ci
rluvaton Jul 20, 2023
e511f95
Revert "trigger ci"
rluvaton Jul 20, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
cleanup
  • Loading branch information
@rluvaton
rluvaton committed Jul 18, 2023
commit 5017fe5e676cb0a07ba275e939a7b206c7dc399d
55 changes: 42 additions & 13 deletions test/parallel/test-runner-run.mjs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -118,14 +118,32 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
assert.strictEqual(result[5], 'ok 2 - this should be executed\n');
});

it('should emit "test:watch:drained" event on watch mode', async () => {
it('should stop watch mode when abortSignal aborts', async () => {
const controller = new AbortController();
await run({ files: [join(testFixtures, 'test/random.cjs')], watch: true, signal: controller.signal })
.on('data', function({ type }) {
if (type === 'test:watch:drained') {
controller.abort();
const result = await run({ files: [join(testFixtures, 'test/random.cjs')], watch: true, signal: controller.signal })
.compose(async function* (source) {
for await (const chunk of source) {
if (chunk.type === 'test:pass') {
controller.abort();
yield chunk.data.name;
}
}
});
})
.toArray();
assert.deepStrictEqual(result, ['this should pass']);
});

it('should emit "test:watch:drained" event on watch mode', async () => {
const controller = new AbortController();
await run({
files: [join(testFixtures, 'test/random.cjs')],
watch: true,
signal: controller.signal,
}).on('data', function({ type }) {
if (type === 'test:watch:drained') {
controller.abort();
}
});
});

describe('AbortSignal', () => {
Expand All @@ -134,7 +152,7 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
const result = await run({
files: [join(testFixtures, 'test/random.cjs')],
watch: true,
signal: controller.signal
signal: controller.signal,
})
.compose(async function* (source) {
for await (const chunk of source) {
Expand All @@ -150,7 +168,13 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {

it('should abort when test succeeded', async () => {
const stream = run({
files: [fixtures.path('test-runner', 'aborts', 'successful-test-still-call-abort.js')]
files: [
fixtures.path(
'test-runner',
'aborts',
'successful-test-still-call-abort.js'
),
],
});

let passedTestCount = 0;
Expand All @@ -177,7 +201,13 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {

it('should abort when test failed', async () => {
const stream = run({
files: [fixtures.path('test-runner', 'aborts', 'failed-test-still-call-abort.js')]
files: [
fixtures.path(
'test-runner',
'aborts',
'failed-test-still-call-abort.js'
),
],
});

let passedTestCount = 0;
Expand All @@ -201,7 +231,6 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
assert.strictEqual(passedTestCount, 0, new Error('no tests should pass'));
assert.strictEqual(failedTestCount, 2);
});

});

describe('sharding', () => {
Expand Down Expand Up @@ -317,7 +346,7 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {
executedTestFiles.push(passedTest.file);
});
// eslint-disable-next-line no-unused-vars
for await (const _ of stream);
for await (const _ of stream) ;

assert.deepStrictEqual(executedTestFiles, [
join(shardsTestsFixtures, 'a.cjs'),
Expand Down Expand Up @@ -347,7 +376,7 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {

await Promise.all(testStreams.map(async (stream) => {
// eslint-disable-next-line no-unused-vars
for await (const _ of stream);
for await (const _ of stream) ;
}));

assert.deepStrictEqual(executedTestFiles, [...new Set(executedTestFiles)]);
Expand Down Expand Up @@ -375,7 +404,7 @@ describe('require(\'node:test\').run', { concurrency: true }, () => {

await Promise.all(testStreams.map(async (stream) => {
// eslint-disable-next-line no-unused-vars
for await (const _ of stream);
for await (const _ of stream) ;
}));

assert.deepStrictEqual(executedTestFiles.sort(), [...shardsTestsFiles].sort());
Expand Down