akovalenko/lnd.xprv
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

cnct/contract_resolvers: reliably publish htlc success sweep

Browse Source
This commit is contained in:
Conner Fromknecht 2018-09-18 00:34:16 -07:00
parent b7aebd92cf
commit 682c4c96c7
No known key found for this signature in database
GPG Key ID: E7D737B67FA592C7
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
contractcourt/contract_resolvers.go
View File

@ -481,22 +481,22 @@ func (h *htlcSuccessResolver) Resolve() (ContractResolver, error) {
log.Infof("%T(%x): crafted sweep tx=%v", h, log.Infof("%T(%x): crafted sweep tx=%v", h,
h.payHash[:], spew.Sdump(h.sweepTx)) h.payHash[:], spew.Sdump(h.sweepTx))
// With the sweep transaction confirmed, we'll now // With the sweep transaction signed, we'll now
// Checkpoint our state. // Checkpoint our state.
if err := h.Checkpoint(h); err != nil { if err := h.Checkpoint(h); err != nil {
log.Errorf("unable to Checkpoint: %v", err) log.Errorf("unable to Checkpoint: %v", err)
} }
}
// Finally, we'll broadcast the sweep transaction to // Regardless of whether an existing transaction was found or newly
// the network. // constructed, we'll broadcast the sweep transaction to the
// // network.
// TODO(roasbeef): validate first? err := h.PublishTx(h.sweepTx)
if err := h.PublishTx(h.sweepTx); err != nil { if err != nil && err != lnwallet.ErrDoubleSpend {
log.Infof("%T(%x): unable to publish tx: %v", log.Infof("%T(%x): unable to publish tx: %v",
h, h.payHash[:], err) h, h.payHash[:], err)
return nil, err return nil, err
} }
}
// With the sweep transaction broadcast, we'll wait for its // With the sweep transaction broadcast, we'll wait for its
// confirmation. // confirmation.