From 7691bccdfb5cd0c20fa85bc28796b5566ed7576f Mon Sep 17 00:00:00 2001 From: pabloFuente Date: Tue, 2 Feb 2021 18:44:20 +0100 Subject: [PATCH] openvidu-server: prepare mediaNodeId property in Session entity --- .../openvidu/server/kurento/core/KurentoSession.java | 11 +++++++++++ .../kurento/core/KurentoSessionEventsHandler.java | 4 ++++ 2 files changed, 15 insertions(+) diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java index 1a296ef6..a4929aab 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSession.java @@ -31,6 +31,8 @@ import org.kurento.client.MediaPipeline; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.google.gson.JsonObject; + import io.openvidu.client.OpenViduException; import io.openvidu.client.OpenViduException.Code; import io.openvidu.client.internal.ProtocolElements; @@ -334,4 +336,13 @@ public class KurentoSession extends Session { }); } + @Override + public JsonObject toJson(boolean withPendingConnections, boolean withWebrtcStats) { + JsonObject json = super.toJson(withPendingConnections, withWebrtcStats); + if (this.kms != null && this.kurentoSessionHandler.addMediaNodeInfoToSessionEntity()) { + json.addProperty("mediaNodeId", kms.getId()); + } + return json; + } + } diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionEventsHandler.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionEventsHandler.java index 6bb3802a..de3253f6 100644 --- a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionEventsHandler.java +++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionEventsHandler.java @@ -56,4 +56,8 @@ public class KurentoSessionEventsHandler extends SessionEventsHandler { rpcNotificationService.sendNotification(connectionId, ProtocolElements.MEDIAERROR_METHOD, notifParams); } + public boolean addMediaNodeInfoToSessionEntity() { + return false; + } + }