Fixed issue that caused long running p2p livestreams to be interrupted

bropat · Dec 17, 2023 · 03a48bb · 03a48bb
1 parent 4d85da8
commit 03a48bb
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/src/p2p/utils.ts b/src/p2p/utils.ts
@@ -293,7 +293,16 @@ export const buildCommandWithStringTypePayload = (encryptionType: EncryptionType
 export const sortP2PMessageParts = (messages: P2PMessageParts): Buffer => {
     let completeMessage = Buffer.from([]);
     Object.keys(messages).map(Number)
-        .sort((a, b) => a - b) // assure the seqNumbers are in correct order
+        .sort((a, b) => {
+            if (Math.abs(a - b) > 65000) {
+                if (a < b) {
+                    return 1;
+                } else if (b < a) {
+                    return -1;
+                }
+            }
+            return a - b;
+        }) // assure the seqNumbers are in correct order
         .forEach((key: number) => {
             completeMessage = Buffer.concat([completeMessage, messages[key]]);
         });