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

backend: fix stale recording evaluation logic and enhance related tests

Browse Source
This commit is contained in:
Carlos Santos 2025-08-14 19:25:55 +02:00
parent 8d45826f8e
commit 4f3fb6cec6
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
backend/tests/integration/api/recordings/stale-recordings-cleanup.test.ts
View File

@ -464,7 +464,12 @@ describe('Recording Cleanup Tests', () => {
const roomId = testRooms.staleRecording; const roomId = testRooms.staleRecording;
const egressId = `EG_${roomId}`; const egressId = `EG_${roomId}`;
const recordingId = `${roomId}--${egressId}--1234567890`; const recordingId = `${roomId}--${egressId}--1234567890`;
const staleUpdateTime = Date.now() - ms(INTERNAL_CONFIG.RECORDING_STALE_AFTER);
// Use Jest fake timers to precisely control Date.now()
jest.useFakeTimers();
const now = 1_000_000;
jest.setSystemTime(now);
const staleUpdateTime = now - ms(INTERNAL_CONFIG.RECORDING_STALE_AFTER);
const egressInfo = createMockEgressInfo(roomId, egressId, EgressStatus.EGRESS_ACTIVE, staleUpdateTime); const egressInfo = createMockEgressInfo(roomId, egressId, EgressStatus.EGRESS_ACTIVE, staleUpdateTime);
// Mock recording as active // Mock recording as active
@ -480,14 +485,11 @@ describe('Recording Cleanup Tests', () => {
const result = await recordingService['evaluateAndAbortStaleRecording'](egressInfo); const result = await recordingService['evaluateAndAbortStaleRecording'](egressInfo);
// Verify that the recording was aborted // Verify that the recording was aborted
expect(result).toBe(true); expect(result).toBe(false);
expect(recordingService.getRecording).toHaveBeenCalledWith(recordingId); expect(recordingService.getRecording).toHaveBeenCalledWith(recordingId);
expect(livekitService.roomExists).toHaveBeenCalledWith(roomId); expect(livekitService.roomExists).toHaveBeenCalledWith(roomId);
expect((recordingService as never)['updateRecordingStatus']).toHaveBeenCalledWith( expect((recordingService as never)['updateRecordingStatus']).not.toHaveBeenCalled();
recordingId, expect(livekitService.stopEgress).not.toHaveBeenCalledWith(egressId);
MeetRecordingStatus.ABORTED
);
expect(livekitService.stopEgress).toHaveBeenCalledWith(egressId);
}); });
it('should handle errors during recording processing and rethrow them', async () => { it('should handle errors during recording processing and rethrow them', async () => {