fix

Reviewed-on: #12

.env

@@ -1,3 +1,7 @@
 PORT=3000
 IP=0.0.0.0 #	Listening IPv4 or IPv6.
 ANNOUNCED_IP=185.8.154.190 # Announced IPv4 or IPv6 (useful when running mediasoup behind NAT with private IP).
+RTC_MIN_PORT=2000
+RTC_MAX_PORT=2020
+SERVER_CERT="./server/ssl/cert.pem"
+SERVER_KEY="./server/ssl/key.pem"

app.js

@@ -5,12 +5,7 @@ const app = express();
 const Server = require('socket.io');
 const path = require('node:path');
 const fs = require('node:fs');
-let https = require('https');
-try {
-  https = require('node:https');
-} catch (err) {
-  console.log('https support is disabled!');
-}
+const https = require('https');
 const mediasoup = require('mediasoup');
 
 let worker
@@ -59,16 +54,17 @@ const io = new Server(httpsServer, {
 // const io = new Server(server, { origins: '*:*', allowEIO3: true });
 
 httpsServer.listen(process.env.PORT, () => {
-  console.log('Video server listening on port:', process.env.PORT)
-})
-
-const peers = io.of('/')
+  console.log('Video server listening on port:', process.env.PORT);
+});
 
+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 () => {
   try {
     worker = await mediasoup.createWorker({
-      rtcMinPort: 2000,
-      rtcMaxPort: 2020,
+      rtcMinPort: process.env.RTC_MIN_PORT,
+      rtcMaxPort: process.env.RTC_MAX_PORT,
     })
     console.log(`[createWorker] worker pid ${worker.pid}`);
   
@@ -84,7 +80,7 @@ const createWorker = async () => {
 }
 
 // We create a Worker as soon as our application starts
-worker = createWorker()
+worker = createWorker();
 
 // This is an Array of RtpCapabilities
 // https://mediasoup.org/documentation/v3/mediasoup/rtp-parameters-and-capabilities/#RtpCodecCapability
@@ -105,11 +101,11 @@ const mediaCodecs = [
       'x-google-start-bitrate': 1000,
     },
   },
-]
+];
 
 const closeCall = (callId) => {
   try {
-    if (videoCalls[callId]) {
+    if (callId && videoCalls[callId]) {
       videoCalls[callId].producer?.close();
       videoCalls[callId].consumer?.close();
       videoCalls[callId]?.consumerTransport?.close();
@@ -215,14 +211,12 @@ peers.on('connection', async socket => {
   socket.on('transport-connect', async ({ dtlsParameters }) => {
     try {
       const callId = socketDetails[socket.id];
-      // console.log('🔴 typeof dtlsParameters', typeof dtlsParameters);
-      // console.log('🟢 dtlsParameters', JSON.parse(dtlsParameters));
-      // console.log('🟡 dtlsParameters', dtlsParameters);
       if (typeof dtlsParameters === 'string') dtlsParameters = JSON.parse(dtlsParameters);
+
       console.log(`[transport-connect] socket.id ${socket.id} | callId ${callId}`);
       await videoCalls[callId].producerTransport.connect({ dtlsParameters });
     } catch (error) {
-      console.log(`ERROR | transport-connect | callId ${socketDetails[socket.id]} | ${error.stack}`);
+      console.log(`ERROR | transport-connect | callId ${socketDetails[socket.id]} | ${error.message}`);
     }
   });
 
@@ -231,9 +225,11 @@ peers.on('connection', async socket => {
     - For the router with the id callId, we make produce on producerTransport
     - Create the handler on producer at the 'transportclose' event
   */
-  socket.on('transport-produce', async ({ kind, rtpParameters, appData }) => {
+  socket.on('transport-produce', async ({ kind, rtpParameters, appData }, callback) => {
     try {
       const callId = socketDetails[socket.id];
+      if (typeof rtpParameters === 'string') rtpParameters = JSON.parse(rtpParameters);
+
       console.log('[transport-produce] | socket.id', socket.id, '| callId', callId);
       videoCalls[callId].producer = await videoCalls[callId].producerTransport.produce({
         kind,
@@ -246,6 +242,11 @@ peers.on('connection', async socket => {
         console.log('transport for this producer closed', callId)
         closeCall(callId);
       });
+
+      // Send back to the client the Producer's id
+      // callback({
+      //   id: videoCalls[callId].producer.id
+      // });
     } catch (error) {
       console.log(`ERROR | transport-produce | callId ${socketDetails[socket.id]} | ${error.message}`);
     }
@@ -294,14 +295,14 @@ peers.on('connection', async socket => {
         videoCalls[callId].consumer.on('transportclose', () => {
           const callId = socketDetails[socket.id];
           console.log('transport close from consumer', callId);
-          closeCall();
+          closeCall(callId);
         });
 
         // https://mediasoup.org/documentation/v3/mediasoup/api/#consumer-on-producerclose
         videoCalls[callId].consumer.on('producerclose', () => {
           const callId = socketDetails[socket.id];
           console.log('producer of consumer closed', callId);
-          closeCall();
+          closeCall(callId);
         });
 
         // From the consumer extract the following params to send back to the Client
@@ -385,7 +386,6 @@ const createWebRtcTransportLayer = async (callId, callback) => {
       dtlsParameters: transport.dtlsParameters,
     };
 
-    console.log(`createWebRtcTransportLayer | params.dtlsParameters ${params.dtlsParameters}`);
     // Send back to the client the params
     callback({ params });