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

replace TVar with IORef in execSQL (#531)

Browse Source
This commit is contained in:
Evgeny Poberezkin
2022-09-18 13:25:06 +01:00
committed by GitHub
parent a3f58fdc6b
commit abb3f20ed5
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/Simplex/Messaging/Agent/Store/SQLite.hs
View File

@@ -118,6 +118,7 @@ import qualified Data.ByteString.Base64.URL as U
import Data.Char (toLower)
import Data.Function (on)
import Data.Functor (($>))
import Data.IORef
import Data.Int (Int64)
import Data.List (foldl', groupBy)
import Data.List.NonEmpty (NonEmpty (..))
@@ -243,11 +244,11 @@ sqlString s = quote <> T.replace quote "''" (T.pack s) <> quote
exexSQL :: DB.Connection -> Text -> IO [Text]
exexSQL db query = do
rs <- newTVarIO []
rs <- newIORef []
SQLite3.execWithCallback (DB.connectionHandle db) query (addRow rs)
reverse <$> readTVarIO rs
reverse <$> readIORef rs
where
addRow rs _count names values = atomically . modifyTVar' rs $ \case
addRow rs _count names values = modifyIORef' rs $ \case
[] -> [showValues values, T.intercalate "|" names]
rs' -> showValues values : rs'
showValues = T.intercalate "|" . map (fromMaybe "")