15561477203

Committed 10 Jun 2025 01:54PM UTC coverage: 58.351% (-10.1%) from 68.487%

Build # 15561477203

Build Type

Pull #9356

github

Committed by

web-flow

Commit Message

Merge 6440b25db into c6d6d4c0b

Pull Request Pull Request #9356: lnrpc: add incoming/outgoing channel ids filter to forwarding history request

Run Details

33 of 36 new or added lines in 2 files covered. (91.67%)

28366 existing lines in 455 files now uncovered.

97715 of 167461 relevant lines covered (58.35%)

1.81 hits per line

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

69.64

/lnwire/closing_signed.go

package lnwire

import (
        "bytes"
        "io"

        "github.com/btcsuite/btcd/btcutil"
        "github.com/lightningnetwork/lnd/tlv"
)

// ClosingSigned is sent by both parties to a channel once the channel is clear
// of HTLCs, and is primarily concerned with negotiating fees for the close
// transaction. Each party provides a signature for a transaction with a fee
// that they believe is fair. The process terminates when both sides agree on
// the same fee, or when one side force closes the channel.
//
// NOTE: The responder is able to send a signature without any additional
// messages as all transactions are assembled observing BIP 69 which defines a
// canonical ordering for input/outputs. Therefore, both sides are able to
// arrive at an identical closure transaction as they know the order of the
// inputs/outputs.
type ClosingSigned struct {
        // ChannelID serves to identify which channel is to be closed.
        ChannelID ChannelID

        // FeeSatoshis is the total fee in satoshis that the party to the
        // channel would like to propose for the close transaction.
        FeeSatoshis btcutil.Amount

        // Signature is for the proposed channel close transaction.
        Signature Sig

        // PartialSig is used to transmit a musig2 extended partial signature
        // that signs the latest fee offer. The nonce isn't sent along side, as
        // that has already been sent in the initial shutdown message.
        //
        // NOTE: This field is only populated if a musig2 taproot channel is
        // being signed for. In this case, the above Sig type MUST be blank.
        PartialSig OptPartialSigTLV

        // ExtraData is the set of data that was appended to this message to
        // fill out the full maximum transport message size. These fields can
        // be used to specify optional data such as custom TLV fields.
        ExtraData ExtraOpaqueData
}

// NewClosingSigned creates a new empty ClosingSigned message.
func NewClosingSigned(cid ChannelID, fs btcutil.Amount,
        sig Sig) *ClosingSigned {

        return &ClosingSigned{
                ChannelID:   cid,
                FeeSatoshis: fs,
                Signature:   sig,
        }
}

// A compile time check to ensure ClosingSigned implements the lnwire.Message
// interface.
var _ Message = (*ClosingSigned)(nil)

// A compile time check to ensure ClosingSigned implements the
// lnwire.SizeableMessage interface.
var _ SizeableMessage = (*ClosingSigned)(nil)

// Decode deserializes a serialized ClosingSigned message stored in the passed
// io.Reader observing the specified protocol version.
//
// This is part of the lnwire.Message interface.
func (c *ClosingSigned) Decode(r io.Reader, pver uint32) error {
        err := ReadElements(
                r, &c.ChannelID, &c.FeeSatoshis, &c.Signature,
        )
        if err != nil {
                return err
        }

        var tlvRecords ExtraOpaqueData
        if err := ReadElements(r, &tlvRecords); err != nil {
                return err
        }

        partialSig := c.PartialSig.Zero()
        typeMap, err := tlvRecords.ExtractRecords(&partialSig)
        if err != nil {
                return err
        }

        // Set the corresponding TLV types if they were included in the stream.
        if val, ok := typeMap[c.PartialSig.TlvType()]; ok && val == nil {
                c.PartialSig = tlv.SomeRecordT(partialSig)
        }

        if len(tlvRecords) != 0 {
                c.ExtraData = tlvRecords
        }

        return nil
}

// Encode serializes the target ClosingSigned into the passed io.Writer
// observing the protocol version specified.
//
// This is part of the lnwire.Message interface.
func (c *ClosingSigned) Encode(w *bytes.Buffer, pver uint32) error {
        recordProducers := make([]tlv.RecordProducer, 0, 1)
        c.PartialSig.WhenSome(func(sig PartialSigTLV) {
                recordProducers = append(recordProducers, &sig)
        })
        err := EncodeMessageExtraData(&c.ExtraData, recordProducers...)
        if err != nil {
                return err
        }

        if err := WriteChannelID(w, c.ChannelID); err != nil {
                return err
        }

        if err := WriteSatoshi(w, c.FeeSatoshis); err != nil {
                return err
        }

        if err := WriteSig(w, c.Signature); err != nil {
                return err
        }

        return WriteBytes(w, c.ExtraData)
}

// MsgType returns the integer uniquely identifying this message type on the
// wire.
//
// This is part of the lnwire.Message interface.
func (c *ClosingSigned) MsgType() MessageType {
        return MsgClosingSigned
}

// SerializedSize returns the serialized size of the message in bytes.
//
// This is part of the lnwire.SizeableMessage interface.
func (c *ClosingSigned) SerializedSize() (uint32, error) {
        return MessageSerializedSize(c)
}

1	package lnwire
2
3	import (
4	"bytes"
5	"io"
6
7	"github.com/btcsuite/btcd/btcutil"
8	"github.com/lightningnetwork/lnd/tlv"
9	)
10
11	// ClosingSigned is sent by both parties to a channel once the channel is clear
12	// of HTLCs, and is primarily concerned with negotiating fees for the close
13	// transaction. Each party provides a signature for a transaction with a fee
14	// that they believe is fair. The process terminates when both sides agree on
15	// the same fee, or when one side force closes the channel.
16	//
17	// NOTE: The responder is able to send a signature without any additional
18	// messages as all transactions are assembled observing BIP 69 which defines a
19	// canonical ordering for input/outputs. Therefore, both sides are able to
20	// arrive at an identical closure transaction as they know the order of the
21	// inputs/outputs.
22	type ClosingSigned struct {
23	// ChannelID serves to identify which channel is to be closed.
24	ChannelID ChannelID
25
26	// FeeSatoshis is the total fee in satoshis that the party to the
27	// channel would like to propose for the close transaction.
28	FeeSatoshis btcutil.Amount
29
30	// Signature is for the proposed channel close transaction.
31	Signature Sig
32
33	// PartialSig is used to transmit a musig2 extended partial signature
34	// that signs the latest fee offer. The nonce isn't sent along side, as
35	// that has already been sent in the initial shutdown message.
36	//
37	// NOTE: This field is only populated if a musig2 taproot channel is
38	// being signed for. In this case, the above Sig type MUST be blank.
39	PartialSig OptPartialSigTLV
40
41	// ExtraData is the set of data that was appended to this message to
42	// fill out the full maximum transport message size. These fields can
43	// be used to specify optional data such as custom TLV fields.
44	ExtraData ExtraOpaqueData
45	}
46
47	// NewClosingSigned creates a new empty ClosingSigned message.
48	func NewClosingSigned(cid ChannelID, fs btcutil.Amount,
49	sig Sig) *ClosingSigned {	3✔
50		3✔
51	return &ClosingSigned{	3✔
52	ChannelID: cid,	3✔
53	FeeSatoshis: fs,	3✔
54	Signature: sig,	3✔
55	}	3✔
56	}	3✔
57
58	// A compile time check to ensure ClosingSigned implements the lnwire.Message
59	// interface.
60	var _ Message = (*ClosingSigned)(nil)
61
62	// A compile time check to ensure ClosingSigned implements the
63	// lnwire.SizeableMessage interface.
64	var _ SizeableMessage = (*ClosingSigned)(nil)
65
66	// Decode deserializes a serialized ClosingSigned message stored in the passed
67	// io.Reader observing the specified protocol version.
68	//
69	// This is part of the lnwire.Message interface.
70	func (c *ClosingSigned) Decode(r io.Reader, pver uint32) error {	3✔
71	err := ReadElements(	3✔
72	r, &c.ChannelID, &c.FeeSatoshis, &c.Signature,	3✔
73	)	3✔
74	if err != nil {	3✔
UNCOV 75	return err	×
UNCOV 76	}	×
77
78	var tlvRecords ExtraOpaqueData	3✔
79	if err := ReadElements(r, &tlvRecords); err != nil {	3✔
80	return err	×
81	}	×
82
83	partialSig := c.PartialSig.Zero()	3✔
84	typeMap, err := tlvRecords.ExtractRecords(&partialSig)	3✔
85	if err != nil {	3✔
UNCOV 86	return err	×
UNCOV 87	}	×
88
89	// Set the corresponding TLV types if they were included in the stream.
90	if val, ok := typeMap[c.PartialSig.TlvType()]; ok && val == nil {	6✔
91	c.PartialSig = tlv.SomeRecordT(partialSig)	3✔
92	}	3✔
93
94	if len(tlvRecords) != 0 {	6✔
95	c.ExtraData = tlvRecords	3✔
96	}	3✔
97
98	return nil	3✔
99	}
100
101	// Encode serializes the target ClosingSigned into the passed io.Writer
102	// observing the protocol version specified.
103	//
104	// This is part of the lnwire.Message interface.
105	func (c ClosingSigned) Encode(w bytes.Buffer, pver uint32) error {	3✔
106	recordProducers := make([]tlv.RecordProducer, 0, 1)	3✔
107	c.PartialSig.WhenSome(func(sig PartialSigTLV) {	6✔
108	recordProducers = append(recordProducers, &sig)	3✔
109	})	3✔
110	err := EncodeMessageExtraData(&c.ExtraData, recordProducers...)	3✔
111	if err != nil {	3✔
112	return err	×
113	}	×
114
115	if err := WriteChannelID(w, c.ChannelID); err != nil {	3✔
116	return err	×
117	}	×
118
119	if err := WriteSatoshi(w, c.FeeSatoshis); err != nil {	3✔
120	return err	×
121	}	×
122
123	if err := WriteSig(w, c.Signature); err != nil {	3✔
124	return err	×
125	}	×
126
127	return WriteBytes(w, c.ExtraData)	3✔
128	}
129
130	// MsgType returns the integer uniquely identifying this message type on the
131	// wire.
132	//
133	// This is part of the lnwire.Message interface.
134	func (c *ClosingSigned) MsgType() MessageType {	3✔
135	return MsgClosingSigned	3✔
136	}	3✔
137
138	// SerializedSize returns the serialized size of the message in bytes.
139	//
140	// This is part of the lnwire.SizeableMessage interface.
141	func (c *ClosingSigned) SerializedSize() (uint32, error) {	×
142	return MessageSerializedSize(c)	×
143	}	×

lightningnetwork / lnd / 15561477203

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