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

openvidu-server: prepare for mediaNode CDR events

pull/331/head
pabloFuente 2019-10-04 13:29:27 +02:00
parent bdc35d6654
commit bf1a86fc9a
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
openvidu-server/src/main/java/io/openvidu/server/cdr/CDREvent.java
View File

@ -45,7 +45,9 @@ public class CDREvent {
public JsonObject toJson() { public JsonObject toJson() {
JsonObject json = new JsonObject(); JsonObject json = new JsonObject();
if (sessionId != null) {
json.addProperty("sessionId", this.sessionId); json.addProperty("sessionId", this.sessionId);
}
json.addProperty("timestamp", this.timeStamp); json.addProperty("timestamp", this.timeStamp);
return json; return json;
} }

2
openvidu-server/src/main/java/io/openvidu/server/cdr/CDREventName.java
View File

@ -19,6 +19,6 @@ package io.openvidu.server.cdr;
public enum CDREventName { public enum CDREventName {
sessionCreated, sessionDestroyed, participantJoined, participantLeft, webrtcConnectionCreated, webrtcConnectionDestroyed, recordingStarted, recordingStopped, recordingStatusChanged, filterEventDispatched sessionCreated, sessionDestroyed, participantJoined, participantLeft, webrtcConnectionCreated, webrtcConnectionDestroyed, recordingStarted, recordingStopped, recordingStatusChanged, filterEventDispatched, mediaNodeAdded, mediaNodeRemoved
} }

6
openvidu-server/src/main/java/io/openvidu/server/cdr/CallDetailRecord.java
View File

@ -93,10 +93,10 @@ import io.openvidu.server.webhook.CDRLoggerWebhook;
public class CallDetailRecord { public class CallDetailRecord {
@Autowired @Autowired
protected SessionManager sessionManager; private SessionManager sessionManager;
@Autowired @Autowired
protected OpenviduConfig openviduConfig; private OpenviduConfig openviduConfig;
private Collection<CDRLogger> loggers; private Collection<CDRLogger> loggers;
@ -226,7 +226,7 @@ public class CallDetailRecord {
this.log(new CDREventFilterEvent(sessionId, participantId, streamId, filterType, event)); this.log(new CDREventFilterEvent(sessionId, participantId, streamId, filterType, event));
} }
private void log(CDREvent event) { protected void log(CDREvent event) {
this.loggers.forEach(logger -> { this.loggers.forEach(logger -> {
// TEMP FIX: AVOID SENDING recordingStarted AND recordingStopped EVENTS TO // TEMP FIX: AVOID SENDING recordingStarted AND recordingStopped EVENTS TO