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

LINXD-2270-p2 #19

Closed
sergiu wants to merge 58 commits from LINXD-2270-p2 into develop
pull from: LINXD-2270-p2
merge into: Safemobile:develop
Conversation 0 Commits 58 Files Changed 8 +8 -5
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 92fbecc36a - Show all commits

13
app.js
View File

@ -200,9 +200,9 @@ peers.on('connection', async socket => {
console.log('[createRoom] callId', callId); console.log('[createRoom] callId', callId);
videoCalls[callId] = { router: await worker.createRouter({ mediaCodecs }) } videoCalls[callId] = { router: await worker.createRouter({ mediaCodecs }) }
console.log(`[createRoom] Router ID: ${videoCalls[callId].router.id}`); console.log(`[createRoom] Router ID: ${videoCalls[callId].router.id}`);
videoCalls[callId].initiatorSockerId = socket.id
} else {
videoCalls[callId].receiverSocketId = socket.id videoCalls[callId].receiverSocketId = socket.id
} else {
videoCalls[callId].initiatorSockerId = socket.id
} }
socketDetails[socket.id] = callId; socketDetails[socket.id] = callId;
// rtpCapabilities is set for callback // rtpCapabilities is set for callback
@ -453,6 +453,10 @@ const consumeAudio = async (callId, rtpCapabilities) => {
console.log('producer of consumer closed', callId); console.log('producer of consumer closed', callId);
closeCall(callId); closeCall(callId);
}); });
if(isInitiator(callId, sockId)) {
}
return { return {
id: videoCalls[callId].consumerAudio.id, id: videoCalls[callId].consumerAudio.id,
producerId: videoCalls[callId].producerAudio.id, producerId: videoCalls[callId].producerAudio.id,
@ -461,9 +465,8 @@ const consumeAudio = async (callId, rtpCapabilities) => {
} }
} }
const isInitiator = async (callId, socketId) => { const isInitiator = (callId, socketId) => {
if (videoCalls[callId].initiatorSockerId === socketId) return true; return (videoCalls[callId].initiatorSockerId === socketId);
else return false
} }
/* /*