dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-04-11 05:45:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

retry ACK

Browse Source
This commit is contained in:
Evgeny Poberezkin
2022-08-30 08:24:52 +01:00
parent 1459a0613a
commit dcf76854ee
1 changed files with 16 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/Simplex/Messaging/Agent.hs
View File

@@ -706,12 +706,22 @@ ackMessage' c connId msgId = do
where
ack :: RcvQueue -> m ()
ack rq = do
let mId = InternalId msgId
srvMsgId <- withStore c $ \db -> setMsgUserAck db connId mId
sendAck c rq srvMsgId `catchError` \case
SMP SMP.NO_MSG -> pure ()
e -> throwError e
withStore' c $ \db -> deleteMsg db connId mId
srvMsgId <- withStore c $ \db -> setMsgUserAck db connId $ InternalId msgId
retrySendAck srvMsgId $ \e -> do
ri <- asks $ messageRetryInterval . config
void . forkIO . withRetryInterval ri $ \loop ->
retrySendAck srvMsgId $ \_ -> loop
throwError e
where
retrySendAck :: SMP.MsgId -> (AgentErrorType -> m ()) -> m ()
retrySendAck srvMsgId retryAck = do
sendAck c rq srvMsgId `catchError` \case
SMP SMP.NO_MSG -> pure ()
SMP AUTH -> pure ()
e
| temporaryAgentError e || e == BROKER HOST -> retryAck e
| otherwise -> throwError e
withStore' c $ \db -> deleteMsg db connId $ InternalId msgId
-- | Suspend SMP agent connection (OFF command) in Reader monad
suspendConnection' :: AgentMonad m => AgentClient -> ConnId -> m ()