openvidu-test-e2e: more flexible composedQuickStartRecordTest

pull/672/head
pabloFuente 2021-11-15 14:29:17 +01:00
parent e63f44d856
commit 03b57c00cf
1 changed files with 22 additions and 13 deletions

View File

@ -1411,22 +1411,31 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestappE2eTest {
session = OV.getActiveSessions().get(0); session = OV.getActiveSessions().get(0);
session.close(); session.close();
// Recording hasn't had time to start. Should trigger stopped, started, failed event = CustomWebhook.waitForEvent("recordingStatusChanged", 1);
event = CustomWebhook.waitForEvent("recordingStatusChanged", 1); // stopped if ("stopped".equals(event.get("status").getAsString())) {
Assert.assertEquals("Wrong status in recordingStatusChanged event", "stopped", // Recording hasn't had time to start. Should trigger stopped, started, failed
event.get("status").getAsString()); event = CustomWebhook.waitForEvent("recordingStatusChanged", 5); // started
event = CustomWebhook.waitForEvent("recordingStatusChanged", 5); // started Assert.assertEquals("Wrong status in recordingStatusChanged event", "started",
Assert.assertEquals("Wrong status in recordingStatusChanged event", "started", event.get("status").getAsString());
event.get("status").getAsString()); event = CustomWebhook.waitForEvent("recordingStatusChanged", 1); // failed
event = CustomWebhook.waitForEvent("recordingStatusChanged", 1); // failed Assert.assertEquals("Wrong status in recordingStatusChanged event", "failed",
Assert.assertEquals("Wrong status in recordingStatusChanged event", "failed", event.get("status").getAsString());
event.get("status").getAsString()); Assert.assertEquals("Wrong recording status", Recording.Status.failed,
OV.getRecording(sessionName + "-2").getStatus());
} else {
// Recording did have time to start. Should trigger started, stopped, ready
event = CustomWebhook.waitForEvent("recordingStatusChanged", 5); // started
Assert.assertEquals("Wrong status in recordingStatusChanged event", "stopped",
event.get("status").getAsString());
event = CustomWebhook.waitForEvent("recordingStatusChanged", 1); // failed
Assert.assertEquals("Wrong status in recordingStatusChanged event", "ready",
event.get("status").getAsString());
Assert.assertEquals("Wrong recording status", Recording.Status.ready,
OV.getRecording(sessionName + "-2").getStatus());
}
checkDockerContainerRunning("openvidu/openvidu-recording", 0); checkDockerContainerRunning("openvidu/openvidu-recording", 0);
Assert.assertEquals("Wrong recording status", Recording.Status.failed,
OV.getRecording(sessionName + "-2").getStatus());
} finally { } finally {
CustomWebhook.shutDown(); CustomWebhook.shutDown();
} }