ov-components: Moved recording and broadcasting middleware logic

backend/src/middlewares/broadcasting.middleware.ts

@@ -0,0 +1,28 @@
+import { Request, Response, NextFunction } from 'express';
+import { GlobalPreferencesService } from '../services/global-preferences.service.js';
+import { RoomPreferences } from '@openvidu/call-common-types';
+import { LoggerService } from '../services/logger.service.js';
+
+export const withBroadcastingEnabled = async (req: Request, res: Response, next: NextFunction) => {
+	try {
+		const preferences = await GlobalPreferencesService.getInstance().getRoomPreferences();
+
+		if (preferences) {
+			const { broadcastingPreferences } = preferences.value as RoomPreferences;
+
+			if (!broadcastingPreferences.enabled) {
+				return res.status(403).json({ message: 'Broadcasting is disabled in this room.' });
+			}
+
+			return next();
+		}
+
+		LoggerService.getInstance().error(
+			'No room preferences found checking broadcasting preferences. Refusing access.'
+		);
+		return res.status(403).json({ message: 'Broadcasting is disabled in this room.' });
+	} catch (error) {
+		LoggerService.getInstance().error('Error checking broadcasting preferences:' + error);
+		return res.status(403).json({ message: 'Broadcasting is disabled in this room.' });
+	}
+};

backend/src/middlewares/index.ts

@@ -1 +1,3 @@
-export * from './auth.middleware.js';
+export * from './auth.middleware.js';
+export * from './recording.middleware.js';
+export * from './broadcasting.middleware.js';

backend/src/middlewares/recording.middleware.ts

@@ -0,0 +1,26 @@
+import { Request, Response, NextFunction } from 'express';
+import { GlobalPreferencesService } from '../services/global-preferences.service.js';
+import { RoomPreferences } from '@openvidu/call-common-types';
+import { LoggerService } from '../services/logger.service.js';
+
+export const withRecordingEnabled = async (req: Request, res: Response, next: NextFunction) => {
+	try {
+		const preferences = await GlobalPreferencesService.getInstance().getRoomPreferences();
+
+		if (preferences) {
+			const { recordingPreferences } = preferences.value as RoomPreferences;
+
+			if (!recordingPreferences.enabled) {
+				return res.status(403).json({ message: 'Recording is disabled in this room.' });
+			}
+
+			return next();
+		}
+
+		LoggerService.getInstance().error('No room preferences found checking recording preferences. Refusing access.');
+		return res.status(403).json({ message: 'Recording is disabled in this room.' });
+	} catch (error) {
+		LoggerService.getInstance().error('Error checking recording preferences:' + error);
+		return res.status(403).json({ message: 'Recording is disabled in this room.' });
+	}
+};

backend/src/routes/api.routes.ts

@@ -7,7 +7,9 @@ import * as authCtrl from '../controllers/auth.controller.js';
 import { getConfig } from '../controllers/global-preferences/global-preferences.controller.js';
 import { healthCheck } from '../controllers/healthcheck.controller.js';
 import { withAdminAndUserBasicAuth, withAdminBasicAuth, withUserBasicAuth } from '../middlewares/auth.middleware.js';
-import { withBroadcastingEnabled, withRecordingEnabled } from '../services/global-preferences.service.js';
+import { withRecordingEnabled } from '../middlewares/recording.middleware.js';
+import { withBroadcastingEnabled } from '../middlewares/broadcasting.middleware.js';
+
 import {
 	getRoomPreferences,
 	updateRoomPreferences

backend/src/services/global-preferences.service.ts

@@ -1,51 +1,6 @@
 import { RoomPreferences } from '@openvidu/call-common-types';
 import { LoggerService } from './logger.service.js';
 import { GlobalPreferencesModel } from '../models/global-preferences.model.js';
-import { Request, Response, NextFunction } from 'express';
-
-export const withRecordingEnabled = async (req: Request, res: Response, next: NextFunction) => {
-	try {
-		const preferences = await GlobalPreferencesService.getInstance().getRoomPreferences();
-
-		if (preferences) {
-			const { recordingPreferences } = preferences.value as RoomPreferences;
-
-			if (!recordingPreferences.enabled) {
-				return res.status(403).json({ message: 'Recording is disabled in this room.' });
-			}
-
-			return next();
-		}
-
-		LoggerService.getInstance().error('No room preferences found checking recording preferences. Refusing access.');
-		return res.status(403).json({ message: 'Recording is disabled in this room.' });
-	} catch (error) {
-		LoggerService.getInstance().error('Error checking recording preferences:' + error);
-		return res.status(403).json({ message: 'Recording is disabled in this room.' });
-	}
-};
-
-export const withBroadcastingEnabled = async (req: Request, res: Response, next: NextFunction) => {
-	try {
-		const preferences = await GlobalPreferencesService.getInstance().getRoomPreferences();
-
-		if (preferences) {
-			const { broadcastingPreferences } = preferences.value as RoomPreferences;
-
-			if (!broadcastingPreferences.enabled) {
-				return res.status(403).json({ message: 'Broadcasting is disabled in this room.' });
-			}
-
-			return next();
-		}
-
-		LoggerService.getInstance().error('No room preferences found checking broadcasting preferences. Refusing access.');
-		return res.status(403).json({ message: 'Broadcasting is disabled in this room.' });
-	} catch (error) {
-		LoggerService.getInstance().error('Error checking broadcasting preferences:' + error);
-		return res.status(403).json({ message: 'Broadcasting is disabled in this room.' });
-	}
-};
 
 export class GlobalPreferencesService {
 	protected logger = LoggerService.getInstance();