From cdfc1c86923332a6993e0d01455f19228646f987 Mon Sep 17 00:00:00 2001
From: Nitzan Uziely <linkgoron@gmail.com>
Date: Sat, 20 Mar 2021 01:02:18 +0200
Subject: [PATCH] child_process: cleanup AbortSignal duplication

cleanup AbortSignal child_process code duplication

PR-URL: https://github.com/nodejs/node/pull/37823
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
---
 lib/child_process.js | 65 +++++++++++---------------------------------
 1 file changed, 16 insertions(+), 49 deletions(-)

diff --git a/lib/child_process.js b/lib/child_process.js
index 18996f8a5643ce..da2f9628ce0808 100644
--- a/lib/child_process.js
+++ b/lib/child_process.js
@@ -605,23 +605,6 @@ function spawn(file, args, options) {
   const killSignal = sanitizeKillSignal(options.killSignal);
   const child = new ChildProcess();
 
-  if (options.signal) {
-    const signal = options.signal;
-    if (signal.aborted) {
-      onAbortListener();
-    } else {
-      signal.addEventListener('abort', onAbortListener, { once: true });
-      child.once('exit',
-                 () => signal.removeEventListener('abort', onAbortListener));
-    }
-
-    function onAbortListener() {
-      process.nextTick(() => {
-        abortChildProcess(child, killSignal);
-      });
-    }
-  }
-
   debug('spawn', options);
   child.spawn(options);
 
@@ -645,6 +628,21 @@ function spawn(file, args, options) {
     });
   }
 
+  if (options.signal) {
+    const signal = options.signal;
+    if (signal.aborted) {
+      process.nextTick(onAbortListener);
+    } else {
+      signal.addEventListener('abort', onAbortListener, { once: true });
+      child.once('exit',
+                 () => signal.removeEventListener('abort', onAbortListener));
+    }
+
+    function onAbortListener() {
+      abortChildProcess(child, killSignal);
+    }
+  }
+
   return child;
 }
 
@@ -778,37 +776,6 @@ function sanitizeKillSignal(killSignal) {
   }
 }
 
-// This level of indirection is here because the other child_process methods
-// call spawn internally but should use different cancellation logic.
-function spawnWithSignal(file, args, options) {
-  // Remove signal from options to spawn
-  // to avoid double emitting of AbortError
-  const opts = options && typeof options === 'object' && ('signal' in options) ?
-    { ...options, signal: undefined } :
-    options;
-
-  if (options?.signal) {
-    // Validate signal, if present
-    validateAbortSignal(options.signal, 'options.signal');
-  }
-  const child = spawn(file, args, opts);
-
-  if (options?.signal) {
-    const killSignal = sanitizeKillSignal(options.killSignal);
-
-    function kill() {
-      abortChildProcess(child, killSignal);
-    }
-    if (options.signal.aborted) {
-      process.nextTick(kill);
-    } else {
-      options.signal.addEventListener('abort', kill, { once: true });
-      const remove = () => options.signal.removeEventListener('abort', kill);
-      child.once('exit', remove);
-    }
-  }
-  return child;
-}
 module.exports = {
   _forkChild,
   ChildProcess,
@@ -817,6 +784,6 @@ module.exports = {
   execFileSync,
   execSync,
   fork,
-  spawn: spawnWithSignal,
+  spawn,
   spawnSync
 };