[mirotalksfu] - fix, update dep

app/src/Peer.js

@@ -238,7 +238,7 @@ module.exports = class Peer {
             producerId: producer_id,
             rtpCapabilities,
             enableRtx: true, // Enable NACK for OPUS.
-            paused: false,
+            paused: true,
         });
 
         const { id, type, kind, rtpParameters, producerPaused } = consumer;

app/src/Server.js

@@ -42,7 +42,7 @@ dependencies: {
  * @license For commercial or closed source, contact us at license.mirotalk@gmail.com or purchase directly via CodeCanyon
  * @license CodeCanyon: https://codecanyon.net/item/mirotalk-sfu-webrtc-realtime-video-conferences/40769970
  * @author  Miroslav Pejic - miroslav.pejic.85@gmail.com
- * @version 1.4.46
+ * @version 1.4.47
  *
  */
 
@@ -1418,6 +1418,38 @@ function startServer() {
             callback('successfully');
         });
 
+        socket.on('resumeConsumer', async ({ consumer_id }, callback) => {
+            if (!roomList.has(socket.room_id)) return;
+
+            const room = roomList.get(socket.room_id);
+
+            const peer_name = getPeerName(room, false);
+
+            const peer = room.getPeer(socket.id);
+
+            if (!peer) {
+                return callback({
+                    error: `peer with ID: "${socket.id}" for consumer with id "${consumer_id}" not found`,
+                });
+            }
+
+            const consumer = peer.getConsumer(consumer_id);
+
+            if (!consumer) {
+                return callback({ error: `consumer with id "${consumer_id}" not found` });
+            }
+
+            try {
+                await consumer.resume();
+            } catch (error) {
+                return callback({ error: error.message });
+            }
+
+            log.debug('Consumer resumed', { peer_name: peer_name, consumer_id: consumer_id });
+
+            callback('successfully');
+        });
+
         socket.on('getProducers', () => {
             if (!roomList.has(socket.room_id)) return;
 

package.json

@@ -1,6 +1,6 @@
 {
     "name": "mirotalksfu",
-    "version": "1.4.46",
+    "version": "1.4.47",
     "description": "WebRTC SFU browser-based video calls",
     "main": "Server.js",
     "scripts": {
@@ -58,7 +58,7 @@
         "mediasoup-client": "3.7.8",
         "ngrok": "^5.0.0-beta.2",
         "nodemailer": "^6.9.13",
-        "openai": "^4.48.2",
+        "openai": "^4.49.0",
         "qs": "6.12.1",
         "socket.io": "4.7.5",
         "swagger-ui-express": "5.0.1",
@@ -68,6 +68,6 @@
     "devDependencies": {
         "node-fetch": "^3.3.2",
         "nodemon": "^3.1.3",
-        "prettier": "3.3.0"
+        "prettier": "3.3.1"
     }
 }

public/js/Room.js

@@ -11,7 +11,7 @@ if (location.href.substr(0, 5) !== 'https') location.href = 'https' + location.h
  * @license For commercial or closed source, contact us at license.mirotalk@gmail.com or purchase directly via CodeCanyon
  * @license CodeCanyon: https://codecanyon.net/item/mirotalk-sfu-webrtc-realtime-video-conferences/40769970
  * @author  Miroslav Pejic - miroslav.pejic.85@gmail.com
- * @version 1.4.46
+ * @version 1.4.47
  *
  */
 

public/js/RoomClient.js

@@ -9,7 +9,7 @@
  * @license For commercial or closed source, contact us at license.mirotalk@gmail.com or purchase directly via CodeCanyon
  * @license CodeCanyon: https://codecanyon.net/item/mirotalk-sfu-webrtc-realtime-video-conferences/40769970
  * @author  Miroslav Pejic - miroslav.pejic.85@gmail.com
- * @version 1.4.46
+ * @version 1.4.47
  *
  */
 
@@ -2064,6 +2064,14 @@ class RoomClient {
 
             this.consumers.set(consumer.id, consumer);
 
+            // https://mediasoup.discourse.group/t/create-server-side-consumers-with-paused-true/244
+            try {
+                const response = await this.socket.request('resumeConsumer', { consumer_id: consumer.id });
+                console.log('Consumer resumed', response);
+            } catch (error) {
+                console.error('Error resuming consumer', error);
+            }
+
             consumer.on('trackended', () => {
                 console.log('Consumer track end', { id: consumer.id });
                 this.removeConsumer(consumer.id, consumer.kind);