From c08cab81df8772f4f619fdde4c2a3b5695c67211 Mon Sep 17 00:00:00 2001
From: Stephen Paul Weber <singpolyma@singpolyma.net>
Date: Wed, 8 Jan 2025 10:55:45 -0500
Subject: [PATCH] Make more timeouts configurable

---
 packages/stream-management/index.js | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/packages/stream-management/index.js b/packages/stream-management/index.js
index 49cff918..bccd3761 100644
--- a/packages/stream-management/index.js
+++ b/packages/stream-management/index.js
@@ -60,6 +60,8 @@ export default function streamManagement({
     inbound: 0,
     max: null,
     timeout: 60_000,
+    requestAckInterval: 300_000,
+    debounceAckRequest: 100,
     _teardown: () => {
       clearTimeout(timeoutTimeout);
       clearTimeout(requestAckTimeout);
@@ -173,7 +175,7 @@ export default function streamManagement({
     entity.send(xml("r", { xmlns: NS })).catch(() => {});
     // Periodically send r to check the connection
     // If a stanza goes out it will cancel this and set a sooner timer
-    requestAckTimeout = setTimeout(requestAck, 300_000);
+    requestAckTimeout = setTimeout(requestAck, sm.requestAckInterval);
   }
 
   middleware.filter((context, next) => {
@@ -184,7 +186,7 @@ export default function streamManagement({
     sm.outbound_q.push({ stanza, stamp: datetime() });
     // Debounce requests so we send only one after a big run of stanza together
     clearTimeout(requestAckTimeout);
-    requestAckTimeout = setTimeout(requestAck, 100);
+    requestAckTimeout = setTimeout(requestAck, sm.debounceAckRequest);
     return next();
   });