chore: remove SIGTERM event handler

e2e/runner/test/signalListener.test.ts

@@ -1,20 +1,21 @@
 import { join } from 'node:path';
-import { expect, it } from '@rstest/core';
+import { it } from '@rstest/core';
 import { runRstestCli } from '../../scripts/';
 
-it('should exit correctly when signal listener exists', async () => {
- const { cli, expectExecSuccess } = await runRstestCli({
- command: 'rstest',
- args: ['run', 'signalListener.test.ts'],
- options: {
- nodeOptions: {
- cwd: join(__dirname, 'fixtures'),
+it.skipIf(process.platform === 'win32')(
+ 'should catch signal exit correctly when signal listener exists',
+ async () => {
+ const { expectExecFailed, expectLog } = await runRstestCli({
+ command: 'rstest',
+ args: ['run', 'signalListener.test.ts'],
+ options: {
+ nodeOptions: {
+ cwd: join(__dirname, 'fixtures'),
+ },
  },
- },
- });
- await expectExecSuccess();
+ });
+ await expectExecFailed();
 
- const logs = cli.stdout.split('\n').filter(Boolean);
-
- expect(logs.find((log) => log.includes('Test Files 1 passed'))).toBeDefined();
-});
+ expectLog(/Rstest exited unexpectedly with code 0/);
+ },
+);

packages/core/src/core/runTests.ts

@@ -448,8 +448,19 @@ export async function runTests(context: Rstest): Promise<void> {
  afterTestsWatchRun();
  });
  } else {
+ const unExpectedExit = (code?: number) => {
+ logger.log(
+ color.red(
+ `Rstest exited unexpectedly with code ${code}, terminating test run.`,
+ ),
+ );
+ process.exitCode = 1;
+ };
+ process.on('exit', unExpectedExit);
+
  await run();
  await pool.close();
  await closeServer();
+ process.off('exit', unExpectedExit);
  }
 }

packages/core/src/runtime/worker/index.ts

@@ -247,10 +247,6 @@ const loadFiles = async ({
  });
 };
 
-const onExit = () => {
- process.exit();
-};
-
 const runInPool = async (
  options: RunWorkerOptions['options'],
 ): Promise<
@@ -294,15 +290,11 @@ const runInPool = async (
  process.exit = exit;
  });
 
- process.off('SIGTERM', onExit);
-
  const teardown = async () => {
  await new Promise((resolve) => getRealTimers().setTimeout!(resolve));
 
  await Promise.all(cleanups.map((fn) => fn()));
  isTeardown = true;
- // should exit correctly when user's signal listener exists
- process.once('SIGTERM', onExit);
  };
 
  if (type === 'collect') {