util: allow safely adding listener to abortSignal

Author: atlowChemi

lib/util.js

@@ -43,6 +43,7 @@ const {
   ObjectValues,
   ReflectApply,
   StringPrototypePadStart,
+  SymbolDispose,
 } = primordials;
 
 const {
@@ -63,6 +64,7 @@ const {
 } = require('internal/util/inspect');
 const { debuglog } = require('internal/util/debuglog');
 const {
+  validateAbortSignal,
   validateFunction,
   validateNumber,
 } = require('internal/validators');
@@ -73,6 +75,7 @@ const {
   deprecate,
   getSystemErrorMap,
   getSystemErrorName: internalErrorName,
+  kEmptyObject,
   promisify,
   toUSVString,
   defineLazyProperties,
@@ -86,6 +89,7 @@ function lazyAbortController() {
 }
 
 let internalDeepEqual;
+let kResistStopPropagation;
 
 /**
  * @deprecated since v4.0.0
@@ -345,11 +349,31 @@ function getSystemErrorName(err) {
   return internalErrorName(err);
 }
 
+function addSafeAbortSignalAbortListener(signal, listener, options = kEmptyObject) {
+  if (signal === undefined) {
+    throw new ERR_INVALID_ARG_TYPE('signal', 'AbortSignal', signal)
+  }
+  validateAbortSignal(signal, 'signal');
+  kResistStopPropagation ??= require('internal/event_target').kResistStopPropagation;
+  signal.addEventListener('abort', listener, { ...options, [kResistStopPropagation]: true });
+  const removeEventListener = () => {
+    signal.removeEventListener('abort', listener, options);
+  };
+  return {
+    __proto__: null,
+    removeEventListener,
+    [SymbolDispose]() {
+      removeEventListener();
+    },
+  };
+}
+
 // Keep the `exports =` so that various functions can still be monkeypatched
 module.exports = {
   _errnoException: errnoException,
   _exceptionWithHostPort: exceptionWithHostPort,
   _extend,
+  addSafeAbortSignalAbortListener,
   callbackify,
   debug: debuglog,
   debuglog,