From c76d16758ef0fc4b220c07085fe0c450237008a2 Mon Sep 17 00:00:00 2001
From: Alexander Bondarenko <486682+dpwiz@users.noreply.github.com>
Date: Thu, 30 May 2024 17:26:14 +0300
Subject: [PATCH] log stalled subQ

---
 src/Simplex/Messaging/Agent/Client.hs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/Simplex/Messaging/Agent/Client.hs b/src/Simplex/Messaging/Agent/Client.hs
index 08912baa5..6633a61d2 100644
--- a/src/Simplex/Messaging/Agent/Client.hs
+++ b/src/Simplex/Messaging/Agent/Client.hs
@@ -1351,12 +1351,13 @@ subscribeQueues c qs = do
         then do
           when (any isNothing subResults) resubscribe
           let up = catMaybes $ L.toList subResults
-          unless (null up) $ notifySub c "" $ UP srv up
+          unless (null up) $ notifyUP up
           pure rs
         else do
           logWarn "subcription batch result for replaced SMP client, resubscribing"
           resubscribe $> L.map (second $ \_ -> Left PCENetworkError) rs
       where
+        notifyUP up = maybe (logError "sndQ full" >> notifyUP up) pure =<< timeout 30000000 (notifySub c "" $ UP srv up)
         tSess@(_, srv, _) = transportSession' smp
         sessId = sessionId $ thParams smp
         processSubResults :: NonEmpty (RcvQueue, Either SMPClientError ()) -> STM (NonEmpty (Maybe ConnId))