fix(fetch): raise AbortSignal max event listeners (#1910)

Author: KhafraDev

lib/fetch/request.js

@@ -28,6 +28,7 @@ const { getGlobalOrigin } = require('./global')
 const { URLSerializer } = require('./dataURL')
 const { kHeadersList } = require('../core/symbols')
 const assert = require('assert')
+const { setMaxListeners, getEventListeners, defaultMaxListeners } = require('events')
 
 let TransformStream = globalThis.TransformStream
 
@@ -352,6 +353,11 @@ class Request {
         const abort = function () {
           acRef.deref()?.abort(this.reason)
         }
+
+        if (getEventListeners(signal, 'abort').length >= defaultMaxListeners) {
+          setMaxListeners(100, signal)
+        }
+
         signal.addEventListener('abort', abort, { once: true })
         requestFinalizer.register(this, { signal, abort })
       }

test/fetch/issue-node-46525.js

@@ -0,0 +1,28 @@
+'use strict'
+
+const { once } = require('events')
+const { createServer } = require('http')
+const { test } = require('tap')
+const { fetch } = require('../..')
+
+// https://github.com/nodejs/node/issues/46525
+test('No warning when reusing AbortController', async (t) => {
+  function onWarning (error) {
+    t.error(error, 'Got warning')
+  }
+
+  const server = createServer((req, res) => res.end()).listen(0)
+
+  await once(server, 'listening')
+
+  process.on('warning', onWarning)
+  t.teardown(() => {
+    process.off('warning', onWarning)
+    return server.close()
+  })
+
+  const controller = new AbortController()
+  for (let i = 0; i < 15; i++) {
+    await fetch(`http://localhost:${server.address().port}`, { signal: controller.signal })
+  }
+})