Remove callback with producer id from transport-produce

app.js

@@ -149,13 +149,12 @@ peers.on('connection', async socket => {
   })
 
   // see client's socket.emit('transport-produce', ...)
-  socket.on('transport-produce', async ({ kind, rtpParameters, appData }, callback) => {
+  socket.on('transport-produce', async ({ kind, rtpParameters, appData }) => {
     // call produce based on the prameters from the client
     producer = await producerTransport.produce({
       kind,
       rtpParameters,
     })
-
     console.log(`[transport-produce] Producer ID: ${producer.id} | kind: ${producer.kind}`)
 
     producer.on('transportclose', () => {
@@ -168,11 +167,6 @@ peers.on('connection', async socket => {
       router[callId].close()
       delete router[callId]
     })
-
-    // Send back to the client the Producer's id
-    callback({
-      id: producer.id
-    })
   })
 
   // see client's socket.emit('transport-recv-connect', ...)
@@ -183,7 +177,7 @@ peers.on('connection', async socket => {
 
   socket.on('consume', async ({ rtpCapabilities, callId }, callback) => {
     try {
-      console.log('consume', rtpCapabilities, callId);
+      // console.log('consume', rtpCapabilities, callId);
       // check if the router can consume the specified producer
       if (router[callId].canConsume({
         producerId: producer.id,
@@ -198,8 +192,12 @@ peers.on('connection', async socket => {
 
         consumer.on('transportclose', () => {
           console.log('transport close from consumer', callId)
-          // closeRoom(callId)
+          
+          // https://mediasoup.org/documentation/v3/mediasoup/api/#router-close
+          router[callId].close()
           delete router[callId]
+          producer.close()
+          consumer.close()
         })
 
         consumer.on('producerclose', () => {
@@ -208,6 +206,8 @@ peers.on('connection', async socket => {
           // https://mediasoup.org/documentation/v3/mediasoup/api/#router-close
           router[callId].close()
           delete router[callId]
+          producer.close()
+          consumer.close()
         })
 
         // from the consumer extract the following params
@@ -278,7 +278,7 @@ const createWebRtcTransportLayer = async (callId, callback) => {
       dtlsParameters: transport.dtlsParameters,
     }
 
-    console.log('params', params);
+    // console.log('params', params);
 
     // send back to the client the following prameters
     callback({