Skip to content

Commit 89d48f9

Browse files
committed
handle recover tx at node-level
1 parent 0b2f6f0 commit 89d48f9

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

hydra-node/src/Hydra/HeadLogic.hs

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1389,11 +1389,6 @@ update env ledger NodeState{headState = st, pendingDeposits, currentSlot} ev = c
13891389
-- should compose event handling better.
13901390
newState TickObserved{chainSlot}
13911391
<> onOpenChainTick env pendingDeposits openState chainTime
1392-
(Open OpenState{headId = ourHeadId}, ChainInput Observation{observedTx = OnRecoverTx{headId, recoveredTxId, recoveredUTxO}, newChainState})
1393-
| ourHeadId == headId ->
1394-
newState DepositRecovered{chainState = newChainState, headId, depositTxId = recoveredTxId, recovered = recoveredUTxO}
1395-
| otherwise ->
1396-
Error NotOurHead{ourHeadId, otherHeadId = headId}
13971392
(Open openState@OpenState{headId = ourHeadId}, ChainInput Observation{observedTx = OnIncrementTx{headId, newVersion, depositTxId}, newChainState})
13981393
| ourHeadId == headId ->
13991394
onOpenChainIncrementTx openState newChainState newVersion depositTxId
@@ -1425,6 +1420,8 @@ update env ledger NodeState{headState = st, pendingDeposits, currentSlot} ev = c
14251420
-- Node-level
14261421
(_, ClientInput Recover{recoverTxId}) -> do
14271422
onClientRecover currentSlot pendingDeposits recoverTxId
1423+
(_, ChainInput Observation{observedTx = OnRecoverTx{headId, recoveredTxId, recoveredUTxO}, newChainState}) ->
1424+
newState DepositRecovered{chainState = newChainState, headId, depositTxId = recoveredTxId, recovered = recoveredUTxO}
14281425
-- General
14291426
(_, ChainInput Rollback{rolledBackChainState}) ->
14301427
newState ChainRolledBack{chainState = rolledBackChainState}

0 commit comments

Comments
 (0)