Modernize (#1513)

Author: ibc

.editorconfig

@@ -0,0 +1,19 @@
+# EditorConfig is awesome: https://editorconfig.org
+
+root = true
+
+[*]
+indent_style = tab
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.{ts,mts,mjs,cjs,js}]
+indent_style = tab
+
+[*.json]
+indent_style = tab
+
+[*.md]
+indent_style = tab

CHANGELOG.md

@@ -3,6 +3,7 @@
 ### NEXT
 
 - CI: Remove redundant hosts `macos-14` and `windows-2022` from `mediasoup-worker-prebuild` job ([PR #1506](https://github.com/versatica/mediasoup/pull/1506)).
+- Node: Modernize code ([PR #1513](https://github.com/versatica/mediasoup/pull/1513)).
 
 ### 3.15.6
 

eslint.config.mjs

@@ -8,7 +8,7 @@ const config = tsEslint.config(
 	{
 		languageOptions: {
 			sourceType: 'module',
-			globals: { ...globals.nodeBuiltin },
+			globals: { ...globals.node },
 		},
 		linterOptions: {
 			noInlineConfig: false,
@@ -108,18 +108,20 @@ const config = tsEslint.config(
 			yoda: 2,
 		},
 	},
-	// NOTE: We need to apply this only to .ts files (and not to .mjs files).
+	// NOTE: We need to apply this only to .ts source files (and not to .mjs
+	// files).
 	...tsEslint.configs.recommendedTypeChecked.map(item => ({
 		...item,
 		files: ['node/src/**/*.ts'],
 	})),
-	// NOTE: We need to apply this only to .ts files (and not to .mjs files).
+	// NOTE: We need to apply this only to .ts source files (and not to .mjs
+	// files).
 	...tsEslint.configs.stylisticTypeChecked.map(item => ({
 		...item,
 		files: ['node/src/**/*.ts'],
 	})),
 	{
-		name: 'mediasoup .ts files',
+		name: '.ts source files',
 		files: ['node/src/**/*.ts'],
 		languageOptions: {
 			parserOptions: {
@@ -153,7 +155,10 @@ const config = tsEslint.config(
 			],
 			// Sorry, we need many `any` usage.
 			'@typescript-eslint/no-explicit-any': 0,
-			'@typescript-eslint/explicit-function-return-type': 2,
+			'@typescript-eslint/explicit-function-return-type': [
+				2,
+				{ allowExpressions: true },
+			],
 			'@typescript-eslint/no-unsafe-member-access': 0,
 			'@typescript-eslint/no-unsafe-assignment': 0,
 			'@typescript-eslint/no-unsafe-call': 0,
@@ -169,7 +174,7 @@ const config = tsEslint.config(
 		},
 	},
 	{
-		name: 'mediasoup .ts test files',
+		name: '.ts test files',
 		...jestEslint.configs['flat/recommended'],
 		files: ['node/src/test/**/*.ts'],
 		rules: {

jest.config.mjs

@@ -0,0 +1,18 @@
+const config = {
+	verbose: true,
+	testEnvironment: 'node',
+	testRegex: 'node/src/test/test-.*\\.ts',
+	transform: {
+		'^.+\\.ts?$': ['ts-jest'],
+	},
+	coveragePathIgnorePatterns: [
+		'node/src/Logger.ts',
+		'node/src/enhancedEvents.ts',
+		'node/src/fbs',
+		'node/src/test',
+	],
+	modulePathIgnorePatterns: ['worker', 'rust', 'target'],
+	cacheDirectory: '.cache/jest',
+};
+
+export default config;

node/src/ActiveSpeakerObserver.ts

@@ -44,7 +44,7 @@ export class ActiveSpeakerObserverImpl<
 		return 'activespeaker';
 	}
 
-	get observer(): ActiveSpeakerObserverObserver {
+	override get observer(): ActiveSpeakerObserverObserver {
 		return super.observer;
 	}
 

node/src/AudioLevelObserver.ts

@@ -46,7 +46,7 @@ export class AudioLevelObserverImpl<
 		return 'audiolevel';
 	}
 
-	get observer(): AudioLevelObserverObserver {
+	override get observer(): AudioLevelObserverObserver {
 		return super.observer;
 	}
 

node/src/Channel.ts

@@ -48,7 +48,7 @@ export class Channel extends EnhancedEventEmitter {
 	readonly #sents: Map<number, Sent> = new Map();
 
 	// Buffer for reading messages from the worker.
-	#recvBuffer = Buffer.alloc(0);
+	#recvBuffer: Buffer = Buffer.alloc(0);
 
 	// flatbuffers builder.
 	#bufferBuilder: flatbuffers.Builder = new flatbuffers.Builder(1024);

node/src/DirectTransport.ts

@@ -72,19 +72,19 @@ export class DirectTransportImpl<
 		return 'direct';
 	}
 
-	get observer(): DirectTransportObserver {
+	override get observer(): DirectTransportObserver {
 		return super.observer;
 	}
 
-	close(): void {
+	override close(): void {
 		if (this.closed) {
 			return;
 		}
 
 		super.close();
 	}
 
-	routerClosed(): void {
+	override routerClosed(): void {
 		if (this.closed) {
 			return;
 		}
@@ -134,21 +134,21 @@ export class DirectTransportImpl<
 	}
 
 	// eslint-disable-next-line @typescript-eslint/no-unused-vars, @typescript-eslint/require-await
-	async setMaxIncomingBitrate(bitrate: number): Promise<void> {
+	override async setMaxIncomingBitrate(bitrate: number): Promise<void> {
 		throw new UnsupportedError(
 			'setMaxIncomingBitrate() not implemented in DirectTransport'
 		);
 	}
 
 	// eslint-disable-next-line @typescript-eslint/no-unused-vars, @typescript-eslint/require-await
-	async setMaxOutgoingBitrate(bitrate: number): Promise<void> {
+	override async setMaxOutgoingBitrate(bitrate: number): Promise<void> {
 		throw new UnsupportedError(
 			'setMaxOutgoingBitrate() not implemented in DirectTransport'
 		);
 	}
 
 	// eslint-disable-next-line @typescript-eslint/no-unused-vars, @typescript-eslint/require-await
-	async setMinOutgoingBitrate(bitrate: number): Promise<void> {
+	override async setMinOutgoingBitrate(bitrate: number): Promise<void> {
 		throw new UnsupportedError(
 			'setMinOutgoingBitrate() not implemented in DirectTransport'
 		);

node/src/PipeTransport.ts

@@ -96,7 +96,7 @@ export class PipeTransportImpl<PipeTransportAppData extends AppData = AppData>
 		return 'pipe';
 	}
 
-	get observer(): PipeTransportObserver {
+	override get observer(): PipeTransportObserver {
 		return super.observer;
 	}
 
@@ -116,7 +116,7 @@ export class PipeTransportImpl<PipeTransportAppData extends AppData = AppData>
 		return this.#data.srtpParameters;
 	}
 
-	close(): void {
+	override close(): void {
 		if (this.closed) {
 			return;
 		}
@@ -128,7 +128,7 @@ export class PipeTransportImpl<PipeTransportAppData extends AppData = AppData>
 		super.close();
 	}
 
-	routerClosed(): void {
+	override routerClosed(): void {
 		if (this.closed) {
 			return;
 		}
@@ -213,7 +213,7 @@ export class PipeTransportImpl<PipeTransportAppData extends AppData = AppData>
 		}
 	}
 
-	async consume<ConsumerAppData extends AppData = AppData>({
+	override async consume<ConsumerAppData extends AppData = AppData>({
 		producerId,
 		appData,
 	}: PipeConsumerOptions<ConsumerAppData>): Promise<Consumer<ConsumerAppData>> {

node/src/PlainTransport.ts

@@ -89,7 +89,7 @@ export class PlainTransportImpl<PlainTransportAppData extends AppData = AppData>
 		return 'plain';
 	}
 
-	get observer(): PlainTransportObserver {
+	override get observer(): PlainTransportObserver {
 		return super.observer;
 	}
 
@@ -113,7 +113,7 @@ export class PlainTransportImpl<PlainTransportAppData extends AppData = AppData>
 		return this.#data.srtpParameters;
 	}
 
-	close(): void {
+	override close(): void {
 		if (this.closed) {
 			return;
 		}
@@ -125,7 +125,7 @@ export class PlainTransportImpl<PlainTransportAppData extends AppData = AppData>
 		super.close();
 	}
 
-	routerClosed(): void {
+	override routerClosed(): void {
 		if (this.closed) {
 			return;
 		}