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

tests: Enhance room deletion tests with custom MEETING_DEPARTURE_TIMEOUT and LiveKit room creation

Browse Source
This commit is contained in:
Carlos Santos 2025-05-07 11:36:15 +02:00
parent ecb50ec0e9
commit a5024fccf2
2 changed files with 29 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
backend/tests/integration/api/rooms/delete-room.test.ts
View File

@ -11,6 +11,9 @@ import {
sleep, sleep,
startTestServer startTestServer
} from '../../../helpers/request-helpers.js'; } from '../../../helpers/request-helpers.js';
import { RoomService } from '../../../../src/services/room.service.js';
import { container } from '../../../../src/config/dependency-injector.config.js';
import { setInternalConfig } from '../../../../src/config/internal-config.js';
describe('Room API Tests', () => { describe('Room API Tests', () => {
beforeAll(() => { beforeAll(() => {
@ -134,6 +137,16 @@ describe('Room API Tests', () => {
autoDeletionDate autoDeletionDate
}); });
const roomService = container.get(RoomService);
// Set MEETING_DEPARTURE_TIMEOUT to 1s to force the room to be closed immediately
setInternalConfig({
MEETING_DEPARTURE_TIMEOUT: '1s'
});
// Create livekit room with custom departure timeout
// This is needed to trigger the room_finished event
await roomService.createLivekitRoom(roomId);
// Join a participant to the room
await joinFakeParticipant(roomId, 'test-participant'); await joinFakeParticipant(roomId, 'test-participant');
const response = await deleteRoom(roomId, { force: false }); const response = await deleteRoom(roomId, { force: false });

21
backend/tests/integration/api/rooms/garbage-collector.test.ts
View File

@ -12,6 +12,8 @@ import {
sleep, sleep,
startTestServer startTestServer
} from '../../../helpers/request-helpers.js'; } from '../../../helpers/request-helpers.js';
import { container } from '../../../../src/config/dependency-injector.config.js';
import { RoomService } from '../../../../src/services/room.service.js';
describe('Room Garbage Collector Tests', () => { describe('Room Garbage Collector Tests', () => {
beforeAll(() => { beforeAll(() => {
@ -75,12 +77,21 @@ describe('Room Garbage Collector Tests', () => {
}); });
it('should delete a room after the last participant leaves when it was marked for deletion', async () => { it('should delete a room after the last participant leaves when it was marked for deletion', async () => {
const createdRoom = await createRoom({ const { roomId } = await createRoom({
roomIdPrefix: 'test-gc-lifecycle', roomIdPrefix: 'test-gc-lifecycle',
autoDeletionDate: Date.now() + ms('1s') autoDeletionDate: Date.now() + ms('1s')
}); });
await joinFakeParticipant(createdRoom.roomId, 'test-participant'); const roomService = container.get(RoomService);
// Set MEETING_DEPARTURE_TIMEOUT to 1s to force the room to be closed immediately
setInternalConfig({
MEETING_DEPARTURE_TIMEOUT: '1s'
});
// Create livekit room with custom departure timeout
// This is needed to trigger the room_finished event
await roomService.createLivekitRoom(roomId);
await joinFakeParticipant(roomId, 'test-participant');
// Wait for the auto-deletion date to pass // Wait for the auto-deletion date to pass
await sleep('1s'); await sleep('1s');
@ -88,7 +99,7 @@ describe('Room Garbage Collector Tests', () => {
// Should mark the room for deletion but not delete it yet // Should mark the room for deletion but not delete it yet
await runRoomGarbageCollector(); await runRoomGarbageCollector();
let response = await getRoom(createdRoom.roomId); let response = await getRoom(roomId);
expect(response.status).toBe(200); expect(response.status).toBe(200);
expect(response.body.markedForDeletion).toBe(true); expect(response.body.markedForDeletion).toBe(true);
expect(response.body.autoDeletionDate).toBeTruthy(); expect(response.body.autoDeletionDate).toBeTruthy();
@ -97,10 +108,10 @@ describe('Room Garbage Collector Tests', () => {
await disconnectFakeParticipants(); await disconnectFakeParticipants();
// Wait to receive webhook room_finished // Wait to receive webhook room_finished
await sleep('4s'); await sleep('1s');
// Verify that the room is deleted // Verify that the room is deleted
response = await getRoom(createdRoom.roomId); response = await getRoom(roomId);
expect(response.status).toBe(404); expect(response.status).toBe(404);
}); });