13593508312

Committed 28 Feb 2025 05:41PM UTC coverage: 58.287% (-10.4%) from 68.65%

Build # 13593508312

Build Type

Pull #9458

github

Committed by

web-flow

Commit Message

Merge d40067c0c into f1182e433

Pull Request Pull Request #9458: multi+server.go: add initial permissions for some peers

Run Details

346 of 548 new or added lines in 10 files covered. (63.14%)

27412 existing lines in 442 files now uncovered.

94709 of 162488 relevant lines covered (58.29%)

1.81 hits per line

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

0.0

/lnwire/channel_announcement_2.go

package lnwire

import (
        "bytes"
        "io"

        "github.com/btcsuite/btcd/chaincfg"
        "github.com/btcsuite/btcd/chaincfg/chainhash"
        "github.com/lightningnetwork/lnd/tlv"
)

// ChannelAnnouncement2 message is used to announce the existence of a taproot
// channel between two peers in the network.
type ChannelAnnouncement2 struct {
        // Signature is a Schnorr signature over the TLV stream of the message.
        Signature Sig

        // ChainHash denotes the target chain that this channel was opened
        // within. This value should be the genesis hash of the target chain.
        ChainHash tlv.RecordT[tlv.TlvType0, chainhash.Hash]

        // Features is the feature vector that encodes the features supported
        // by the target node. This field can be used to signal the type of the
        // channel, or modifications to the fields that would normally follow
        // this vector.
        Features tlv.RecordT[tlv.TlvType2, RawFeatureVector]

        // ShortChannelID is the unique description of the funding transaction,
        // or where exactly it's located within the target blockchain.
        ShortChannelID tlv.RecordT[tlv.TlvType4, ShortChannelID]

        // Capacity is the number of satoshis of the capacity of this channel.
        // It must be less than or equal to the value of the on-chain funding
        // output.
        Capacity tlv.RecordT[tlv.TlvType6, uint64]

        // NodeID1 is the numerically-lesser public key ID of one of the channel
        // operators.
        NodeID1 tlv.RecordT[tlv.TlvType8, [33]byte]

        // NodeID2 is the numerically-greater public key ID of one of the
        // channel operators.
        NodeID2 tlv.RecordT[tlv.TlvType10, [33]byte]

        // BitcoinKey1 is the public key of the key used by Node1 in the
        // construction of the on-chain funding transaction. This is an optional
        // field and only needs to be set if the 4-of-4 MuSig construction was
        // used in the creation of the message signature.
        BitcoinKey1 tlv.OptionalRecordT[tlv.TlvType12, [33]byte]

        // BitcoinKey2 is the public key of the key used by Node2 in the
        // construction of the on-chain funding transaction. This is an optional
        // field and only needs to be set if the 4-of-4 MuSig construction was
        // used in the creation of the message signature.
        BitcoinKey2 tlv.OptionalRecordT[tlv.TlvType14, [33]byte]

        // MerkleRootHash is the hash used to create the optional tweak in the
        // funding output. If this is not set but the bitcoin keys are, then
        // the funding output is a pure 2-of-2 MuSig aggregate public key.
        MerkleRootHash tlv.OptionalRecordT[tlv.TlvType16, [32]byte]

        // ExtraOpaqueData is the set of data that was appended to this
        // message, some of which we may not actually know how to iterate or
        // parse. By holding onto this data, we ensure that we're able to
        // properly validate the set of signatures that cover these new fields,
        // and ensure we're able to make upgrades to the network in a forwards
        // compatible manner.
        ExtraOpaqueData ExtraOpaqueData
}

// Decode deserializes a serialized AnnounceSignatures1 stored in the passed
// io.Reader observing the specified protocol version.
//
// This is part of the lnwire.Message interface.
func (c *ChannelAnnouncement2) Decode(r io.Reader, _ uint32) error {
        err := ReadElement(r, &c.Signature)
        if err != nil {
                return err
        }
        c.Signature.ForceSchnorr()

        return c.DecodeTLVRecords(r)
}

// DecodeTLVRecords decodes only the TLV section of the message.
func (c *ChannelAnnouncement2) DecodeTLVRecords(r io.Reader) error {
        // First extract into extra opaque data.
        var tlvRecords ExtraOpaqueData
        if err := ReadElements(r, &tlvRecords); err != nil {
                return err
        }

        var (
                chainHash      = tlv.ZeroRecordT[tlv.TlvType0, [32]byte]()
                btcKey1        = tlv.ZeroRecordT[tlv.TlvType12, [33]byte]()
                btcKey2        = tlv.ZeroRecordT[tlv.TlvType14, [33]byte]()
                merkleRootHash = tlv.ZeroRecordT[tlv.TlvType16, [32]byte]()
        )
        typeMap, err := tlvRecords.ExtractRecords(
                &chainHash, &c.Features, &c.ShortChannelID, &c.Capacity,
                &c.NodeID1, &c.NodeID2, &btcKey1, &btcKey2, &merkleRootHash,
        )
        if err != nil {
                return err
        }

        // By default, the chain-hash is the bitcoin mainnet genesis block hash.
        c.ChainHash.Val = *chaincfg.MainNetParams.GenesisHash
        if _, ok := typeMap[c.ChainHash.TlvType()]; ok {
                c.ChainHash.Val = chainHash.Val
        }

        if _, ok := typeMap[c.BitcoinKey1.TlvType()]; ok {
                c.BitcoinKey1 = tlv.SomeRecordT(btcKey1)
        }

        if _, ok := typeMap[c.BitcoinKey2.TlvType()]; ok {
                c.BitcoinKey2 = tlv.SomeRecordT(btcKey2)
        }

        if _, ok := typeMap[c.MerkleRootHash.TlvType()]; ok {
                c.MerkleRootHash = tlv.SomeRecordT(merkleRootHash)
        }

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

        return nil
}

// Encode serializes the target AnnounceSignatures1 into the passed io.Writer
// observing the protocol version specified.
//
// This is part of the lnwire.Message interface.
func (c *ChannelAnnouncement2) Encode(w *bytes.Buffer, _ uint32) error {
        _, err := w.Write(c.Signature.RawBytes())
        if err != nil {
                return err
        }
        _, err = c.DataToSign()
        if err != nil {
                return err
        }

        return WriteBytes(w, c.ExtraOpaqueData)
}

// DataToSign encodes the data to be signed into the ExtraOpaqueData member and
// returns it.
func (c *ChannelAnnouncement2) DataToSign() ([]byte, error) {
        // The chain-hash record is only included if it is _not_ equal to the
        // bitcoin mainnet genisis block hash.
        var recordProducers []tlv.RecordProducer
        if !c.ChainHash.Val.IsEqual(chaincfg.MainNetParams.GenesisHash) {
                hash := tlv.ZeroRecordT[tlv.TlvType0, [32]byte]()
                hash.Val = c.ChainHash.Val

                recordProducers = append(recordProducers, &hash)
        }

        recordProducers = append(recordProducers,
                &c.Features, &c.ShortChannelID, &c.Capacity, &c.NodeID1,
                &c.NodeID2,
        )

        c.BitcoinKey1.WhenSome(func(key tlv.RecordT[tlv.TlvType12, [33]byte]) {
                recordProducers = append(recordProducers, &key)
        })

        c.BitcoinKey2.WhenSome(func(key tlv.RecordT[tlv.TlvType14, [33]byte]) {
                recordProducers = append(recordProducers, &key)
        })

        c.MerkleRootHash.WhenSome(
                func(hash tlv.RecordT[tlv.TlvType16, [32]byte]) {
                        recordProducers = append(recordProducers, &hash)
                },
        )

        err := EncodeMessageExtraData(&c.ExtraOpaqueData, recordProducers...)
        if err != nil {
                return nil, err
        }

        return c.ExtraOpaqueData, nil
}

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

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

// Node1KeyBytes returns the bytes representing the public key of node 1 in the
// channel.
//
// NOTE: This is part of the ChannelAnnouncement interface.
func (c *ChannelAnnouncement2) Node1KeyBytes() [33]byte {
        return c.NodeID1.Val
}

// Node2KeyBytes returns the bytes representing the public key of node 2 in the
// channel.
//
// NOTE: This is part of the ChannelAnnouncement interface.
func (c *ChannelAnnouncement2) Node2KeyBytes() [33]byte {
        return c.NodeID2.Val
}

// GetChainHash returns the hash of the chain which this channel's funding
// transaction is confirmed in.
//
// NOTE: This is part of the ChannelAnnouncement interface.
func (c *ChannelAnnouncement2) GetChainHash() chainhash.Hash {
        return c.ChainHash.Val
}

// SCID returns the short channel ID of the channel.
//
// NOTE: This is part of the ChannelAnnouncement interface.
func (c *ChannelAnnouncement2) SCID() ShortChannelID {
        return c.ShortChannelID.Val
}

// A compile-time check to ensure that ChannelAnnouncement2 implements the
// ChannelAnnouncement interface.
var _ ChannelAnnouncement = (*ChannelAnnouncement2)(nil)

1	package lnwire
2
3	import (
4	"bytes"
5	"io"
6
7	"github.com/btcsuite/btcd/chaincfg"
8	"github.com/btcsuite/btcd/chaincfg/chainhash"
9	"github.com/lightningnetwork/lnd/tlv"
10	)
11
12	// ChannelAnnouncement2 message is used to announce the existence of a taproot
13	// channel between two peers in the network.
14	type ChannelAnnouncement2 struct {
15	// Signature is a Schnorr signature over the TLV stream of the message.
16	Signature Sig
17
18	// ChainHash denotes the target chain that this channel was opened
19	// within. This value should be the genesis hash of the target chain.
20	ChainHash tlv.RecordT[tlv.TlvType0, chainhash.Hash]
21
22	// Features is the feature vector that encodes the features supported
23	// by the target node. This field can be used to signal the type of the
24	// channel, or modifications to the fields that would normally follow
25	// this vector.
26	Features tlv.RecordT[tlv.TlvType2, RawFeatureVector]
27
28	// ShortChannelID is the unique description of the funding transaction,
29	// or where exactly it's located within the target blockchain.
30	ShortChannelID tlv.RecordT[tlv.TlvType4, ShortChannelID]
31
32	// Capacity is the number of satoshis of the capacity of this channel.
33	// It must be less than or equal to the value of the on-chain funding
34	// output.
35	Capacity tlv.RecordT[tlv.TlvType6, uint64]
36
37	// NodeID1 is the numerically-lesser public key ID of one of the channel
38	// operators.
39	NodeID1 tlv.RecordT[tlv.TlvType8, [33]byte]
40
41	// NodeID2 is the numerically-greater public key ID of one of the
42	// channel operators.
43	NodeID2 tlv.RecordT[tlv.TlvType10, [33]byte]
44
45	// BitcoinKey1 is the public key of the key used by Node1 in the
46	// construction of the on-chain funding transaction. This is an optional
47	// field and only needs to be set if the 4-of-4 MuSig construction was
48	// used in the creation of the message signature.
49	BitcoinKey1 tlv.OptionalRecordT[tlv.TlvType12, [33]byte]
50
51	// BitcoinKey2 is the public key of the key used by Node2 in the
52	// construction of the on-chain funding transaction. This is an optional
53	// field and only needs to be set if the 4-of-4 MuSig construction was
54	// used in the creation of the message signature.
55	BitcoinKey2 tlv.OptionalRecordT[tlv.TlvType14, [33]byte]
56
57	// MerkleRootHash is the hash used to create the optional tweak in the
58	// funding output. If this is not set but the bitcoin keys are, then
59	// the funding output is a pure 2-of-2 MuSig aggregate public key.
60	MerkleRootHash tlv.OptionalRecordT[tlv.TlvType16, [32]byte]
61
62	// ExtraOpaqueData is the set of data that was appended to this
63	// message, some of which we may not actually know how to iterate or
64	// parse. By holding onto this data, we ensure that we're able to
65	// properly validate the set of signatures that cover these new fields,
66	// and ensure we're able to make upgrades to the network in a forwards
67	// compatible manner.
68	ExtraOpaqueData ExtraOpaqueData
69	}
70
71	// Decode deserializes a serialized AnnounceSignatures1 stored in the passed
72	// io.Reader observing the specified protocol version.
73	//
74	// This is part of the lnwire.Message interface.
UNCOV 75	func (c *ChannelAnnouncement2) Decode(r io.Reader, _ uint32) error {	×
UNCOV 76	err := ReadElement(r, &c.Signature)	×
UNCOV 77	if err != nil {	×
UNCOV 78	return err	×
UNCOV 79	}	×
UNCOV 80	c.Signature.ForceSchnorr()	×
UNCOV 81		×
UNCOV 82	return c.DecodeTLVRecords(r)	×
83	}
84
85	// DecodeTLVRecords decodes only the TLV section of the message.
UNCOV 86	func (c *ChannelAnnouncement2) DecodeTLVRecords(r io.Reader) error {	×
UNCOV 87	// First extract into extra opaque data.	×
UNCOV 88	var tlvRecords ExtraOpaqueData	×
UNCOV 89	if err := ReadElements(r, &tlvRecords); err != nil {	×
90	return err	×
91	}	×
92
UNCOV 93	var (	×
UNCOV 94	chainHash = tlv.ZeroRecordT[tlv.TlvType0, [32]byte]()	×
UNCOV 95	btcKey1 = tlv.ZeroRecordT[tlv.TlvType12, [33]byte]()	×
UNCOV 96	btcKey2 = tlv.ZeroRecordT[tlv.TlvType14, [33]byte]()	×
UNCOV 97	merkleRootHash = tlv.ZeroRecordT[tlv.TlvType16, [32]byte]()	×
UNCOV 98	)	×
UNCOV 99	typeMap, err := tlvRecords.ExtractRecords(	×
UNCOV 100	&chainHash, &c.Features, &c.ShortChannelID, &c.Capacity,	×
UNCOV 101	&c.NodeID1, &c.NodeID2, &btcKey1, &btcKey2, &merkleRootHash,	×
UNCOV 102	)	×
UNCOV 103	if err != nil {	×
UNCOV 104	return err	×
UNCOV 105	}	×
106
107	// By default, the chain-hash is the bitcoin mainnet genesis block hash.
UNCOV 108	c.ChainHash.Val = *chaincfg.MainNetParams.GenesisHash	×
UNCOV 109	if _, ok := typeMap[c.ChainHash.TlvType()]; ok {	×
UNCOV 110	c.ChainHash.Val = chainHash.Val	×
UNCOV 111	}	×
112
UNCOV 113	if _, ok := typeMap[c.BitcoinKey1.TlvType()]; ok {	×
UNCOV 114	c.BitcoinKey1 = tlv.SomeRecordT(btcKey1)	×
UNCOV 115	}	×
116
UNCOV 117	if _, ok := typeMap[c.BitcoinKey2.TlvType()]; ok {	×
UNCOV 118	c.BitcoinKey2 = tlv.SomeRecordT(btcKey2)	×
UNCOV 119	}	×
120
UNCOV 121	if _, ok := typeMap[c.MerkleRootHash.TlvType()]; ok {	×
UNCOV 122	c.MerkleRootHash = tlv.SomeRecordT(merkleRootHash)	×
UNCOV 123	}	×
124
UNCOV 125	if len(tlvRecords) != 0 {	×
UNCOV 126	c.ExtraOpaqueData = tlvRecords	×
UNCOV 127	}	×
128
UNCOV 129	return nil	×
130	}
131
132	// Encode serializes the target AnnounceSignatures1 into the passed io.Writer
133	// observing the protocol version specified.
134	//
135	// This is part of the lnwire.Message interface.
UNCOV 136	func (c ChannelAnnouncement2) Encode(w bytes.Buffer, _ uint32) error {	×
UNCOV 137	_, err := w.Write(c.Signature.RawBytes())	×
UNCOV 138	if err != nil {	×
139	return err	×
140	}	×
UNCOV 141	_, err = c.DataToSign()	×
UNCOV 142	if err != nil {	×
143	return err	×
144	}	×
145
UNCOV 146	return WriteBytes(w, c.ExtraOpaqueData)	×
147	}
148
149	// DataToSign encodes the data to be signed into the ExtraOpaqueData member and
150	// returns it.
UNCOV 151	func (c *ChannelAnnouncement2) DataToSign() ([]byte, error) {	×
UNCOV 152	// The chain-hash record is only included if it is _not_ equal to the	×
UNCOV 153	// bitcoin mainnet genisis block hash.	×
UNCOV 154	var recordProducers []tlv.RecordProducer	×
UNCOV 155	if !c.ChainHash.Val.IsEqual(chaincfg.MainNetParams.GenesisHash) {	×
UNCOV 156	hash := tlv.ZeroRecordT[tlv.TlvType0, [32]byte]()	×
UNCOV 157	hash.Val = c.ChainHash.Val	×
UNCOV 158		×
UNCOV 159	recordProducers = append(recordProducers, &hash)	×
UNCOV 160	}	×
161
UNCOV 162	recordProducers = append(recordProducers,	×
UNCOV 163	&c.Features, &c.ShortChannelID, &c.Capacity, &c.NodeID1,	×
UNCOV 164	&c.NodeID2,	×
UNCOV 165	)	×
UNCOV 166		×
UNCOV 167	c.BitcoinKey1.WhenSome(func(key tlv.RecordT[tlv.TlvType12, [33]byte]) {	×
UNCOV 168	recordProducers = append(recordProducers, &key)	×
UNCOV 169	})	×
170
UNCOV 171	c.BitcoinKey2.WhenSome(func(key tlv.RecordT[tlv.TlvType14, [33]byte]) {	×
UNCOV 172	recordProducers = append(recordProducers, &key)	×
UNCOV 173	})	×
174
UNCOV 175	c.MerkleRootHash.WhenSome(	×
UNCOV 176	func(hash tlv.RecordT[tlv.TlvType16, [32]byte]) {	×
UNCOV 177	recordProducers = append(recordProducers, &hash)	×
UNCOV 178	},	×
179	)
180
UNCOV 181	err := EncodeMessageExtraData(&c.ExtraOpaqueData, recordProducers...)	×
UNCOV 182	if err != nil {	×
183	return nil, err	×
184	}	×
185
UNCOV 186	return c.ExtraOpaqueData, nil	×
187	}
188
189	// MsgType returns the integer uniquely identifying this message type on the
190	// wire.
191	//
192	// This is part of the lnwire.Message interface.
UNCOV 193	func (c *ChannelAnnouncement2) MsgType() MessageType {	×
UNCOV 194	return MsgChannelAnnouncement2	×
UNCOV 195	}	×
196
197	// A compile time check to ensure ChannelAnnouncement2 implements the
198	// lnwire.Message interface.
199	var _ Message = (*ChannelAnnouncement2)(nil)
200
201	// Node1KeyBytes returns the bytes representing the public key of node 1 in the
202	// channel.
203	//
204	// NOTE: This is part of the ChannelAnnouncement interface.
205	func (c *ChannelAnnouncement2) Node1KeyBytes() [33]byte {	×
206	return c.NodeID1.Val	×
207	}	×
208
209	// Node2KeyBytes returns the bytes representing the public key of node 2 in the
210	// channel.
211	//
212	// NOTE: This is part of the ChannelAnnouncement interface.
213	func (c *ChannelAnnouncement2) Node2KeyBytes() [33]byte {	×
214	return c.NodeID2.Val	×
215	}	×
216
217	// GetChainHash returns the hash of the chain which this channel's funding
218	// transaction is confirmed in.
219	//
220	// NOTE: This is part of the ChannelAnnouncement interface.
221	func (c *ChannelAnnouncement2) GetChainHash() chainhash.Hash {	×
222	return c.ChainHash.Val	×
223	}	×
224
225	// SCID returns the short channel ID of the channel.
226	//
227	// NOTE: This is part of the ChannelAnnouncement interface.
228	func (c *ChannelAnnouncement2) SCID() ShortChannelID {	×
229	return c.ShortChannelID.Val	×
230	}	×
231
232	// A compile-time check to ensure that ChannelAnnouncement2 implements the
233	// ChannelAnnouncement interface.
234	var _ ChannelAnnouncement = (*ChannelAnnouncement2)(nil)

lightningnetwork / lnd / 13593508312

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