test: refactor code to use AbortSignal.abort()

PR-URL: #37798
Refs: whatwg/dom#960
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Reviewed-By: Zijian Liu <lxxyxzj@gmail.com>
Reviewed-By: Zeyu Yang <himself65@outlook.com>

Author: manekinekko

test/parallel/test-child-process-exec-abortcontroller-promisified.js

@@ -37,9 +37,7 @@ const waitCommand = common.isLinux ?
 }
 
 {
-  const ac = new AbortController();
-  const { signal } = ac;
-  ac.abort();
+  const signal = AbortSignal.abort(); // Abort in advance
   const promise = execPromisifed(waitCommand, { signal });
 
   assert.rejects(promise, /AbortError/, 'pre aborted signal failed')

test/parallel/test-child-process-execFile-promisified-abortController.js

@@ -29,9 +29,7 @@ const invalidArgTypeError = {
 
 {
   // Verify that the signal option works properly when already aborted
-  const ac = new AbortController();
-  const { signal } = ac;
-  ac.abort();
+  const signal = AbortSignal.abort();
 
   assert.rejects(
     promisified(process.execPath, [echoFixture, 0], { signal }),

test/parallel/test-child-process-execfile.js

@@ -69,9 +69,7 @@ const execOpts = { encoding: 'utf8', shell: true };
 
 {
   // Verify that does not spawn a child if already aborted
-  const ac = new AbortController();
-  const { signal } = ac;
-  ac.abort();
+  const signal = AbortSignal.abort();
 
   const check = common.mustCall((err) => {
     assert.strictEqual(err.code, 'ABORT_ERR');

test/parallel/test-child-process-fork-abort-signal.js

@@ -23,9 +23,7 @@ const { fork } = require('child_process');
 }
 {
   // Test passing an already aborted signal to a forked child_process
-  const ac = new AbortController();
-  const { signal } = ac;
-  ac.abort();
+  const signal = AbortSignal.abort();
   const cp = fork(fixtures.path('child-process-stay-alive-forever.js'), {
     signal
   });
@@ -40,9 +38,7 @@ const { fork } = require('child_process');
 
 {
   // Test passing a different kill signal
-  const ac = new AbortController();
-  const { signal } = ac;
-  ac.abort();
+  const signal = AbortSignal.abort();
   const cp = fork(fixtures.path('child-process-stay-alive-forever.js'), {
     signal,
     killSignal: 'SIGKILL',

test/parallel/test-child-process-spawn-controller.js

@@ -29,10 +29,7 @@ const aliveScript = fixtures.path('child-process-stay-alive-forever.js');
 
 {
   // Verify that passing an already-aborted signal works.
-  const controller = new AbortController();
-  const { signal } = controller;
-
-  controller.abort();
+  const signal = AbortSignal.abort();
 
   const cp = spawn(process.execPath, [aliveScript], {
     signal,

test/parallel/test-dgram-close-signal.js

@@ -25,9 +25,7 @@ const dgram = require('dgram');
 
 {
   // Test close with pre-aborted signal.
-  const controller = new AbortController();
-  controller.abort();
-  const { signal } = controller;
+  const signal = AbortSignal.abort();
   const server = dgram.createSocket({ type: 'udp4', signal });
   server.on('close', common.mustCall());
 }

test/parallel/test-event-on-async-iterator.js

@@ -248,28 +248,26 @@ async function nodeEventTarget() {
 
 async function abortableOnBefore() {
   const ee = new EventEmitter();
-  const ac = new AbortController();
-  ac.abort();
+  const abortedSignal = AbortSignal.abort();
   [1, {}, null, false, 'hi'].forEach((signal) => {
     assert.throws(() => on(ee, 'foo', { signal }), {
       code: 'ERR_INVALID_ARG_TYPE'
     });
   });
-  assert.throws(() => on(ee, 'foo', { signal: ac.signal }), {
+  assert.throws(() => on(ee, 'foo', { signal: abortedSignal }), {
     name: 'AbortError'
   });
 }
 
 async function eventTargetAbortableOnBefore() {
   const et = new EventTarget();
-  const ac = new AbortController();
-  ac.abort();
+  const abortedSignal = AbortSignal.abort();
   [1, {}, null, false, 'hi'].forEach((signal) => {
     assert.throws(() => on(et, 'foo', { signal }), {
       code: 'ERR_INVALID_ARG_TYPE'
     });
   });
-  assert.throws(() => on(et, 'foo', { signal: ac.signal }), {
+  assert.throws(() => on(et, 'foo', { signal: abortedSignal }), {
     name: 'AbortError'
   });
 }

test/parallel/test-events-once.js

@@ -133,17 +133,16 @@ async function prioritizesEventEmitter() {
 
 async function abortSignalBefore() {
   const ee = new EventEmitter();
-  const ac = new AbortController();
   ee.on('error', common.mustNotCall());
-  ac.abort();
+  const abortedSignal = AbortSignal.abort();
 
   await Promise.all([1, {}, 'hi', null, false].map((signal) => {
     return rejects(once(ee, 'foo', { signal }), {
       code: 'ERR_INVALID_ARG_TYPE'
     });
   }));
 
-  return rejects(once(ee, 'foo', { signal: ac.signal }), {
+  return rejects(once(ee, 'foo', { signal: abortedSignal }), {
     name: 'AbortError'
   });
 }
@@ -184,16 +183,15 @@ async function abortSignalRemoveListener() {
 
 async function eventTargetAbortSignalBefore() {
   const et = new EventTarget();
-  const ac = new AbortController();
-  ac.abort();
+  const abortedSignal = AbortSignal.abort();
 
   await Promise.all([1, {}, 'hi', null, false].map((signal) => {
     return rejects(once(et, 'foo', { signal }), {
       code: 'ERR_INVALID_ARG_TYPE'
     });
   }));
 
-  return rejects(once(et, 'foo', { signal: ac.signal }), {
+  return rejects(once(et, 'foo', { signal: abortedSignal }), {
     name: 'AbortError'
   });
 }

test/parallel/test-fs-promises-file-handle-readFile.js

@@ -58,9 +58,7 @@ async function doReadAndCancel() {
     const fileHandle = await open(filePathForHandle, 'w+');
     const buffer = Buffer.from('Dogs running'.repeat(10000), 'utf8');
     fs.writeFileSync(filePathForHandle, buffer);
-    const controller = new AbortController();
-    const { signal } = controller;
-    controller.abort();
+    const signal = AbortSignal.abort();
     await assert.rejects(readFile(fileHandle, { signal }), {
       name: 'AbortError'
     });

test/parallel/test-fs-promises-readfile.js

@@ -43,9 +43,7 @@ async function validateReadFileProc() {
 }
 
 function validateReadFileAbortLogicBefore() {
-  const controller = new AbortController();
-  const signal = controller.signal;
-  controller.abort();
+  const signal = AbortSignal.abort();
   assert.rejects(readFile(fn, { signal }), {
     name: 'AbortError'
   });