From dec7186edbf731f827ae941bd8634737c8247c12 Mon Sep 17 00:00:00 2001 From: Evgeny Poberezkin Date: Fri, 29 Aug 2025 18:54:27 +0100 Subject: [PATCH] fix test --- src/Simplex/Messaging/Agent.hs | 2 +- tests/ServerTests.hs | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/src/Simplex/Messaging/Agent.hs b/src/Simplex/Messaging/Agent.hs index 825d124bf..04872ce64 100644 --- a/src/Simplex/Messaging/Agent.hs +++ b/src/Simplex/Messaging/Agent.hs @@ -1370,7 +1370,7 @@ subscribeClientServices' c userId = useService = liftIO $ (Just True ==) <$> TM.lookupIO userId (useClientServices c) subscribe = do srvs <- withStore' c (`getClientServiceServers` userId) - lift $ M.fromList . zip srvs <$> mapConcurrently (tryAgentError' . subscribeClientService c userId) srvs + lift $ M.fromList . zip srvs <$> mapConcurrently (tryAllErrors' . subscribeClientService c userId) srvs -- requesting messages sequentially, to reduce memory usage getConnectionMessages' :: AgentClient -> NonEmpty ConnMsgReq -> AM' (NonEmpty (Either AgentErrorType (Maybe SMPMsgMeta))) diff --git a/tests/ServerTests.hs b/tests/ServerTests.hs index 2eacc78f0..cad598a0e 100644 --- a/tests/ServerTests.hs +++ b/tests/ServerTests.hs @@ -724,6 +724,7 @@ testServiceDeliverSubscribe = pure $ Just $ Just mId3 _ -> pure Nothing ] + Resp "" NoEntity SALL <- tGet1 sh Resp "12" _ OK <- signSendRecv sh rKey ("12", rId, ACK mId3) Resp "14" _ OK <- signSendRecv h sKey ("14", sId, _SEND "hello 4") Resp "" _ (Msg mId4 msg4) <- tGet1 sh