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 :: forall (c :: ConnectionMode). SQLiteStore -> TVar ChaChaDRG -> ConnData -> RcvQueue -> SConnectionMode c -> 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 ()

createInvitation :: SQLiteStore -> TVar ChaChaDRG -> NewInvitation -> m InvitationId

getInvitation :: SQLiteStore -> InvitationId -> m Invitation

acceptInvitation :: SQLiteStore -> InvitationId -> ConnInfo -> m ()

deleteInvitation :: SQLiteStore -> ConnId -> InvitationId -> 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 MsgBody

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

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 AConnectionRequest

Methods

fromField :: FieldParser AConnectionRequest

FromField SMPQueueUri

Methods

fromField :: FieldParser SMPQueueUri

FromField AConnectionMode

Methods

fromField :: FieldParser AConnectionMode

FromField ConnectionMode

Methods

fromField :: FieldParser ConnectionMode

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 AConnectionRequest

Methods

toField :: AConnectionRequest -> SQLData

ToField SMPQueueUri

Methods

toField :: SMPQueueUri -> SQLData

ToField ConnectionMode

Methods

toField :: ConnectionMode -> 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

(Typeable c, ConnectionModeI c) => FromField (ConnectionRequest c)

Methods

fromField :: FieldParser (ConnectionRequest c)

ToField (ConnectionRequest c)

Methods

toField :: ConnectionRequest c -> SQLData

ToField (SConnectionMode c)

Methods

toField :: SConnectionMode c -> 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)

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

Methods

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

(ToField a, ToField b, ToField c, ToField d, ToField e, ToField f, ToField g, ToField h, ToField i, ToField j, ToField k, ToField l) => ToRow (a, b, c, d, e, f, g, h, i, j, k, l)

Methods

toRow :: (a, b, c, d, e, f, g, h, i, j, k, l) -> [SQLData]