Add refresh of simple-peer objects when DC

Author: WZWren

comms/server.js

@@ -27,6 +27,11 @@ io.on("connection", (socket) => {
     socket.to(data.target).emit("peerConnected");
   });
 
+  // leave the room - this is performed as part of a cleanup function.
+  socket.on("leaveRoom", (data) => {
+    socket.leave(data.target);
+  });
+
   // propagate the socket events for starting and handshaking a call forward.
   socket.on("startCall", (data) => {
     console.log(socket.id + " is starting call in "+ data.target);

peerprep/components/questionpage/CommsPanel.tsx

@@ -87,6 +87,8 @@ function CommsPanel({ className, roomId }: Props) {
     attachSocketReceiver(stream, roomId, userVideo, connectionRef);
 
     socket.on("endCall", () => {
+      // immediately destroy the socket listeners
+      destroyCallListeners(roomId);
       if (userVideo.current) {
         (userVideo.current.srcObject as MediaStream)
           .getTracks()
@@ -95,6 +97,16 @@ function CommsPanel({ className, roomId }: Props) {
           });
         userVideo.current.srcObject = null;
       }
+      if (connectionRef.current && !connectionRef.current.destroyed) {
+        connectionRef.current.destroy();
+      }
+      // reattach the sockets
+      attachSocketInitiator(stream, roomId, userVideo, connectionRef);
+      attachSocketReceiver(stream, roomId, userVideo, connectionRef);
+      // rejoin the room
+      socket.emit("joinRoom", {
+        target: roomId,
+      });
     });
 
     socket.emit("joinRoom", {
@@ -126,6 +138,15 @@ function CommsPanel({ className, roomId }: Props) {
   );
 }
 
+function destroyCallListeners(roomId: string) {
+  socket.emit("leaveRoom", {
+    target: roomId,
+  });
+  socket.removeAllListeners("startCall");
+  socket.removeAllListeners("peerConnected");
+  socket.removeAllListeners("handshakeCall");
+}
+
 function attachSocketReceiver(
   stream: MediaStream,
   roomId: string,