From 21b4b6d04f387fa8bfa19503d247fccd0d4ed9ae Mon Sep 17 00:00:00 2001
From: Sergiu Toma <sergiu.toma@safemobile.com>
Date: Mon, 20 Feb 2023 19:55:39 +0200
Subject: [PATCH] LH-276: Update producer close enent handler

---
 app.js | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

diff --git a/app.js b/app.js
index eaa31d4..a8297c9 100644
--- a/app.js
+++ b/app.js
@@ -289,13 +289,11 @@ 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', () => {
-            const callId = socketDetails[socket.id];
             console.log('receiverVideoProducer for this producer closed', callId);
           });
 
@@ -315,16 +313,20 @@ 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', () => {
-            const callId = socketDetails[socket.id];
-            console.log('initiatorVideoProducer for this producer closed', callId);
+            console.log('1 initiatorVideoProducer for this producer closed', callId);
           });
 
+          videoCalls[callId].initiatorVideoProducer.observer.on("close", () => {
+            console.log('2 initiatorVideoProducer for this producer closed', callId);
+          })
+
           callback &&
             callback({
               id: videoCalls[callId].initiatorVideoProducer.id,
@@ -342,13 +344,11 @@ 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', () => {
-            const callId = socketDetails[socket.id];
             console.log('receiverAudioProducer for this producer closed', callId);
           });
 
@@ -368,13 +368,11 @@ 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', () => {
-            const callId = socketDetails[socket.id];
             console.log('initiatorAudioProducer for this producer closed', callId);
           });