dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-03-30 20:45:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

agent store: fix updateQueueStatus

Browse Source
This commit is contained in:
Efim Poberezkin
2021-01-10 23:41:53 +04:00
parent b9cdc6a09d
commit f5aaab3861
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/Simplex/Messaging/Agent/Store/SQLite.hs
View File

@@ -405,16 +405,20 @@ instance (MonadUnliftIO m, MonadError StoreError m) => MonadAgentStore SQLiteSto
removeSndAuth :: SQLiteStore -> ConnAlias -> m ()
removeSndAuth _st _connAlias = throwError SEInternal
-- TODO finalize
-- updateQueueStatus :: SQLiteStore -> ConnAlias -> QueueDirection -> QueueStatus -> m ()
-- updateQueueStatus st connAlias qDirection status = do
-- (rcvQId, sndQId) <- getConnection st connAlias
-- case qDirection of
-- RCV -> do
-- updateRcvQueueStatus st rcvQId status
-- SND -> do
-- updateSndQueueStatus st sndQId status
-- when (isNothing rcvQId && isNothing sndQId) $ throwError SEBadConn
-- TODO test
updateQueueStatus :: SQLiteStore -> ConnAlias -> QueueDirection -> QueueStatus -> m ()
updateQueueStatus st connAlias qDirection status = do
case qDirection of
RCV -> do
(rcvQId, _) <- getConnection st connAlias
case rcvQId of
Just qId -> updateRcvQueueStatus st qId status
Nothing -> throwError SEBadConn
SND -> do
(_, sndQId) <- getConnection st connAlias
case sndQId of
Just qId -> updateSndQueueStatus st qId status
Nothing -> throwError SEBadConn
createMsg :: SQLiteStore -> ConnAlias -> QueueDirection -> AMessage -> m MessageDelivery
createMsg _st _connAlias _dir _msg = throwError SEInternal