fix: switched to increasing the warning limit for only the QUICSocket EventTarget

[ci skip]

Author: tegefaulkes

src/QUICClient.ts

@@ -28,9 +28,6 @@ import { clientDefault, minIdleTimeout } from './config';
 import * as utils from './utils';
 import * as events from './events';
 import * as errors from './errors';
-import nodeEvents from 'events';
-nodeEvents.setMaxListeners(1000000);
-
 interface QUICClient extends CreateDestroy {}
 @CreateDestroy({
   eventDestroy: events.EventQUICClientDestroy,

src/QUICSocket.ts

@@ -1,10 +1,12 @@
 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';
 import { utils as errorsUtils } from '@matrixai/errors';
+import { _eventTarget } from '@matrixai/events/dist/utils';
 import QUICConnectionId from './QUICConnectionId';
 import QUICConnectionMap from './QUICConnectionMap';
 import { quiche } from './native';
@@ -247,6 +249,9 @@ class QUICSocket {
     reuseAddr?: boolean;
     ipv6Only?: boolean;
   } = {}): 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]);
     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.

tests/QUICClient.test.ts

@@ -1935,7 +1935,7 @@ describe(QUICClient.name, () => {
     }
     const clients = await Promise.all(clientPs);
     await connectionEventProm.p;
-    await Promise.all(clients.map(client => client.destroy({ force: true })));
+    await Promise.all(clients.map((client) => client.destroy({ force: true })));
     await sharedSocket.stop({ force: true });
     await server.stop({ force: true });
   });