neoris/openvidu
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

backend: fix stopAllRecordings request adding participant role header

Browse Source 
- enhance stopAllRecordings function to filter active recordings
- validate responses
This commit is contained in:
Carlos Santos 2025-07-14 13:42:53 +02:00
parent 169030a995
commit bbd3c274c4
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
backend/tests/helpers/request-helpers.ts
View File

@ -19,6 +19,8 @@ import {
AuthMode, AuthMode,
AuthType, AuthType,
MeetRecordingAccess, MeetRecordingAccess,
MeetRecordingInfo,
MeetRecordingStatus,
MeetRoom, MeetRoom,
MeetRoomOptions, MeetRoomOptions,
ParticipantRole, ParticipantRole,
@ -662,23 +664,31 @@ export const downloadRecordings = async (
export const stopAllRecordings = async (moderatorCookie: string) => { export const stopAllRecordings = async (moderatorCookie: string) => {
checkAppIsRunning(); checkAppIsRunning();
const response = await getAllRecordings({ fields: 'recordingId' }); const response = await getAllRecordings();
const recordingIds: string[] = response.body.recordings.map(
(recording: { recordingId: string }) => recording.recordingId const recordingIds: string[] = response.body.recordings
); .filter((rec: MeetRecordingInfo) => rec.status === MeetRecordingStatus.ACTIVE)
.map((recording: { recordingId: string }) => recording.recordingId);
if (recordingIds.length === 0) { if (recordingIds.length === 0) {
return; return;
} }
console.log(`Stopping ${recordingIds.length} recordings...`); console.log(`Stopping ${recordingIds.length} recordings...`, recordingIds);
const tasks = recordingIds.map((recordingId: string) => const tasks = recordingIds.map((recordingId: string) =>
request(app) request(app)
.post(`${INTERNAL_CONFIG.INTERNAL_API_BASE_PATH_V1}/recordings/${recordingId}/stop`) .post(`${INTERNAL_CONFIG.INTERNAL_API_BASE_PATH_V1}/recordings/${recordingId}/stop`)
.set(INTERNAL_CONFIG.PARTICIPANT_ROLE_HEADER, ParticipantRole.MODERATOR)
.set('Cookie', moderatorCookie) .set('Cookie', moderatorCookie)
.send() .send()
); );
await Promise.all(tasks); const results = await Promise.all(tasks);
// Check responses
results.forEach((response) => {
console.log(`Response for stopping recording: ${response.status}`, response.body);
expect(response.status).toBe(202);
});
await sleep('1s'); await sleep('1s');
}; };