testapp: add functionality to delete all recordings and enhance UI for action buttons

testapp/public/css/home.css

@@ -27,6 +27,10 @@ html {
 	transform: translate(-50%, -50%);
 }
 
+.action-buttons-container {
+	display: inline-flex;
+	gap: 2px;
+}
 .rooms-container {
 	flex: 2;
 	background: white;

testapp/public/views/index.mustache

@@ -21,17 +21,31 @@
 				</div>
 
 				<div class="rooms-list">
-					<div class="mb-3 text-center">
+					<div class="action-buttons-container mb-3 text-center">
-						<form action="/delete-all-rooms" method="post">
+						<div class="mb-3 text-center">
-							<button
+							<form action="/delete-all-rooms" method="post">
-								type="submit"
+								<button
-								class="btn btn-danger btn-sm"
+									type="submit"
-								id="delete-all-rooms"
+									class="btn btn-danger btn-sm"
-							>
+									id="delete-all-rooms"
-								Delete All Rooms
+								>
-							</button>
+									Delete All Rooms
-						</form>
+								</button>
+							</form>
+						</div>
+						<div class="mb-3 text-center">
+							<form action="/delete-all-recordings" method="post">
+								<button
+									type="submit"
+									class="btn btn-danger btn-sm"
+									id="delete-all-rooms"
+								>
+									Delete All Recordings
+								</button>
+							</form>
+						</div>
 					</div>
+
 					{{#rooms.length}}
 					<ul class="list-group">
 						{{#rooms}}

testapp/src/controllers/homeController.ts

@@ -5,6 +5,10 @@ import {
 	deleteRoom,
 	deleteAllRooms,
 } from '../services/roomService';
+import {
+	deleteAllRecordings,
+	getAllRecordings,
+} from '../services/recordingService';
 
 export const getHome = async (req: Request, res: Response) => {
 	try {
@@ -61,6 +65,7 @@ export const deleteAllRoomsCtrl = async (_req: Request, res: Response) => {
 			return;
 		}
 		const roomIds = allRooms.rooms.map((room) => room.roomId);
+		console.log(`Deleting ${roomIds.length} rooms`, roomIds);
 		await deleteAllRooms(roomIds);
 		res.render('index', { rooms: [] });
 	} catch (error) {
@@ -70,26 +75,50 @@ export const deleteAllRoomsCtrl = async (_req: Request, res: Response) => {
 	}
 };
 
+export const deleteAllRecordingsCtrl = async (_req: Request, res: Response) => {
+	try {
+		const [{ recordings }, { rooms }] = await Promise.all([
+			getAllRecordings(),
+			getAllRooms(),
+		]);
+		if (recordings.length === 0) {
+			console.log('No recordings to delete');
+			res.render('index', { rooms });
+			return;
+		}
+		const recordingIds = recordings.map((recording) => recording.recordingId);
+		await deleteAllRecordings(recordingIds);
+		console.log(`Deleted ${recordingIds.length} recordings`);
+		res.render('index', { rooms });
+	} catch (error) {
+		console.error('Error deleting all recordings:', error);
+		res.status(500).send('Internal Server Error ' + JSON.stringify(error));
+		return;
+	}
+};
 
 /**
  * Converts flat form data to nested MeetRoomPreferences object
  */
 const processFormPreferences = (body: any): any => {
-    const preferences = {
+	const preferences = {
-        chatPreferences: {
+		chatPreferences: {
-            enabled: body['preferences.chatPreferences.enabled'] === 'on'
+			enabled: body['preferences.chatPreferences.enabled'] === 'on',
-        },
+		},
-        recordingPreferences: {
+		recordingPreferences: {
-            enabled: body['preferences.recordingPreferences.enabled'] === 'on',
+			enabled: body['preferences.recordingPreferences.enabled'] === 'on',
-            // Only include allowAccessTo if recording is enabled
+			// Only include allowAccessTo if recording is enabled
-            ...(body['preferences.recordingPreferences.enabled'] === 'on' && {
+			...(body['preferences.recordingPreferences.enabled'] === 'on' && {
-                allowAccessTo: body['preferences.recordingPreferences.allowAccessTo'] || 'admin-moderator-publisher'
+				allowAccessTo:
-            })
+					body['preferences.recordingPreferences.allowAccessTo'] ||
-        },
+					'admin-moderator-publisher',
-        virtualBackgroundPreferences: {
+			}),
-            enabled: body['preferences.virtualBackgroundPreferences.enabled'] === 'on'
+		},
-        }
+		virtualBackgroundPreferences: {
-    };
+			enabled:
+				body['preferences.virtualBackgroundPreferences.enabled'] === 'on',
+		},
+	};
 
-    return preferences;
+	return preferences;
-}
+};

testapp/src/index.ts

@@ -7,6 +7,7 @@ import {
 	postCreateRoom,
 	deleteRoomCtrl,
 	deleteAllRoomsCtrl,
+	deleteAllRecordingsCtrl,
 } from './controllers/homeController';
 import { handleWebhook, joinRoom } from './controllers/roomController';
 import { configService } from './services/configService';
@@ -34,6 +35,7 @@ app.get('/room', joinRoom);
 app.post('/room', postCreateRoom);
 app.post('/room/delete', deleteRoomCtrl);
 app.post('/delete-all-rooms', deleteAllRoomsCtrl);
+app.post('/delete-all-recordings', deleteAllRecordingsCtrl);
 app.post('/join-room', joinRoom);
 app.post('/webhook', (req, res) => {
 	handleWebhook(req, res, io);

testapp/src/services/recordingService.ts

@@ -0,0 +1,41 @@
+import { del, get } from '../utils/http';
+import { MeetRecordingInfo } from '../../../typings/src/recording.model';
+import { configService } from './configService';
+
+export const getAllRecordings = async (): Promise<{
+	pagination: { isTruncated: boolean; nextPageToken?: string };
+	recordings: MeetRecordingInfo[];
+}> => {
+	const url = `${configService.meetApiUrl}/recordings`;
+
+	let { pagination, recordings } = await get<{
+		pagination: any;
+		recordings: MeetRecordingInfo[];
+	}>(url, {
+		headers: { 'x-api-key': configService.apiKey },
+	});
+
+	while (pagination.isTruncated) {
+		const nextPageUrl = `${url}?nextPageToken=${pagination.nextPageToken}`;
+		const nextPageResult = await get<{
+			pagination: any;
+			recordings: MeetRecordingInfo[];
+		}>(nextPageUrl, {
+			headers: { 'x-api-key': configService.apiKey },
+		});
+		recordings.push(...nextPageResult.recordings);
+		pagination = nextPageResult.pagination;
+	}
+	return { pagination, recordings };
+};
+
+export const deleteAllRecordings = async (
+	recordingIds: string[]
+): Promise<void> => {
+	const url = `${
+		configService.meetApiUrl
+	}/recordings?recordingIds=${recordingIds.join(',')}`;
+	await del<void>(url, {
+		headers: { 'x-api-key': configService.apiKey },
+	});
+};

testapp/src/utils/http.ts

@@ -31,7 +31,14 @@ async function request<T>(
 		const text = await response.text();
 		throw new Error(`HTTP ${response.status}: ${text}`);
 	}
-	return response.json() as Promise<T>;
+
+	// Handle empty responses (e.g., for DELETE requests)
+	const text = await response.text();
+	if (!text) {
+		return {} as T;
+	}
+
+	return JSON.parse(text) as T;
 }
 
 export function get<T>(