12343072627

Committed 15 Dec 2024 11:09PM UTC coverage: 57.504% (-1.1%) from 58.636%

Build # 12343072627

Build Type

Pull #9315

github

Committed by

yyforyongyu

Commit Message

contractcourt: offer outgoing htlc one block earlier before its expiry

We need to offer the outgoing htlc one block earlier to make sure when
the expiry height hits, the sweeper will not miss sweeping it in the
same block. This also means the outgoing contest resolver now only does
one thing - watch for preimage spend till height expiry-1, which can
easily be moved into the timeout resolver instead in the future.

Pull Request Pull Request #9315: Implement `blockbeat`

Run Details

1445 of 2007 new or added lines in 26 files covered. (72.0%)

19246 existing lines in 249 files now uncovered.

102342 of 177975 relevant lines covered (57.5%)

24772.24 hits per line

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

0.0

/netann/node_announcement.go

package netann

import (
        "image/color"
        "net"
        "time"

        "github.com/lightningnetwork/lnd/keychain"
        "github.com/lightningnetwork/lnd/lnwallet"
        "github.com/lightningnetwork/lnd/lnwire"
)

// NodeAnnModifier is a closure that makes in-place modifications to an
// lnwire.NodeAnnouncement.
type NodeAnnModifier func(*lnwire.NodeAnnouncement)

// NodeAnnSetAlias is a functional option that sets the alias of the
// given node announcement.
func NodeAnnSetAlias(alias lnwire.NodeAlias) func(*lnwire.NodeAnnouncement) {
        return func(nodeAnn *lnwire.NodeAnnouncement) {
                nodeAnn.Alias = alias
        }
}

// NodeAnnSetAddrs is a functional option that allows updating the addresses of
// the given node announcement.
func NodeAnnSetAddrs(addrs []net.Addr) func(*lnwire.NodeAnnouncement) {
        return func(nodeAnn *lnwire.NodeAnnouncement) {
                nodeAnn.Addresses = addrs
        }
}

// NodeAnnSetColor is a functional option that sets the color of the
// given node announcement.
func NodeAnnSetColor(newColor color.RGBA) func(*lnwire.NodeAnnouncement) {
        return func(nodeAnn *lnwire.NodeAnnouncement) {
                nodeAnn.RGBColor = newColor
        }
}

// NodeAnnSetFeatures is a functional option that allows updating the features of
// the given node announcement.
func NodeAnnSetFeatures(features *lnwire.RawFeatureVector) func(*lnwire.NodeAnnouncement) {
        return func(nodeAnn *lnwire.NodeAnnouncement) {
                nodeAnn.Features = features
        }
}

// NodeAnnSetTimestamp is a functional option that sets the timestamp of the
// announcement to the current time, or increments it if the timestamp is
// already in the future.
func NodeAnnSetTimestamp(nodeAnn *lnwire.NodeAnnouncement) {
        newTimestamp := uint32(time.Now().Unix())
        if newTimestamp <= nodeAnn.Timestamp {
                // Increment the prior value to  ensure the timestamp
                // monotonically increases, otherwise the announcement won't
                // propagate.
                newTimestamp = nodeAnn.Timestamp + 1
        }
        nodeAnn.Timestamp = newTimestamp
}

// SignNodeAnnouncement signs the lnwire.NodeAnnouncement provided, which
// should be the most recent, valid update, otherwise the timestamp may not
// monotonically increase from the prior.
func SignNodeAnnouncement(signer lnwallet.MessageSigner,
        keyLoc keychain.KeyLocator, nodeAnn *lnwire.NodeAnnouncement) error {

        // Create the DER-encoded ECDSA signature over the message digest.
        sig, err := SignAnnouncement(signer, keyLoc, nodeAnn)
        if err != nil {
                return err
        }

        // Parse the DER-encoded signature into a fixed-size 64-byte array.
        nodeAnn.Signature, err = lnwire.NewSigFromSignature(sig)
        return err
}

1	package netann
2
3	import (
4	"image/color"
5	"net"
6	"time"
7
8	"github.com/lightningnetwork/lnd/keychain"
9	"github.com/lightningnetwork/lnd/lnwallet"
10	"github.com/lightningnetwork/lnd/lnwire"
11	)
12
13	// NodeAnnModifier is a closure that makes in-place modifications to an
14	// lnwire.NodeAnnouncement.
15	type NodeAnnModifier func(*lnwire.NodeAnnouncement)
16
17	// NodeAnnSetAlias is a functional option that sets the alias of the
18	// given node announcement.
UNCOV 19	func NodeAnnSetAlias(alias lnwire.NodeAlias) func(*lnwire.NodeAnnouncement) {	×
UNCOV 20	return func(nodeAnn *lnwire.NodeAnnouncement) {	×
UNCOV 21	nodeAnn.Alias = alias	×
UNCOV 22	}	×
23	}
24
25	// NodeAnnSetAddrs is a functional option that allows updating the addresses of
26	// the given node announcement.
UNCOV 27	func NodeAnnSetAddrs(addrs []net.Addr) func(*lnwire.NodeAnnouncement) {	×
UNCOV 28	return func(nodeAnn *lnwire.NodeAnnouncement) {	×
UNCOV 29	nodeAnn.Addresses = addrs	×
UNCOV 30	}	×
31	}
32
33	// NodeAnnSetColor is a functional option that sets the color of the
34	// given node announcement.
UNCOV 35	func NodeAnnSetColor(newColor color.RGBA) func(*lnwire.NodeAnnouncement) {	×
UNCOV 36	return func(nodeAnn *lnwire.NodeAnnouncement) {	×
UNCOV 37	nodeAnn.RGBColor = newColor	×
UNCOV 38	}	×
39	}
40
41	// NodeAnnSetFeatures is a functional option that allows updating the features of
42	// the given node announcement.
UNCOV 43	func NodeAnnSetFeatures(features lnwire.RawFeatureVector) func(lnwire.NodeAnnouncement) {	×
UNCOV 44	return func(nodeAnn *lnwire.NodeAnnouncement) {	×
UNCOV 45	nodeAnn.Features = features	×
UNCOV 46	}	×
47	}
48
49	// NodeAnnSetTimestamp is a functional option that sets the timestamp of the
50	// announcement to the current time, or increments it if the timestamp is
51	// already in the future.
UNCOV 52	func NodeAnnSetTimestamp(nodeAnn *lnwire.NodeAnnouncement) {	×
UNCOV 53	newTimestamp := uint32(time.Now().Unix())	×
UNCOV 54	if newTimestamp <= nodeAnn.Timestamp {	×
UNCOV 55	// Increment the prior value to ensure the timestamp	×
UNCOV 56	// monotonically increases, otherwise the announcement won't	×
UNCOV 57	// propagate.	×
UNCOV 58	newTimestamp = nodeAnn.Timestamp + 1	×
UNCOV 59	}	×
UNCOV 60	nodeAnn.Timestamp = newTimestamp	×
61	}
62
63	// SignNodeAnnouncement signs the lnwire.NodeAnnouncement provided, which
64	// should be the most recent, valid update, otherwise the timestamp may not
65	// monotonically increase from the prior.
66	func SignNodeAnnouncement(signer lnwallet.MessageSigner,
UNCOV 67	keyLoc keychain.KeyLocator, nodeAnn *lnwire.NodeAnnouncement) error {	×
UNCOV 68		×
UNCOV 69	// Create the DER-encoded ECDSA signature over the message digest.	×
UNCOV 70	sig, err := SignAnnouncement(signer, keyLoc, nodeAnn)	×
UNCOV 71	if err != nil {	×
72	return err	×
73	}	×
74
75	// Parse the DER-encoded signature into a fixed-size 64-byte array.
UNCOV 76	nodeAnn.Signature, err = lnwire.NewSigFromSignature(sig)	×
UNCOV 77	return err	×
78	}

lightningnetwork / lnd / 12343072627

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