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

Update

Browse Source
This commit is contained in:
Sergiu Toma 2022-12-19 12:01:21 +02:00
parent bb4cd756f3
commit b15357d089
2 changed files with 66 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
public/bundle.js
View File

@ -20763,32 +20763,42 @@ const connectRecvTransport = async () => {
rtpCapabilities: device.rtpCapabilities, rtpCapabilities: device.rtpCapabilities,
callId callId
}, async ({videoParams, audioParams}) => { }, async ({videoParams, audioParams}) => {
console.log(`[consume] videoParams ${videoParams}`); console.log(`[consume] 🟩 videoParams`, videoParams)
console.log(`[consume] audioParams ${audioParams}`); console.log(`[consume] 🟩 audioParams`, audioParams)
if (!audioParams) { console.log('[consume] 🟩 consumerTransport', consumerTransport)
console.log('Cannot Consume audio')
return
}
// Then consume with the local consumer transport
// which creates a consumer
consumer = await consumerTransport.consume({
id: audioParams.id,
producerId: audioParams.producerId,
kind: audioParams.kind,
rtpParameters: audioParams.rtpParameters
})
// destructure and retrieve the video track from the producer
const { track } = consumer
let stream = new MediaStream() let stream = new MediaStream()
stream.addTrack(track)
// stream.removeTrack(track)
remoteVideo.srcObject = stream
socket.emit('consumer-resume')
console.log('consumer', consumer);
// Maybe the unit does not produce video or audio, so we must only consume what is produced
if (videoParams) {
stream.addTrack(await getVideoTrask(videoParams))
} else {
console.log('❗ Don\'t have VIDEO stream to consume');
}
if (audioParams) {
let audioTrack = await getAudioTrask(audioParams)
stream.addTrack(audioTrack)
} else {
console.log('❗ Don\'t have AUDIO stream to consume');
// const soundElement = document.getElementById('sound');
// soundElement.remove();
}
socket.emit('consumer-resume')
let remoteVideo = document.getElementById('remoteVideo')
remoteVideo.srcObject = stream
remoteVideo.setAttribute('autoplay', true)
remoteVideo.setAttribute('muted', false)
remoteVideo.play()
.then(() => {
console.log('remoteVideo PLAY')
})
.catch((error) => {
displayError(`remoteVideo PLAY ERROR | ${error.message}`)
})
}) })
} }

56
public/index.js
View File

@ -405,32 +405,42 @@ const connectRecvTransport = async () => {
rtpCapabilities: device.rtpCapabilities, rtpCapabilities: device.rtpCapabilities,
callId callId
}, async ({videoParams, audioParams}) => { }, async ({videoParams, audioParams}) => {
console.log(`[consume] videoParams ${videoParams}`); console.log(`[consume] 🟩 videoParams`, videoParams)
console.log(`[consume] audioParams ${audioParams}`); console.log(`[consume] 🟩 audioParams`, audioParams)
if (!audioParams) { console.log('[consume] 🟩 consumerTransport', consumerTransport)
console.log('Cannot Consume audio')
return
}
// Then consume with the local consumer transport
// which creates a consumer
consumer = await consumerTransport.consume({
id: audioParams.id,
producerId: audioParams.producerId,
kind: audioParams.kind,
rtpParameters: audioParams.rtpParameters
})
// destructure and retrieve the video track from the producer
const { track } = consumer
let stream = new MediaStream() let stream = new MediaStream()
stream.addTrack(track)
// stream.removeTrack(track)
remoteVideo.srcObject = stream
socket.emit('consumer-resume')
console.log('consumer', consumer);
// Maybe the unit does not produce video or audio, so we must only consume what is produced
if (videoParams) {
stream.addTrack(await getVideoTrask(videoParams))
} else {
console.log('❗ Don\'t have VIDEO stream to consume');
}
if (audioParams) {
let audioTrack = await getAudioTrask(audioParams)
stream.addTrack(audioTrack)
} else {
console.log('❗ Don\'t have AUDIO stream to consume');
// const soundElement = document.getElementById('sound');
// soundElement.remove();
}
socket.emit('consumer-resume')
let remoteVideo = document.getElementById('remoteVideo')
remoteVideo.srcObject = stream
remoteVideo.setAttribute('autoplay', true)
remoteVideo.setAttribute('muted', false)
remoteVideo.play()
.then(() => {
console.log('remoteVideo PLAY')
})
.catch((error) => {
displayError(`remoteVideo PLAY ERROR | ${error.message}`)
})
}) })
} }