We change this to make it more robust to open heads. Now, all head participants would try to open a head with a collect, not only the last to commit. This is also how it is written in the spec right now.
-- __Transition__: 'InitialState' → 'InitialState'
onInitialChainCommitTx ::
Monoid (UTxOType tx) =>
Environment ->
InitialState tx ->
-- | New chain state
ChainStateType tx ->
-- | Committed UTxO
UTxOType tx ->
Outcome tx
onInitialChainCommitTx env st newChainState pt utxo =
onInitialChainCommitTx st newChainState pt utxo =
NewState newState $
notifyClient :
[postCollectCom | canCollectCom]
, postChainTx = CollectComTx $ fold newCommitted
}
canCollectCom = null remainingParties && pt == us
canCollectCom = null remainingParties
remainingParties = Set.delete pt pendingCommits
InitialState{parameters, pendingCommits, committed, headId} = st
Environment{party = us} = env
-- | Client request to abort the head. This leads to an abort transaction on
-- chain, reimbursing already committed UTxOs.
--
(Initial idleState, ClientEvent clientInput@(Commit _)) ->
onInitialClientCommit env idleState clientInput
(Initial initialState, OnChainEvent Observation{observedTx = OnCommitTx{party = pt, committed = utxo}, newChainState}) ->
onInitialChainCommitTx env initialState newChainState pt utxo
onInitialChainCommitTx initialState newChainState pt utxo
(Initial initialState, ClientEvent Abort) ->
onInitialClientAbort initialState
(Initial initialState, OnChainEvent Observation{observedTx = OnCollectComTx{}, newChainState}) ->
HeadParameters (..),
IsChainState,
OnChainTx (..),
PostChainTx (ContestTx),
PostChainTx (CollectComTx, ContestTx),
)
import Hydra.Crypto (aggregate, generateSigningKey, sign)
import Hydra.HeadLogic (
update bobEnv ledger (inOpenState threeParties ledger) (NetworkEvent defaultTTL $ Connected nodeId)
`hasEffect` ClientEffect (PeerConnected nodeId)
it "everyone does collect on last commit after collect com" $ do
let s0 = inInitialState threeParties
aliceCommit = OnCommitTx alice (utxoRef 1)
bobCommit = OnCommitTx bob (utxoRef 2)
carolCommit = OnCommitTx carol (utxoRef 3)
s1 <- assertNewState $ update bobEnv ledger s0 (observeEventAtSlot 1 aliceCommit)
s2 <- assertNewState $ update bobEnv ledger s1 (observeEventAtSlot 2 bobCommit)
-- Bob is not the last party, but still does post a collect
update bobEnv ledger s2 (observeEventAtSlot 3 carolCommit) `hasEffectSatisfying` \case
OnChainEffect{postChainTx = CollectComTx{}} -> True
_ -> False
it "cannot observe abort after collect com" $ do
let s0 = inInitialState threeParties
s1 <- assertNewState $ update bobEnv ledger s0 (observationEvent OnCollectComTx)
, chainState = SimpleChainState{slot = ChainSlot 0}
}
observeEventAtSlot :: Natural -> OnChainTx SimpleTx -> Event SimpleTx
observeEventAtSlot slot observedTx =
OnChainEvent
{ chainEvent =
Observation
{ observedTx
, newChainState = SimpleChainState{slot = ChainSlot slot}
}
}
-- | Create an observation event with fixed chain state and slot.
observationEvent :: OnChainTx SimpleTx -> Event SimpleTx
observationEvent observedTx =
Includes direct 1:1 wrappers for misc builders (#197) and tx_builder (#210)
Wrappers around custom-written code written earlier for the rust crate.
Previous work on the builders/etc updates rust but introduced things caused the WASM to no longer compile. This updates the WASM bindings as well. Includes genesis module that wasn't pushed before.
