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

openvidu-test-browsers: add accumulated events map to CustomWebhook

pull/711/head
pabloFuente 2022-03-28 23:04:30 +02:00
parent bba002c046
commit ce37fa6747
1 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
openvidu-test-browsers/src/main/java/io/openvidu/test/browsers/utils/webhook/CustomWebhook.java
View File

@ -25,6 +25,7 @@ import java.util.concurrent.CountDownLatch;
import java.util.concurrent.LinkedBlockingDeque; import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException; import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicInteger;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.boot.builder.SpringApplicationBuilder;
@ -48,31 +49,33 @@ public class CustomWebhook {
public static CountDownLatch initLatch; public static CountDownLatch initLatch;
public static int accumulatedNumberOfEvents = 0; public static int accumulatedNumberOfEvents = 0;
public static ConcurrentMap<String, AtomicInteger> accumulatedEvents = new ConcurrentHashMap<>();
static ConcurrentMap<String, BlockingQueue<JsonObject>> events = new ConcurrentHashMap<>(); static ConcurrentMap<String, BlockingQueue<JsonObject>> events = new ConcurrentHashMap<>();
static BlockingQueue<JsonObject> eventsInOrder = new LinkedBlockingDeque<>(); static BlockingQueue<JsonObject> eventsInOrder = new LinkedBlockingDeque<>();
public static void main(String[] args, CountDownLatch initLatch) { public static void main(String[] args, CountDownLatch initLatch) {
CustomWebhook.initLatch = initLatch; CustomWebhook.initLatch = initLatch;
accumulatedNumberOfEvents = 0; CustomWebhook.clean();
CustomWebhook.eventsInOrder.clear();
CustomWebhook.events.clear();
CustomWebhook.context = new SpringApplicationBuilder(CustomWebhook.class) CustomWebhook.context = new SpringApplicationBuilder(CustomWebhook.class)
.properties("spring.config.location:classpath:aplication-pro-webhook.properties").build().run(args); .properties("spring.config.location:classpath:aplication-pro-webhook.properties").build().run(args);
} }
public static void shutDown() { public static void shutDown() {
accumulatedNumberOfEvents = 0; CustomWebhook.clean();
CustomWebhook.eventsInOrder.clear();
CustomWebhook.events.clear();
CustomWebhook.context.close(); CustomWebhook.context.close();
} }
public static void clean() { public static void clean() {
accumulatedNumberOfEvents = 0; CustomWebhook.accumulatedNumberOfEvents = 0;
CustomWebhook.accumulatedEvents.clear();
CustomWebhook.eventsInOrder.clear(); CustomWebhook.eventsInOrder.clear();
CustomWebhook.events.clear(); CustomWebhook.events.clear();
} }
public static void cleanEventsInOrder() {
CustomWebhook.eventsInOrder.clear();
}
public synchronized static JsonObject waitForEvent(String eventName, int maxSecondsWait) throws Exception { public synchronized static JsonObject waitForEvent(String eventName, int maxSecondsWait) throws Exception {
return CustomWebhook.waitForEvent(eventName, maxSecondsWait, TimeUnit.SECONDS); return CustomWebhook.waitForEvent(eventName, maxSecondsWait, TimeUnit.SECONDS);
} }
@ -98,7 +101,8 @@ public class CustomWebhook {
} else { } else {
String ev = event.get("event").getAsString(); String ev = event.get("event").getAsString();
if (!eventName.equals(ev)) { if (!eventName.equals(ev)) {
throw new Exception("Wrong event type receieved. Excpeceted " + eventName + " but got " + ev); throw new Exception("Wrong event type receieved. Excpeceted " + eventName + " but got " + ev + ": "
+ event.toString());
} else { } else {
// Remove the very same event from the map of events // Remove the very same event from the map of events
long maxWait = System.currentTimeMillis(); long maxWait = System.currentTimeMillis();
@ -152,6 +156,9 @@ public class CustomWebhook {
accumulatedNumberOfEvents++; accumulatedNumberOfEvents++;
eventsInOrder.add(event); eventsInOrder.add(event);
final String eventName = event.get("event").getAsString(); final String eventName = event.get("event").getAsString();
if (accumulatedEvents.putIfAbsent(eventName, new AtomicInteger(1)) != null) {
accumulatedEvents.get(eventName).incrementAndGet();
}
final BlockingQueue<JsonObject> queue = new LinkedBlockingDeque<>(); final BlockingQueue<JsonObject> queue = new LinkedBlockingDeque<>();
if (!CustomWebhook.events.computeIfAbsent(eventName, e -> { if (!CustomWebhook.events.computeIfAbsent(eventName, e -> {
queue.add(event); queue.add(event);