Compare commits
2 Commits
LINXD-2270
...
LINXD-2270
Author | SHA1 | Date | |
---|---|---|---|
342d09c3e6 | |||
b3409de3ba |
30
app.js
30
app.js
@ -13,40 +13,40 @@ try {
|
||||
}
|
||||
const mediasoup = require('mediasoup');
|
||||
|
||||
let worker
|
||||
let worker;
|
||||
/**
|
||||
*
|
||||
* videoCalls - Dictionary of Object(s)
|
||||
* '<callId>': {
|
||||
* router: Router, router
|
||||
* router: Router,
|
||||
* initiatorAudioProducer: Producer,
|
||||
* initiatorVideoProducer: Producer,
|
||||
* receiverVideoProducer: Producer, producerVideo
|
||||
* receiverAudioProducer: Producer, producerAudio
|
||||
* receiverVideoProducer: Producer,
|
||||
* receiverAudioProducer: Producer,
|
||||
* initiatorProducerTransport: Producer Transport,
|
||||
* receiverProducerTransport: Producer Transport, producerTransport
|
||||
* initiatorConsumerVideo: Consumer, consumerVideo
|
||||
* initiatorConsumerAudio: Consumer, consumerAudio
|
||||
* initiatorConsumerTransport: Consumer Transport consumerTransport
|
||||
* receiverProducerTransport: Producer Transport,
|
||||
* initiatorConsumerVideo: Consumer,
|
||||
* initiatorConsumerAudio: Consumer,
|
||||
* initiatorConsumerTransport: Consumer Transport
|
||||
* initiatorSockerId
|
||||
* receiverSocketId
|
||||
* }
|
||||
*
|
||||
**/
|
||||
let videoCalls = {}
|
||||
let socketDetails = {}
|
||||
let videoCalls = {};
|
||||
let socketDetails = {};
|
||||
|
||||
app.get('/', (_req, res) => {
|
||||
res.send('Hello from mediasoup app!')
|
||||
})
|
||||
});
|
||||
|
||||
app.use('/sfu', express.static(path.join(__dirname, 'public')))
|
||||
app.use('/sfu', express.static(path.join(__dirname, 'public')));
|
||||
|
||||
// SSL cert for HTTPS access
|
||||
const options = {
|
||||
key: fs.readFileSync(process.env.SERVER_KEY, 'utf-8'),
|
||||
cert: fs.readFileSync(process.env.SERVER_CERT, 'utf-8'),
|
||||
}
|
||||
};
|
||||
|
||||
const httpsServer = https.createServer(options, app);
|
||||
|
||||
@ -225,7 +225,6 @@ peers.on('connection', async socket => {
|
||||
*/
|
||||
socket.on('createWebRtcTransport', async ({ sender }, callback) => {
|
||||
try {
|
||||
console.log('🟥', socket.id, JSON.stringify(sender));
|
||||
const callId = socketDetails[socket.id];
|
||||
console.log(`[createWebRtcTransport] socket ${socket.id} | sender ${sender} | callId ${callId}`);
|
||||
if (sender) {
|
||||
@ -429,7 +428,6 @@ peers.on('connection', async socket => {
|
||||
} else if (!canConsumeVideo && canConsumeAudio) {
|
||||
const audioParams = await consumeAudio(callId, socket.id, rtpCapabilities)
|
||||
const data = { videoParams: null, audioParams };
|
||||
console.log('-----------======= data', data);
|
||||
callback(data);
|
||||
} else {
|
||||
console.log(`[consume] Can't consume | callId ${callId}`);
|
||||
@ -459,8 +457,6 @@ peers.on('connection', async socket => {
|
||||
(videoCalls[callId].receiverConsumerVideo) && await videoCalls[callId].receiverConsumerVideo.resume();
|
||||
(videoCalls[callId].receiverConsumerVideo) && await videoCalls[callId].receiverConsumerAudio.resume();
|
||||
}
|
||||
// await videoCalls[callId].consumerVideo.resume();
|
||||
// await videoCalls[callId].consumerAudio.resume();
|
||||
} catch (error) {
|
||||
console.log(`ERROR | consumer-resume | callId ${socketDetails[socket.id]} | ${error.message}`);
|
||||
}
|
||||
|
@ -20811,28 +20811,15 @@ const connectRecvTransport = async () => {
|
||||
if (audioParams) {
|
||||
console.log('❗ Have AUDIO stream to consume');
|
||||
let audioTrack = await getAudioTrask(audioParams)
|
||||
console.log('audioTrack', audioTrack);
|
||||
stream.addTrack(audioTrack)
|
||||
} else {
|
||||
console.log('❗ Don\'t have AUDIO stream to consume');
|
||||
}
|
||||
|
||||
console.log('----------stream', stream);
|
||||
console.log('stream.getAudioTracks()', stream.getAudioTracks());
|
||||
socket.emit('consumer-resume')
|
||||
|
||||
remoteVideo.srcObject = stream
|
||||
// remoteVideo.autoplay = true
|
||||
remoteVideo.controls = true;
|
||||
remoteVideo.muted = true;
|
||||
remoteVideo.loop = true;
|
||||
remoteVideo.setAttribute('playsinline', '');
|
||||
remoteVideo.src = stream;
|
||||
remoteVideo.volume = 1.0;
|
||||
|
||||
// window.localStream = stream; // A
|
||||
// window.localAudio.srcObject = stream; // B
|
||||
// window.localAudio.autoplay = true; // C
|
||||
remoteVideo.setAttribute('autoplay', true)
|
||||
|
||||
remoteVideo.play()
|
||||
.then(() => {
|
||||
@ -20873,24 +20860,24 @@ const getAudioTrask = async (audioParams) => {
|
||||
|
||||
const audioTrack = consumerAudio.track
|
||||
|
||||
// audioTrack.applyConstraints({
|
||||
// audio: {
|
||||
// advanced: [
|
||||
// {
|
||||
// echoCancellation: {exact: true}
|
||||
// },
|
||||
// {
|
||||
// autoGainControl: {exact: true}
|
||||
// },
|
||||
// {
|
||||
// noiseSuppression: {exact: true}
|
||||
// },
|
||||
// {
|
||||
// highpassFilter: {exact: true}
|
||||
// }
|
||||
// ]
|
||||
// }
|
||||
// })
|
||||
audioTrack.applyConstraints({
|
||||
audio: {
|
||||
advanced: [
|
||||
{
|
||||
echoCancellation: {exact: true}
|
||||
},
|
||||
{
|
||||
autoGainControl: {exact: true}
|
||||
},
|
||||
{
|
||||
noiseSuppression: {exact: true}
|
||||
},
|
||||
{
|
||||
highpassFilter: {exact: true}
|
||||
}
|
||||
]
|
||||
}
|
||||
})
|
||||
|
||||
return audioTrack
|
||||
}
|
||||
|
Binary file not shown.
Before Width: | Height: | Size: 4.2 KiB |
Binary file not shown.
Before Width: | Height: | Size: 493 B |
Binary file not shown.
Before Width: | Height: | Size: 418 B |
@ -453,28 +453,15 @@ const connectRecvTransport = async () => {
|
||||
if (audioParams) {
|
||||
console.log('❗ Have AUDIO stream to consume');
|
||||
let audioTrack = await getAudioTrask(audioParams)
|
||||
console.log('audioTrack', audioTrack);
|
||||
stream.addTrack(audioTrack)
|
||||
} else {
|
||||
console.log('❗ Don\'t have AUDIO stream to consume');
|
||||
}
|
||||
|
||||
console.log('----------stream', stream);
|
||||
console.log('stream.getAudioTracks()', stream.getAudioTracks());
|
||||
socket.emit('consumer-resume')
|
||||
|
||||
remoteVideo.srcObject = stream
|
||||
// remoteVideo.autoplay = true
|
||||
remoteVideo.controls = true;
|
||||
remoteVideo.muted = true;
|
||||
remoteVideo.loop = true;
|
||||
remoteVideo.setAttribute('playsinline', '');
|
||||
remoteVideo.src = stream;
|
||||
remoteVideo.volume = 1.0;
|
||||
|
||||
// window.localStream = stream; // A
|
||||
// window.localAudio.srcObject = stream; // B
|
||||
// window.localAudio.autoplay = true; // C
|
||||
remoteVideo.setAttribute('autoplay', true)
|
||||
|
||||
remoteVideo.play()
|
||||
.then(() => {
|
||||
@ -515,24 +502,24 @@ const getAudioTrask = async (audioParams) => {
|
||||
|
||||
const audioTrack = consumerAudio.track
|
||||
|
||||
// audioTrack.applyConstraints({
|
||||
// audio: {
|
||||
// advanced: [
|
||||
// {
|
||||
// echoCancellation: {exact: true}
|
||||
// },
|
||||
// {
|
||||
// autoGainControl: {exact: true}
|
||||
// },
|
||||
// {
|
||||
// noiseSuppression: {exact: true}
|
||||
// },
|
||||
// {
|
||||
// highpassFilter: {exact: true}
|
||||
// }
|
||||
// ]
|
||||
// }
|
||||
// })
|
||||
audioTrack.applyConstraints({
|
||||
audio: {
|
||||
advanced: [
|
||||
{
|
||||
echoCancellation: {exact: true}
|
||||
},
|
||||
{
|
||||
autoGainControl: {exact: true}
|
||||
},
|
||||
{
|
||||
noiseSuppression: {exact: true}
|
||||
},
|
||||
{
|
||||
highpassFilter: {exact: true}
|
||||
}
|
||||
]
|
||||
}
|
||||
})
|
||||
|
||||
return audioTrack
|
||||
}
|
||||
|
Reference in New Issue
Block a user