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

openvidu-test-e2e tests dynamic change of Publisher

pull/30/head
pabloFuente 2018-01-18 16:18:42 +01:00
parent 391be208af
commit 8d02a4928f
2 changed files with 77 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
openvidu-test-e2e/src/test/java/io/openvidu/test/e2e/OpenViduEventManager.java
View File

@ -117,6 +117,10 @@ public class OpenViduEventManager {
this.eventCallbacks.put(eventName, new RunnableCallback(callback));
}
public void off(String eventName) {
this.eventCallbacks.remove(eventName);
}
// 'eventNumber' is accumulative for event 'eventName' for one page while it is not refreshed
public void waitUntilEventReaches(String eventName, int eventNumber) throws Exception {
CountDownLatch eventSignal = new CountDownLatch(eventNumber);

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

@ -19,31 +19,31 @@ package io.openvidu.test.e2e;
import static java.lang.invoke.MethodHandles.lookup;
import static org.slf4j.LoggerFactory.getLogger;
import static org.hamcrest.CoreMatchers.is;
import static org.openqa.selenium.OutputType.BASE64;
import org.slf4j.Logger;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Tag;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.*;
import org.junit.jupiter.api.extension.ExtendWith;
import org.junit.runner.RunWith;
import org.junit.platform.runner.JUnitPlatform;
import org.json.simple.JSONObject;
import org.junit.Assert;
import org.openqa.selenium.By;
import org.openqa.selenium.Keys;
import org.openqa.selenium.TakesScreenshot;
import org.openqa.selenium.WebElement;
import org.openqa.selenium.support.ui.ExpectedConditions;
import org.slf4j.Logger;
import io.github.bonigarcia.SeleniumExtension;
import io.github.bonigarcia.wdm.ChromeDriverManager;
import io.github.bonigarcia.wdm.FirefoxDriverManager;
import io.openvidu.java.client.OpenVidu;
import io.openvidu.java.client.Session;
import io.openvidu.test.e2e.browser.BrowserUser;
@ -627,6 +627,71 @@ public class OpenViduTestAppE2eTest {
}
@Test
@DisplayName("Change publisher dynamically")
void changePublisher() throws Exception {
List<Boolean> listOfThreadAssertions = new ArrayList<>();
setupBrowser("chrome");
log.info("Change publisher dynamically");
WebElement oneToManyInput = user.getDriver().findElement(By.id("one2many-input"));
oneToManyInput.clear();
oneToManyInput.sendKeys("1");
user.getDriver().findElement(By.id("auto-join-checkbox")).click();
// First publication (audio + video [CAMERA])
user.getEventManager().on("videoPlaying", (event)-> {
listOfThreadAssertions.add(((String)event.get("eventContent")).contains("CAMERA"));
});
user.getDriver().findElement(By.id("one2many-btn")).click();
user.getEventManager().waitUntilEventReaches("videoPlaying", 2);
user.getEventManager().off("videoPlaying");
for (Iterator<Boolean> iter = listOfThreadAssertions.iterator(); iter.hasNext();) {
Assert.assertTrue(iter.next());
iter.remove();
}
Assert.assertTrue(user.getEventManager().assertMediaTracks(user.getDriver().findElements(By.tagName("video")),
true, true));
// Second publication (only video (SCREEN))
user.getEventManager().on("videoPlaying", (event)-> {
listOfThreadAssertions.add(((String)event.get("eventContent")).contains("SCREEN"));
});
user.getDriver().findElements(By.className("change-publisher-btn")).get(0).click();
user.getEventManager().waitUntilEventReaches("videoPlaying", 4);
user.getEventManager().off("videoPlaying");
for (Iterator<Boolean> iter = listOfThreadAssertions.iterator(); iter.hasNext();) {
Assert.assertTrue(iter.next());
iter.remove();
}
Assert.assertTrue(user.getEventManager().assertMediaTracks(user.getDriver().findElements(By.tagName("video")),
false, true));
// Third publication (audio + video [CAMERA])
user.getEventManager().on("videoPlaying", (event)-> {
listOfThreadAssertions.add(((String)event.get("eventContent")).contains("CAMERA"));
});
user.getDriver().findElements(By.className("change-publisher-btn")).get(0).click();
user.getEventManager().waitUntilEventReaches("videoPlaying", 6);
user.getEventManager().off("videoPlaying");
for (Iterator<Boolean> iter = listOfThreadAssertions.iterator(); iter.hasNext();) {
Assert.assertTrue(iter.next());
iter.remove();
}
Assert.assertTrue(user.getEventManager().assertMediaTracks(user.getDriver().findElements(By.tagName("video")),
true, true));
gracefullyLeaveParticipants(2);
}
private void gracefullyLeaveParticipants(int numberOfParticipants) throws Exception {
int accumulatedConnectionDestroyed = 0;
for (int j = 1; j <= numberOfParticipants; j++) {