diff --git a/contractcourt/chain_arbitrator.go b/contractcourt/chain_arbitrator.go index 3bfbafa1..db401735 100644 --- a/contractcourt/chain_arbitrator.go +++ b/contractcourt/chain_arbitrator.go @@ -105,7 +105,7 @@ type ChainArbitratorConfig struct { // absolute/relative item block. IncubateOutputs func(wire.OutPoint, *lnwallet.CommitOutputResolution, *lnwallet.OutgoingHtlcResolution, - *lnwallet.IncomingHtlcResolution) error + *lnwallet.IncomingHtlcResolution, uint32) error // PreimageDB is a global store of all known pre-images. We'll use this // to decide if we should broadcast a commitment transaction to claim diff --git a/contractcourt/channel_arbitrator.go b/contractcourt/channel_arbitrator.go index 55a6e238..ae3fe967 100644 --- a/contractcourt/channel_arbitrator.go +++ b/contractcourt/channel_arbitrator.go @@ -648,7 +648,7 @@ func (c *ChannelArbitrator) stateStep(triggerHeight uint32, err = c.cfg.IncubateOutputs( c.cfg.ChanPoint, commitRes, - nil, nil, + nil, nil, triggerHeight, ) if err != nil { // TODO(roasbeef): check for AlreadyExists errors diff --git a/contractcourt/contract_resolvers.go b/contractcourt/contract_resolvers.go index 7b8be486..3ecc6be9 100644 --- a/contractcourt/contract_resolvers.go +++ b/contractcourt/contract_resolvers.go @@ -152,7 +152,10 @@ func (h *htlcTimeoutResolver) Resolve() (ContractResolver, error) { log.Tracef("%T(%v): incubating htlc output", h, h.htlcResolution.ClaimOutpoint) - err := h.IncubateOutputs(h.ChanPoint, nil, &h.htlcResolution, nil) + err := h.IncubateOutputs( + h.ChanPoint, nil, &h.htlcResolution, nil, + h.broadcastHeight, + ) if err != nil { return nil, err } @@ -568,7 +571,10 @@ func (h *htlcSuccessResolver) Resolve() (ContractResolver, error) { log.Infof("%T(%x): incubating incoming htlc output", h, h.payHash[:]) - err := h.IncubateOutputs(h.ChanPoint, nil, nil, &h.htlcResolution) + err := h.IncubateOutputs( + h.ChanPoint, nil, nil, &h.htlcResolution, + h.broadcastHeight, + ) if err != nil { return nil, err } diff --git a/server.go b/server.go index 525d6d31..48ed123c 100644 --- a/server.go +++ b/server.go @@ -628,7 +628,8 @@ func newServer(listenAddrs []net.Addr, chanDB *channeldb.DB, cc *chainControl, IncubateOutputs: func(chanPoint wire.OutPoint, commitRes *lnwallet.CommitOutputResolution, outHtlcRes *lnwallet.OutgoingHtlcResolution, - inHtlcRes *lnwallet.IncomingHtlcResolution) error { + inHtlcRes *lnwallet.IncomingHtlcResolution, + broadcastHeight uint32) error { var ( inRes []lnwallet.IncomingHtlcResolution