diff --git a/app.js b/app.js index 34fcc51..0e38012 100644 --- a/app.js +++ b/app.js @@ -335,6 +335,14 @@ peers.on('connection', async (socket) => { }); videoCalls[callId].initiatorVideoProducer.observer.on("close", () => { console.log('====================2 initiatorVideoProducer for this producer closed', callId); + // const socketToEmit = isInitiator(callId, socket.id) + // ? videoCalls[callId].receiverSocket + // : videoCalls[callId].initiatorSocket; + + // // callId - Id of the call + // // kind - producer type: audio/video + // socketToEmit.emit('new-producer', { callId, kind }); + receiverSocket.emit('close-producer', { callId, kind }); }) videoCalls[callId].initiatorVideoProducer.on('producerclose', () => { diff --git a/public/bundle.js b/public/bundle.js index 57ef38c..6208ae5 100644 --- a/public/bundle.js +++ b/public/bundle.js @@ -20457,6 +20457,10 @@ setTimeout(() => { console.log(`🟢 new-producer | callId: ${callId} | kind: ${kind} | Ready to consume`); connectRecvTransport(); }) + + socket.on('close-producer', ({ callId, kind }) => { + console.log(`🔴 close-producer | callId: ${callId} | kind: ${kind}`); + }) } if (IS_PRODUCER === true) { @@ -20857,6 +20861,28 @@ const getVideoTrask = async (videoParams) => { consumerVideo.on("producerclose", () => { console.log('====================2 consumerVideo producerclose'); }) + consumerVideo.on("close", () => { + console.log('====================3 consumerVideo producerclose'); + }) + consumerVideo.on("close-producer", () => { + console.log('====================4 consumerVideo producerclose'); + }) + + + + consumerVideo.observer.on('producerclose', () => { + console.log('===================11 consumerVideo producerclose'); + }); + + consumerVideo.observer.on("producerclose", () => { + console.log('====================22 consumerVideo producerclose'); + }) + consumerVideo.observer.on("close", () => { + console.log('====================33 consumerVideo producerclose'); + }) + consumerVideo.observer.on("close-producer", () => { + console.log('====================44 consumerVideo producerclose'); + }) return consumerVideo.track } diff --git a/public/index.js b/public/index.js index ed66dc8..ba76d61 100644 --- a/public/index.js +++ b/public/index.js @@ -99,6 +99,10 @@ setTimeout(() => { console.log(`🟢 new-producer | callId: ${callId} | kind: ${kind} | Ready to consume`); connectRecvTransport(); }) + + socket.on('close-producer', ({ callId, kind }) => { + console.log(`🔴 close-producer | callId: ${callId} | kind: ${kind}`); + }) } if (IS_PRODUCER === true) { @@ -499,6 +503,28 @@ const getVideoTrask = async (videoParams) => { consumerVideo.on("producerclose", () => { console.log('====================2 consumerVideo producerclose'); }) + consumerVideo.on("close", () => { + console.log('====================3 consumerVideo producerclose'); + }) + consumerVideo.on("close-producer", () => { + console.log('====================4 consumerVideo producerclose'); + }) + + + + consumerVideo.observer.on('producerclose', () => { + console.log('===================11 consumerVideo producerclose'); + }); + + consumerVideo.observer.on("producerclose", () => { + console.log('====================22 consumerVideo producerclose'); + }) + consumerVideo.observer.on("close", () => { + console.log('====================33 consumerVideo producerclose'); + }) + consumerVideo.observer.on("close-producer", () => { + console.log('====================44 consumerVideo producerclose'); + }) return consumerVideo.track }