simplexmq-0.4.1: SimpleXMQ message broker
Safe HaskellNone
LanguageHaskell2010

Simplex.Messaging.Agent.Store.SQLite

Documentation

data SQLiteStore Source #

Constructors

SQLiteStore 

Fields

Instances

Instances details
(MonadUnliftIO m, MonadError StoreError m) => MonadAgentStore SQLiteStore m Source # 
Instance details

Defined in Simplex.Messaging.Agent.Store.SQLite

Methods

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

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

getConn :: SQLiteStore -> ConnId -> m SomeConn Source #

getAllConnIds :: SQLiteStore -> m [ConnId] Source #

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

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

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

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

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

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

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

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

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

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

getAcceptedConfirmation :: SQLiteStore -> ConnId -> m AcceptedConfirmation Source #

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

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

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

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

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

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

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

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

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

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

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

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

connectSQLiteStore :: FilePath -> Int -> IO SQLiteStore Source #

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

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

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

Orphan instances

FromField MsgIntegrity Source # 
Instance details

Methods

fromField :: FieldParser MsgIntegrity #

FromField QueueStatus Source # 
Instance details

Methods

fromField :: FieldParser QueueStatus #

FromField SMPQueueInfo Source # 
Instance details

Methods

fromField :: FieldParser SMPQueueInfo #

FromField InternalId Source # 
Instance details

Methods

fromField :: FieldParser InternalId #

FromField InternalSndId Source # 
Instance details

Methods

fromField :: FieldParser InternalSndId #

FromField InternalRcvId Source # 
Instance details

Methods

fromField :: FieldParser InternalRcvId #

ToField MsgIntegrity Source # 
Instance details

Methods

toField :: MsgIntegrity -> SQLData #

ToField QueueStatus Source # 
Instance details

Methods

toField :: QueueStatus -> SQLData #

ToField SMPQueueInfo Source # 
Instance details

Methods

toField :: SMPQueueInfo -> SQLData #

ToField InternalId Source # 
Instance details

Methods

toField :: InternalId -> SQLData #

ToField SndMsgStatus Source # 
Instance details

Methods

toField :: SndMsgStatus -> SQLData #

ToField InternalSndId Source # 
Instance details

Methods

toField :: InternalSndId -> SQLData #

ToField RcvMsgStatus Source # 
Instance details

Methods

toField :: RcvMsgStatus -> SQLData #

ToField InternalRcvId Source # 
Instance details

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) Source # 
Instance details

Methods

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