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

openvidu-test-e2e: extended streamPropertyChangedEventTest

pull/621/head
pabloFuente 2021-03-24 12:20:40 +01:00
parent faf7f6820b
commit bd83a1993b
1 changed files with 44 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -800,6 +800,12 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
user.getDriver().findElement(By.id("one2many-btn")).click(); user.getDriver().findElement(By.id("one2many-btn")).click();
user.getDriver().findElement(By.className("screen-radio")).click(); user.getDriver().findElement(By.className("screen-radio")).click();
user.getDriver().findElement(By.id("session-settings-btn-0")).click();
Thread.sleep(1000);
user.getDriver().findElement(By.id("radio-btn-mod")).click();
user.getDriver().findElement(By.id("save-btn")).click();
Thread.sleep(1000);
List<WebElement> joinButtons = user.getDriver().findElements(By.className("join-btn")); List<WebElement> joinButtons = user.getDriver().findElements(By.className("join-btn"));
for (WebElement el : joinButtons) { for (WebElement el : joinButtons) {
el.sendKeys(Keys.ENTER); el.sendKeys(Keys.ENTER);
@ -812,19 +818,21 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
// Give some time for the screen sharing warning to stop resizing the viewport // Give some time for the screen sharing warning to stop resizing the viewport
Thread.sleep(3000); Thread.sleep(3000);
user.getEventManager().clearCurrentEvents("streamPropertyChanged");
// Unpublish video // Unpublish video
final CountDownLatch latch1 = new CountDownLatch(2); final CountDownLatch latch1 = new CountDownLatch(2);
user.getEventManager().on("streamPropertyChanged", (event) -> { user.getEventManager().on("streamPropertyChanged", (event) -> {
System.out.println(event.toString()); System.out.println(event.toString());
threadAssertions.add("videoActive".equals(event.get("changedProperty").getAsString())); threadAssertions.add("videoActive".equals(event.get("changedProperty").getAsString()));
threadAssertions.add("publishVideo".equals(event.get("reason").getAsString()));
threadAssertions.add(!event.get("newValue").getAsBoolean()); threadAssertions.add(!event.get("newValue").getAsBoolean());
latch1.countDown(); latch1.countDown();
}); });
user.getDriver().findElement(By.cssSelector("#openvidu-instance-0 .pub-video-btn")).click(); user.getDriver().findElement(By.cssSelector("#openvidu-instance-0 .pub-video-btn")).click();
user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 2); user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 2);
if (!latch1.await(5000, TimeUnit.MILLISECONDS)) { if (!latch1.await(4000, TimeUnit.MILLISECONDS)) {
gracefullyLeaveParticipants(2); gracefullyLeaveParticipants(2);
fail(); fail();
return; return;
@ -842,13 +850,40 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
user.getEventManager().on("streamPropertyChanged", (event) -> { user.getEventManager().on("streamPropertyChanged", (event) -> {
System.out.println(event.toString()); System.out.println(event.toString());
threadAssertions.add("audioActive".equals(event.get("changedProperty").getAsString())); threadAssertions.add("audioActive".equals(event.get("changedProperty").getAsString()));
threadAssertions.add("publishAudio".equals(event.get("reason").getAsString()));
threadAssertions.add(!event.get("newValue").getAsBoolean()); threadAssertions.add(!event.get("newValue").getAsBoolean());
latch2.countDown(); latch2.countDown();
}); });
user.getDriver().findElement(By.cssSelector("#openvidu-instance-0 .pub-audio-btn")).click(); user.getDriver().findElement(By.cssSelector("#openvidu-instance-0 .pub-audio-btn")).click();
user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 4); user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 4);
if (!latch2.await(5000, TimeUnit.MILLISECONDS)) { if (!latch2.await(4000, TimeUnit.MILLISECONDS)) {
gracefullyLeaveParticipants(2);
fail();
return;
}
// Filter
final CountDownLatch latch3 = new CountDownLatch(2);
user.getEventManager().on("streamPropertyChanged", (event) -> {
threadAssertions.add("filter".equals(event.get("changedProperty").getAsString()));
threadAssertions.add("applyFilter".equals(event.get("reason").getAsString()));
threadAssertions.add(!event.has("oldValue"));
JsonObject newValue = event.get("newValue").getAsJsonObject();
threadAssertions.add("GStreamerFilter".equals(newValue.get("type").getAsString()));
JsonObject options = newValue.get("options").getAsJsonObject();
threadAssertions.add("videobalance saturation=0.0".equals(options.get("command").getAsString()));
latch3.countDown();
});
user.getDriver().findElement(By.cssSelector("#openvidu-instance-0 .filter-btn")).click();
Thread.sleep(1000);
user.getDriver().findElement(By.id("apply-filter-btn")).click();
user.getDriver().findElement(By.id("close-dialog-btn")).click();
Thread.sleep(500);
user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 6);
if (!latch3.await(4000, TimeUnit.MILLISECONDS)) {
gracefullyLeaveParticipants(2); gracefullyLeaveParticipants(2);
fail(); fail();
return; return;
@ -862,7 +897,7 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
} }
// Resize captured window // Resize captured window
final CountDownLatch latch3 = new CountDownLatch(2); final CountDownLatch latch4 = new CountDownLatch(2);
int newWidth = 1000; int newWidth = 1000;
int newHeight = 700; int newHeight = 700;
@ -873,10 +908,10 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
+ "}"; + "}";
System.out.println("Publisher dimensions: " + event.get("newValue").getAsJsonObject().toString()); System.out.println("Publisher dimensions: " + event.get("newValue").getAsJsonObject().toString());
System.out.println("Real dimensions of viewport: " + expectedDimensions); System.out.println("Real dimensions of viewport: " + expectedDimensions);
if ("videoDimensions".equals(event.get("changedProperty").getAsString())) { if ("videoDimensions".equals(event.get("changedProperty").getAsString())
if (expectedDimensions.equals(event.get("newValue").getAsJsonObject().toString())) { && "screenResized".equals(event.get("reason").getAsString())
latch3.countDown(); && expectedDimensions.equals(event.get("newValue").getAsJsonObject().toString())) {
} latch4.countDown();
} }
}); });
@ -890,9 +925,9 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestAppE2eTest {
System.out.println("New viewport dimension: " + obj.toString()); System.out.println("New viewport dimension: " + obj.toString());
user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 6); user.getEventManager().waitUntilEventReaches("streamPropertyChanged", 8);
if (!latch3.await(6000, TimeUnit.MILLISECONDS)) { if (!latch3.await(4000, TimeUnit.MILLISECONDS)) {
gracefullyLeaveParticipants(2); gracefullyLeaveParticipants(2);
fail(); fail();
return; return;