Node: Add 'listenererror' in all entities

- 'listenererror' event is emitted when an event listener throws (only if it's a synchronous error, otherwise an unhandled rejection will happen anyway).
- Usage:
  ```ts
  consumer.on('listenererror', (eventName, error) => { ... });
  ```
- Related to ongoing issue #1188 (but it's not fixing it at all, this is just a tool that should be helpful in that issue).

node/src/Consumer.ts

@@ -173,6 +173,7 @@ export type ConsumerEvents =
 	layerschange: [ConsumerLayers?];
 	trace: [ConsumerTraceEventData];
 	rtp: [Buffer];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 	'@producerclose': [];

node/src/DataConsumer.ts

@@ -85,6 +85,7 @@ export type DataConsumerEvents =
 	message: [Buffer, number];
 	sctpsendbufferfull: [];
 	bufferedamountlow: [number];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 	'@dataproducerclose': [];

node/src/DataProducer.ts

@@ -61,6 +61,7 @@ export type DataProducerType = 'sctp' | 'direct';
 export type DataProducerEvents =
 {
 	transportclose: [];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 };

node/src/EnhancedEventEmitter.ts

@@ -23,8 +23,6 @@ export class EnhancedEventEmitter<E extends Events = Events> extends EventEmitte
 	 */
 	safeEmit<K extends keyof E & string>(eventName: K, ...args: E[K]): boolean
 	{
-		const numListeners = super.listenerCount(eventName);
-
 		try
 		{
 			return super.emit(eventName, ...args);
@@ -33,9 +31,19 @@ export class EnhancedEventEmitter<E extends Events = Events> extends EventEmitte
 		{
 			logger.error(
 				'safeEmit() | event listener threw an error [eventName:%s]:%o',
-				eventName, error);
-
-			return Boolean(numListeners);
+				eventName, error
+			);
+
+			try
+			{
+				super.emit('listenererror', eventName, error);
+			}
+			catch (error2)
+			{
+				// Ignore it.
+			}
+
+			return Boolean(super.listenerCount(eventName));
 		}
 	}
 

node/src/Producer.ts

@@ -134,6 +134,7 @@ export type ProducerEvents =
 	score: [ProducerScore[]];
 	videoorientationchange: [ProducerVideoOrientation];
 	trace: [ProducerTraceEventData];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 };

node/src/Router.ts

@@ -172,6 +172,7 @@ type PipeTransportPair =
 export type RouterEvents =
 {
 	workerclose: [];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 };

node/src/RtpObserver.ts

@@ -11,6 +11,7 @@ import * as FbsRtpObserver from './fbs/rtp-observer';
 export type RtpObserverEvents =
 {
 	routerclose: [];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 };

node/src/Transport.ts

@@ -154,6 +154,7 @@ export type TransportEvents =
 	routerclose: [];
 	listenserverclose: [];
 	trace: [TransportTraceEventData];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 	'@newproducer': [Producer];

node/src/WebRtcServer.ts

@@ -31,6 +31,7 @@ export type WebRtcServerListenInfo = TransportListenInfo;
 export type WebRtcServerEvents =
 {
 	workerclose: [];
+	listenererror: [string, Error];
 	// Private events.
 	'@close': [];
 };

node/src/Worker.ts

@@ -197,6 +197,7 @@ export type WorkerDump =
 export type WorkerEvents =
 {
 	died: [Error];
+	listenererror: [string, Error];
 	// Private events.
 	'@success': [];
 	'@failure': [Error];

node/src/tests/test-DirectTransport.ts

@@ -130,6 +130,24 @@ test('dataProducer.send() succeeds', async () =>
 	let lastSentMessageId = 0;
 	let lastRecvMessageId = 0;
 
+	console.log('TODO: REMOVE');
+	transport2.on('listenererror', (eventName, error) =>
+	{
+		throw new Error(`------ transport2 listener error [eventName:${eventName}]: ${error}`);
+	});
+
+	console.log('TODO: REMOVE');
+	dataProducer.on('listenererror', (eventName, error) =>
+	{
+		throw new Error(`------ dataProducer listener error [eventName:${eventName}]: ${error}`);
+	});
+
+	console.log('TODO: REMOVE');
+	dataConsumer.on('listenererror', (eventName, error) =>
+	{
+		throw new Error(`------ dataConsumer listener error [eventName:${eventName}]: ${error}`);
+	});
+
 	// eslint-disable-next-line no-async-promise-executor
 	await new Promise<void>(async (resolve) =>
 	{