Safe Haskell	Safe-Inferred
Language	Haskell2010

Hydra.HeadLogic

Description

Implements the Head Protocol's state machine as pure functions in an event sourced manner.

More specifically, the update will handle incoming Event (or rather "commands" in event sourcing speak) and convert that into a set of side-Effects and internal StateChanged events, which in turn are aggregated into a single HeadState.

As the specification is using a more imperative way of specifying the protocl behavior, one would find the decision logic in update while state updates can be found in the corresponding aggregate branch.

Synopsis

defaultTTL :: TTL
onIdleClientInit :: Environment -> Outcome tx
onIdleChainInitTx :: ChainStateType tx -> [Party] -> ContestationPeriod -> HeadId -> Outcome tx
onInitialChainCommitTx :: Monoid (UTxOType tx) => InitialState tx -> ChainStateType tx -> Party -> UTxOType tx -> Outcome tx
onInitialClientAbort :: Monoid (UTxOType tx) => InitialState tx -> Outcome tx
onInitialChainAbortTx :: Monoid (UTxOType tx) => ChainStateType tx -> Committed tx -> HeadId -> Outcome tx
onInitialChainCollectTx :: IsChainState tx => InitialState tx -> ChainStateType tx -> Outcome tx
onOpenClientNewTx :: tx -> Outcome tx
onOpenNetworkReqTx :: IsTx tx => Environment -> Ledger tx -> OpenState tx -> TTL -> tx -> Outcome tx
onOpenNetworkReqSn :: IsTx tx => Environment -> Ledger tx -> OpenState tx -> Party -> SnapshotNumber -> [TxIdType tx] -> Outcome tx
onOpenNetworkAckSn :: IsTx tx => Environment -> OpenState tx -> Party -> Signature (Snapshot tx) -> SnapshotNumber -> Outcome tx
onOpenClientClose :: OpenState tx -> Outcome tx
onOpenChainCloseTx :: OpenState tx -> ChainStateType tx -> SnapshotNumber -> UTCTime -> Outcome tx
onClosedChainContestTx :: ClosedState tx -> SnapshotNumber -> Outcome tx
onClosedClientFanout :: ClosedState tx -> Outcome tx
onClosedChainFanoutTx :: ClosedState tx -> ChainStateType tx -> Outcome tx
update :: IsChainState tx => Environment -> Ledger tx -> HeadState tx -> Event tx -> Outcome tx
aggregate :: IsChainState tx => HeadState tx -> StateChanged tx -> HeadState tx
aggregateState :: IsChainState tx => HeadState tx -> Outcome tx -> HeadState tx
recoverState :: (Foldable t, IsChainState tx) => HeadState tx -> t (StateChanged tx) -> HeadState tx
data Event tx
- = ClientEvent {
  - clientInput :: ClientInput tx
  }
- | NetworkEvent {
  - ttl :: TTL
  - party :: Party
  - message :: Message tx
  }
- | OnChainEvent {
  - chainEvent :: ChainEvent tx
  }
- | PostTxError {
  - postChainTx :: PostChainTx tx
  - postTxError :: PostTxError tx
  }
type TTL = Natural
data RequirementFailure tx
- = ReqSnNumberInvalid {
  - requestedSn :: SnapshotNumber
  - lastSeenSn :: SnapshotNumber
  }
- | ReqSnNotLeader {
  - requestedSn :: SnapshotNumber
  - leader :: Party
  }
- | InvalidMultisignature {
  - multisig :: Text
  - vkeys :: [VerificationKey HydraKey]
  }
- | SnapshotAlreadySigned {
  - knownSignatures :: [Party]
  - receivedSignature :: Party
  }
- | AckSnNumberInvalid {
  - requestedSn :: SnapshotNumber
  - lastSeenSn :: SnapshotNumber
  }
- | SnapshotDoesNotApply {
  - requestedSn :: SnapshotNumber
  - txid :: TxIdType tx
  - error :: ValidationError
  }
data LogicError tx
- = InvalidEvent (Event tx) (HeadState tx)
- | RequireFailed (RequirementFailure tx)
- | NotOurHead {
  - ourHeadId :: HeadId
  - otherHeadId :: HeadId
  }
data ClosedState tx = ClosedState {
- parameters :: HeadParameters
- confirmedSnapshot :: ConfirmedSnapshot tx
- contestationDeadline :: UTCTime
- readyToFanoutSent :: Bool
- chainState :: ChainStateType tx
- headId :: HeadId
}
data SeenSnapshot tx
- = NoSeenSnapshot
- | LastSeenSnapshot {
  - lastSeen :: SnapshotNumber
  }
- | RequestedSnapshot {
  - lastSeen :: SnapshotNumber
  - requested :: SnapshotNumber
  }
- | SeenSnapshot {
  - snapshot :: Snapshot tx
  - signatories :: Map Party (Signature (Snapshot tx))
  }
data CoordinatedHeadState tx = CoordinatedHeadState {
- localUTxO :: UTxOType tx
- localTxs :: [tx]
- allTxs :: Map (TxIdType tx) tx
- confirmedSnapshot :: ConfirmedSnapshot tx
- seenSnapshot :: SeenSnapshot tx
}
data OpenState tx = OpenState {
- parameters :: HeadParameters
- coordinatedHeadState :: CoordinatedHeadState tx
- chainState :: ChainStateType tx
- headId :: HeadId
- currentSlot :: ChainSlot
}
type Committed tx = Map Party (UTxOType tx)
type PendingCommits = Set Party
data InitialState tx = InitialState {
- parameters :: HeadParameters
- pendingCommits :: PendingCommits
- committed :: Committed tx
- chainState :: ChainStateType tx
- headId :: HeadId
}
newtype IdleState tx = IdleState {
- chainState :: ChainStateType tx
}
data HeadState tx
- = Idle (IdleState tx)
- | Initial (InitialState tx)
- | Open (OpenState tx)
- | Closed (ClosedState tx)
data Environment = Environment {
- party :: Party
- signingKey :: SigningKey HydraKey
- otherParties :: [Party]
- contestationPeriod :: ContestationPeriod
}
getChainState :: HeadState tx -> ChainStateType tx
setChainState :: ChainStateType tx -> HeadState tx -> HeadState tx
seenSnapshotNumber :: SeenSnapshot tx -> SnapshotNumber
data WaitReason tx
- = WaitOnNotApplicableTx {
  - validationError :: ValidationError
  }
- | WaitOnSnapshotNumber {
  - waitingFor :: SnapshotNumber
  }
- | WaitOnSeenSnapshot
- | WaitOnTxs {
  - waitingForTxIds :: [TxIdType tx]
  }
- | WaitOnContestationDeadline
data Outcome tx
- = Effects {
  - effects :: [Effect tx]
  }
- | StateChanged (StateChanged tx)
- | Wait {
  - reason :: WaitReason tx
  }
- | Error {
  - error :: LogicError tx
  }
- | Combined {
  - left :: Outcome tx
  - right :: Outcome tx
  }
data StateChanged tx
- = HeadInitialized {
  - parameters :: HeadParameters
  - chainState :: ChainStateType tx
  - headId :: HeadId
  }
- | CommittedUTxO {
  - party :: Party
  - committedUTxO :: UTxOType tx
  - chainState :: ChainStateType tx
  }
- | HeadAborted {
  - chainState :: ChainStateType tx
  }
- | HeadOpened {
  - chainState :: ChainStateType tx
  - initialUTxO :: UTxOType tx
  }
- | TransactionAppliedToLocalUTxO {
  - tx :: tx
  - newLocalUTxO :: UTxOType tx
  }
- | SnapshotRequestDecided {
  - snapshotNumber :: SnapshotNumber
  }
- | SnapshotRequested {
  - snapshot :: Snapshot tx
  - requestedTxIds :: [TxIdType tx]
  - newLocalUTxO :: UTxOType tx
  - newLocalTxs :: [tx]
  }
- | TransactionReceived {
  - tx :: tx
  }
- | PartySignedSnapshot {
  - snapshot :: Snapshot tx
  - party :: Party
  - signature :: Signature (Snapshot tx)
  }
- | SnapshotConfirmed {
  - snapshot :: Snapshot tx
  - signatures :: MultiSignature (Snapshot tx)
  }
- | HeadClosed {
  - chainState :: ChainStateType tx
  - contestationDeadline :: UTCTime
  }
- | HeadIsReadyToFanout
- | HeadFannedOut {
  - chainState :: ChainStateType tx
  }
- | ChainRolledBack {
  - chainState :: ChainStateType tx
  }
- | TickObserved {
  - chainSlot :: ChainSlot
  }
data Effect tx
- = ClientEffect {
  - serverOutput :: ServerOutput tx
  }
- | NetworkEffect {
  - message :: Message tx
  }
- | OnChainEffect {
  - postChainTx :: PostChainTx tx
  }
collectEffects :: Outcome tx -> [Effect tx]
collectWaits :: Outcome tx -> [WaitReason tx]
isLeader :: HeadParameters -> Party -> SnapshotNumber -> Bool

Documentation

defaultTTL :: TTL Source #

onIdleClientInit :: Environment -> Outcome tx Source #

Client request to init the head. This leads to an init transaction on chain, containing the head parameters.

Transition: IdleState → IdleState

onIdleChainInitTx Source #

Arguments

:: ChainStateType tx	New chain state.
-> [Party]
-> ContestationPeriod
-> HeadId
-> Outcome tx

Observe an init transaction, initialize parameters in an InitialState and notify clients that they can now commit.

Transition: IdleState → InitialState

onInitialChainCommitTx Source #

Arguments

:: Monoid (UTxOType tx)
=> InitialState tx
-> ChainStateType tx	New chain state
-> Party	Comitting party
-> UTxOType tx	Committed UTxO
-> Outcome tx

Observe a commit transaction and record the committed UTxO in the state. Also, if this is the last commit to be observed, post a collect-com transaction on-chain.

Transition: InitialState → InitialState

onInitialClientAbort :: Monoid (UTxOType tx) => InitialState tx -> Outcome tx Source #

Client request to abort the head. This leads to an abort transaction on chain, reimbursing already committed UTxOs.

Transition: InitialState → InitialState

onInitialChainAbortTx Source #

Arguments

:: Monoid (UTxOType tx)
=> ChainStateType tx	New chain state
-> Committed tx
-> HeadId
-> Outcome tx

Observe an abort transaction by switching the state and notifying clients about it.

Transition: InitialState → IdleState

onInitialChainCollectTx Source #

Arguments

:: IsChainState tx
=> InitialState tx
-> ChainStateType tx	New chain state
-> Outcome tx

Observe a collectCom transaction. We initialize the OpenState using the head parameters from IdleState and construct an InitialSnapshot holding u0 from the committed UTxOs.

Transition: InitialState → OpenState

onOpenClientNewTx Source #

Arguments

:: tx	The transaction to be submitted to the head.
-> Outcome tx

Client request to ingest a new transaction into the head.

Transition: OpenState → OpenState

onOpenNetworkReqTx Source #

Arguments

:: IsTx tx
=> Environment
-> Ledger tx
-> OpenState tx
-> TTL
-> tx	The transaction to be submitted to the head.
-> Outcome tx

Process a transaction request (ReqTx) from a party.

We apply this transaction to the seen utxo (ledger state). If not applicable, we wait and retry later. If it applies, this yields an updated seen ledger state. Then, we check whether we are the leader for the next snapshot and emit a snapshot request ReqSn including this transaction if needed.

Transition: OpenState → OpenState

onOpenNetworkReqSn Source #

Arguments

:: IsTx tx
=> Environment
-> Ledger tx
-> OpenState tx
-> Party	Party which sent the ReqSn.
-> SnapshotNumber	Requested snapshot number.
-> [TxIdType tx]	List of transactions to snapshot.
-> Outcome tx

Process a snapshot request (ReqSn) from party.

This checks that s is the next snapshot number and that the party is responsible for leading that snapshot. Then, we potentially wait until the previous snapshot is confirmed (no snapshot is in flight), before we apply (or wait until applicable) the requested transactions to the last confirmed snapshot. Only then, we start tracking this new "seen" snapshot, compute a signature of it and send the corresponding AckSn to all parties. Finally, the pending transaction set gets pruned to only contain still applicable transactions.

Transition: OpenState → OpenState

onOpenNetworkAckSn Source #

Arguments

:: IsTx tx
=> Environment
-> OpenState tx
-> Party	Party which sent the AckSn.
-> Signature (Snapshot tx)	Signature from other party.
-> SnapshotNumber	Snapshot number of this AckSn.
-> Outcome tx

Process a snapshot acknowledgement (AckSn) from a party.

We do require that the is from the last seen or next expected snapshot, and potentially wait wait for the corresponding ReqSn before proceeding. If the party hasn't sent us a signature yet, we store it. Once a signature from each party has been collected, we aggregate a multi-signature and verify it is correct. If everything is fine, the snapshot can be considered as the latest confirmed one. Similar to processing a ReqTx, we check whether we are leading the next snapshot and craft a corresponding ReqSn if needed.

Transition: OpenState → OpenState

onOpenClientClose :: OpenState tx -> Outcome tx Source #

Client request to close the head. This leads to a close transaction on chain using the latest confirmed snaphshot of the OpenState.

Transition: OpenState → OpenState

onOpenChainCloseTx Source #

Arguments

:: OpenState tx
-> ChainStateType tx	New chain state.
-> SnapshotNumber	Closed snapshot number.
-> UTCTime	Contestation deadline.
-> Outcome tx

Observe a close transaction. If the closed snapshot number is smaller than our last confirmed, we post a contest transaction. Also, we do schedule a notification for clients to fanout at the deadline.

Transition: OpenState → ClosedState

onClosedChainContestTx :: ClosedState tx -> SnapshotNumber -> Outcome tx Source #

Observe a contest transaction. If the contested snapshot number is smaller than our last confirmed snapshot, we post a contest transaction.

Transition: ClosedState → ClosedState

onClosedClientFanout :: ClosedState tx -> Outcome tx Source #

Client request to fanout leads to a fanout transaction on chain using the latest confirmed snapshot from ClosedState.

Transition: ClosedState → ClosedState

onClosedChainFanoutTx Source #

Arguments

:: ClosedState tx
-> ChainStateType tx	New chain state
-> Outcome tx

Observe a fanout transaction by finalize the head state and notifying clients about it.

Transition: ClosedState → IdleState

update Source #

Arguments

:: IsChainState tx
=> Environment
-> Ledger tx
-> HeadState tx	Current HeadState to validate the command against.
-> Event tx	Command sent to the HeadLogic to be processed.
-> Outcome tx

Handles commands and converts them into internal StateChanged events along with Effects, in case it is processed succesfully. Later, the Node will aggregate the events, resulting in a new HeadState.

aggregate :: IsChainState tx => HeadState tx -> StateChanged tx -> HeadState tx Source #

Reflect StateChanged events onto the HeadState aggregate.

aggregateState :: IsChainState tx => HeadState tx -> Outcome tx -> HeadState tx Source #

recoverState :: (Foldable t, IsChainState tx) => HeadState tx -> t (StateChanged tx) -> HeadState tx Source #

data Event tx Source #

The different events which are processed by the head logic (the "core"). Corresponding to each of the "shell" layers, we distinguish between events from the client, the network and the chain.

Constructors

ClientEvent	Event received from clients via the Hydra.API.
Fields clientInput :: ClientInput tx
NetworkEvent	Event received from peers via a Hydra.Network. `ttl` is a simple counter that's decreased every time the event is reenqueued due to a wait. It's default value is `defaultTTL`
Fields ttl :: TTL party :: Party message :: Message tx
OnChainEvent	Event received from the chain via a Hydra.Chain.
Fields chainEvent :: ChainEvent tx
PostTxError	Event to re-ingest errors from `postTx` for further processing.
Fields postChainTx :: PostChainTx tx postTxError :: PostTxError tx

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event Methods arbitrary :: Gen (Event tx) shrink :: Event tx -> [Event tx]
IsChainState tx => FromJSON (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event Methods parseJSON :: Value -> Parser (Event tx) parseJSONList :: Value -> Parser [Event tx]
IsChainState tx => ToJSON (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event Methods toJSON :: Event tx -> Value toEncoding :: Event tx -> Encoding toJSONList :: [Event tx] -> Value toEncodingList :: [Event tx] -> Encoding
Generic (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event Associated Types type Rep (Event tx) :: Type -> Type Source # Methods from :: Event tx -> Rep (Event tx) x Source # to :: Rep (Event tx) x -> Event tx Source #
IsChainState tx => Show (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event Methods showsPrec :: Int -> Event tx -> ShowS Source # show :: Event tx -> String Source # showList :: [Event tx] -> ShowS Source #
IsChainState tx => Eq (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event Methods (==) :: Event tx -> Event tx -> Bool Source # (/=) :: Event tx -> Event tx -> Bool Source #
type Rep (Event tx) Source #
Instance details Defined in Hydra.HeadLogic.Event type Rep (Event tx) = D1 ('MetaData "Event" "Hydra.HeadLogic.Event" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) ((C1 ('MetaCons "ClientEvent" 'PrefixI 'True) (S1 ('MetaSel ('Just "clientInput") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ClientInput tx))) :+: C1 ('MetaCons "NetworkEvent" 'PrefixI 'True) (S1 ('MetaSel ('Just "ttl") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 TTL) :: (S1 ('MetaSel ('Just "party") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Party) :: S1 ('MetaSel ('Just "message") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Message tx))))) :+: (C1 ('MetaCons "OnChainEvent" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainEvent") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainEvent tx))) :+: C1 ('MetaCons "PostTxError" 'PrefixI 'True) (S1 ('MetaSel ('Just "postChainTx") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (PostChainTx tx)) :*: S1 ('MetaSel ('Just "postTxError") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (PostTxError tx)))))

type TTL = Natural Source #

data RequirementFailure tx Source #

Constructors

ReqSnNumberInvalid
Fields requestedSn :: SnapshotNumber lastSeenSn :: SnapshotNumber
ReqSnNotLeader
Fields requestedSn :: SnapshotNumber leader :: Party
InvalidMultisignature
Fields multisig :: Text vkeys :: [VerificationKey HydraKey]
SnapshotAlreadySigned
Fields knownSignatures :: [Party] receivedSignature :: Party
AckSnNumberInvalid
Fields requestedSn :: SnapshotNumber lastSeenSn :: SnapshotNumber
SnapshotDoesNotApply
Fields requestedSn :: SnapshotNumber txid :: TxIdType tx error :: ValidationError

Instances

Instances details

Arbitrary (TxIdType tx) => Arbitrary (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods arbitrary :: Gen (RequirementFailure tx) shrink :: RequirementFailure tx -> [RequirementFailure tx]
FromJSON (TxIdType tx) => FromJSON (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods parseJSON :: Value -> Parser (RequirementFailure tx) parseJSONList :: Value -> Parser [RequirementFailure tx]
ToJSON (TxIdType tx) => ToJSON (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods toJSON :: RequirementFailure tx -> Value toEncoding :: RequirementFailure tx -> Encoding toJSONList :: [RequirementFailure tx] -> Value toEncodingList :: [RequirementFailure tx] -> Encoding
Generic (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Associated Types type Rep (RequirementFailure tx) :: Type -> Type Source # Methods from :: RequirementFailure tx -> Rep (RequirementFailure tx) x Source # to :: Rep (RequirementFailure tx) x -> RequirementFailure tx Source #
Show (TxIdType tx) => Show (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods showsPrec :: Int -> RequirementFailure tx -> ShowS Source # show :: RequirementFailure tx -> String Source # showList :: [RequirementFailure tx] -> ShowS Source #
Eq (TxIdType tx) => Eq (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods (==) :: RequirementFailure tx -> RequirementFailure tx -> Bool Source # (/=) :: RequirementFailure tx -> RequirementFailure tx -> Bool Source #
type Rep (RequirementFailure tx) Source #
Instance details Defined in Hydra.HeadLogic.Error type Rep (RequirementFailure tx) = D1 ('MetaData "RequirementFailure" "Hydra.HeadLogic.Error" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) ((C1 ('MetaCons "ReqSnNumberInvalid" 'PrefixI 'True) (S1 ('MetaSel ('Just "requestedSn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber) :: S1 ('MetaSel ('Just "lastSeenSn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber)) :+: (C1 ('MetaCons "ReqSnNotLeader" 'PrefixI 'True) (S1 ('MetaSel ('Just "requestedSn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber) :: S1 ('MetaSel ('Just "leader") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Party)) :+: C1 ('MetaCons "InvalidMultisignature" 'PrefixI 'True) (S1 ('MetaSel ('Just "multisig") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text) :: S1 ('MetaSel ('Just "vkeys") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [VerificationKey HydraKey])))) :+: (C1 ('MetaCons "SnapshotAlreadySigned" 'PrefixI 'True) (S1 ('MetaSel ('Just "knownSignatures") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Party]) :: S1 ('MetaSel ('Just "receivedSignature") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Party)) :+: (C1 ('MetaCons "AckSnNumberInvalid" 'PrefixI 'True) (S1 ('MetaSel ('Just "requestedSn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber) :: S1 ('MetaSel ('Just "lastSeenSn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber)) :+: C1 ('MetaCons "SnapshotDoesNotApply" 'PrefixI 'True) (S1 ('MetaSel ('Just "requestedSn") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber) :: (S1 ('MetaSel ('Just "txid") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (TxIdType tx)) :*: S1 ('MetaSel ('Just "error") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ValidationError))))))

data LogicError tx Source #

Preliminary type for collecting errors occurring during update. TODO: Try to merge this (back) into Outcome.

Constructors

InvalidEvent (Event tx) (HeadState tx)
RequireFailed (RequirementFailure tx)
NotOurHead
Fields ourHeadId :: HeadId otherHeadId :: HeadId

Instances

Instances details

(Arbitrary (Event tx), Arbitrary (HeadState tx), Arbitrary (RequirementFailure tx)) => Arbitrary (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods arbitrary :: Gen (LogicError tx) shrink :: LogicError tx -> [LogicError tx]
(FromJSON (HeadState tx), FromJSON (Event tx), FromJSON (RequirementFailure tx)) => FromJSON (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods parseJSON :: Value -> Parser (LogicError tx) parseJSONList :: Value -> Parser [LogicError tx]
(ToJSON (HeadState tx), ToJSON (Event tx), ToJSON (RequirementFailure tx)) => ToJSON (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods toJSON :: LogicError tx -> Value toEncoding :: LogicError tx -> Encoding toJSONList :: [LogicError tx] -> Value toEncodingList :: [LogicError tx] -> Encoding
(Typeable tx, Show (Event tx), Show (HeadState tx), Show (RequirementFailure tx)) => Exception (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods toException :: LogicError tx -> SomeException Source # fromException :: SomeException -> Maybe (LogicError tx) Source # displayException :: LogicError tx -> String Source #
Generic (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Associated Types type Rep (LogicError tx) :: Type -> Type Source # Methods from :: LogicError tx -> Rep (LogicError tx) x Source # to :: Rep (LogicError tx) x -> LogicError tx Source #
(Show (HeadState tx), Show (Event tx), Show (RequirementFailure tx)) => Show (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods showsPrec :: Int -> LogicError tx -> ShowS Source # show :: LogicError tx -> String Source # showList :: [LogicError tx] -> ShowS Source #
(Eq (HeadState tx), Eq (Event tx), Eq (RequirementFailure tx)) => Eq (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error Methods (==) :: LogicError tx -> LogicError tx -> Bool Source # (/=) :: LogicError tx -> LogicError tx -> Bool Source #
type Rep (LogicError tx) Source #
Instance details Defined in Hydra.HeadLogic.Error type Rep (LogicError tx) = D1 ('MetaData "LogicError" "Hydra.HeadLogic.Error" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (C1 ('MetaCons "InvalidEvent" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Event tx)) :: S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (HeadState tx))) :+: (C1 ('MetaCons "RequireFailed" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (RequirementFailure tx))) :+: C1 ('MetaCons "NotOurHead" 'PrefixI 'True) (S1 ('MetaSel ('Just "ourHeadId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadId) :: S1 ('MetaSel ('Just "otherHeadId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadId))))

data ClosedState tx Source #

An Closed head with an current candidate ConfirmedSnapshot, which may be contested before the $sel:contestationDeadline:ClosedState.

Constructors

ClosedState
Fields parameters :: HeadParameters confirmedSnapshot :: ConfirmedSnapshot tx contestationDeadline :: UTCTime readyToFanoutSent :: Bool Tracks whether we have informed clients already about being `ReadyToFanout`. chainState :: ChainStateType tx headId :: HeadId

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (ClosedState tx) shrink :: ClosedState tx -> [ClosedState tx]
(IsTx tx, FromJSON (ChainStateType tx)) => FromJSON (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (ClosedState tx) parseJSONList :: Value -> Parser [ClosedState tx]
(IsTx tx, ToJSON (ChainStateType tx)) => ToJSON (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: ClosedState tx -> Value toEncoding :: ClosedState tx -> Encoding toJSONList :: [ClosedState tx] -> Value toEncodingList :: [ClosedState tx] -> Encoding
Generic (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (ClosedState tx) :: Type -> Type Source # Methods from :: ClosedState tx -> Rep (ClosedState tx) x Source # to :: Rep (ClosedState tx) x -> ClosedState tx Source #
(IsTx tx, Show (ChainStateType tx)) => Show (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> ClosedState tx -> ShowS Source # show :: ClosedState tx -> String Source # showList :: [ClosedState tx] -> ShowS Source #
(IsTx tx, Eq (ChainStateType tx)) => Eq (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: ClosedState tx -> ClosedState tx -> Bool Source # (/=) :: ClosedState tx -> ClosedState tx -> Bool Source #
type Rep (ClosedState tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (ClosedState tx) = D1 ('MetaData "ClosedState" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (C1 ('MetaCons "ClosedState" 'PrefixI 'True) ((S1 ('MetaSel ('Just "parameters") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadParameters) :: (S1 ('MetaSel ('Just "confirmedSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ConfirmedSnapshot tx)) :: S1 ('MetaSel ('Just "contestationDeadline") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime))) :: (S1 ('MetaSel ('Just "readyToFanoutSent") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :: (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)) :*: S1 ('MetaSel ('Just "headId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadId)))))

data SeenSnapshot tx Source #

Data structure to help in tracking whether we have seen or requested a ReqSn already and if seen, the signatures we collected already.

Constructors

NoSeenSnapshot	Never saw a ReqSn.
LastSeenSnapshot	No snapshot in flight with last seen snapshot number as given.
Fields lastSeen :: SnapshotNumber
RequestedSnapshot	ReqSn was sent out and it should be considered already in flight.
Fields lastSeen :: SnapshotNumber requested :: SnapshotNumber
SeenSnapshot	ReqSn for given snapshot was received.
Fields snapshot :: Snapshot tx signatories :: Map Party (Signature (Snapshot tx)) Collected signatures and so far.

Instances

Instances details

IsTx tx => Arbitrary (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (SeenSnapshot tx) shrink :: SeenSnapshot tx -> [SeenSnapshot tx]
IsTx tx => FromJSON (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (SeenSnapshot tx) parseJSONList :: Value -> Parser [SeenSnapshot tx]
IsTx tx => ToJSON (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: SeenSnapshot tx -> Value toEncoding :: SeenSnapshot tx -> Encoding toJSONList :: [SeenSnapshot tx] -> Value toEncodingList :: [SeenSnapshot tx] -> Encoding
Generic (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (SeenSnapshot tx) :: Type -> Type Source # Methods from :: SeenSnapshot tx -> Rep (SeenSnapshot tx) x Source # to :: Rep (SeenSnapshot tx) x -> SeenSnapshot tx Source #
IsTx tx => Show (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> SeenSnapshot tx -> ShowS Source # show :: SeenSnapshot tx -> String Source # showList :: [SeenSnapshot tx] -> ShowS Source #
IsTx tx => Eq (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: SeenSnapshot tx -> SeenSnapshot tx -> Bool Source # (/=) :: SeenSnapshot tx -> SeenSnapshot tx -> Bool Source #
type Rep (SeenSnapshot tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (SeenSnapshot tx) = D1 ('MetaData "SeenSnapshot" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) ((C1 ('MetaCons "NoSeenSnapshot" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "LastSeenSnapshot" 'PrefixI 'True) (S1 ('MetaSel ('Just "lastSeen") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber))) :+: (C1 ('MetaCons "RequestedSnapshot" 'PrefixI 'True) (S1 ('MetaSel ('Just "lastSeen") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber) :: S1 ('MetaSel ('Just "requested") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber)) :+: C1 ('MetaCons "SeenSnapshot" 'PrefixI 'True) (S1 ('MetaSel ('Just "snapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Snapshot tx)) :: S1 ('MetaSel ('Just "signatories") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Map Party (Signature (Snapshot tx)))))))

data CoordinatedHeadState tx Source #

Off-chain state of the Coordinated Head protocol.

Constructors

CoordinatedHeadState

Fields

localUTxO :: UTxOType tx
The latest UTxO resulting from applying $sel:localTxs:CoordinatedHeadState to CoordinatedHeadState. Spec: L̂
localTxs :: [tx]
List of transactions applied locally and pending inclusion in a snapshot. Spec: T̂
allTxs :: Map (TxIdType tx) tx
Map containing all the transactions ever seen by this node and not yet included in a snapshot. Spec: Tall
confirmedSnapshot :: ConfirmedSnapshot tx
The latest confirmed snapshot. Spec: U̅, s̅ and σ̅
seenSnapshot :: SeenSnapshot tx
Last seen snapshot and signatures accumulator. Spec: Û, ŝ and Σ̂

Instances

Instances details

IsTx tx => Arbitrary (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (CoordinatedHeadState tx) shrink :: CoordinatedHeadState tx -> [CoordinatedHeadState tx]
IsTx tx => FromJSON (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (CoordinatedHeadState tx) parseJSONList :: Value -> Parser [CoordinatedHeadState tx]
IsTx tx => ToJSON (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: CoordinatedHeadState tx -> Value toEncoding :: CoordinatedHeadState tx -> Encoding toJSONList :: [CoordinatedHeadState tx] -> Value toEncodingList :: [CoordinatedHeadState tx] -> Encoding
Generic (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (CoordinatedHeadState tx) :: Type -> Type Source # Methods from :: CoordinatedHeadState tx -> Rep (CoordinatedHeadState tx) x Source # to :: Rep (CoordinatedHeadState tx) x -> CoordinatedHeadState tx Source #
IsTx tx => Show (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> CoordinatedHeadState tx -> ShowS Source # show :: CoordinatedHeadState tx -> String Source # showList :: [CoordinatedHeadState tx] -> ShowS Source #
IsTx tx => Eq (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: CoordinatedHeadState tx -> CoordinatedHeadState tx -> Bool Source # (/=) :: CoordinatedHeadState tx -> CoordinatedHeadState tx -> Bool Source #
type Rep (CoordinatedHeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (CoordinatedHeadState tx) = D1 ('MetaData "CoordinatedHeadState" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (C1 ('MetaCons "CoordinatedHeadState" 'PrefixI 'True) ((S1 ('MetaSel ('Just "localUTxO") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (UTxOType tx)) :: S1 ('MetaSel ('Just "localTxs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [tx])) :: (S1 ('MetaSel ('Just "allTxs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Map (TxIdType tx) tx)) :: (S1 ('MetaSel ('Just "confirmedSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ConfirmedSnapshot tx)) :: S1 ('MetaSel ('Just "seenSnapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (SeenSnapshot tx))))))

data OpenState tx Source #

An Open head with a CoordinatedHeadState tracking off-chain transactions.

Constructors

OpenState
Fields parameters :: HeadParameters coordinatedHeadState :: CoordinatedHeadState tx chainState :: ChainStateType tx headId :: HeadId currentSlot :: ChainSlot

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (OpenState tx) shrink :: OpenState tx -> [OpenState tx]
(IsTx tx, FromJSON (ChainStateType tx)) => FromJSON (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (OpenState tx) parseJSONList :: Value -> Parser [OpenState tx]
(IsTx tx, ToJSON (ChainStateType tx)) => ToJSON (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: OpenState tx -> Value toEncoding :: OpenState tx -> Encoding toJSONList :: [OpenState tx] -> Value toEncodingList :: [OpenState tx] -> Encoding
Generic (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (OpenState tx) :: Type -> Type Source # Methods from :: OpenState tx -> Rep (OpenState tx) x Source # to :: Rep (OpenState tx) x -> OpenState tx Source #
(IsTx tx, Show (ChainStateType tx)) => Show (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> OpenState tx -> ShowS Source # show :: OpenState tx -> String Source # showList :: [OpenState tx] -> ShowS Source #
(IsTx tx, Eq (ChainStateType tx)) => Eq (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: OpenState tx -> OpenState tx -> Bool Source # (/=) :: OpenState tx -> OpenState tx -> Bool Source #
type Rep (OpenState tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (OpenState tx) = D1 ('MetaData "OpenState" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (C1 ('MetaCons "OpenState" 'PrefixI 'True) ((S1 ('MetaSel ('Just "parameters") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadParameters) :: S1 ('MetaSel ('Just "coordinatedHeadState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (CoordinatedHeadState tx))) :: (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)) :: (S1 ('MetaSel ('Just "headId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadId) :: S1 ('MetaSel ('Just "currentSlot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainSlot)))))

type Committed tx = Map Party (UTxOType tx) Source #

type PendingCommits = Set Party Source #

data InitialState tx Source #

An Initial head which already has an identity and is collecting commits.

Constructors

InitialState
Fields parameters :: HeadParameters pendingCommits :: PendingCommits committed :: Committed tx chainState :: ChainStateType tx headId :: HeadId

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (InitialState tx) shrink :: InitialState tx -> [InitialState tx]
(IsTx tx, FromJSON (ChainStateType tx)) => FromJSON (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (InitialState tx) parseJSONList :: Value -> Parser [InitialState tx]
(IsTx tx, ToJSON (ChainStateType tx)) => ToJSON (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: InitialState tx -> Value toEncoding :: InitialState tx -> Encoding toJSONList :: [InitialState tx] -> Value toEncodingList :: [InitialState tx] -> Encoding
Generic (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (InitialState tx) :: Type -> Type Source # Methods from :: InitialState tx -> Rep (InitialState tx) x Source # to :: Rep (InitialState tx) x -> InitialState tx Source #
(IsTx tx, Show (ChainStateType tx)) => Show (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> InitialState tx -> ShowS Source # show :: InitialState tx -> String Source # showList :: [InitialState tx] -> ShowS Source #
(IsTx tx, Eq (ChainStateType tx)) => Eq (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: InitialState tx -> InitialState tx -> Bool Source # (/=) :: InitialState tx -> InitialState tx -> Bool Source #
type Rep (InitialState tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (InitialState tx) = D1 ('MetaData "InitialState" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (C1 ('MetaCons "InitialState" 'PrefixI 'True) ((S1 ('MetaSel ('Just "parameters") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadParameters) :: S1 ('MetaSel ('Just "pendingCommits") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 PendingCommits)) :: (S1 ('MetaSel ('Just "committed") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Committed tx)) :: (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)) :: S1 ('MetaSel ('Just "headId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadId)))))

newtype IdleState tx Source #

An Idle head only having a chain state with things seen on chain so far.

Constructors

IdleState
Fields chainState :: ChainStateType tx

Instances

Instances details

Arbitrary (ChainStateType tx) => Arbitrary (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (IdleState tx) shrink :: IdleState tx -> [IdleState tx]
FromJSON (ChainStateType tx) => FromJSON (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (IdleState tx) parseJSONList :: Value -> Parser [IdleState tx]
ToJSON (ChainStateType tx) => ToJSON (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: IdleState tx -> Value toEncoding :: IdleState tx -> Encoding toJSONList :: [IdleState tx] -> Value toEncodingList :: [IdleState tx] -> Encoding
Generic (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (IdleState tx) :: Type -> Type Source # Methods from :: IdleState tx -> Rep (IdleState tx) x Source # to :: Rep (IdleState tx) x -> IdleState tx Source #
Show (ChainStateType tx) => Show (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> IdleState tx -> ShowS Source # show :: IdleState tx -> String Source # showList :: [IdleState tx] -> ShowS Source #
Eq (ChainStateType tx) => Eq (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: IdleState tx -> IdleState tx -> Bool Source # (/=) :: IdleState tx -> IdleState tx -> Bool Source #
type Rep (IdleState tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (IdleState tx) = D1 ('MetaData "IdleState" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'True) (C1 ('MetaCons "IdleState" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx))))

data HeadState tx Source #

The main state of the Hydra protocol state machine. It holds both, the overall protocol state, but also the off-chain CoordinatedHeadState.

Each of the sub-types (InitialState, OpenState, etc.) contain black-box IdleState corresponding to OnChainEvent that has been observed leading to the state.

Note that rollbacks are currently not fully handled in the head logic and only this internal chain state gets replaced with the "rolled back to" version.

Constructors

Idle (IdleState tx)
Initial (InitialState tx)
Open (OpenState tx)
Closed (ClosedState tx)

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen (HeadState tx) shrink :: HeadState tx -> [HeadState tx]
(IsTx tx, FromJSON (ChainStateType tx)) => FromJSON (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods parseJSON :: Value -> Parser (HeadState tx) parseJSONList :: Value -> Parser [HeadState tx]
(IsTx tx, ToJSON (ChainStateType tx)) => ToJSON (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods toJSON :: HeadState tx -> Value toEncoding :: HeadState tx -> Encoding toJSONList :: [HeadState tx] -> Value toEncodingList :: [HeadState tx] -> Encoding
Generic (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Associated Types type Rep (HeadState tx) :: Type -> Type Source # Methods from :: HeadState tx -> Rep (HeadState tx) x Source # to :: Rep (HeadState tx) x -> HeadState tx Source #
(IsTx tx, Show (ChainStateType tx)) => Show (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> HeadState tx -> ShowS Source # show :: HeadState tx -> String Source # showList :: [HeadState tx] -> ShowS Source #
(IsTx tx, Eq (ChainStateType tx)) => Eq (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State Methods (==) :: HeadState tx -> HeadState tx -> Bool Source # (/=) :: HeadState tx -> HeadState tx -> Bool Source #
type Rep (HeadState tx) Source #
Instance details Defined in Hydra.HeadLogic.State type Rep (HeadState tx) = D1 ('MetaData "HeadState" "Hydra.HeadLogic.State" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) ((C1 ('MetaCons "Idle" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (IdleState tx))) :+: C1 ('MetaCons "Initial" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (InitialState tx)))) :+: (C1 ('MetaCons "Open" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (OpenState tx))) :+: C1 ('MetaCons "Closed" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ClosedState tx)))))

data Environment Source #

Constructors

Environment
Fields party :: Party This is the p_i from the paper signingKey :: SigningKey HydraKey otherParties :: [Party] contestationPeriod :: ContestationPeriod

Instances

Instances details

Arbitrary Environment Source #
Instance details Defined in Hydra.HeadLogic.State Methods arbitrary :: Gen Environment shrink :: Environment -> [Environment]
Show Environment Source #
Instance details Defined in Hydra.HeadLogic.State Methods showsPrec :: Int -> Environment -> ShowS Source # show :: Environment -> String Source # showList :: [Environment] -> ShowS Source #

getChainState :: HeadState tx -> ChainStateType tx Source #

Get the chain state in any HeadState.

setChainState :: ChainStateType tx -> HeadState tx -> HeadState tx Source #

Update the chain state in any HeadState.

seenSnapshotNumber :: SeenSnapshot tx -> SnapshotNumber Source #

Get the last seen snapshot number given a SeenSnapshot.

data WaitReason tx Source #

Constructors

WaitOnNotApplicableTx
Fields validationError :: ValidationError
WaitOnSnapshotNumber
Fields waitingFor :: SnapshotNumber
WaitOnSeenSnapshot
WaitOnTxs
Fields waitingForTxIds :: [TxIdType tx]
WaitOnContestationDeadline

Instances

Instances details

IsTx tx => Arbitrary (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods arbitrary :: Gen (WaitReason tx) shrink :: WaitReason tx -> [WaitReason tx]
IsTx tx => FromJSON (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods parseJSON :: Value -> Parser (WaitReason tx) parseJSONList :: Value -> Parser [WaitReason tx]
IsTx tx => ToJSON (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods toJSON :: WaitReason tx -> Value toEncoding :: WaitReason tx -> Encoding toJSONList :: [WaitReason tx] -> Value toEncodingList :: [WaitReason tx] -> Encoding
Generic (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Associated Types type Rep (WaitReason tx) :: Type -> Type Source # Methods from :: WaitReason tx -> Rep (WaitReason tx) x Source # to :: Rep (WaitReason tx) x -> WaitReason tx Source #
IsTx tx => Show (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods showsPrec :: Int -> WaitReason tx -> ShowS Source # show :: WaitReason tx -> String Source # showList :: [WaitReason tx] -> ShowS Source #
IsTx tx => Eq (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods (==) :: WaitReason tx -> WaitReason tx -> Bool Source # (/=) :: WaitReason tx -> WaitReason tx -> Bool Source #
type Rep (WaitReason tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome type Rep (WaitReason tx) = D1 ('MetaData "WaitReason" "Hydra.HeadLogic.Outcome" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) ((C1 ('MetaCons "WaitOnNotApplicableTx" 'PrefixI 'True) (S1 ('MetaSel ('Just "validationError") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ValidationError)) :+: C1 ('MetaCons "WaitOnSnapshotNumber" 'PrefixI 'True) (S1 ('MetaSel ('Just "waitingFor") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber))) :+: (C1 ('MetaCons "WaitOnSeenSnapshot" 'PrefixI 'False) (U1 :: Type -> Type) :+: (C1 ('MetaCons "WaitOnTxs" 'PrefixI 'True) (S1 ('MetaSel ('Just "waitingForTxIds") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [TxIdType tx])) :+: C1 ('MetaCons "WaitOnContestationDeadline" 'PrefixI 'False) (U1 :: Type -> Type))))

data Outcome tx Source #

Constructors

Effects
Fields effects :: [Effect tx]
StateChanged (StateChanged tx)
Wait
Fields reason :: WaitReason tx
Error
Fields error :: LogicError tx
Combined
Fields left :: Outcome tx right :: Outcome tx

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods arbitrary :: Gen (Outcome tx) shrink :: Outcome tx -> [Outcome tx]
IsChainState tx => FromJSON (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods parseJSON :: Value -> Parser (Outcome tx) parseJSONList :: Value -> Parser [Outcome tx]
IsChainState tx => ToJSON (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods toJSON :: Outcome tx -> Value toEncoding :: Outcome tx -> Encoding toJSONList :: [Outcome tx] -> Value toEncodingList :: [Outcome tx] -> Encoding
Semigroup (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods (<>) :: Outcome tx -> Outcome tx -> Outcome tx Source # sconcat :: NonEmpty (Outcome tx) -> Outcome tx Source # stimes :: Integral b => b -> Outcome tx -> Outcome tx Source #
Generic (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Associated Types type Rep (Outcome tx) :: Type -> Type Source # Methods from :: Outcome tx -> Rep (Outcome tx) x Source # to :: Rep (Outcome tx) x -> Outcome tx Source #
IsChainState tx => Show (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods showsPrec :: Int -> Outcome tx -> ShowS Source # show :: Outcome tx -> String Source # showList :: [Outcome tx] -> ShowS Source #
IsChainState tx => Eq (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods (==) :: Outcome tx -> Outcome tx -> Bool Source # (/=) :: Outcome tx -> Outcome tx -> Bool Source #
type Rep (Outcome tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome type Rep (Outcome tx) = D1 ('MetaData "Outcome" "Hydra.HeadLogic.Outcome" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) ((C1 ('MetaCons "Effects" 'PrefixI 'True) (S1 ('MetaSel ('Just "effects") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [Effect tx])) :+: C1 ('MetaCons "StateChanged" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (StateChanged tx)))) :+: (C1 ('MetaCons "Wait" 'PrefixI 'True) (S1 ('MetaSel ('Just "reason") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (WaitReason tx))) :+: (C1 ('MetaCons "Error" 'PrefixI 'True) (S1 ('MetaSel ('Just "error") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (LogicError tx))) :+: C1 ('MetaCons "Combined" 'PrefixI 'True) (S1 ('MetaSel ('Just "left") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Outcome tx)) :*: S1 ('MetaSel ('Just "right") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Outcome tx))))))

data StateChanged tx Source #

Head state changed event. These events represent all the internal state changes, get persisted and processed in an event sourcing manner.

Constructors

HeadInitialized
Fields parameters :: HeadParameters chainState :: ChainStateType tx headId :: HeadId
CommittedUTxO
Fields party :: Party committedUTxO :: UTxOType tx chainState :: ChainStateType tx
HeadAborted
Fields chainState :: ChainStateType tx
HeadOpened
Fields chainState :: ChainStateType tx initialUTxO :: UTxOType tx
TransactionAppliedToLocalUTxO
Fields tx :: tx newLocalUTxO :: UTxOType tx
SnapshotRequestDecided
Fields snapshotNumber :: SnapshotNumber
SnapshotRequested	A snapshot was requested by some party. NOTE: We deliberately already include an updated local ledger state to not need a ledger to interpret this event.
Fields snapshot :: Snapshot tx requestedTxIds :: [TxIdType tx] newLocalUTxO :: UTxOType tx newLocalTxs :: [tx]
TransactionReceived
Fields tx :: tx
PartySignedSnapshot
Fields snapshot :: Snapshot tx party :: Party signature :: Signature (Snapshot tx)
SnapshotConfirmed
Fields snapshot :: Snapshot tx signatures :: MultiSignature (Snapshot tx)
HeadClosed
Fields chainState :: ChainStateType tx contestationDeadline :: UTCTime
HeadIsReadyToFanout
HeadFannedOut
Fields chainState :: ChainStateType tx
ChainRolledBack
Fields chainState :: ChainStateType tx
TickObserved
Fields chainSlot :: ChainSlot

Instances

Instances details

(IsTx tx, Arbitrary (HeadState tx), Arbitrary (ChainStateType tx)) => Arbitrary (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods arbitrary :: Gen (StateChanged tx) shrink :: StateChanged tx -> [StateChanged tx]
(IsTx tx, FromJSON (HeadState tx), FromJSON (ChainStateType tx)) => FromJSON (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods parseJSON :: Value -> Parser (StateChanged tx) parseJSONList :: Value -> Parser [StateChanged tx]
(IsTx tx, ToJSON (ChainStateType tx)) => ToJSON (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods toJSON :: StateChanged tx -> Value toEncoding :: StateChanged tx -> Encoding toJSONList :: [StateChanged tx] -> Value toEncodingList :: [StateChanged tx] -> Encoding
Generic (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Associated Types type Rep (StateChanged tx) :: Type -> Type Source # Methods from :: StateChanged tx -> Rep (StateChanged tx) x Source # to :: Rep (StateChanged tx) x -> StateChanged tx Source #
(IsTx tx, Show (HeadState tx), Show (ChainStateType tx)) => Show (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods showsPrec :: Int -> StateChanged tx -> ShowS Source # show :: StateChanged tx -> String Source # showList :: [StateChanged tx] -> ShowS Source #
(IsTx tx, Eq (HeadState tx), Eq (ChainStateType tx)) => Eq (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods (==) :: StateChanged tx -> StateChanged tx -> Bool Source # (/=) :: StateChanged tx -> StateChanged tx -> Bool Source #
type Rep (StateChanged tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome type Rep (StateChanged tx) = D1 ('MetaData "StateChanged" "Hydra.HeadLogic.Outcome" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (((C1 ('MetaCons "HeadInitialized" 'PrefixI 'True) (S1 ('MetaSel ('Just "parameters") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadParameters) :: (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)) :: S1 ('MetaSel ('Just "headId") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 HeadId))) :+: (C1 ('MetaCons "CommittedUTxO" 'PrefixI 'True) (S1 ('MetaSel ('Just "party") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Party) :: (S1 ('MetaSel ('Just "committedUTxO") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (UTxOType tx)) :: S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)))) :+: C1 ('MetaCons "HeadAborted" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx))))) :+: ((C1 ('MetaCons "HeadOpened" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)) :: S1 ('MetaSel ('Just "initialUTxO") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (UTxOType tx))) :+: C1 ('MetaCons "TransactionAppliedToLocalUTxO" 'PrefixI 'True) (S1 ('MetaSel ('Just "tx") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 tx) :: S1 ('MetaSel ('Just "newLocalUTxO") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (UTxOType tx)))) :+: (C1 ('MetaCons "SnapshotRequestDecided" 'PrefixI 'True) (S1 ('MetaSel ('Just "snapshotNumber") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 SnapshotNumber)) :+: C1 ('MetaCons "SnapshotRequested" 'PrefixI 'True) ((S1 ('MetaSel ('Just "snapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Snapshot tx)) :: S1 ('MetaSel ('Just "requestedTxIds") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [TxIdType tx])) :: (S1 ('MetaSel ('Just "newLocalUTxO") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (UTxOType tx)) :: S1 ('MetaSel ('Just "newLocalTxs") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 [tx])))))) :+: (((C1 ('MetaCons "TransactionReceived" 'PrefixI 'True) (S1 ('MetaSel ('Just "tx") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 tx)) :+: C1 ('MetaCons "PartySignedSnapshot" 'PrefixI 'True) (S1 ('MetaSel ('Just "snapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Snapshot tx)) :: (S1 ('MetaSel ('Just "party") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Party) :: S1 ('MetaSel ('Just "signature") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Signature (Snapshot tx)))))) :+: (C1 ('MetaCons "SnapshotConfirmed" 'PrefixI 'True) (S1 ('MetaSel ('Just "snapshot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Snapshot tx)) :: S1 ('MetaSel ('Just "signatures") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (MultiSignature (Snapshot tx)))) :+: C1 ('MetaCons "HeadClosed" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)) :*: S1 ('MetaSel ('Just "contestationDeadline") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UTCTime)))) :+: ((C1 ('MetaCons "HeadIsReadyToFanout" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "HeadFannedOut" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx)))) :+: (C1 ('MetaCons "ChainRolledBack" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainState") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ChainStateType tx))) :+: C1 ('MetaCons "TickObserved" 'PrefixI 'True) (S1 ('MetaSel ('Just "chainSlot") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 ChainSlot))))))

data Effect tx Source #

Analogous to events, the pure head logic "core" can have effects emited to the "shell" layers and we distinguish the same: effects onto the client, the network and the chain.

Constructors

ClientEffect	Effect to be handled by the Hydra.API, results in sending this `ServerOutput`.
Fields serverOutput :: ServerOutput tx
NetworkEffect	Effect to be handled by a Hydra.Network, results in a `broadcast`.
Fields message :: Message tx
OnChainEffect	Effect to be handled by a Hydra.Chain, results in a `postTx`.
Fields postChainTx :: PostChainTx tx

Instances

Instances details

(IsTx tx, Arbitrary (ChainStateType tx)) => Arbitrary (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods arbitrary :: Gen (Effect tx) shrink :: Effect tx -> [Effect tx]
IsChainState tx => FromJSON (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods parseJSON :: Value -> Parser (Effect tx) parseJSONList :: Value -> Parser [Effect tx]
IsChainState tx => ToJSON (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods toJSON :: Effect tx -> Value toEncoding :: Effect tx -> Encoding toJSONList :: [Effect tx] -> Value toEncodingList :: [Effect tx] -> Encoding
Generic (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Associated Types type Rep (Effect tx) :: Type -> Type Source # Methods from :: Effect tx -> Rep (Effect tx) x Source # to :: Rep (Effect tx) x -> Effect tx Source #
IsChainState tx => Show (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods showsPrec :: Int -> Effect tx -> ShowS Source # show :: Effect tx -> String Source # showList :: [Effect tx] -> ShowS Source #
IsChainState tx => Eq (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome Methods (==) :: Effect tx -> Effect tx -> Bool Source # (/=) :: Effect tx -> Effect tx -> Bool Source #
type Rep (Effect tx) Source #
Instance details Defined in Hydra.HeadLogic.Outcome type Rep (Effect tx) = D1 ('MetaData "Effect" "Hydra.HeadLogic.Outcome" "hydra-node-0.13.0-HKlbaPrFKjs2dhEMwn7ono" 'False) (C1 ('MetaCons "ClientEffect" 'PrefixI 'True) (S1 ('MetaSel ('Just "serverOutput") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (ServerOutput tx))) :+: (C1 ('MetaCons "NetworkEffect" 'PrefixI 'True) (S1 ('MetaSel ('Just "message") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Message tx))) :+: C1 ('MetaCons "OnChainEffect" 'PrefixI 'True) (S1 ('MetaSel ('Just "postChainTx") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (PostChainTx tx)))))

collectEffects :: Outcome tx -> [Effect tx] Source #

collectWaits :: Outcome tx -> [WaitReason tx] Source #

isLeader :: HeadParameters -> Party -> SnapshotNumber -> Bool Source #