ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-test-e2e: add simulcastDisabledDynacastEnabled test

pull/850/merge
pabloFuente 2024-11-06 11:31:34 +01:00
parent 6a7ab9b026
commit baa753ac21
1 changed files with 62 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

66
openvidu-test-e2e/src/test/java/io/openvidu/test/e2e/OpenViduTestAppE2eTest.java
View File

@ -20,7 +20,6 @@ package io.openvidu.test.e2e;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.Optional;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -1048,6 +1047,50 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestappE2eTest {
gracefullyLeaveParticipants(user, 2); gracefullyLeaveParticipants(user, 2);
} }
@Test
@DisplayName("Simulcast disabled dynacast enabled")
void simulcastDisabledDynacastEnabledTest() throws Exception {
OpenViduTestappUser user = setupBrowserAndConnectToOpenViduTestapp("chrome");
log.info("Simulcast disabled dynacast enabled");
// Only video publisher with simulcast without dynacast
this.addOnlyPublisherVideo(user, false, true, false);
// Only subscriber without adaptive stream
this.addSubscriber(user, true);
user.getDriver().findElements(By.className("connect-btn")).forEach(el -> el.sendKeys(Keys.ENTER));
user.getEventManager().waitUntilEventReaches("localTrackSubscribed", "RoomEvent", 1);
user.getEventManager().waitUntilEventReaches("trackSubscribed", "RoomEvent", 1);
user.getEventManager().clearAllCurrentEvents();
final int numberOfVideos = user.getDriver().findElements(By.tagName("video")).size();
Assertions.assertEquals(2, numberOfVideos, "Wrong number of videos");
final int numberOfAudios = user.getDriver().findElements(By.tagName("audio")).size();
Assertions.assertEquals(0, numberOfAudios, "Wrong number of audios");
Assertions.assertTrue(user.getBrowserUser().assertAllElementsHaveTracks("video", false, true),
"HTMLVideoElements were expected to have only one audio track");
WebElement publisherVideo = user.getDriver().findElement(By.cssSelector("#openvidu-instance-0 video.local"));
Assertions.assertEquals(1, countNumberOfPublishedLayers(user, publisherVideo),
"Wrong number of published layers");
WebElement subscriberVideo = user.getDriver().findElement(By.cssSelector("#openvidu-instance-1 video.remote"));
long bytesReceived = this.getSubscriberVideoBytesReceived(user, subscriberVideo);
long bytesSent = this.getPublisherVideoLayerAttribute(user, publisherVideo, null, "bytesSent").getAsLong();
Thread.sleep(3000);
this.waitUntilSubscriberBytesReceivedIncrease(user, subscriberVideo, bytesReceived);
this.waitUntilPublisherLayerActive(user, publisherVideo, null, true);
this.waitUntilPublisherBytesSentIncrease(user, publisherVideo, null, bytesSent);
gracefullyLeaveParticipants(user, 2);
}
private int countNumberOfPublishedLayers(OpenViduTestappUser user, WebElement publisherVideo) { private int countNumberOfPublishedLayers(OpenViduTestappUser user, WebElement publisherVideo) {
JsonArray json = this.getLayersAsJsonArray(user, publisherVideo); JsonArray json = this.getLayersAsJsonArray(user, publisherVideo);
return json.size(); return json.size();
@ -1063,12 +1106,19 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestappE2eTest {
return json.get(0).getAsJsonObject().get("bytesReceived").getAsLong(); return json.get(0).getAsJsonObject().get("bytesReceived").getAsLong();
} }
// If rid is null, retrieve the first layer
private JsonElement getPublisherVideoLayerAttribute(OpenViduTestappUser user, WebElement publisherVideo, String rid, private JsonElement getPublisherVideoLayerAttribute(OpenViduTestappUser user, WebElement publisherVideo, String rid,
String attribute) { String attribute) {
JsonArray json = this.getLayersAsJsonArray(user, publisherVideo); JsonArray json = this.getLayersAsJsonArray(user, publisherVideo);
Optional<JsonElement> result = json.asList().stream().parallel() JsonElement result;
.filter(jsonElement -> rid.equals(jsonElement.getAsJsonObject().get("rid").getAsString())).findAny(); if (rid != null) {
return result.get().getAsJsonObject().get(attribute); result = json.asList().stream().parallel()
.filter(jsonElement -> rid.equals(jsonElement.getAsJsonObject().get("rid").getAsString())).findAny()
.get();
} else {
result = json.get(0);
}
return result.getAsJsonObject().get(attribute);
} }
private JsonArray getLayersAsJsonArray(OpenViduTestappUser user, WebElement video) { private JsonArray getLayersAsJsonArray(OpenViduTestappUser user, WebElement video) {
@ -1110,6 +1160,14 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestappE2eTest {
}, "Timeout waiting for subscriber track to increase its bytesReceived from " + previousBytesReceived); }, "Timeout waiting for subscriber track to increase its bytesReceived from " + previousBytesReceived);
} }
private void waitUntilPublisherBytesSentIncrease(OpenViduTestappUser user, WebElement videoElement, String rid,
final long previousBytesSent) {
this.waitUntilAux(user, videoElement, () -> {
return this.getPublisherVideoLayerAttribute(user, videoElement, rid, "bytesSent")
.getAsLong() > previousBytesSent;
}, "Timeout waiting for publisher track to increase its bytesSent from " + previousBytesSent);
}
private void waitUntilPublisherLayerActive(OpenViduTestappUser user, final WebElement publisherVideo, private void waitUntilPublisherLayerActive(OpenViduTestappUser user, final WebElement publisherVideo,
final String rid, final boolean active) { final String rid, final boolean active) {
this.waitUntilAux(user, publisherVideo, () -> { this.waitUntilAux(user, publisherVideo, () -> {