From 92717803ba4a324a68b98d34344447df5244ccd5 Mon Sep 17 00:00:00 2001 From: pabloFuente Date: Tue, 20 Apr 2021 13:10:01 +0200 Subject: [PATCH] openvidu-server: log webhook for debugging --- .../java/io/openvidu/server/webhook/CDRLoggerWebhook.java | 5 +++++ .../java/io/openvidu/server/webhook/HttpWebhookSender.java | 3 ++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/openvidu-server/src/main/java/io/openvidu/server/webhook/CDRLoggerWebhook.java b/openvidu-server/src/main/java/io/openvidu/server/webhook/CDRLoggerWebhook.java index aeb9fdeb..7deacf0d 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/webhook/CDRLoggerWebhook.java +++ b/openvidu-server/src/main/java/io/openvidu/server/webhook/CDRLoggerWebhook.java @@ -20,6 +20,8 @@ package io.openvidu.server.webhook; import java.util.List; import org.apache.http.Header; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import io.openvidu.server.cdr.CDREvent; import io.openvidu.server.cdr.CDREventName; @@ -30,6 +32,8 @@ import io.openvidu.server.summary.SessionSummary; public class CDRLoggerWebhook implements CDRLogger { + private static final Logger log = LoggerFactory.getLogger(HttpWebhookSender.class); + private HttpWebhookSender webhookSender; public CDRLoggerWebhook(String webhookEndpoint, List
webhookHeaders, List webhookEvents) { @@ -38,6 +42,7 @@ public class CDRLoggerWebhook implements CDRLogger { @Override public void log(CDREvent event) { + log.info("Sending event {} to Webhook 1", event.getEventName().name()); this.webhookSender.sendHttpPostCallbackAsync(event); } diff --git a/openvidu-server/src/main/java/io/openvidu/server/webhook/HttpWebhookSender.java b/openvidu-server/src/main/java/io/openvidu/server/webhook/HttpWebhookSender.java index a6a5ac6c..6ca72f2d 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/webhook/HttpWebhookSender.java +++ b/openvidu-server/src/main/java/io/openvidu/server/webhook/HttpWebhookSender.java @@ -18,7 +18,6 @@ package io.openvidu.server.webhook; import java.io.IOException; -import java.io.UnsupportedEncodingException; import java.security.KeyManagementException; import java.security.KeyStoreException; import java.security.NoSuchAlgorithmException; @@ -109,6 +108,7 @@ public class HttpWebhookSender { public void sendHttpPostCallbackAsync(CDREvent event) { executor.execute(() -> { try { + log.info("Sending event {} to Webhook 2", event.getEventName().name()); this.sendHttpPostCallbackBlocking(event); } catch (IOException e) { log.error("Error sending webhook event: {}", e.getMessage()); @@ -141,6 +141,7 @@ public class HttpWebhookSender { HttpResponse response = null; try { + log.info("Sending event {} to Webhook 3", event.getEventName().name()); response = this.httpClient.execute(request); int statusCode = response.getStatusLine().getStatusCode(); if ((statusCode == org.apache.http.HttpStatus.SC_OK)) {