Merge pull request #315 from platinouss/fix/240313-not-removed-RTCPee…

…rConnection Fix: disconnect된 클라이언트의 WebRTC connection이 해제되지 않는 문제 해결
boostcampwm2023 · Mar 14, 2024 · b94c2d9 · b94c2d9
2 parents ea602f6 + 1f2e6f6
commit b94c2d9
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/mediaServer/src/RelayServer.ts b/mediaServer/src/RelayServer.ts
@@ -47,7 +47,7 @@ export class RelayServer {
       console.log('존재하지 않는 방입니다.');
       return;
     }
-    roomConnectionInfo.closeParticipantConnection(roomId);
+    roomConnectionInfo.closeAllParticipantConnection(roomId);
     this._roomConnectionInfoList.delete(roomId);
     const presenterConnectionInfo = this._clientConnectionInfoList.get(presenterEmail);
     if (!presenterConnectionInfo) {

diff --git a/mediaServer/src/listeners/lecture.listener.ts b/mediaServer/src/listeners/lecture.listener.ts
@@ -82,6 +82,7 @@ export class LectureListener {
           return;
         }
         presenterStreamInfo.pauseRecording();
+        clientConnectionInfo.disconnectWebRTCConnection();
       }
       if (isParticipant(clientInfo.type, clientInfo.roomId, clientInfo.roomId)) {
         leaveRoom(clientInfo.roomId, email);

diff --git a/mediaServer/src/models/RoomConnectionInfo.ts b/mediaServer/src/models/RoomConnectionInfo.ts
@@ -31,7 +31,7 @@ export class RoomConnectionInfo {
     return this._stream;
   }
 
-  closeParticipantConnection = (roomId: string) => {
+  closeAllParticipantConnection = (roomId: string) => {
     this._participantIdList.forEach((participantId: string) => {
       const participantConnectionInfo = relayServer.clientConnectionInfoList.get(participantId);
       if (participantConnectionInfo) {
@@ -46,6 +46,7 @@ export class RoomConnectionInfo {
     const participantConnectionInfo = relayServer.clientConnectionInfoList.get(participantId);
     if (participantConnectionInfo) {
       participantConnectionInfo.disconnectSocket(participantId, roomId);
+      participantConnectionInfo.disconnectWebRTCConnection();
       this._participantIdList.delete(participantId);
     }
   };