15736109134

Committed 18 Jun 2025 02:46PM UTC coverage: 58.197% (-10.1%) from 68.248%

Build # 15736109134

Build Type

Pull #9752

github

Committed by

web-flow

Commit Message

Merge d2634a68c into 31c74f20f

Pull Request Pull Request #9752: routerrpc: reject payment to invoice that don't have payment secret or blinded paths

Run Details

6 of 13 new or added lines in 2 files covered. (46.15%)

28331 existing lines in 455 files now uncovered.

97860 of 168153 relevant lines covered (58.2%)

1.81 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

81.99

/invoices/invoice_expiry_watcher.go

package invoices

import (
        "errors"
        "fmt"
        "sync"
        "time"

        "github.com/btcsuite/btcd/chaincfg/chainhash"
        "github.com/lightningnetwork/lnd/chainntnfs"
        "github.com/lightningnetwork/lnd/clock"
        "github.com/lightningnetwork/lnd/lntypes"
        "github.com/lightningnetwork/lnd/queue"
        "github.com/lightningnetwork/lnd/zpay32"
)

// invoiceExpiry is a vanity interface for different invoice expiry types
// which implement the priority queue item interface, used to improve code
// readability.
type invoiceExpiry queue.PriorityQueueItem

// Compile time assertion that invoiceExpiryTs implements invoiceExpiry.
var _ invoiceExpiry = (*invoiceExpiryTs)(nil)

// invoiceExpiryTs holds and invoice's payment hash and its expiry. This
// is used to order invoices by their expiry time for cancellation.
type invoiceExpiryTs struct {
        PaymentHash lntypes.Hash
        Expiry      time.Time
        Keysend     bool
}

// Less implements PriorityQueueItem.Less such that the top item in the
// priority queue will be the one that expires next.
func (e invoiceExpiryTs) Less(other queue.PriorityQueueItem) bool {
        return e.Expiry.Before(other.(*invoiceExpiryTs).Expiry)
}

// Compile time assertion that invoiceExpiryHeight implements invoiceExpiry.
var _ invoiceExpiry = (*invoiceExpiryHeight)(nil)

// invoiceExpiryHeight holds information about an invoice which can be used to
// cancel it based on its expiry height.
type invoiceExpiryHeight struct {
        paymentHash  lntypes.Hash
        expiryHeight uint32
}

// Less implements PriorityQueueItem.Less such that the top item in the
// priority queue is the lowest block height.
func (b invoiceExpiryHeight) Less(other queue.PriorityQueueItem) bool {
        return b.expiryHeight < other.(*invoiceExpiryHeight).expiryHeight
}

// expired returns a boolean that indicates whether this entry has expired,
// taking our expiry delta into account.
func (b invoiceExpiryHeight) expired(currentHeight, delta uint32) bool {
        return currentHeight+delta >= b.expiryHeight
}

// InvoiceExpiryWatcher handles automatic invoice cancellation of expired
// invoices. Upon start InvoiceExpiryWatcher will retrieve all pending (not yet
// settled or canceled) invoices invoices to its watching queue. When a new
// invoice is added to the InvoiceRegistry, it'll be forwarded to the
// InvoiceExpiryWatcher and will end up in the watching queue as well.
// If any of the watched invoices expire, they'll be removed from the watching
// queue and will be cancelled through InvoiceRegistry.CancelInvoice().
type InvoiceExpiryWatcher struct {
        sync.Mutex
        started bool

        // clock is the clock implementation that InvoiceExpiryWatcher uses.
        // It is useful for testing.
        clock clock.Clock

        // notifier provides us with block height updates.
        notifier chainntnfs.ChainNotifier

        // blockExpiryDelta is the number of blocks before a htlc's expiry that
        // we expire the invoice based on expiry height. We use a delta because
        // we will go to some delta before our expiry, so we want to cancel
        // before this to prevent force closes.
        blockExpiryDelta uint32

        // currentHeight is the current block height.
        currentHeight uint32

        // currentHash is the block hash for our current height.
        currentHash *chainhash.Hash

        // cancelInvoice is a template method that cancels an expired invoice.
        cancelInvoice func(lntypes.Hash, bool) error

        // timestampExpiryQueue holds invoiceExpiry items and is used to find
        // the next invoice to expire.
        timestampExpiryQueue queue.PriorityQueue

        // blockExpiryQueue holds blockExpiry items and is used to find the
        // next invoice to expire based on block height. Only hold invoices
        // with active htlcs are added to this queue, because they require
        // manual cancellation when the hltc is going to time out. Items in
        // this queue may already be in the timestampExpiryQueue, this is ok
        // because they will not be expired based on timestamp if they have
        // active htlcs.
        blockExpiryQueue queue.PriorityQueue

        // newInvoices channel is used to wake up the main loop when a new
        // invoices is added.
        newInvoices chan []invoiceExpiry

        wg sync.WaitGroup

        // quit signals InvoiceExpiryWatcher to stop.
        quit chan struct{}
}

// NewInvoiceExpiryWatcher creates a new InvoiceExpiryWatcher instance.
func NewInvoiceExpiryWatcher(clock clock.Clock,
        expiryDelta, startHeight uint32, startHash *chainhash.Hash,
        notifier chainntnfs.ChainNotifier) *InvoiceExpiryWatcher {

        return &InvoiceExpiryWatcher{
                clock:            clock,
                notifier:         notifier,
                blockExpiryDelta: expiryDelta,
                currentHeight:    startHeight,
                currentHash:      startHash,
                newInvoices:      make(chan []invoiceExpiry),
                quit:             make(chan struct{}),
        }
}

// Start starts the subscription handler and the main loop. Start() will
// return with error if InvoiceExpiryWatcher is already started. Start()
// expects a cancellation function passed that will be use to cancel expired
// invoices by their payment hash.
func (ew *InvoiceExpiryWatcher) Start(
        cancelInvoice func(lntypes.Hash, bool) error) error {

        ew.Lock()
        defer ew.Unlock()

        if ew.started {
                return fmt.Errorf("InvoiceExpiryWatcher already started")
        }

        ew.started = true
        ew.cancelInvoice = cancelInvoice

        ntfn, err := ew.notifier.RegisterBlockEpochNtfn(&chainntnfs.BlockEpoch{
                Height: int32(ew.currentHeight),
                Hash:   ew.currentHash,
        })
        if err != nil {
                return err
        }

        ew.wg.Add(1)
        go ew.mainLoop(ntfn)

        return nil
}

// Stop quits the expiry handler loop and waits for InvoiceExpiryWatcher to
// fully stop.
func (ew *InvoiceExpiryWatcher) Stop() {
        ew.Lock()
        defer ew.Unlock()

        if ew.started {
                // Signal subscriptionHandler to quit and wait for it to return.
                close(ew.quit)
                ew.wg.Wait()
                ew.started = false
        }
}

// makeInvoiceExpiry checks if the passed invoice may be canceled and calculates
// the expiry time and creates a slimmer invoiceExpiry implementation.
func makeInvoiceExpiry(paymentHash lntypes.Hash,
        invoice *Invoice) invoiceExpiry {

        switch invoice.State {
        // If we have an open invoice with no htlcs, we want to expire the
        // invoice based on timestamp
        case ContractOpen:
                return makeTimestampExpiry(paymentHash, invoice)

        // If an invoice has active htlcs, we want to expire it based on block
        // height. We only do this for hodl invoices, since regular invoices
        // should resolve themselves automatically.
        case ContractAccepted:
                if !invoice.HodlInvoice {
                        log.Debugf("Invoice in accepted state not added to "+
                                "expiry watcher: %v", paymentHash)

                        return nil
                }

                var minHeight uint32
                for _, htlc := range invoice.Htlcs {
                        // We only care about accepted htlcs, since they will
                        // trigger force-closes.
                        if htlc.State != HtlcStateAccepted {
                                continue
                        }

                        if minHeight == 0 || htlc.Expiry < minHeight {
                                minHeight = htlc.Expiry
                        }
                }

                return makeHeightExpiry(paymentHash, minHeight)

        default:
                log.Debugf("Invoice not added to expiry watcher: %v",
                        paymentHash)

                return nil
        }
}

// makeTimestampExpiry creates a timestamp-based expiry entry.
func makeTimestampExpiry(paymentHash lntypes.Hash,
        invoice *Invoice) *invoiceExpiryTs {

        if invoice.State != ContractOpen {
                return nil
        }

        realExpiry := invoice.Terms.Expiry
        if realExpiry == 0 {
                realExpiry = zpay32.DefaultInvoiceExpiry
        }

        expiry := invoice.CreationDate.Add(realExpiry)
        return &invoiceExpiryTs{
                PaymentHash: paymentHash,
                Expiry:      expiry,
                Keysend:     len(invoice.PaymentRequest) == 0,
        }
}

// makeHeightExpiry creates height-based expiry for an invoice based on its
// lowest htlc expiry height.
func makeHeightExpiry(paymentHash lntypes.Hash,
        minHeight uint32) *invoiceExpiryHeight {

        if minHeight == 0 {
                log.Warnf("make height expiry called with 0 height")
                return nil
        }

        return &invoiceExpiryHeight{
                paymentHash:  paymentHash,
                expiryHeight: minHeight,
        }
}

// AddInvoices adds invoices to the InvoiceExpiryWatcher.
func (ew *InvoiceExpiryWatcher) AddInvoices(invoices ...invoiceExpiry) {
        if len(invoices) == 0 {
                return
        }

        select {
        case ew.newInvoices <- invoices:
                log.Debugf("Added %d invoices to the expiry watcher",
                        len(invoices))

        // Select on quit too so that callers won't get blocked in case
        // of concurrent shutdown.
        case <-ew.quit:
        }
}

// nextTimestampExpiry returns a Time chan to wait on until the next invoice
// expires. If there are no active invoices, then it'll simply wait
// indefinitely.
func (ew *InvoiceExpiryWatcher) nextTimestampExpiry() <-chan time.Time {
        if !ew.timestampExpiryQueue.Empty() {
                top := ew.timestampExpiryQueue.Top().(*invoiceExpiryTs)
                return ew.clock.TickAfter(top.Expiry.Sub(ew.clock.Now()))
        }

        return nil
}

// nextHeightExpiry returns a channel that will immediately be read from if
// the top item on our queue has expired.
func (ew *InvoiceExpiryWatcher) nextHeightExpiry() <-chan uint32 {
        if ew.blockExpiryQueue.Empty() {
                return nil
        }

        top := ew.blockExpiryQueue.Top().(*invoiceExpiryHeight)
        if !top.expired(ew.currentHeight, ew.blockExpiryDelta) {
                return nil
        }

        blockChan := make(chan uint32, 1)
        blockChan <- top.expiryHeight
        return blockChan
}

// cancelNextExpiredInvoice will cancel the next expired invoice and removes
// it from the expiry queue.
func (ew *InvoiceExpiryWatcher) cancelNextExpiredInvoice() {
        if !ew.timestampExpiryQueue.Empty() {
                top := ew.timestampExpiryQueue.Top().(*invoiceExpiryTs)
                if !top.Expiry.Before(ew.clock.Now()) {
                        return
                }

                // Don't force-cancel already accepted invoices. An exception to
                // this are auto-generated keysend invoices. Because those move
                // to the Accepted state directly after being opened, the expiry
                // field would never be used. Enabling cancellation for accepted
                // keysend invoices creates a safety mechanism that can prevents
                // channel force-closes.
                ew.expireInvoice(top.PaymentHash, top.Keysend)
                ew.timestampExpiryQueue.Pop()
        }
}

// cancelNextHeightExpiredInvoice looks at our height based queue and expires
// the next invoice if we have reached its expiry block.
func (ew *InvoiceExpiryWatcher) cancelNextHeightExpiredInvoice() {
        if ew.blockExpiryQueue.Empty() {
                return
        }

        top := ew.blockExpiryQueue.Top().(*invoiceExpiryHeight)
        if !top.expired(ew.currentHeight, ew.blockExpiryDelta) {
                return
        }

        // We always force-cancel block-based expiry so that we can
        // cancel invoices that have been accepted but not yet resolved.
        // This helps us avoid force closes.
        ew.expireInvoice(top.paymentHash, true)
        ew.blockExpiryQueue.Pop()
}

// expireInvoice attempts to expire an invoice and logs an error if we get an
// unexpected error.
func (ew *InvoiceExpiryWatcher) expireInvoice(hash lntypes.Hash, force bool) {
        err := ew.cancelInvoice(hash, force)
        switch {
        case err == nil:

        case errors.Is(err, ErrInvoiceAlreadyCanceled):

        case errors.Is(err, ErrInvoiceAlreadySettled):

        case errors.Is(err, ErrInvoiceNotFound):
                // It's possible that the user has manually canceled the invoice
                // which will then be deleted by the garbage collector resulting
                // in an ErrInvoiceNotFound error.

        default:
                log.Errorf("Unable to cancel invoice: %v: %v", hash, err)
        }
}

// pushInvoices adds invoices to be expired to their relevant queue.
func (ew *InvoiceExpiryWatcher) pushInvoices(invoices []invoiceExpiry) {
        for _, inv := range invoices {
                // Switch on the type of entry we have. We need to check nil
                // on the implementation of the interface because the interface
                // itself is non-nil.
                switch expiry := inv.(type) {
                case *invoiceExpiryTs:
                        if expiry != nil {
                                ew.timestampExpiryQueue.Push(expiry)
                        }

                case *invoiceExpiryHeight:
                        if expiry != nil {
                                ew.blockExpiryQueue.Push(expiry)
                        }

                default:
                        log.Errorf("unexpected queue item: %T", inv)
                }
        }
}

// mainLoop is a goroutine that receives new invoices and handles cancellation
// of expired invoices.
func (ew *InvoiceExpiryWatcher) mainLoop(blockNtfns *chainntnfs.BlockEpochEvent) {
        defer func() {
                blockNtfns.Cancel()
                ew.wg.Done()
        }()

        // We have two different queues, so we use a different cancel method
        // depending on which expiry condition we have hit. Starting with time
        // based expiry is an arbitrary choice to start off.
        cancelNext := ew.cancelNextExpiredInvoice

        for {
                // Cancel any invoices that may have expired.
                cancelNext()

                select {
                case newInvoices := <-ew.newInvoices:
                        // Take newly forwarded invoices with higher priority
                        // in order to not block the newInvoices channel.
                        ew.pushInvoices(newInvoices)
                        continue

                default:
                        select {
                        // Wait until the next invoice expires.
                        case <-ew.nextTimestampExpiry():
                                cancelNext = ew.cancelNextExpiredInvoice
                                continue

                        case <-ew.nextHeightExpiry():
                                cancelNext = ew.cancelNextHeightExpiredInvoice
                                continue

                        case newInvoices := <-ew.newInvoices:
                                ew.pushInvoices(newInvoices)

                        // Consume new blocks.
                        case block, ok := <-blockNtfns.Epochs:
                                if !ok {
                                        log.Debugf("block notifications " +
                                                "canceled")
                                        return
                                }

                                ew.currentHeight = uint32(block.Height)
                                ew.currentHash = block.Hash

                        case <-ew.quit:
                                return
                        }
                }
        }
}

1	package invoices
2
3	import (
4	"errors"
5	"fmt"
6	"sync"
7	"time"
8
9	"github.com/btcsuite/btcd/chaincfg/chainhash"
10	"github.com/lightningnetwork/lnd/chainntnfs"
11	"github.com/lightningnetwork/lnd/clock"
12	"github.com/lightningnetwork/lnd/lntypes"
13	"github.com/lightningnetwork/lnd/queue"
14	"github.com/lightningnetwork/lnd/zpay32"
15	)
16
17	// invoiceExpiry is a vanity interface for different invoice expiry types
18	// which implement the priority queue item interface, used to improve code
19	// readability.
20	type invoiceExpiry queue.PriorityQueueItem
21
22	// Compile time assertion that invoiceExpiryTs implements invoiceExpiry.
23	var _ invoiceExpiry = (*invoiceExpiryTs)(nil)
24
25	// invoiceExpiryTs holds and invoice's payment hash and its expiry. This
26	// is used to order invoices by their expiry time for cancellation.
27	type invoiceExpiryTs struct {
28	PaymentHash lntypes.Hash
29	Expiry time.Time
30	Keysend bool
31	}
32
33	// Less implements PriorityQueueItem.Less such that the top item in the
34	// priority queue will be the one that expires next.
35	func (e invoiceExpiryTs) Less(other queue.PriorityQueueItem) bool {	3✔
36	return e.Expiry.Before(other.(*invoiceExpiryTs).Expiry)	3✔
37	}	3✔
38
39	// Compile time assertion that invoiceExpiryHeight implements invoiceExpiry.
40	var _ invoiceExpiry = (*invoiceExpiryHeight)(nil)
41
42	// invoiceExpiryHeight holds information about an invoice which can be used to
43	// cancel it based on its expiry height.
44	type invoiceExpiryHeight struct {
45	paymentHash lntypes.Hash
46	expiryHeight uint32
47	}
48
49	// Less implements PriorityQueueItem.Less such that the top item in the
50	// priority queue is the lowest block height.
51	func (b invoiceExpiryHeight) Less(other queue.PriorityQueueItem) bool {	3✔
52	return b.expiryHeight < other.(*invoiceExpiryHeight).expiryHeight	3✔
53	}	3✔
54
55	// expired returns a boolean that indicates whether this entry has expired,
56	// taking our expiry delta into account.
57	func (b invoiceExpiryHeight) expired(currentHeight, delta uint32) bool {	3✔
58	return currentHeight+delta >= b.expiryHeight	3✔
59	}	3✔
60
61	// InvoiceExpiryWatcher handles automatic invoice cancellation of expired
62	// invoices. Upon start InvoiceExpiryWatcher will retrieve all pending (not yet
63	// settled or canceled) invoices invoices to its watching queue. When a new
64	// invoice is added to the InvoiceRegistry, it'll be forwarded to the
65	// InvoiceExpiryWatcher and will end up in the watching queue as well.
66	// If any of the watched invoices expire, they'll be removed from the watching
67	// queue and will be cancelled through InvoiceRegistry.CancelInvoice().
68	type InvoiceExpiryWatcher struct {
69	sync.Mutex
70	started bool
71
72	// clock is the clock implementation that InvoiceExpiryWatcher uses.
73	// It is useful for testing.
74	clock clock.Clock
75
76	// notifier provides us with block height updates.
77	notifier chainntnfs.ChainNotifier
78
79	// blockExpiryDelta is the number of blocks before a htlc's expiry that
80	// we expire the invoice based on expiry height. We use a delta because
81	// we will go to some delta before our expiry, so we want to cancel
82	// before this to prevent force closes.
83	blockExpiryDelta uint32
84
85	// currentHeight is the current block height.
86	currentHeight uint32
87
88	// currentHash is the block hash for our current height.
89	currentHash *chainhash.Hash
90
91	// cancelInvoice is a template method that cancels an expired invoice.
92	cancelInvoice func(lntypes.Hash, bool) error
93
94	// timestampExpiryQueue holds invoiceExpiry items and is used to find
95	// the next invoice to expire.
96	timestampExpiryQueue queue.PriorityQueue
97
98	// blockExpiryQueue holds blockExpiry items and is used to find the
99	// next invoice to expire based on block height. Only hold invoices
100	// with active htlcs are added to this queue, because they require
101	// manual cancellation when the hltc is going to time out. Items in
102	// this queue may already be in the timestampExpiryQueue, this is ok
103	// because they will not be expired based on timestamp if they have
104	// active htlcs.
105	blockExpiryQueue queue.PriorityQueue
106
107	// newInvoices channel is used to wake up the main loop when a new
108	// invoices is added.
109	newInvoices chan []invoiceExpiry
110
111	wg sync.WaitGroup
112
113	// quit signals InvoiceExpiryWatcher to stop.
114	quit chan struct{}
115	}
116
117	// NewInvoiceExpiryWatcher creates a new InvoiceExpiryWatcher instance.
118	func NewInvoiceExpiryWatcher(clock clock.Clock,
119	expiryDelta, startHeight uint32, startHash *chainhash.Hash,
120	notifier chainntnfs.ChainNotifier) *InvoiceExpiryWatcher {	3✔
121		3✔
122	return &InvoiceExpiryWatcher{	3✔
123	clock: clock,	3✔
124	notifier: notifier,	3✔
125	blockExpiryDelta: expiryDelta,	3✔
126	currentHeight: startHeight,	3✔
127	currentHash: startHash,	3✔
128	newInvoices: make(chan []invoiceExpiry),	3✔
129	quit: make(chan struct{}),	3✔
130	}	3✔
131	}	3✔
132
133	// Start starts the subscription handler and the main loop. Start() will
134	// return with error if InvoiceExpiryWatcher is already started. Start()
135	// expects a cancellation function passed that will be use to cancel expired
136	// invoices by their payment hash.
137	func (ew *InvoiceExpiryWatcher) Start(
138	cancelInvoice func(lntypes.Hash, bool) error) error {	3✔
139		3✔
140	ew.Lock()	3✔
141	defer ew.Unlock()	3✔
142		3✔
143	if ew.started {	3✔
UNCOV 144	return fmt.Errorf("InvoiceExpiryWatcher already started")	×
UNCOV 145	}	×
146
147	ew.started = true	3✔
148	ew.cancelInvoice = cancelInvoice	3✔
149		3✔
150	ntfn, err := ew.notifier.RegisterBlockEpochNtfn(&chainntnfs.BlockEpoch{	3✔
151	Height: int32(ew.currentHeight),	3✔
152	Hash: ew.currentHash,	3✔
153	})	3✔
154	if err != nil {	3✔
155	return err	×
156	}	×
157
158	ew.wg.Add(1)	3✔
159	go ew.mainLoop(ntfn)	3✔
160		3✔
161	return nil	3✔
162	}
163
164	// Stop quits the expiry handler loop and waits for InvoiceExpiryWatcher to
165	// fully stop.
166	func (ew *InvoiceExpiryWatcher) Stop() {	3✔
167	ew.Lock()	3✔
168	defer ew.Unlock()	3✔
169		3✔
170	if ew.started {	6✔
171	// Signal subscriptionHandler to quit and wait for it to return.	3✔
172	close(ew.quit)	3✔
173	ew.wg.Wait()	3✔
174	ew.started = false	3✔
175	}	3✔
176	}
177
178	// makeInvoiceExpiry checks if the passed invoice may be canceled and calculates
179	// the expiry time and creates a slimmer invoiceExpiry implementation.
180	func makeInvoiceExpiry(paymentHash lntypes.Hash,
181	invoice *Invoice) invoiceExpiry {	3✔
182		3✔
183	switch invoice.State {	3✔
184	// If we have an open invoice with no htlcs, we want to expire the
185	// invoice based on timestamp
186	case ContractOpen:	3✔
187	return makeTimestampExpiry(paymentHash, invoice)	3✔
188
189	// If an invoice has active htlcs, we want to expire it based on block
190	// height. We only do this for hodl invoices, since regular invoices
191	// should resolve themselves automatically.
192	case ContractAccepted:	3✔
193	if !invoice.HodlInvoice {	3✔
194	log.Debugf("Invoice in accepted state not added to "+	×
195	"expiry watcher: %v", paymentHash)	×
196		×
197	return nil	×
198	}	×
199
200	var minHeight uint32	3✔
201	for _, htlc := range invoice.Htlcs {	6✔
202	// We only care about accepted htlcs, since they will	3✔
203	// trigger force-closes.	3✔
204	if htlc.State != HtlcStateAccepted {	3✔
UNCOV 205	continue	×
206	}
207
208	if minHeight == 0 \|\| htlc.Expiry < minHeight {	6✔
209	minHeight = htlc.Expiry	3✔
210	}	3✔
211	}
212
213	return makeHeightExpiry(paymentHash, minHeight)	3✔
214
215	default:	×
216	log.Debugf("Invoice not added to expiry watcher: %v",	×
217	paymentHash)	×
218		×
219	return nil	×
220	}
221	}
222
223	// makeTimestampExpiry creates a timestamp-based expiry entry.
224	func makeTimestampExpiry(paymentHash lntypes.Hash,
225	invoice Invoice) invoiceExpiryTs {	3✔
226		3✔
227	if invoice.State != ContractOpen {	3✔
228	return nil	×
229	}	×
230
231	realExpiry := invoice.Terms.Expiry	3✔
232	if realExpiry == 0 {	6✔
233	realExpiry = zpay32.DefaultInvoiceExpiry	3✔
234	}	3✔
235
236	expiry := invoice.CreationDate.Add(realExpiry)	3✔
237	return &invoiceExpiryTs{	3✔
238	PaymentHash: paymentHash,	3✔
239	Expiry: expiry,	3✔
240	Keysend: len(invoice.PaymentRequest) == 0,	3✔
241	}	3✔
242	}
243
244	// makeHeightExpiry creates height-based expiry for an invoice based on its
245	// lowest htlc expiry height.
246	func makeHeightExpiry(paymentHash lntypes.Hash,
247	minHeight uint32) *invoiceExpiryHeight {	3✔
248		3✔
249	if minHeight == 0 {	3✔
UNCOV 250	log.Warnf("make height expiry called with 0 height")	×
UNCOV 251	return nil	×
UNCOV 252	}	×
253
254	return &invoiceExpiryHeight{	3✔
255	paymentHash: paymentHash,	3✔
256	expiryHeight: minHeight,	3✔
257	}	3✔
258	}
259
260	// AddInvoices adds invoices to the InvoiceExpiryWatcher.
261	func (ew *InvoiceExpiryWatcher) AddInvoices(invoices ...invoiceExpiry) {	3✔
262	if len(invoices) == 0 {	6✔
263	return	3✔
264	}	3✔
265
266	select {	3✔
267	case ew.newInvoices <- invoices:	3✔
268	log.Debugf("Added %d invoices to the expiry watcher",	3✔
269	len(invoices))	3✔
270
271	// Select on quit too so that callers won't get blocked in case
272	// of concurrent shutdown.
273	case <-ew.quit:	×
274	}
275	}
276
277	// nextTimestampExpiry returns a Time chan to wait on until the next invoice
278	// expires. If there are no active invoices, then it'll simply wait
279	// indefinitely.
280	func (ew *InvoiceExpiryWatcher) nextTimestampExpiry() <-chan time.Time {	3✔
281	if !ew.timestampExpiryQueue.Empty() {	6✔
282	top := ew.timestampExpiryQueue.Top().(*invoiceExpiryTs)	3✔
283	return ew.clock.TickAfter(top.Expiry.Sub(ew.clock.Now()))	3✔
284	}	3✔
285
286	return nil	3✔
287	}
288
289	// nextHeightExpiry returns a channel that will immediately be read from if
290	// the top item on our queue has expired.
291	func (ew *InvoiceExpiryWatcher) nextHeightExpiry() <-chan uint32 {	3✔
292	if ew.blockExpiryQueue.Empty() {	6✔
293	return nil	3✔
294	}	3✔
295
296	top := ew.blockExpiryQueue.Top().(*invoiceExpiryHeight)	3✔
297	if !top.expired(ew.currentHeight, ew.blockExpiryDelta) {	6✔
298	return nil	3✔
299	}	3✔
300
301	blockChan := make(chan uint32, 1)	3✔
302	blockChan <- top.expiryHeight	3✔
303	return blockChan	3✔
304	}
305
306	// cancelNextExpiredInvoice will cancel the next expired invoice and removes
307	// it from the expiry queue.
308	func (ew *InvoiceExpiryWatcher) cancelNextExpiredInvoice() {	3✔
309	if !ew.timestampExpiryQueue.Empty() {	6✔
310	top := ew.timestampExpiryQueue.Top().(*invoiceExpiryTs)	3✔
311	if !top.Expiry.Before(ew.clock.Now()) {	6✔
312	return	3✔
313	}	3✔
314
315	// Don't force-cancel already accepted invoices. An exception to
316	// this are auto-generated keysend invoices. Because those move
317	// to the Accepted state directly after being opened, the expiry
318	// field would never be used. Enabling cancellation for accepted
319	// keysend invoices creates a safety mechanism that can prevents
320	// channel force-closes.
UNCOV 321	ew.expireInvoice(top.PaymentHash, top.Keysend)	×
UNCOV 322	ew.timestampExpiryQueue.Pop()	×
323	}
324	}
325
326	// cancelNextHeightExpiredInvoice looks at our height based queue and expires
327	// the next invoice if we have reached its expiry block.
328	func (ew *InvoiceExpiryWatcher) cancelNextHeightExpiredInvoice() {	3✔
329	if ew.blockExpiryQueue.Empty() {	6✔
330	return	3✔
331	}	3✔
332
333	top := ew.blockExpiryQueue.Top().(*invoiceExpiryHeight)	3✔
334	if !top.expired(ew.currentHeight, ew.blockExpiryDelta) {	3✔
335	return	×
336	}	×
337
338	// We always force-cancel block-based expiry so that we can
339	// cancel invoices that have been accepted but not yet resolved.
340	// This helps us avoid force closes.
341	ew.expireInvoice(top.paymentHash, true)	3✔
342	ew.blockExpiryQueue.Pop()	3✔
343	}
344
345	// expireInvoice attempts to expire an invoice and logs an error if we get an
346	// unexpected error.
347	func (ew *InvoiceExpiryWatcher) expireInvoice(hash lntypes.Hash, force bool) {	3✔
348	err := ew.cancelInvoice(hash, force)	3✔
349	switch {	3✔
350	case err == nil:	3✔
351
352	case errors.Is(err, ErrInvoiceAlreadyCanceled):	×
353
354	case errors.Is(err, ErrInvoiceAlreadySettled):	3✔
355
356	case errors.Is(err, ErrInvoiceNotFound):	×
357	// It's possible that the user has manually canceled the invoice
358	// which will then be deleted by the garbage collector resulting
359	// in an ErrInvoiceNotFound error.
360
361	default:	×
362	log.Errorf("Unable to cancel invoice: %v: %v", hash, err)	×
363	}
364	}
365
366	// pushInvoices adds invoices to be expired to their relevant queue.
367	func (ew *InvoiceExpiryWatcher) pushInvoices(invoices []invoiceExpiry) {	3✔
368	for _, inv := range invoices {	6✔
369	// Switch on the type of entry we have. We need to check nil	3✔
370	// on the implementation of the interface because the interface	3✔
371	// itself is non-nil.	3✔
372	switch expiry := inv.(type) {	3✔
373	case *invoiceExpiryTs:	3✔
374	if expiry != nil {	6✔
375	ew.timestampExpiryQueue.Push(expiry)	3✔
376	}	3✔
377
378	case *invoiceExpiryHeight:	3✔
379	if expiry != nil {	6✔
380	ew.blockExpiryQueue.Push(expiry)	3✔
381	}	3✔
382
383	default:	×
384	log.Errorf("unexpected queue item: %T", inv)	×
385	}
386	}
387	}
388
389	// mainLoop is a goroutine that receives new invoices and handles cancellation
390	// of expired invoices.
391	func (ew InvoiceExpiryWatcher) mainLoop(blockNtfns chainntnfs.BlockEpochEvent) {	3✔
392	defer func() {	6✔
393	blockNtfns.Cancel()	3✔
394	ew.wg.Done()	3✔
395	}()	3✔
396
397	// We have two different queues, so we use a different cancel method
398	// depending on which expiry condition we have hit. Starting with time
399	// based expiry is an arbitrary choice to start off.
400	cancelNext := ew.cancelNextExpiredInvoice	3✔
401		3✔
402	for {	6✔
403	// Cancel any invoices that may have expired.	3✔
404	cancelNext()	3✔
405		3✔
406	select {	3✔
407	case newInvoices := <-ew.newInvoices:	3✔
408	// Take newly forwarded invoices with higher priority	3✔
409	// in order to not block the newInvoices channel.	3✔
410	ew.pushInvoices(newInvoices)	3✔
411	continue	3✔
412
413	default:	3✔
414	select {	3✔
415	// Wait until the next invoice expires.
UNCOV 416	case <-ew.nextTimestampExpiry():	×
UNCOV 417	cancelNext = ew.cancelNextExpiredInvoice	×
UNCOV 418	continue	×
419
420	case <-ew.nextHeightExpiry():	3✔
421	cancelNext = ew.cancelNextHeightExpiredInvoice	3✔
422	continue	3✔
423
424	case newInvoices := <-ew.newInvoices:	3✔
425	ew.pushInvoices(newInvoices)	3✔
426
427	// Consume new blocks.
428	case block, ok := <-blockNtfns.Epochs:	3✔
429	if !ok {	3✔
430	log.Debugf("block notifications " +	×
431	"canceled")	×
432	return	×
433	}	×
434
435	ew.currentHeight = uint32(block.Height)	3✔
436	ew.currentHash = block.Hash	3✔
437
438	case <-ew.quit:	3✔
439	return	3✔
440	}
441	}
442	}
443	}

lightningnetwork / lnd / 15736109134

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous