core: update simplexmq (revert DB busy error handling)
This commit is contained in:
parent
5353b466a9
commit
38dc14f041
@ -7,7 +7,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: fdbfe0e8d159f394f6eb0f5168620da8694033cd
|
tag: 82aec2cd8f7b4033dbf08d5de33ced216f574bbb
|
||||||
|
|
||||||
source-repository-package
|
source-repository-package
|
||||||
type: git
|
type: git
|
||||||
|
@ -1,5 +1,5 @@
|
|||||||
{
|
{
|
||||||
"https://github.com/simplex-chat/simplexmq.git"."fdbfe0e8d159f394f6eb0f5168620da8694033cd" = "0c0r14kzcp9rmc1nxypknaa93aczl13yxyaj1c0zrd1b17c2m8cx";
|
"https://github.com/simplex-chat/simplexmq.git"."82aec2cd8f7b4033dbf08d5de33ced216f574bbb" = "1x3rjq10d3c8qb6wf66a2j127xi9xdg21pyw5r4n124f8yvlb0nc";
|
||||||
"https://github.com/simplex-chat/hs-socks.git"."a30cc7a79a08d8108316094f8f2f82a0c5e1ac51" = "0yasvnr7g91k76mjkamvzab2kvlb1g5pspjyjn2fr6v83swjhj38";
|
"https://github.com/simplex-chat/hs-socks.git"."a30cc7a79a08d8108316094f8f2f82a0c5e1ac51" = "0yasvnr7g91k76mjkamvzab2kvlb1g5pspjyjn2fr6v83swjhj38";
|
||||||
"https://github.com/kazu-yamamoto/http2.git"."b5a1b7200cf5bc7044af34ba325284271f6dff25" = "0dqb50j57an64nf4qcf5vcz4xkd1vzvghvf8bk529c1k30r9nfzb";
|
"https://github.com/kazu-yamamoto/http2.git"."b5a1b7200cf5bc7044af34ba325284271f6dff25" = "0dqb50j57an64nf4qcf5vcz4xkd1vzvghvf8bk529c1k30r9nfzb";
|
||||||
"https://github.com/simplex-chat/direct-sqlcipher.git"."34309410eb2069b029b8fc1872deb1e0db123294" = "0kwkmhyfsn2lixdlgl15smgr1h5gjk7fky6abzh8rng2h5ymnffd";
|
"https://github.com/simplex-chat/direct-sqlcipher.git"."34309410eb2069b029b8fc1872deb1e0db123294" = "0kwkmhyfsn2lixdlgl15smgr1h5gjk7fky6abzh8rng2h5ymnffd";
|
||||||
|
@ -49,7 +49,7 @@ extra-deps:
|
|||||||
# - simplexmq-1.0.0@sha256:34b2004728ae396e3ae449cd090ba7410781e2b3cefc59259915f4ca5daa9ea8,8561
|
# - simplexmq-1.0.0@sha256:34b2004728ae396e3ae449cd090ba7410781e2b3cefc59259915f4ca5daa9ea8,8561
|
||||||
# - ../simplexmq
|
# - ../simplexmq
|
||||||
- github: simplex-chat/simplexmq
|
- github: simplex-chat/simplexmq
|
||||||
commit: fdbfe0e8d159f394f6eb0f5168620da8694033cd
|
commit: 82aec2cd8f7b4033dbf08d5de33ced216f574bbb
|
||||||
- github: kazu-yamamoto/http2
|
- github: kazu-yamamoto/http2
|
||||||
commit: b5a1b7200cf5bc7044af34ba325284271f6dff25
|
commit: b5a1b7200cf5bc7044af34ba325284271f6dff25
|
||||||
# - ../direct-sqlcipher
|
# - ../direct-sqlcipher
|
||||||
|
@ -10,7 +10,7 @@ import Data.List (dropWhileEnd)
|
|||||||
import Data.Maybe (fromJust, isJust)
|
import Data.Maybe (fromJust, isJust)
|
||||||
import Simplex.Chat.Store (createChatStore)
|
import Simplex.Chat.Store (createChatStore)
|
||||||
import qualified Simplex.Chat.Store as Store
|
import qualified Simplex.Chat.Store as Store
|
||||||
import Simplex.Messaging.Agent.Store.SQLite (MigrationConfirmation (..), closeSQLiteStore, createSQLiteStore)
|
import Simplex.Messaging.Agent.Store.SQLite (MigrationConfirmation (..), closeSQLiteStore, createSQLiteStore, withConnection)
|
||||||
import Simplex.Messaging.Agent.Store.SQLite.Migrations (Migration (..), MigrationsToRun (..), toDownMigration)
|
import Simplex.Messaging.Agent.Store.SQLite.Migrations (Migration (..), MigrationsToRun (..), toDownMigration)
|
||||||
import qualified Simplex.Messaging.Agent.Store.SQLite.Migrations as Migrations
|
import qualified Simplex.Messaging.Agent.Store.SQLite.Migrations as Migrations
|
||||||
import Simplex.Messaging.Util (ifM, whenM)
|
import Simplex.Messaging.Util (ifM, whenM)
|
||||||
@ -53,14 +53,14 @@ testSchemaMigrations = withTmpFiles $ do
|
|||||||
putStrLn $ "down migration " <> name m
|
putStrLn $ "down migration " <> name m
|
||||||
let downMigr = fromJust $ toDownMigration m
|
let downMigr = fromJust $ toDownMigration m
|
||||||
schema <- getSchema testDB testSchema
|
schema <- getSchema testDB testSchema
|
||||||
Migrations.run st $ MTRUp [m]
|
withConnection st (`Migrations.run` MTRUp [m])
|
||||||
schema' <- getSchema testDB testSchema
|
schema' <- getSchema testDB testSchema
|
||||||
schema' `shouldNotBe` schema
|
schema' `shouldNotBe` schema
|
||||||
Migrations.run st $ MTRDown [downMigr]
|
withConnection st (`Migrations.run` MTRDown [downMigr])
|
||||||
unless (name m `elem` skipComparisonForDownMigrations) $ do
|
unless (name m `elem` skipComparisonForDownMigrations) $ do
|
||||||
schema'' <- getSchema testDB testSchema
|
schema'' <- getSchema testDB testSchema
|
||||||
schema'' `shouldBe` schema
|
schema'' `shouldBe` schema
|
||||||
Migrations.run st $ MTRUp [m]
|
withConnection st (`Migrations.run` MTRUp [m])
|
||||||
schema''' <- getSchema testDB testSchema
|
schema''' <- getSchema testDB testSchema
|
||||||
schema''' `shouldBe` schema'
|
schema''' `shouldBe` schema'
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user