dandri/simplex-chat
1
0
Fork 0
mirror of https://github.com/simplex-chat/simplex-chat.git synced 2026-07-28 12:09:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Evgeny Poberezkin
2026-07-21 16:26:51 +01:00
parent 472e6a5552
commit ad925ab670
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Simplex/Chat/Library/Subscriber.hs
+6 -6
View File
@@ -183,7 +183,7 @@ processAgentMsgSndFile :: (Maybe ChatRef, FileTransferId) -> ACorrId -> SndFileI
processAgentMsgSndFile (cRef_, fileId) _corrId aFileId msg =
withEntityLock_ cRef_ . withFileLock "processAgentMsgSndFile" fileId $
withStore' (`getUserByASndFileId` AgentSndFileId aFileId) >>= \case
Just user -> process user fileId `catchAllErrors` eToView
Just user -> process user `catchAllErrors` eToView
_ -> do
lift $ withAgent' (`xftpDeleteSndFileInternal` aFileId)
throwChatError $ CENoSndFileUser $ AgentSndFileId aFileId
@@ -193,8 +193,8 @@ processAgentMsgSndFile (cRef_, fileId) _corrId aFileId msg =
Just (ChatRef CTDirect contactId _) -> withContactLock "processAgentMsgSndFile" contactId
Just (ChatRef CTGroup groupId _scope) -> withGroupLock "processAgentMsgSndFile" groupId
_ -> id
process :: User -> FileTransferId -> CM ()
process user fileId = do
process :: User -> CM ()
process user = do
(ft@FileTransferMeta {xftpRedirectFor, cancelled}, sfts) <- withStore $ \db -> getSndFileTransfer db user fileId
cxt <- chatStoreCxt
unless cancelled $ case msg of
@@ -322,7 +322,7 @@ processAgentMsgRcvFile :: (Maybe ChatRef, FileTransferId) -> ACorrId -> RcvFileI
processAgentMsgRcvFile (cRef_, fileId) _corrId aFileId msg =
withEntityLock_ cRef_ . withFileLock "processAgentMsgRcvFile" fileId $
withStore' (`getUserByARcvFileId` AgentRcvFileId aFileId) >>= \case
Just user -> process user fileId `catchAllErrors` eToView
Just user -> process user `catchAllErrors` eToView
_ -> do
lift $ withAgent' (`xftpDeleteRcvFile` aFileId)
throwChatError $ CENoRcvFileUser $ AgentRcvFileId aFileId
@@ -332,8 +332,8 @@ processAgentMsgRcvFile (cRef_, fileId) _corrId aFileId msg =
Just (ChatRef CTDirect contactId _) -> withContactLock "processAgentMsgRcvFile" contactId
Just (ChatRef CTGroup groupId _scope) -> withGroupLock "processAgentMsgRcvFile" groupId
_ -> id
process :: User -> FileTransferId -> CM ()
process user fileId = do
process :: User -> CM ()
process user = do
ft <- withStore $ \db -> getRcvFileTransfer db user fileId
cxt <- chatStoreCxt
unless (rcvFileCompleteOrCancelled ft) $ case msg of