Added logs

Reviewed-on: #8

app.js

@@ -112,10 +112,12 @@ const closeCall = (callId) => {
     if (videoCalls[callId]) {
       videoCalls[callId].producer?.close();
       videoCalls[callId].consumer?.close();
-      videoCalls[callId]?.consumerTransport.close();
-      videoCalls[callId]?.producerTransport.close();
-      videoCalls[callId].router.close();
+      videoCalls[callId]?.consumerTransport?.close();
+      videoCalls[callId]?.producerTransport?.close();
+      videoCalls[callId]?.router?.close();
       delete videoCalls[callId];
+    } else {
+      console.log(`The call with id ${callId} has already been deleted`);
     }
   } catch (error) {
     console.log(`ERROR | closeCall | callid ${callId} | ${error.message}`);
@@ -146,8 +148,10 @@ peers.on('connection', async socket => {
 
   // It is triggered when the peer is disconnected
   socket.on('disconnect', () => {
-    console.log('peer disconnected | socket.id', socket.id);
+    const callId = socketDetails[socket.id];
+    console.log(`disconnect | socket ${socket.id} | callId ${callId}`);
     delete socketDetails[socket.id];
+    closeCall(callId);
   });
 
   /*
@@ -186,13 +190,21 @@ peers.on('connection', async socket => {
     try {
       const callId = socketDetails[socket.id];
       console.log(`[createWebRtcTransport] sender ${sender} | callId ${callId}`);
-      if (sender && !videoCalls[callId].producerTransport) {
-        videoCalls[callId].producerTransport = await createWebRtcTransportLayer(callId, callback)
-      } else if (!sender && !videoCalls[callId].consumerTransport) {
-        videoCalls[callId].consumerTransport = await createWebRtcTransportLayer(callId, callback)
+      if (sender) {
+        if (!videoCalls[callId].producerTransport) {
+          videoCalls[callId].producerTransport = await createWebRtcTransportLayer(callId, callback);
+        } else {
+          console.log(`producerTransport has already been defined | callId ${callId}`);
+        }
+      } else if (!sender) {
+        if (!videoCalls[callId].consumerTransport) {
+          videoCalls[callId].consumerTransport = await createWebRtcTransportLayer(callId, callback);
+        } else {
+          console.log(`consumerTransport has already been defined | callId ${callId}`);
+        }
       }
     } catch (error) {
-      console.log(`ERROR | createWebRtcTransport | callId ${callId} | sender ${sender} | ${error.message}`);
+      console.log(`ERROR | createWebRtcTransport | callId ${socketDetails[socket.id]} | sender ${sender} | ${error.message}`);
     }
   });
 
@@ -203,10 +215,14 @@ peers.on('connection', async socket => {
   socket.on('transport-connect', async ({ dtlsParameters }) => {
     try {
       const callId = socketDetails[socket.id];
-      console.log(`[transport-connect] socket.id ${socket.id} | callId ${callId}`)
+      // console.log('🔴 typeof dtlsParameters', typeof dtlsParameters);
+      // console.log('🟢 dtlsParameters', JSON.parse(dtlsParameters));
+      // console.log('🟡 dtlsParameters', dtlsParameters);
+      if (typeof dtlsParameters === 'string') dtlsParameters = JSON.parse(dtlsParameters);
+      console.log(`[transport-connect] socket.id ${socket.id} | callId ${callId}`);
       await videoCalls[callId].producerTransport.connect({ dtlsParameters });
     } catch (error) {
-      console.log(`ERROR | transport-connect | callId ${socketDetails[socket.id]} | ${error.message}`);
+      console.log(`ERROR | transport-connect | callId ${socketDetails[socket.id]} | ${error.stack}`);
     }
   });
 
@@ -245,7 +261,7 @@ peers.on('connection', async socket => {
       console.log(`[transport-recv-connect] socket.id ${socket.id} | callId ${callId}`);
       await videoCalls[callId].consumerTransport.connect({ dtlsParameters });
     } catch (error) {
-      console.log(`ERROR | transport-recv-connect | callId ${socketDetails[socket.id]} | ERROR`);
+      console.log(`ERROR | transport-recv-connect | callId ${socketDetails[socket.id]} | ${error.message}`);
     }
   })
 
@@ -302,7 +318,7 @@ peers.on('connection', async socket => {
         console.log(`[canConsume] Can't consume | callId ${callId}`);
       }
     } catch (error) {
-      console.log(`ERROR | consume | callId ${callId} | ${error.message}`)
+      console.log(`ERROR | consume | callId ${socketDetails[socket.id]} | ${error.message}`)
       callback({ params: { error } });
     }
   });
@@ -369,6 +385,7 @@ const createWebRtcTransportLayer = async (callId, callback) => {
       dtlsParameters: transport.dtlsParameters,
     };
 
+    console.log(`createWebRtcTransportLayer | params.dtlsParameters ${params.dtlsParameters}`);
     // Send back to the client the params
     callback({ params });
 
@@ -376,7 +393,7 @@ const createWebRtcTransportLayer = async (callId, callback) => {
     return transport;
 
   } catch (error) {
-    console.log(`ERROR | createWebRtcTransportLayer | callId ${callId} | ${error.message}`);
+    console.log(`ERROR | createWebRtcTransportLayer | callId ${socketDetails[socket.id]} | ${error.message}`);
     callback({ params: { error } });
   }
 }