@scrypted/client - npm Package Compare versions

Comparing version 1.1.25 to 1.1.26

dist/packages/client/package.json

 {
     "name": "@scrypted/client",
-    "version": "1.1.25",
+    "version": "1.1.26",
     "description": "",
@@ -5,0 +5,0 @@ "main": "dist/packages/client/src/index.js",

dist/packages/client/src/index.js

@@ -263,5 +263,6 @@ "use strict";
                 const session = new rtc_signaling_1.BrowserSignalingSession();
+                const droppedMessages = [];
                 session.onPeerConnection = async (pc) => {
                     pc.ondatachannel = e => {
-                        e.channel.onmessage = () => console.log('dropped mesage');
+                        e.channel.onmessage = message => droppedMessages.push(message);
                         e.channel.binaryType = 'arraybuffer';
@@ -311,2 +312,6 @@ dcDeferred.resolve(e.channel);
                         });
+                        while (droppedMessages.length) {
+                            const message = droppedMessages.shift();
+                            dc.dispatchEvent(message);
+                        }
                         const ret = new rpc_1.RpcPeer('webrtc-client', "api", (message, reject, serializationContext) => {
@@ -313,0 +318,0 @@ try {

package.json

 {
   "name": "@scrypted/client",
-  "version": "1.1.25",
+  "version": "1.1.26",
   "description": "",
@@ -5,0 +5,0 @@ "main": "dist/packages/client/src/index.js",

src/index.ts

@@ -301,5 +301,6 @@ import { RTCConnectionManagement, RTCSignalingSession, ScryptedStatic } from "@scrypted/types";
                 const session = new BrowserSignalingSession();
+                const droppedMessages: any[] = [];
                 session.onPeerConnection = async pc => {
                     pc.ondatachannel = e => {
-                        e.channel.onmessage = () => console.log('dropped mesage');
+                        e.channel.onmessage = message => droppedMessages.push(message);
                         e.channel.binaryType = 'arraybuffer';
@@ -358,2 +359,7 @@ dcDeferred.resolve(e.channel)
 
+                    while (droppedMessages.length) {
+                        const message = droppedMessages.shift();
+                        dc.dispatchEvent(message);
+                    }
+
                     const ret = new RpcPeer('webrtc-client', "api", (message, reject, serializationContext) => {
@@ -360,0 +366,0 @@ try {

No alert changes

Improved metrics

Total package byte prevSize

373628

increased by0.25%

Lines of code

3913

increased by0.26%

No dependency changes