fix: moved setMaxListeners to a utility function

[ci skip]

Author: tegefaulkes

package-lock.json

@@ -10,7 +10,6 @@ import type {
   StreamReasonToCode,
 } from './types';
 import type { Header } from './native/types';
-import nodesEvents from 'events';
 import Logger from '@matrixai/logger';
 import { AbstractEvent, EventAll } from '@matrixai/events';
 import {
@@ -376,7 +375,7 @@ class QUICServer {
     this.stopAbortController = new AbortController();
     // Since we have a one-to-many relationship with clients and connections,
     // we want to up the warning limit on the stopAbortController
-    nodesEvents.setMaxListeners(100000, this.stopAbortController.signal);
+    utils.setMaxListeners(this.stopAbortController.signal);
     let address: string;
     if (!this.isSocketShared) {
       address = utils.buildAddress(host, port);

src/QUICServer.ts

@@ -1,7 +1,6 @@
 import type QUICServer from './QUICServer';
 import type { Host, Hostname, Port, ResolveHostname } from './types';
 import type { Header } from './native/types';
-import nodesEvents from 'events';
 import dgram from 'dgram';
 import Logger from '@matrixai/logger';
 import { StartStop, ready, running } from '@matrixai/async-init/dist/StartStop';
@@ -251,7 +250,7 @@ class QUICSocket {
   } = {}): Promise<void> {
     // Since we have a one-to-many relationship with clients and connections,
     // we want to up the warning limit on the EventTarget
-    nodesEvents.setMaxListeners(100000, this[_eventTarget]);
+    utils.setMaxListeners(this[_eventTarget]);
     let address = utils.buildAddress(host, port);
     this.logger.info(`Start ${this.constructor.name} on ${address}`);
     // Resolves the host which could be a hostname and acquire the type.

src/QUICSocket.ts

@@ -10,6 +10,7 @@ import type {
   StreamId,
 } from './types';
 import dns from 'dns';
+import events from 'events';
 import { IPv4, IPv6, Validator } from 'ip-num';
 import QUICConnectionId from './QUICConnectionId';
 import * as errors from './errors';
@@ -554,6 +555,20 @@ function isStreamReset(e: Error): number | false {
   }
 }
 
+/**
+ * Increases the total number of registered event handlers before a node warning is emitted.
+ * In most cases this is not needed but in the case where you have one event emitter for multiple handlers you'll need
+ * to increase the limit.
+ * @param target - The specific `EventTarget` or `EventEmitter` to increase the warning for.
+ * @param limit - The limit before the warning is emitted, defaults to 100000.
+ */
+function setMaxListeners(
+  target: EventTarget | NodeJS.EventEmitter,
+  limit: number = 100000,
+) {
+  events.setMaxListeners(limit, target);
+}
+
 export {
   textEncoder,
   textDecoder,
@@ -592,4 +607,5 @@ export {
   isStreamUnidirectional,
   isStreamStopped,
   isStreamReset,
+  setMaxListeners,
 };