dandri/simplexmq
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplexmq.git synced 2026-08-25 16:10:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into journal-store

Browse Source
This commit is contained in:
Evgeny Poberezkin
2024-10-26 12:58:32 +01:00
parent 56ca7bf30e 1735b619e8
commit 916150742e
4 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Messaging/Server/QueueStore/STM.hs
+2 -1
View File
@@ -47,10 +47,11 @@ newQueueStore = do
pure QueueStore {queues, senders, notifiers}
addQueue :: QueueStore -> QueueRec -> IO (Either ErrorType ())
addQueue QueueStore {queues, senders} q@QueueRec {recipientId = rId, senderId = sId} = atomically $ do
addQueue QueueStore {queues, senders, notifiers} q@QueueRec {recipientId = rId, senderId = sId, notifier} = atomically $ do
ifM hasId (pure $ Left DUPLICATE_) $ do
TM.insertM rId (newTVar q) queues
TM.insert sId rId senders
forM_ notifier $ \NtfCreds {notifierId} -> TM.insert notifierId rId notifiers
pure $ Right ()
where
hasId = (||) <$> TM.member rId queues <*> TM.member sId senders