highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-04-06 02:58:03 +02:00
Code Issues Packages Projects Releases Wiki Activity

contractcourt: move breach handling into its own function

Browse Source 
This commit refactors the breach handling logic into its own function
so that the related code can be unit tested.
This commit is contained in:
yyforyongyu 2022-04-06 20:20:31 +08:00
parent 9a4589d54e
commit 291a8e4eff
No known key found for this signature in database
GPG Key ID: 9BCD95C4FF296868
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
contractcourt/chain_watcher.go
View File

@ -729,7 +729,6 @@ func (c *chainWatcher) handleKnownRemoteState(
commitTxBroadcast := commitSpend.SpendingTx
commitHash := commitTxBroadcast.TxHash()
spendHeight := uint32(commitSpend.SpendingHeight)
switch {
// If the spending transaction matches the current latest state, then
@ -780,8 +779,19 @@ func (c *chainWatcher) handleKnownRemoteState(
return true, nil
}
// This is neither a remote force close or a "future" commitment, we
// now check whether it's a remote breach and properly handle it.
return c.handlePossibleBreach(commitSpend, broadcastStateNum, chainSet)
}
// handlePossibleBreach checks whether the remote has breached and dispatches a
// breach resolution to claim funds.
func (c *chainWatcher) handlePossibleBreach(commitSpend *chainntnfs.SpendDetail,
broadcastStateNum uint64, chainSet *chainSet) (bool, error) {
// We check if we have a revoked state at this state num that matches
// the spend transaction.
spendHeight := uint32(commitSpend.SpendingHeight)
retribution, err := lnwallet.NewBreachRetribution(
c.cfg.chanState, broadcastStateNum, spendHeight,
)
@ -801,6 +811,7 @@ func (c *chainWatcher) handleKnownRemoteState(
// We found a revoked state at this height, but it could still be our
// own broadcasted state we are looking at. Therefore check that the
// commit matches before assuming it was a breach.
commitHash := commitSpend.SpendingTx.TxHash()
if retribution.BreachTransaction.TxHash() != commitHash {
return false, nil
}