Safemobile/mediasoup
21
0
Fork 0
Code Issues Pull Requests 1 Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
Sergiu Toma 2023-01-13 19:37:27 +02:00
parent c7049ef909
commit 1f3fbba5c0
1 changed files with 29 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
app.js
View File

@ -290,31 +290,36 @@ peers.on('connection', async socket => {
const router = videoCalls[callId].router;
router.observer.on("newtransport", (transport) => {
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
);
if (!isInitiator(callId, socket.id)) {
console.log('🟥 Emit to initiatorSocket');
videoCalls[callId].initiatorSocket.emit('new-producer', {
callId
});
} else {
console.log('🟥 Emit to receiverSocket');
videoCalls[callId].receiverSocket.emit('new-producer', {
callId
});
}
try {
const router = videoCalls[callId].router;
router.observer.on("newtransport", (transport) => {
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
);
if (!isInitiator(callId, socket.id)) {
console.log('🟥 Emit to initiatorSocket');
videoCalls[callId].initiatorSocket.emit('new-producer', {
callId
});
} else {
console.log('🟥 Emit to receiverSocket');
videoCalls[callId].receiverSocket.emit('new-producer', {
callId
});
}
});
});
});
} catch (error) {
console.log('&&&&&&&&&&&&&&&&', error.message);
}