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

openvidu-test-browsers: total accumulated number of events in CustomWebhook

pull/707/head
pabloFuente 2022-03-17 17:16:52 +01:00
parent 85c0cc0584
commit 664e608cba
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -46,21 +46,25 @@ public class CustomWebhook {
private static ConfigurableApplicationContext context; private static ConfigurableApplicationContext context;
public static CountDownLatch initLatch; public static CountDownLatch initLatch;
public static int accumulatedNumberOfEvents = 0;
static ConcurrentMap<String, BlockingQueue<JsonObject>> events = new ConcurrentHashMap<>(); static ConcurrentMap<String, BlockingQueue<JsonObject>> events = new ConcurrentHashMap<>();
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.events.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.events.clear(); CustomWebhook.events.clear();
CustomWebhook.context.close(); CustomWebhook.context.close();
} }
public static void clean() { public static void clean() {
accumulatedNumberOfEvents = 0;
CustomWebhook.events.clear(); CustomWebhook.events.clear();
} }
@ -88,6 +92,7 @@ public class CustomWebhook {
public void webhook(@RequestBody String eventString) { public void webhook(@RequestBody String eventString) {
JsonObject event = JsonParser.parseString(eventString).getAsJsonObject(); JsonObject event = JsonParser.parseString(eventString).getAsJsonObject();
System.out.println("Webhook event: " + event.toString()); System.out.println("Webhook event: " + event.toString());
accumulatedNumberOfEvents++;
final String eventName = event.get("event").getAsString(); final String eventName = event.get("event").getAsString();
final BlockingQueue<JsonObject> queue = new LinkedBlockingDeque<>(); final BlockingQueue<JsonObject> queue = new LinkedBlockingDeque<>();
if (!CustomWebhook.events.computeIfAbsent(eventName, e -> { if (!CustomWebhook.events.computeIfAbsent(eventName, e -> {