Compare commits
10 Commits
4.01
...
fix-branch
Author | SHA1 | Date | |
---|---|---|---|
2e336a429e | |||
b14e82fd87 | |||
c4f72eddd5 | |||
6e4ceb9977 | |||
2c00de1dd0 | |||
f96fd24e03 | |||
fce2f30648 | |||
be5f97762a | |||
03a11126c4 | |||
fafbee6e4c |
20
app.js
20
app.js
@ -5,12 +5,7 @@ const app = express();
|
|||||||
const Server = require('socket.io');
|
const Server = require('socket.io');
|
||||||
const path = require('node:path');
|
const path = require('node:path');
|
||||||
const fs = require('node:fs');
|
const fs = require('node:fs');
|
||||||
let https;
|
const https = require('https');
|
||||||
try {
|
|
||||||
https = require('node:https');
|
|
||||||
} catch (err) {
|
|
||||||
console.log('https support is disabled!');
|
|
||||||
}
|
|
||||||
const mediasoup = require('mediasoup');
|
const mediasoup = require('mediasoup');
|
||||||
|
|
||||||
let worker
|
let worker
|
||||||
@ -42,8 +37,8 @@ app.use('/sfu', express.static(path.join(__dirname, 'public')))
|
|||||||
|
|
||||||
// SSL cert for HTTPS access
|
// SSL cert for HTTPS access
|
||||||
const options = {
|
const options = {
|
||||||
key: fs.readFileSync(process.env.SERVER_KEY, 'utf-8'),
|
key: fs.readFileSync('./server/ssl/key.pem', 'utf-8'),
|
||||||
cert: fs.readFileSync(process.env.SERVER_CERT, 'utf-8'),
|
cert: fs.readFileSync('./server/ssl/cert.pem', 'utf-8'),
|
||||||
}
|
}
|
||||||
|
|
||||||
const httpsServer = https.createServer(options, app);
|
const httpsServer = https.createServer(options, app);
|
||||||
@ -63,7 +58,8 @@ httpsServer.listen(process.env.PORT, () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
const peers = io.of('/');
|
const peers = io.of('/');
|
||||||
|
console.log('process.env.RTC_MIN_PORT', process.env.RTC_MIN_PORT);
|
||||||
|
console.log('process.env.RTC_MAX_PORT', process.env.RTC_MAX_PORT, process.env.RTC_MAX_PORT.length);
|
||||||
const createWorker = async () => {
|
const createWorker = async () => {
|
||||||
try {
|
try {
|
||||||
worker = await mediasoup.createWorker({
|
worker = await mediasoup.createWorker({
|
||||||
@ -109,7 +105,7 @@ const mediaCodecs = [
|
|||||||
|
|
||||||
const closeCall = (callId) => {
|
const closeCall = (callId) => {
|
||||||
try {
|
try {
|
||||||
if (videoCalls[callId]) {
|
if (callId && videoCalls[callId]) {
|
||||||
videoCalls[callId].producer?.close();
|
videoCalls[callId].producer?.close();
|
||||||
videoCalls[callId].consumer?.close();
|
videoCalls[callId].consumer?.close();
|
||||||
videoCalls[callId]?.consumerTransport?.close();
|
videoCalls[callId]?.consumerTransport?.close();
|
||||||
@ -299,14 +295,14 @@ peers.on('connection', async socket => {
|
|||||||
videoCalls[callId].consumer.on('transportclose', () => {
|
videoCalls[callId].consumer.on('transportclose', () => {
|
||||||
const callId = socketDetails[socket.id];
|
const callId = socketDetails[socket.id];
|
||||||
console.log('transport close from consumer', callId);
|
console.log('transport close from consumer', callId);
|
||||||
closeCall();
|
closeCall(callId);
|
||||||
});
|
});
|
||||||
|
|
||||||
// https://mediasoup.org/documentation/v3/mediasoup/api/#consumer-on-producerclose
|
// https://mediasoup.org/documentation/v3/mediasoup/api/#consumer-on-producerclose
|
||||||
videoCalls[callId].consumer.on('producerclose', () => {
|
videoCalls[callId].consumer.on('producerclose', () => {
|
||||||
const callId = socketDetails[socket.id];
|
const callId = socketDetails[socket.id];
|
||||||
console.log('producer of consumer closed', callId);
|
console.log('producer of consumer closed', callId);
|
||||||
closeCall();
|
closeCall(callId);
|
||||||
});
|
});
|
||||||
|
|
||||||
// From the consumer extract the following params to send back to the Client
|
// From the consumer extract the following params to send back to the Client
|
||||||
|
Reference in New Issue
Block a user