mirror of
https://github.com/simplex-chat/simplex-chat.git
synced 2025-06-29 04:39:53 +00:00
core: update simplexmq (reopenStore), fix postgres compilation (#5543)
This commit is contained in:
parent
a59dea27b9
commit
d238a3c18f
4 changed files with 8 additions and 9 deletions
|
@ -12,7 +12,7 @@ constraints: zip +disable-bzip2 +disable-zstd
|
||||||
source-repository-package
|
source-repository-package
|
||||||
type: git
|
type: git
|
||||||
location: https://github.com/simplex-chat/simplexmq.git
|
location: https://github.com/simplex-chat/simplexmq.git
|
||||||
tag: dadf6ec5b67ee49b0f18ac4aecdce0d0be26786d
|
tag: fdde9863cdc87dc47609a3a5f51a4c2c4c038858
|
||||||
|
|
||||||
source-repository-package
|
source-repository-package
|
||||||
type: git
|
type: git
|
||||||
|
|
|
@ -1,5 +1,5 @@
|
||||||
{
|
{
|
||||||
"https://github.com/simplex-chat/simplexmq.git"."dadf6ec5b67ee49b0f18ac4aecdce0d0be26786d" = "0rgnqqkvhgd0a3vncbfx75sqlnd6spgyi2nj303pifdh9hza7k57";
|
"https://github.com/simplex-chat/simplexmq.git"."fdde9863cdc87dc47609a3a5f51a4c2c4c038858" = "00jx2zy7b8c8mav01h0ycj6qm5298pxhd960x0p1r1ram4a0nhww";
|
||||||
"https://github.com/simplex-chat/hs-socks.git"."a30cc7a79a08d8108316094f8f2f82a0c5e1ac51" = "0yasvnr7g91k76mjkamvzab2kvlb1g5pspjyjn2fr6v83swjhj38";
|
"https://github.com/simplex-chat/hs-socks.git"."a30cc7a79a08d8108316094f8f2f82a0c5e1ac51" = "0yasvnr7g91k76mjkamvzab2kvlb1g5pspjyjn2fr6v83swjhj38";
|
||||||
"https://github.com/simplex-chat/direct-sqlcipher.git"."f814ee68b16a9447fbb467ccc8f29bdd3546bfd9" = "1ql13f4kfwkbaq7nygkxgw84213i0zm7c1a8hwvramayxl38dq5d";
|
"https://github.com/simplex-chat/direct-sqlcipher.git"."f814ee68b16a9447fbb467ccc8f29bdd3546bfd9" = "1ql13f4kfwkbaq7nygkxgw84213i0zm7c1a8hwvramayxl38dq5d";
|
||||||
"https://github.com/simplex-chat/sqlcipher-simple.git"."a46bd361a19376c5211f1058908fc0ae6bf42446" = "1z0r78d8f0812kxbgsm735qf6xx8lvaz27k1a0b4a2m0sshpd5gl";
|
"https://github.com/simplex-chat/sqlcipher-simple.git"."a46bd361a19376c5211f1058908fc0ae6bf42446" = "1z0r78d8f0812kxbgsm735qf6xx8lvaz27k1a0b4a2m0sshpd5gl";
|
||||||
|
|
|
@ -46,6 +46,7 @@ import Data.Maybe (catMaybes, fromMaybe, isJust, isNothing, listToMaybe, mapMayb
|
||||||
import Data.Text (Text)
|
import Data.Text (Text)
|
||||||
import qualified Data.Text as T
|
import qualified Data.Text as T
|
||||||
import Data.Text.Encoding (decodeLatin1, encodeUtf8)
|
import Data.Text.Encoding (decodeLatin1, encodeUtf8)
|
||||||
|
import Data.Time (NominalDiffTime, addUTCTime, defaultTimeLocale, formatTime)
|
||||||
import Data.Time.Clock (UTCTime, getCurrentTime, nominalDay)
|
import Data.Time.Clock (UTCTime, getCurrentTime, nominalDay)
|
||||||
import Data.Type.Equality
|
import Data.Type.Equality
|
||||||
import qualified Data.UUID as UUID
|
import qualified Data.UUID as UUID
|
||||||
|
@ -117,12 +118,10 @@ import UnliftIO.IO (hClose)
|
||||||
import UnliftIO.STM
|
import UnliftIO.STM
|
||||||
#if defined(dbPostgres)
|
#if defined(dbPostgres)
|
||||||
import Data.Bifunctor (bimap, second)
|
import Data.Bifunctor (bimap, second)
|
||||||
import Data.Time (NominalDiffTime, addUTCTime)
|
|
||||||
import Simplex.Messaging.Agent.Client (SubInfo (..), getAgentQueuesInfo, getAgentWorkersDetails, getAgentWorkersSummary)
|
import Simplex.Messaging.Agent.Client (SubInfo (..), getAgentQueuesInfo, getAgentWorkersDetails, getAgentWorkersSummary)
|
||||||
#else
|
#else
|
||||||
import Data.Bifunctor (bimap, first, second)
|
import Data.Bifunctor (bimap, first, second)
|
||||||
import qualified Data.ByteArray as BA
|
import qualified Data.ByteArray as BA
|
||||||
import Data.Time (NominalDiffTime, addUTCTime, defaultTimeLocale, formatTime)
|
|
||||||
import qualified Database.SQLite.Simple as SQL
|
import qualified Database.SQLite.Simple as SQL
|
||||||
import Simplex.Chat.Archive
|
import Simplex.Chat.Archive
|
||||||
import Simplex.Messaging.Agent.Client (SubInfo (..), agentClientStore, getAgentQueuesInfo, getAgentWorkersDetails, getAgentWorkersSummary)
|
import Simplex.Messaging.Agent.Client (SubInfo (..), agentClientStore, getAgentQueuesInfo, getAgentWorkersDetails, getAgentWorkersSummary)
|
||||||
|
|
|
@ -49,7 +49,7 @@ import Simplex.Chat.Store.Profiles
|
||||||
import Simplex.Chat.Types
|
import Simplex.Chat.Types
|
||||||
import Simplex.Messaging.Agent.Client (agentClientStore)
|
import Simplex.Messaging.Agent.Client (agentClientStore)
|
||||||
import Simplex.Messaging.Agent.Env.SQLite (createAgentStore)
|
import Simplex.Messaging.Agent.Env.SQLite (createAgentStore)
|
||||||
import Simplex.Messaging.Agent.Store.SQLite (closeDBStore, reopenSQLiteStore)
|
import Simplex.Messaging.Agent.Store (closeStore, reopenStore)
|
||||||
import Simplex.Messaging.Agent.Store.Shared (MigrationConfirmation (..), MigrationError)
|
import Simplex.Messaging.Agent.Store.Shared (MigrationConfirmation (..), MigrationError)
|
||||||
import qualified Simplex.Messaging.Crypto as C
|
import qualified Simplex.Messaging.Crypto as C
|
||||||
import Simplex.Messaging.Encoding.String
|
import Simplex.Messaging.Encoding.String
|
||||||
|
@ -262,13 +262,13 @@ chatMigrateInitKey dbFilePrefix dbKey keepKey confirm backgroundMode = runExcept
|
||||||
|
|
||||||
chatCloseStore :: ChatController -> IO String
|
chatCloseStore :: ChatController -> IO String
|
||||||
chatCloseStore ChatController {chatStore, smpAgent} = handleErr $ do
|
chatCloseStore ChatController {chatStore, smpAgent} = handleErr $ do
|
||||||
closeDBStore chatStore
|
closeStore chatStore
|
||||||
closeDBStore $ agentClientStore smpAgent
|
closeStore $ agentClientStore smpAgent
|
||||||
|
|
||||||
chatReopenStore :: ChatController -> IO String
|
chatReopenStore :: ChatController -> IO String
|
||||||
chatReopenStore ChatController {chatStore, smpAgent} = handleErr $ do
|
chatReopenStore ChatController {chatStore, smpAgent} = handleErr $ do
|
||||||
reopenSQLiteStore chatStore
|
reopenStore chatStore
|
||||||
reopenSQLiteStore (agentClientStore smpAgent)
|
reopenStore (agentClientStore smpAgent)
|
||||||
|
|
||||||
handleErr :: IO () -> IO String
|
handleErr :: IO () -> IO String
|
||||||
handleErr a = (a $> "") `catch` (pure . show @SomeException)
|
handleErr a = (a $> "") `catch` (pure . show @SomeException)
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue