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

Update server

Browse Source
This commit is contained in:
Sergiu Toma 2022-11-29 02:39:11 +02:00
parent a3b083fe24
commit 5169d0d49f
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app.js
View File

@ -377,11 +377,11 @@ peers.on('connection', async socket => {
}) })
if (canConsumeVideo && !canConsumeAudio) { if (canConsumeVideo && !canConsumeAudio) {
const videoParams = consumeVideo(callId) const videoParams = consumeVideo(callId, rtpCapabilities)
callback({ videoParams, audioParams: null }); callback({ videoParams, audioParams: null });
} if (canConsumeVideo && canConsumeAudio) { } if (canConsumeVideo && canConsumeAudio) {
const videoParams = consumeVideo(callId) const videoParams = consumeVideo(callId, rtpCapabilities)
const audioParams = consumeAudio(callId) const audioParams = consumeAudio(callId, rtpCapabilities)
callback({ videoParams, audioParams }); callback({ videoParams, audioParams });
} else { } else {
console.log(`[canConsume] Can't consume | callId ${callId}`); console.log(`[canConsume] Can't consume | callId ${callId}`);
@ -409,7 +409,7 @@ peers.on('connection', async socket => {
}); });
}); });
const consumeVideo = async (callId) => { const consumeVideo = async (callId, rtpCapabilities) => {
videoCalls[callId].consumerVideo = await videoCalls[callId].consumerTransport.consume({ videoCalls[callId].consumerVideo = await videoCalls[callId].consumerTransport.consume({
producerId: videoCalls[callId].producerVideo.id, producerId: videoCalls[callId].producerVideo.id,
rtpCapabilities, rtpCapabilities,
@ -438,7 +438,7 @@ const consumeVideo = async (callId) => {
} }
} }
const consumeAudio = async (callId) => { const consumeAudio = async (callId, rtpCapabilities) => {
videoCalls[callId].consumerAudio = await videoCalls[callId].consumerTransport.consume({ videoCalls[callId].consumerAudio = await videoCalls[callId].consumerTransport.consume({
producerId: videoCalls[callId].producerAudio.id, producerId: videoCalls[callId].producerAudio.id,
rtpCapabilities, rtpCapabilities,