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

openvidu-server: "echo" rpc method

pull/630/head
pabloFuente 2021-05-26 14:47:16 +02:00
parent fccd21eefd
commit 21020c1ca9
3 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
openvidu-server/src/main/java/io/openvidu/server/core/SessionEventsHandler.java
View File

@ -638,6 +638,10 @@ public class SessionEventsHandler {
rpcNotificationService.sendResponse(participant.getParticipantPrivateId(), transactionId, new JsonObject());
}
public void onEcho(String participantPrivateId, Integer transactionId) {
rpcNotificationService.sendResponse(participantPrivateId, transactionId, new JsonObject());
}
/**
* This handler must be called before cleaning any sessions or recordings hosted
* by the crashed Media Node

4
openvidu-server/src/main/java/io/openvidu/server/core/SessionManager.java
View File

@ -194,6 +194,10 @@ public abstract class SessionManager {
public abstract void onVideoData(Participant participant, Integer transactionId, Integer height, Integer width,
Boolean videoActive, Boolean audioActive);
public void onEcho(String participantPrivateId, Integer requestId) {
sessionEventsHandler.onEcho(participantPrivateId, requestId);
}
/**
* Returns a Session given its id
*

7
openvidu-server/src/main/java/io/openvidu/server/rpc/RpcHandler.java
View File

@ -172,6 +172,9 @@ public class RpcHandler extends DefaultJsonRpcHandler<JsonObject> {
case ProtocolElements.VIDEODATA_METHOD:
updateVideoData(rpcConnection, request);
break;
case ProtocolElements.ECHO_METHOD:
echo(rpcConnection, request);
break;
default:
log.error("Unrecognized request {}", request);
break;
@ -717,6 +720,10 @@ public class RpcHandler extends DefaultJsonRpcHandler<JsonObject> {
}
}
private void echo(RpcConnection rpcConnection, Request<JsonObject> request) {
sessionManager.onEcho(rpcConnection.getParticipantPrivateId(), request.getId());
}
public void leaveRoomAfterConnClosed(String participantPrivateId, EndReason reason) {
try {
sessionManager.evictParticipant(this.sessionManager.getParticipant(participantPrivateId), null, null,