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

openvidu-server: log webhook for debugging

pull/621/head
pabloFuente 2021-04-20 13:10:01 +02:00
parent 5b1a5fe4e9
commit 92717803ba
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
openvidu-server/src/main/java/io/openvidu/server/webhook/CDRLoggerWebhook.java
View File

@ -20,6 +20,8 @@ package io.openvidu.server.webhook;
import java.util.List; import java.util.List;
import org.apache.http.Header; import org.apache.http.Header;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import io.openvidu.server.cdr.CDREvent; import io.openvidu.server.cdr.CDREvent;
import io.openvidu.server.cdr.CDREventName; import io.openvidu.server.cdr.CDREventName;
@ -30,6 +32,8 @@ import io.openvidu.server.summary.SessionSummary;
public class CDRLoggerWebhook implements CDRLogger { public class CDRLoggerWebhook implements CDRLogger {
private static final Logger log = LoggerFactory.getLogger(HttpWebhookSender.class);
private HttpWebhookSender webhookSender; private HttpWebhookSender webhookSender;
public CDRLoggerWebhook(String webhookEndpoint, List<Header> webhookHeaders, List<CDREventName> webhookEvents) { public CDRLoggerWebhook(String webhookEndpoint, List<Header> webhookHeaders, List<CDREventName> webhookEvents) {
@ -38,6 +42,7 @@ public class CDRLoggerWebhook implements CDRLogger {
@Override @Override
public void log(CDREvent event) { public void log(CDREvent event) {
log.info("Sending event {} to Webhook 1", event.getEventName().name());
this.webhookSender.sendHttpPostCallbackAsync(event); this.webhookSender.sendHttpPostCallbackAsync(event);
} }

3
openvidu-server/src/main/java/io/openvidu/server/webhook/HttpWebhookSender.java
View File

@ -18,7 +18,6 @@
package io.openvidu.server.webhook; package io.openvidu.server.webhook;
import java.io.IOException; import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.security.KeyManagementException; import java.security.KeyManagementException;
import java.security.KeyStoreException; import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException; import java.security.NoSuchAlgorithmException;
@ -109,6 +108,7 @@ public class HttpWebhookSender {
public void sendHttpPostCallbackAsync(CDREvent event) { public void sendHttpPostCallbackAsync(CDREvent event) {
executor.execute(() -> { executor.execute(() -> {
try { try {
log.info("Sending event {} to Webhook 2", event.getEventName().name());
this.sendHttpPostCallbackBlocking(event); this.sendHttpPostCallbackBlocking(event);
} catch (IOException e) { } catch (IOException e) {
log.error("Error sending webhook event: {}", e.getMessage()); log.error("Error sending webhook event: {}", e.getMessage());
@ -141,6 +141,7 @@ public class HttpWebhookSender {
HttpResponse response = null; HttpResponse response = null;
try { try {
log.info("Sending event {} to Webhook 3", event.getEventName().name());
response = this.httpClient.execute(request); response = this.httpClient.execute(request);
int statusCode = response.getStatusLine().getStatusCode(); int statusCode = response.getStatusLine().getStatusCode();
if ((statusCode == org.apache.http.HttpStatus.SC_OK)) { if ((statusCode == org.apache.http.HttpStatus.SC_OK)) {