From a530944f7d9023c16f40883be88ad6e68489ff75 Mon Sep 17 00:00:00 2001
From: Bruno Windels <274386+bwindels@users.noreply.github.com>
Date: Thu, 2 Jun 2022 11:11:32 +0200
Subject: [PATCH] add logging to seq queueing

---
 src/matrix/calls/group/Member.ts | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/src/matrix/calls/group/Member.ts b/src/matrix/calls/group/Member.ts
index a40100d2..541cdf13 100644
--- a/src/matrix/calls/group/Member.ts
+++ b/src/matrix/calls/group/Member.ts
@@ -257,18 +257,26 @@ export class Member {
             }
             const idx = sortedIndex(connection.queuedSignallingMessages, message, (a, b) => a.content.seq - b.content.seq);
             connection.queuedSignallingMessages.splice(idx, 0, message);
+            let hasBeenDequeued = false;
             if (connection.peerCall) {
                 while (
                     connection.queuedSignallingMessages.length && (
-                    connection.lastProcessedSeqNr === undefined ||
-                    connection.queuedSignallingMessages[0].content.seq === connection.lastProcessedSeqNr + 1
-                )) {
+                        connection.lastProcessedSeqNr === undefined ||
+                        connection.queuedSignallingMessages[0].content.seq === connection.lastProcessedSeqNr + 1
+                    )
+               ) {
                     const dequeuedMessage = connection.queuedSignallingMessages.shift()!;
+                    if (dequeuedMessage === message) {
+                        hasBeenDequeued = true;
+                    }
                     const item = connection.peerCall!.handleIncomingSignallingMessage(dequeuedMessage, this.deviceId, connection.logItem);
-                    connection.lastProcessedSeqNr = dequeuedMessage.content.seq;
                     syncLog.refDetached(item);
+                    connection.lastProcessedSeqNr = dequeuedMessage.content.seq;
                 }
             }
+            if (!hasBeenDequeued) {
+                syncLog.refDetached(connection.logItem.log({l: "queued signalling message", type: message.type}));
+            }
         } else {
             syncLog.log({l: "member not connected", userId: this.userId, deviceId: this.deviceId});
         }