LH-276: Update client js bundle

Reviewed-on: #29
Reviewed-by: Cristi Ene <cristi.ene@safemobile.com>

app.js

@@ -227,6 +227,17 @@ peers.on('connection', async (socket) => {
           videoCalls[callId].receiverProducerTransport = await createWebRtcTransportLayer(callId, callback);
         } else if (!videoCalls[callId].initiatorProducerTransport && isInitiator(callId, socket.id)) {
           videoCalls[callId].initiatorProducerTransport = await createWebRtcTransportLayer(callId, callback);
+
+          videoCalls[callId].initiatorProducerTransport.observer.on("newproducer", (producer) =>
+          {
+            console.log(
+              "------------------new producer created [worker.pid:%d, router.id:%s, transport.id:%s, producer.id:%s]", producer.id);
+    
+            producer.observer.on("close", () => {
+              console.log("-------------------producer closed [producer.id:%s]", producer.id);
+            });
+          });
+
         } else {
           console.log(`producerTransport has already been defined | callId ${callId}`);
           callback(null);
@@ -260,7 +271,6 @@ peers.on('connection', async (socket) => {
       isInitiator(callId, socket.id)
         ? await videoCalls[callId].initiatorProducerTransport.connect({ dtlsParameters })
         : await videoCalls[callId].receiverProducerTransport.connect({ dtlsParameters });
-
     } catch (error) {
       console.log(`ERROR | transport-connect | callId ${socketDetails[socket.id]} | ${error.message}`);
     }
@@ -290,11 +300,14 @@ peers.on('connection', async (socket) => {
           );
 
           videoCalls[callId].receiverVideoProducer.on('transportclose', () => {
-            const callId = socketDetails[socket.id];
             console.log('transport for this producer closed', callId);
             closeCall(callId);
           });
 
+          videoCalls[callId].receiverVideoProducer.on('close', () => {
+            console.log('receiverVideoProducer for this producer closed', callId);
+          });
+
           // Send back to the client the Producer's id
           callback &&
             callback({
@@ -311,11 +324,30 @@ peers.on('connection', async (socket) => {
           );
 
           videoCalls[callId].initiatorVideoProducer.on('transportclose', () => {
-            const callId = socketDetails[socket.id];
             console.log('transport for this producer closed', callId);
             closeCall(callId);
           });
 
+          console.log('🟢');
+
+          videoCalls[callId].initiatorVideoProducer.on('close', () => {
+            console.log('===================1 initiatorVideoProducer for this producer closed', callId);
+          });
+
+          videoCalls[callId].initiatorVideoProducer.observer.on("close", () => {
+            console.log('====================2 initiatorVideoProducer for this producer closed', callId);
+          })
+
+          // videoCalls[callId].initiatorProducerTransport.observer.on("newproducer", (producer) =>
+          // {
+          //   console.log(
+          //     "new producer created [worker.pid:%d, router.id:%s, transport.id:%s, producer.id:%s]", producer.id);
+    
+          //   producer.observer.on("close", () => {
+          //     console.log("producer closed [producer.id:%s]", producer.id);
+          //   });
+          // });
+
           callback &&
             callback({
               id: videoCalls[callId].initiatorVideoProducer.id,
@@ -333,11 +365,14 @@ peers.on('connection', async (socket) => {
           );
 
           videoCalls[callId].receiverAudioProducer.on('transportclose', () => {
-            const callId = socketDetails[socket.id];
             console.log('transport for this producer closed', callId);
             closeCall(callId);
           });
 
+          videoCalls[callId].receiverAudioProducer.on('close', () => {
+            console.log('receiverAudioProducer for this producer closed', callId);
+          });
+
           // Send back to the client the Producer's id
           callback &&
             callback({
@@ -354,11 +389,14 @@ peers.on('connection', async (socket) => {
           );
 
           videoCalls[callId].initiatorAudioProducer.on('transportclose', () => {
-            const callId = socketDetails[socket.id];
             console.log('transport for this producer closed', callId);
             closeCall(callId);
           });
 
+          videoCalls[callId].initiatorAudioProducer.on('close', () => {
+            console.log('initiatorAudioProducer for this producer closed', callId);
+          });
+
           // Send back to the client the Producer's id
           callback &&
             callback({
@@ -370,8 +408,10 @@ peers.on('connection', async (socket) => {
       const socketToEmit = isInitiator(callId, socket.id)
         ? videoCalls[callId].receiverSocket
         : videoCalls[callId].initiatorSocket;
-      socketToEmit.emit('new-producer', { callId });
 
+      // callId - Id of the call
+      // kind - producer type: audio/video
+      socketToEmit.emit('new-producer', { callId, kind });
     } catch (error) {
       console.log(`ERROR | transport-produce | callId ${socketDetails[socket.id]} | ${error.message}`);
     }
@@ -644,6 +684,30 @@ const createWebRtcTransportLayer = async (callId, callback) => {
       console.log(`transport | closed | calldId ${callId}`);
     });
 
+    transport.observer.on("newdataproducer", (dataProducer) =>
+    {
+      console.log(
+        "^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^new data producer created [worker.pid:%d, router.id:%s, transport.id:%s, dataProducer.id:%s]",
+        worker.pid, router.id, transport.id, dataProducer.id);
+
+      dataProducer.observer.on("close", () => 
+      {
+        console.log("^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^data producer closed [dataProducer.id:%s]", dataProducer.id);
+      });
+    });
+
+    transport.observer.on("newproducer", (producer) =>
+    {
+      console.log(
+        "$$$$$$$$$$$$$$$$$$$$$$$$$$new producer created [worker.pid:%d, router.id:%s, transport.id:%s, producer.id:%s]",
+        worker.pid, router.id, transport.id, producer.id);
+
+      producer.observer.on("close", () => 
+      {
+        console.log("$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$$producer closed [producer.id:%s]", producer.id);
+      });
+    });
+
     const params = {
       id: transport.id,
       iceParameters: transport.iceParameters,

public/bundle.js

@@ -20353,7 +20353,7 @@ module.exports = yeast;
 },{}],94:[function(require,module,exports){
 module.exports = {
   hubAddress: 'https://hub.dev.linx.safemobile.com/',
-  mediasoupAddress: 'https://testing.video.safemobile.org',
+  mediasoupAddress: 'https://testing.video.safemobile.org/',
 }
 },{}],95:[function(require,module,exports){
 const io = require('socket.io-client')
@@ -20453,9 +20453,9 @@ setTimeout(() => {
       if (IS_PRODUCER && urlParams.get('testing') === 'true') { getLocalStream() }
     })
 
-    socket.on('new-producer', ({ callId }) => {
-      console.log(`🟢 new-producer | callId: ${callId} | Ready to consume`);
-      consume()
+    socket.on('new-producer', ({ callId, kind }) => {
+      console.log(`🟢 new-producer | callId: ${callId} | kind: ${kind} | Ready to consume`);
+      connectRecvTransport();
     })
   }
   
@@ -20735,6 +20735,8 @@ const connectSendTransport = async () => {
   // Enable Close call button
   const closeCallBtn = document.getElementById('btnCloseCall');
   closeCallBtn.removeAttribute('disabled');
+
+  createRecvTransport();
 }
 
 const createRecvTransport = async () => {
@@ -20774,7 +20776,8 @@ const createRecvTransport = async () => {
         errback(error)
       }
     })
-    connectRecvTransport()
+    // We call it in new-rpoducer, we don't need it here anymore
+    // connectRecvTransport()
   })
 }
 
@@ -20847,6 +20850,14 @@ const getVideoTrask = async (videoParams) => {
     console.log('transport closed so consumer closed')
   })
 
+  consumerVideo.on('producerclose', () => {
+    console.log('===================1 consumerVideo producerclose');
+  });
+
+  consumerVideo.on("producerclose", () => {
+    console.log('====================2 consumerVideo producerclose');
+  })
+
   return consumerVideo.track
 }
 
@@ -20862,6 +20873,14 @@ const getAudioTrask = async (audioParams) => {
     console.log('transport closed so consumer closed')
   })
 
+  consumerAudio.on('producerclose', () => {
+    console.log('===================1 consumerAudio producerclose');
+  });
+
+  consumerAudio.on("producerclose", () => {
+    console.log('====================2 consumerAudio producerclose');
+  })
+
   const audioTrack = consumerAudio.track
 
   audioTrack.applyConstraints({
@@ -20907,31 +20926,31 @@ const closeCall = () => {
   resetCallSettings()
 }
 
-const consume = async () => {
-  console.log('[consume]')
-  console.log('createRecvTransport Consumer')
-  await socket.emit('createWebRtcTransport', { sender: false, callId, dispatcher: true }, ({ params }) => {
-    if (params.error) {
-      console.log('createRecvTransport | createWebRtcTransport | Error', params.error)
-      return
-    }
-    consumerTransport = device.createRecvTransport(params)
-    consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
-      try {
-        await socket.emit('transport-recv-connect', {
-          dtlsParameters,
-        })
-        callback()
-      } catch (error) {
-        errback(error)
-      }
-    })
+// const consume = async (kind) => {
+//   console.log(`[consume] kind: ${kind}`)
+//   console.log('createRecvTransport Consumer')
+//   await socket.emit('createWebRtcTransport', { sender: false, callId, dispatcher: true }, ({ params }) => {
+//     if (params.error) {
+//       console.log('createRecvTransport | createWebRtcTransport | Error', params.error)
+//       return
+//     }
+//     consumerTransport = device.createRecvTransport(params)
+//     consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
+//       try {
+//         await socket.emit('transport-recv-connect', {
+//           dtlsParameters,
+//         })
+//         callback()
+//       } catch (error) {
+//         errback(error)
+//       }
+//     })
     
-    connectRecvTransport()
-  })
-}
+//     connectRecvTransport()
+//   })
+// }
 
 btnLocalVideo.addEventListener('click', getLocalStream)
-btnRecvSendTransport.addEventListener('click', consume)
+// btnRecvSendTransport.addEventListener('click', consume)
 btnCloseCall.addEventListener('click', closeCall)
 },{"./config":94,"mediasoup-client":66,"socket.io-client":82}]},{},[95]);

public/config.js

@@ -1,4 +1,4 @@
 module.exports = {
   hubAddress: 'https://hub.dev.linx.safemobile.com/',
-  mediasoupAddress: 'https://testing.video.safemobile.org',
+  mediasoupAddress: 'https://testing.video.safemobile.org/',
 }

public/index.html

@@ -75,7 +75,7 @@
                         </td>
                         <td>
                             <div id="sharedBtns">
-                                <button id="btnRecvSendTransport">Consume</button>
+                                <!-- <button id="btnRecvSendTransport">Consume</button> -->
                                 <button id="remoteSoundControl">Unmute</button>
                             </div>
                         </td>

public/index.js

@@ -95,9 +95,9 @@ setTimeout(() => {
       if (IS_PRODUCER && urlParams.get('testing') === 'true') { getLocalStream() }
     })
 
-    socket.on('new-producer', ({ callId }) => {
-      console.log(`🟢 new-producer | callId: ${callId} | Ready to consume`);
-      consume()
+    socket.on('new-producer', ({ callId, kind }) => {
+      console.log(`🟢 new-producer | callId: ${callId} | kind: ${kind} | Ready to consume`);
+      connectRecvTransport();
     })
   }
   
@@ -377,6 +377,8 @@ const connectSendTransport = async () => {
   // Enable Close call button
   const closeCallBtn = document.getElementById('btnCloseCall');
   closeCallBtn.removeAttribute('disabled');
+
+  createRecvTransport();
 }
 
 const createRecvTransport = async () => {
@@ -416,7 +418,8 @@ const createRecvTransport = async () => {
         errback(error)
       }
     })
-    connectRecvTransport()
+    // We call it in new-rpoducer, we don't need it here anymore
+    // connectRecvTransport()
   })
 }
 
@@ -489,6 +492,14 @@ const getVideoTrask = async (videoParams) => {
     console.log('transport closed so consumer closed')
   })
 
+  consumerVideo.on('producerclose', () => {
+    console.log('===================1 consumerVideo producerclose');
+  });
+
+  consumerVideo.on("producerclose", () => {
+    console.log('====================2 consumerVideo producerclose');
+  })
+
   return consumerVideo.track
 }
 
@@ -504,6 +515,14 @@ const getAudioTrask = async (audioParams) => {
     console.log('transport closed so consumer closed')
   })
 
+  consumerAudio.on('producerclose', () => {
+    console.log('===================1 consumerAudio producerclose');
+  });
+
+  consumerAudio.on("producerclose", () => {
+    console.log('====================2 consumerAudio producerclose');
+  })
+
   const audioTrack = consumerAudio.track
 
   audioTrack.applyConstraints({
@@ -549,30 +568,30 @@ const closeCall = () => {
   resetCallSettings()
 }
 
-const consume = async () => {
-  console.log('[consume]')
-  console.log('createRecvTransport Consumer')
-  await socket.emit('createWebRtcTransport', { sender: false, callId, dispatcher: true }, ({ params }) => {
-    if (params.error) {
-      console.log('createRecvTransport | createWebRtcTransport | Error', params.error)
-      return
-    }
-    consumerTransport = device.createRecvTransport(params)
-    consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
-      try {
-        await socket.emit('transport-recv-connect', {
-          dtlsParameters,
-        })
-        callback()
-      } catch (error) {
-        errback(error)
-      }
-    })
+// const consume = async (kind) => {
+//   console.log(`[consume] kind: ${kind}`)
+//   console.log('createRecvTransport Consumer')
+//   await socket.emit('createWebRtcTransport', { sender: false, callId, dispatcher: true }, ({ params }) => {
+//     if (params.error) {
+//       console.log('createRecvTransport | createWebRtcTransport | Error', params.error)
+//       return
+//     }
+//     consumerTransport = device.createRecvTransport(params)
+//     consumerTransport.on('connect', async ({ dtlsParameters }, callback, errback) => {
+//       try {
+//         await socket.emit('transport-recv-connect', {
+//           dtlsParameters,
+//         })
+//         callback()
+//       } catch (error) {
+//         errback(error)
+//       }
+//     })
     
-    connectRecvTransport()
-  })
-}
+//     connectRecvTransport()
+//   })
+// }
 
 btnLocalVideo.addEventListener('click', getLocalStream)
-btnRecvSendTransport.addEventListener('click', consume)
+// btnRecvSendTransport.addEventListener('click', consume)
 btnCloseCall.addEventListener('click', closeCall)