mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-09-01 18:08:36 +00:00
Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
dfb0be2c0e | ||
|
|
2e808192de |
@@ -41,6 +41,7 @@ library
|
|||||||
Simplex.Messaging.Agent.Store.SQLite.Migrations
|
Simplex.Messaging.Agent.Store.SQLite.Migrations
|
||||||
Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220101_initial
|
Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220101_initial
|
||||||
Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220301_snd_queue_keys
|
Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220301_snd_queue_keys
|
||||||
|
Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220320_server_ips
|
||||||
Simplex.Messaging.Client
|
Simplex.Messaging.Client
|
||||||
Simplex.Messaging.Crypto
|
Simplex.Messaging.Crypto
|
||||||
Simplex.Messaging.Crypto.Ratchet
|
Simplex.Messaging.Crypto.Ratchet
|
||||||
|
|||||||
@@ -26,6 +26,7 @@ import Database.SQLite.Simple.QQ (sql)
|
|||||||
import qualified Database.SQLite3 as SQLite3
|
import qualified Database.SQLite3 as SQLite3
|
||||||
import Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220101_initial
|
import Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220101_initial
|
||||||
import Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220301_snd_queue_keys
|
import Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220301_snd_queue_keys
|
||||||
|
import Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220320_server_ips
|
||||||
|
|
||||||
data Migration = Migration {name :: String, up :: Text}
|
data Migration = Migration {name :: String, up :: Text}
|
||||||
deriving (Show)
|
deriving (Show)
|
||||||
@@ -33,7 +34,8 @@ data Migration = Migration {name :: String, up :: Text}
|
|||||||
schemaMigrations :: [(String, Query)]
|
schemaMigrations :: [(String, Query)]
|
||||||
schemaMigrations =
|
schemaMigrations =
|
||||||
[ ("20220101_initial", m20220101_initial),
|
[ ("20220101_initial", m20220101_initial),
|
||||||
("20220301_snd_queue_keys", m20220301_snd_queue_keys)
|
("20220301_snd_queue_keys", m20220301_snd_queue_keys),
|
||||||
|
("20220320_server_ips", m20220320_server_ips)
|
||||||
]
|
]
|
||||||
|
|
||||||
-- | The list of migrations in ascending order by date
|
-- | The list of migrations in ascending order by date
|
||||||
|
|||||||
@@ -0,0 +1,14 @@
|
|||||||
|
{-# LANGUAGE QuasiQuotes #-}
|
||||||
|
|
||||||
|
module Simplex.Messaging.Agent.Store.SQLite.Migrations.M20220320_server_ips where
|
||||||
|
|
||||||
|
import Database.SQLite.Simple (Query)
|
||||||
|
import Database.SQLite.Simple.QQ (sql)
|
||||||
|
|
||||||
|
m20220320_server_ips :: Query
|
||||||
|
m20220320_server_ips =
|
||||||
|
[sql|
|
||||||
|
UPDATE servers SET host = '178.79.168.175' WHERE host = 'smp8.simplex.im';
|
||||||
|
UPDATE servers SET host = '178.79.169.107' WHERE host = 'smp9.simplex.im';
|
||||||
|
UPDATE servers SET host = '45.33.54.229' WHERE host = 'smp10.simplex.im';
|
||||||
|
|]
|
||||||
@@ -75,7 +75,7 @@ validateCertificateChain (C.KeyHash kh) host port cc@(X.CertificateChain sc@[_,
|
|||||||
x509validate = XV.validate X.HashSHA256 hooks checks certStore cache serviceID cc
|
x509validate = XV.validate X.HashSHA256 hooks checks certStore cache serviceID cc
|
||||||
where
|
where
|
||||||
hooks = XV.defaultHooks
|
hooks = XV.defaultHooks
|
||||||
checks = XV.defaultChecks
|
checks = XV.defaultChecks {XV.checkFQHN = False}
|
||||||
certStore = XS.makeCertificateStore sc
|
certStore = XS.makeCertificateStore sc
|
||||||
cache = XV.exceptionValidationCache [] -- we manually check fingerprint only of the identity certificate (ca.crt)
|
cache = XV.exceptionValidationCache [] -- we manually check fingerprint only of the identity certificate (ca.crt)
|
||||||
serviceID = (host, port)
|
serviceID = (host, port)
|
||||||
|
|||||||
+1
-1
@@ -468,7 +468,7 @@ syntaxTests t = do
|
|||||||
"a",
|
"a",
|
||||||
"JOIN https://simpex.chat/invitation#/?smp=smp%3A%2F%2F"
|
"JOIN https://simpex.chat/invitation#/?smp=smp%3A%2F%2F"
|
||||||
<> urlEncode True "LcJUMfVhwD8yxjAiSaDzzGF3-kLG4Uh0Fl_ZIjrRwjI="
|
<> urlEncode True "LcJUMfVhwD8yxjAiSaDzzGF3-kLG4Uh0Fl_ZIjrRwjI="
|
||||||
<> "%40localhost%3A5001%2F3456-w%3D%3D%23"
|
<> "%40127.0.0.1%3A5001%2F3456-w%3D%3D%23"
|
||||||
<> urlEncode True sampleDhKey
|
<> urlEncode True sampleDhKey
|
||||||
<> "&v=1"
|
<> "&v=1"
|
||||||
<> "&e2e=v%3D1%26x3dh%3DMEIwBQYDK2VvAzkAmKuSYeQ_m0SixPDS8Wq8VBaTS1cW-Lp0n0h4Diu-kUpR-qXx4SDJ32YGEFoGFGSbGPry5Ychr6U%3D%2CMEIwBQYDK2VvAzkAmKuSYeQ_m0SixPDS8Wq8VBaTS1cW-Lp0n0h4Diu-kUpR-qXx4SDJ32YGEFoGFGSbGPry5Ychr6U%3D"
|
<> "&e2e=v%3D1%26x3dh%3DMEIwBQYDK2VvAzkAmKuSYeQ_m0SixPDS8Wq8VBaTS1cW-Lp0n0h4Diu-kUpR-qXx4SDJ32YGEFoGFGSbGPry5Ychr6U%3D%2CMEIwBQYDK2VvAzkAmKuSYeQ_m0SixPDS8Wq8VBaTS1cW-Lp0n0h4Diu-kUpR-qXx4SDJ32YGEFoGFGSbGPry5Ychr6U%3D"
|
||||||
|
|||||||
@@ -157,7 +157,7 @@ cfg :: AgentConfig
|
|||||||
cfg =
|
cfg =
|
||||||
defaultAgentConfig
|
defaultAgentConfig
|
||||||
{ tcpPort = agentTestPort,
|
{ tcpPort = agentTestPort,
|
||||||
initialSMPServers = L.fromList ["smp://LcJUMfVhwD8yxjAiSaDzzGF3-kLG4Uh0Fl_ZIjrRwjI=@localhost:5001"],
|
initialSMPServers = L.fromList ["smp://LcJUMfVhwD8yxjAiSaDzzGF3-kLG4Uh0Fl_ZIjrRwjI=@127.0.0.1:5001"],
|
||||||
tbqSize = 1,
|
tbqSize = 1,
|
||||||
dbFile = testDB,
|
dbFile = testDB,
|
||||||
smpCfg =
|
smpCfg =
|
||||||
@@ -174,7 +174,7 @@ cfg =
|
|||||||
|
|
||||||
withSmpAgentThreadOn_ :: (MonadUnliftIO m, MonadRandom m) => ATransport -> (ServiceName, ServiceName, String) -> m () -> (ThreadId -> m a) -> m a
|
withSmpAgentThreadOn_ :: (MonadUnliftIO m, MonadRandom m) => ATransport -> (ServiceName, ServiceName, String) -> m () -> (ThreadId -> m a) -> m a
|
||||||
withSmpAgentThreadOn_ t (port', smpPort', db') afterProcess =
|
withSmpAgentThreadOn_ t (port', smpPort', db') afterProcess =
|
||||||
let cfg' = cfg {tcpPort = port', dbFile = db', initialSMPServers = L.fromList [SMPServer "localhost" smpPort' testKeyHash]}
|
let cfg' = cfg {tcpPort = port', dbFile = db', initialSMPServers = L.fromList [SMPServer "127.0.0.1" smpPort' testKeyHash]}
|
||||||
in serverBracket
|
in serverBracket
|
||||||
(\started -> runSMPAgentBlocking t started cfg')
|
(\started -> runSMPAgentBlocking t started cfg')
|
||||||
afterProcess
|
afterProcess
|
||||||
|
|||||||
+1
-1
@@ -29,7 +29,7 @@ import UnliftIO.STM (TMVar, atomically, newEmptyTMVarIO, takeTMVar)
|
|||||||
import UnliftIO.Timeout (timeout)
|
import UnliftIO.Timeout (timeout)
|
||||||
|
|
||||||
testHost :: HostName
|
testHost :: HostName
|
||||||
testHost = "localhost"
|
testHost = "127.0.0.1"
|
||||||
|
|
||||||
testPort :: ServiceName
|
testPort :: ServiceName
|
||||||
testPort = "5001"
|
testPort = "5001"
|
||||||
|
|||||||
Reference in New Issue
Block a user