Safe Haskell	Safe-Inferred
Language	Haskell2010

Language.Marlowe.Runtime.Sync.Database

Documentation

data DatabaseSelector f where Source #

Constructors

GetTip :: DatabaseSelector (QueryField () ChainPoint)
GetTipForContract :: DatabaseSelector (QueryField ContractId ChainPoint)
GetCreateStep :: DatabaseSelector (QueryField ContractId (Maybe GetCreateStepResult))
GetIntersectionForContract :: DatabaseSelector (QueryField GetIntersectionForContractArguments (Maybe GetIntersectionForContractResult))
GetIntersection :: DatabaseSelector (QueryField [BlockHeader] (Maybe BlockHeader))
GetNextHeaders :: DatabaseSelector (QueryField ChainPoint (Next ContractHeader))
GetNextSteps :: MarloweVersion v -> DatabaseSelector (QueryField (GetNextStepsArguments v) (Next (ContractStep v)))
GetHeaders :: DatabaseSelector (QueryField GetHeadersArguments (Maybe (Page ContractId ContractHeader)))
GetContractState :: DatabaseSelector (QueryField ContractId (Maybe SomeContractState))
GetTransaction :: DatabaseSelector (QueryField TxId (Maybe SomeTransaction))
GetTransactions :: DatabaseSelector (QueryField ContractId (Maybe SomeTransactions))
GetWithdrawal :: DatabaseSelector (QueryField TxId (Maybe Withdrawal))
GetWithdrawals :: DatabaseSelector (QueryField GetWithdrawalsArguments (Maybe (Page TxId Withdrawal)))
GetPayouts :: DatabaseSelector (QueryField GetPayoutsArguments (Maybe (Page TxOutRef PayoutHeader)))
GetPayout :: DatabaseSelector (QueryField TxOutRef (Maybe SomePayoutState))

data GetPayoutsArguments Source #

Constructors

GetPayoutsArguments
Fields filter :: PayoutFilter range :: Range TxOutRef

Instances

Instances details

ToJSON GetPayoutsArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetPayoutsArguments -> Value toEncoding :: GetPayoutsArguments -> Encoding toJSONList :: [GetPayoutsArguments] -> Value toEncodingList :: [GetPayoutsArguments] -> Encoding
Generic GetPayoutsArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep GetPayoutsArguments :: Type -> Type Source # Methods from :: GetPayoutsArguments -> Rep GetPayoutsArguments x Source # to :: Rep GetPayoutsArguments x -> GetPayoutsArguments Source #
type Rep GetPayoutsArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep GetPayoutsArguments = D1 ('MetaData "GetPayoutsArguments" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetPayoutsArguments" 'PrefixI 'True) (S1 ('MetaSel ('Just "filter") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 PayoutFilter) :*: S1 ('MetaSel ('Just "range") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Range TxOutRef))))

data GetWithdrawalsArguments Source #

Constructors

GetWithdrawalsArguments
Fields filter :: WithdrawalFilter range :: Range TxId

Instances

Instances details

ToJSON GetWithdrawalsArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetWithdrawalsArguments -> Value toEncoding :: GetWithdrawalsArguments -> Encoding toJSONList :: [GetWithdrawalsArguments] -> Value toEncodingList :: [GetWithdrawalsArguments] -> Encoding
Generic GetWithdrawalsArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep GetWithdrawalsArguments :: Type -> Type Source # Methods from :: GetWithdrawalsArguments -> Rep GetWithdrawalsArguments x Source # to :: Rep GetWithdrawalsArguments x -> GetWithdrawalsArguments Source #
type Rep GetWithdrawalsArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep GetWithdrawalsArguments = D1 ('MetaData "GetWithdrawalsArguments" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetWithdrawalsArguments" 'PrefixI 'True) (S1 ('MetaSel ('Just "filter") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 WithdrawalFilter) :*: S1 ('MetaSel ('Just "range") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Range TxId))))

data GetHeadersArguments Source #

Constructors

GetHeadersArguments
Fields filter :: ContractFilter range :: Range ContractId

Instances

Instances details

ToJSON GetHeadersArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetHeadersArguments -> Value toEncoding :: GetHeadersArguments -> Encoding toJSONList :: [GetHeadersArguments] -> Value toEncodingList :: [GetHeadersArguments] -> Encoding
Generic GetHeadersArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep GetHeadersArguments :: Type -> Type Source # Methods from :: GetHeadersArguments -> Rep GetHeadersArguments x Source # to :: Rep GetHeadersArguments x -> GetHeadersArguments Source #
type Rep GetHeadersArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep GetHeadersArguments = D1 ('MetaData "GetHeadersArguments" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetHeadersArguments" 'PrefixI 'True) (S1 ('MetaSel ('Just "filter") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ContractFilter) :*: S1 ('MetaSel ('Just "range") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Range ContractId))))

data QueryField p r Source #

Constructors

Arguments p
Result r

data GetCreateStepResult Source #

Constructors

GetCreateStepResult
Fields block :: BlockHeader createStep :: SomeCreateStep

Instances

Instances details

ToJSON GetCreateStepResult Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetCreateStepResult -> Value toEncoding :: GetCreateStepResult -> Encoding toJSONList :: [GetCreateStepResult] -> Value toEncodingList :: [GetCreateStepResult] -> Encoding
Generic GetCreateStepResult Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep GetCreateStepResult :: Type -> Type Source # Methods from :: GetCreateStepResult -> Rep GetCreateStepResult x Source # to :: Rep GetCreateStepResult x -> GetCreateStepResult Source #
type Rep GetCreateStepResult Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep GetCreateStepResult = D1 ('MetaData "GetCreateStepResult" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetCreateStepResult" 'PrefixI 'True) (S1 ('MetaSel ('Just "block") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 BlockHeader) :*: S1 ('MetaSel ('Just "createStep") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SomeCreateStep)))

data GetIntersectionForContractArguments Source #

Constructors

GetIntersectionForContractArguments
Fields contractId :: ContractId points :: [BlockHeader]

Instances

Instances details

ToJSON GetIntersectionForContractArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetIntersectionForContractArguments -> Value toEncoding :: GetIntersectionForContractArguments -> Encoding toJSONList :: [GetIntersectionForContractArguments] -> Value toEncodingList :: [GetIntersectionForContractArguments] -> Encoding
Generic GetIntersectionForContractArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep GetIntersectionForContractArguments :: Type -> Type Source # Methods from :: GetIntersectionForContractArguments -> Rep GetIntersectionForContractArguments x Source # to :: Rep GetIntersectionForContractArguments x -> GetIntersectionForContractArguments Source #
type Rep GetIntersectionForContractArguments Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep GetIntersectionForContractArguments = D1 ('MetaData "GetIntersectionForContractArguments" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetIntersectionForContractArguments" 'PrefixI 'True) (S1 ('MetaSel ('Just "contractId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ContractId) :*: S1 ('MetaSel ('Just "points") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [BlockHeader])))

data GetIntersectionForContractResult Source #

Constructors

GetIntersectionForContractResult
Fields block :: BlockHeader version :: SomeMarloweVersion

Instances

Instances details

ToJSON GetIntersectionForContractResult Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetIntersectionForContractResult -> Value toEncoding :: GetIntersectionForContractResult -> Encoding toJSONList :: [GetIntersectionForContractResult] -> Value toEncodingList :: [GetIntersectionForContractResult] -> Encoding
Generic GetIntersectionForContractResult Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep GetIntersectionForContractResult :: Type -> Type Source # Methods from :: GetIntersectionForContractResult -> Rep GetIntersectionForContractResult x Source # to :: Rep GetIntersectionForContractResult x -> GetIntersectionForContractResult Source #
type Rep GetIntersectionForContractResult Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep GetIntersectionForContractResult = D1 ('MetaData "GetIntersectionForContractResult" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetIntersectionForContractResult" 'PrefixI 'True) (S1 ('MetaSel ('Just "block") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 BlockHeader) :*: S1 ('MetaSel ('Just "version") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SomeMarloweVersion)))

data GetNextStepsArguments v Source #

Constructors

GetNextStepsArguments
Fields version :: MarloweVersion v contractId :: ContractId fromPoint :: ChainPoint

Instances

Instances details

ToJSON (GetNextStepsArguments v) Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: GetNextStepsArguments v -> Value toEncoding :: GetNextStepsArguments v -> Encoding toJSONList :: [GetNextStepsArguments v] -> Value toEncodingList :: [GetNextStepsArguments v] -> Encoding
Generic (GetNextStepsArguments v) Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep (GetNextStepsArguments v) :: Type -> Type Source # Methods from :: GetNextStepsArguments v -> Rep (GetNextStepsArguments v) x Source # to :: Rep (GetNextStepsArguments v) x -> GetNextStepsArguments v Source #
type Rep (GetNextStepsArguments v) Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep (GetNextStepsArguments v) = D1 ('MetaData "GetNextStepsArguments" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "GetNextStepsArguments" 'PrefixI 'True) (S1 ('MetaSel ('Just "version") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (MarloweVersion v)) :: (S1 ('MetaSel ('Just "contractId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ContractId) :: S1 ('MetaSel ('Just "fromPoint") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainPoint))))

logDatabaseQueries :: MonadInjectEvent r DatabaseSelector s m => DatabaseQueries m -> DatabaseQueries m Source #

hoistDatabaseQueries :: (forall x. m x -> n x) -> DatabaseQueries m -> DatabaseQueries n Source #

data DatabaseQueries m Source #

Constructors

DatabaseQueries

Fields

getTip :: m ChainPoint
getTipForContract :: ContractId -> m ChainPoint
getCreateStep :: ContractId -> m (Maybe (BlockHeader, SomeCreateStep))
getIntersection :: [BlockHeader] -> m (Maybe BlockHeader)
getIntersectionForContract :: ContractId -> [BlockHeader] -> m (Maybe (BlockHeader, SomeMarloweVersion))
getNextHeaders :: ChainPoint -> m (Next ContractHeader)
getNextSteps :: forall v. MarloweVersion v -> ContractId -> ChainPoint -> m (Next (ContractStep v))
getHeaders :: ContractFilter -> Range ContractId -> m (Maybe (Page ContractId ContractHeader))
getContractState :: ContractId -> m (Maybe SomeContractState)
getTransaction :: TxId -> m (Maybe SomeTransaction)
getTransactions :: ContractId -> m (Maybe SomeTransactions)
getWithdrawal :: TxId -> m (Maybe Withdrawal)
getWithdrawals :: WithdrawalFilter -> Range TxId -> m (Maybe (Page TxId Withdrawal))
getPayouts :: PayoutFilter -> Range TxOutRef -> m (Maybe (Page TxOutRef PayoutHeader))
getPayout :: TxOutRef -> m (Maybe SomePayoutState)

data Next a Source #

Constructors

Rollback ChainPoint
Wait
Next BlockHeader [a]

Instances

Instances details

Functor Next Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods fmap :: (a -> b) -> Next a -> Next b Source # (<$) :: a -> Next b -> Next a Source #
ToJSON a => ToJSON (Next a) Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Methods toJSON :: Next a -> Value toEncoding :: Next a -> Encoding toJSONList :: [Next a] -> Value toEncodingList :: [Next a] -> Encoding
Generic (Next a) Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database Associated Types type Rep (Next a) :: Type -> Type Source # Methods from :: Next a -> Rep (Next a) x Source # to :: Rep (Next a) x -> Next a Source #
type Rep (Next a) Source #
Instance details Defined in Language.Marlowe.Runtime.Sync.Database type Rep (Next a) = D1 ('MetaData "Next" "Language.Marlowe.Runtime.Sync.Database" "marlowe-runtime-0.0.5-HVNZfQdm0XTApwwy2MBPay-sync" 'False) (C1 ('MetaCons "Rollback" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainPoint)) :+: (C1 ('MetaCons "Wait" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "Next" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 BlockHeader) :*: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [a]))))