f

xmppjs · Jan 16, 2025 · 1431160 · 1431160
1 parent 0a32122
commit 1431160
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 116 deletions.
diff --git a/packages/stream-management/index.js b/packages/stream-management/index.js
@@ -66,7 +66,6 @@ export default function streamManagement({
   entity.on("disconnect", () => {
     clearTimeout(timeoutTimeout);
     clearTimeout(requestAckTimeout);
-    sm.removeListener("stanza", scheduleRequestAck);
   });
 
   async function resumed(resumed) {
@@ -80,6 +79,12 @@ export default function streamManagement({
     entity._ready(true);
   }
 
+  function failed() {
+    sm.enabled = false;
+    sm.id = "";
+    failQueue();
+  }
+
   function ackQueue(n) {
     const oldOutbound = sm.outbound;
     for (let i = 0; i < +n - oldOutbound; i++) {
@@ -97,18 +102,11 @@ export default function streamManagement({
     sm.outbound = 0;
   }
 
-  function failed() {
-    sm.enabled = false;
-    sm.id = "";
-    failQueue();
-  }
-
   function enabled({ id, max }) {
     sm.enabled = true;
     sm.id = id;
     sm.max = max;
     scheduleRequestAck();
-    sm.on("stanza", scheduleRequestAck);
   }
 
   entity.on("online", () => {
@@ -129,8 +127,8 @@ export default function streamManagement({
   });
 
   middleware.use((context, next) => {
-    clearTimeout(timeoutTimeout);
     const { stanza } = context;
+    clearTimeout(timeoutTimeout);
     if (["presence", "message", "iq"].includes(stanza.name)) {
       sm.inbound += 1;
     } else if (stanza.is("r", NS)) {

diff --git a/test/stream-management.js b/test/stream-management.js
diff --git a/test/stream-management.test.js b/test/stream-management.test.js
@@ -94,7 +94,7 @@ test(
     xmpp = client({ credentials, service: domain });
     xmpp.streamManagement.timeout = 10;
     xmpp.streamManagement.debounceAckRequest = 1;
-    debug(xmpp, true);
+    debug(xmpp);
 
     const promise_resumed = promise(xmpp.streamManagement, "resumed");
     await xmpp.start();