Simplex.Messaging.Agent.Store.SQLite

Documentation

data SQLiteStore

Constructors

SQLiteStore

Fields

• dbFilePath :: FilePath
• dbConnPool :: TBQueue Connection
• dbNew :: Bool

Instances

(MonadUnliftIO m, MonadError StoreError m) => MonadAgentStore SQLiteStore m

Defined in Simplex.Messaging.Agent.Store.SQLite

Methods

createRcvConn :: SQLiteStore -> TVar ChaChaDRG -> ConnData -> RcvQueue -> m ConnId

createSndConn :: SQLiteStore -> TVar ChaChaDRG -> ConnData -> SndQueue -> m ConnId

getConn :: SQLiteStore -> ConnId -> m SomeConn

getAllConnIds :: SQLiteStore -> m [ConnId]

getRcvConn :: SQLiteStore -> SMPServer -> RecipientId -> m SomeConn

deleteConn :: SQLiteStore -> ConnId -> m ()

upgradeRcvConnToDuplex :: SQLiteStore -> ConnId -> SndQueue -> m ()

upgradeSndConnToDuplex :: SQLiteStore -> ConnId -> RcvQueue -> m ()

setRcvQueueStatus :: SQLiteStore -> RcvQueue -> QueueStatus -> m ()

setRcvQueueActive :: SQLiteStore -> RcvQueue -> VerificationKey -> m ()

setSndQueueStatus :: SQLiteStore -> SndQueue -> QueueStatus -> m ()

updateSignKey :: SQLiteStore -> SndQueue -> SignatureKey -> m ()

createConfirmation :: SQLiteStore -> TVar ChaChaDRG -> NewConfirmation -> m ConfirmationId

acceptConfirmation :: SQLiteStore -> ConfirmationId -> ConnInfo -> m AcceptedConfirmation

getAcceptedConfirmation :: SQLiteStore -> ConnId -> m AcceptedConfirmation

removeConfirmations :: SQLiteStore -> ConnId -> m ()

updateRcvIds :: SQLiteStore -> ConnId -> m (InternalId, InternalRcvId, PrevExternalSndId, PrevRcvMsgHash)

createRcvMsg :: SQLiteStore -> ConnId -> RcvMsgData -> m ()

updateSndIds :: SQLiteStore -> ConnId -> m (InternalId, InternalSndId, PrevSndMsgHash)

createSndMsg :: SQLiteStore -> ConnId -> SndMsgData -> m ()

updateSndMsgStatus :: SQLiteStore -> ConnId -> InternalId -> SndMsgStatus -> m ()

getPendingMsgData :: SQLiteStore -> ConnId -> InternalId -> m (SndQueue, MsgBody)

getPendingMsgs :: SQLiteStore -> ConnId -> m [PendingMsg]

getMsg :: SQLiteStore -> ConnId -> InternalId -> m Msg

checkRcvMsg :: SQLiteStore -> ConnId -> InternalId -> m ()

updateRcvMsgAck :: SQLiteStore -> ConnId -> InternalId -> m ()

createSQLiteStore :: FilePath -> Int -> [Migration] -> IO SQLiteStore

connectSQLiteStore :: FilePath -> Int -> IO SQLiteStore

withConnection :: SQLiteStore -> (Connection -> IO a) -> IO a

withTransaction :: forall a. SQLiteStore -> (Connection -> IO a) -> IO a

fromTextField_ :: Typeable a => (Text -> Maybe a) -> Field -> Ok a

Orphan instances

FromField MsgIntegrity

Methods

fromField :: FieldParser MsgIntegrity

FromField QueueStatus

Methods

fromField :: FieldParser QueueStatus

FromField SMPQueueInfo

Methods

fromField :: FieldParser SMPQueueInfo

FromField InternalId

Methods

fromField :: FieldParser InternalId

FromField InternalSndId

Methods

fromField :: FieldParser InternalSndId

FromField InternalRcvId

Methods

fromField :: FieldParser InternalRcvId

ToField MsgIntegrity

Methods

toField :: MsgIntegrity -> SQLData

ToField QueueStatus

Methods

toField :: QueueStatus -> SQLData

ToField SMPQueueInfo

Methods

toField :: SMPQueueInfo -> SQLData

ToField InternalId

Methods

toField :: InternalId -> SQLData

ToField SndMsgStatus

Methods

toField :: SndMsgStatus -> SQLData

ToField InternalSndId

Methods

toField :: InternalSndId -> SQLData

ToField RcvMsgStatus

Methods

toField :: RcvMsgStatus -> SQLData

ToField InternalRcvId

Methods

toField :: InternalRcvId -> SQLData

(FromField a, FromField b, FromField c, FromField d, FromField e, FromField f, FromField g, FromField h, FromField i, FromField j, FromField k) => FromRow (a, b, c, d, e, f, g, h, i, j, k)

Methods

fromRow :: RowParser (a, b, c, d, e, f, g, h, i, j, k)