send iceCandidates between clients added

server/src/gateways/message.gateway.ts

@@ -62,6 +62,16 @@ export class MessageGateway implements OnGatewayInit, OnGatewayDisconnect {
     });
   }
 
+  @SubscribeMessage('candidate')
+  public iceCandidate(client: Socket, data: any): void {
+    console.log(data);
+
+    client.to(data.user).emit('candidate', {
+      user: client.id,
+      candidate: data.candidate,
+    });
+  }
+
   @SubscribeMessage('reject-call')
   public rejectCall(client: Socket, data: any): void {
     client.to(data.from).emit('call-rejected', {

web/src/hooks/useStartPeerSession.js

@@ -32,6 +32,8 @@ export const useStartPeerSession = (room, userMediaStream, localVideoRef) => {
         }
       });
 
+      peerVideoConnection.onNewIceCandidate((user,candidate) => peerVideoConnection.newIceCandidate(user,candidate));
+
       peerVideoConnection.onAnswerMade((socket) => peerVideoConnection.callUser(socket));
     }
 

web/src/utils/PeerConnectionSession.js

@@ -1,6 +1,6 @@
 import * as io from 'socket.io-client';
 
-const { RTCPeerConnection, RTCSessionDescription } = window;
+const { RTCPeerConnection, RTCSessionDescription, RTCIceCandidate } = window;
 
 function capitalizeFirstLetter(string) {
   return string.charAt(0).toUpperCase() + string.slice(1);
@@ -40,6 +40,18 @@ class PeerConnectionSession {
       callback(stream);
     };
 
+    const emitIceCandidate = (id, candidate) => {
+      this.socket.emit('candidate', {user: id, candidate: candidate});
+    }
+
+    this.peerConnections[id].onicecandidate = function (event) {
+      // console.log({ id, _stream });
+      console.log("new ice candidate");
+      if(event.candidate){
+        emitIceCandidate(id,event.candidate)
+      }
+    };
+
     console.log(this.peerConnections);
   }
 
@@ -116,6 +128,14 @@ class PeerConnectionSession {
     this.senders = [];
     Object.keys(this.peerConnections).forEach(this.removePeerConnection.bind(this));
   }
+
+  onNewIceCandidate(callback) {
+    this.socket.on('candidate', (response) => callback(response.user, response.candidate))
+  }
+
+  newIceCandidate(user, candidate) {
+    this.peerConnections[user].addIceCandidate(new RTCIceCandidate(candidate))
+  }
 }
 
 export const createPeerConnectionContext = () => {