16588862317

Committed 29 Jul 2025 06:52AM UTC coverage: 67.102% (-0.1%) from 67.241%

Build # 16588862317

Build Type

Pull #10034

github

Committed by

web-flow

Commit Message

Merge cabb3a0a2 into ce10a9d82

Pull Request Pull Request #10034: scripts: add cherry-pick verification tool with fuzzy matching

Run Details

135243 of 201549 relevant lines covered (67.1%)

21780.91 hits per line

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

74.07

/lnwire/stfu.go

package lnwire

import (
        "bytes"
        "io"
)

// Stfu is a message that is sent to lock the channel state prior to some other
// interactive protocol where channel updates need to be paused.
type Stfu struct {
        // ChanID identifies which channel needs to be frozen.
        ChanID ChannelID

        // Initiator is a byte that identifies whether we are the initiator of
        // this process.
        Initiator bool

        // 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
}

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

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

// Encode serializes the target Stfu into the passed io.Writer.
// Serialization will observe the rules defined by the passed protocol version.
//
// This is a part of the lnwire.Message interface.
func (s *Stfu) Encode(w *bytes.Buffer, _ uint32) error {
        if err := WriteChannelID(w, s.ChanID); err != nil {
                return err
        }

        if err := WriteBool(w, s.Initiator); err != nil {
                return err
        }

        return WriteBytes(w, s.ExtraData)
}

// Decode deserializes the serialized Stfu stored in the passed io.Reader
// into the target Stfu using the deserialization rules defined by the
// passed protocol version.
//
// This is a part of the lnwire.Message interface.
func (s *Stfu) Decode(r io.Reader, _ uint32) error {
        if err := ReadElements(
                r, &s.ChanID, &s.Initiator, &s.ExtraData,
        ); err != nil {
                return err
        }

        // This is required to pass the fuzz test round trip equality check.
        if len(s.ExtraData) == 0 {
                s.ExtraData = nil
        }

        return nil
}

// MsgType returns the MessageType code which uniquely identifies this message
// as a Stfu on the wire.
//
// This is part of the lnwire.Message interface.
func (s *Stfu) MsgType() MessageType {
        return MsgStfu
}

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

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

// TargetChanID returns the channel id of the link for which this message is
// intended.
//
// NOTE: Part of peer.LinkUpdater interface.
func (s *Stfu) TargetChanID() ChannelID {
        return s.ChanID
}

1	package lnwire
2
3	import (
4	"bytes"
5	"io"
6	)
7
8	// Stfu is a message that is sent to lock the channel state prior to some other
9	// interactive protocol where channel updates need to be paused.
10	type Stfu struct {
11	// ChanID identifies which channel needs to be frozen.
12	ChanID ChannelID
13
14	// Initiator is a byte that identifies whether we are the initiator of
15	// this process.
16	Initiator bool
17
18	// ExtraData is the set of data that was appended to this message to
19	// fill out the full maximum transport message size. These fields can
20	// be used to specify optional data such as custom TLV fields.
21	ExtraData ExtraOpaqueData
22	}
23
24	// A compile time check to ensure Stfu implements the lnwire.Message interface.
25	var _ Message = (*Stfu)(nil)
26
27	// A compile time check to ensure Stfu implements the lnwire.SizeableMessage
28	// interface.
29	var _ SizeableMessage = (*Stfu)(nil)
30
31	// Encode serializes the target Stfu into the passed io.Writer.
32	// Serialization will observe the rules defined by the passed protocol version.
33	//
34	// This is a part of the lnwire.Message interface.
35	func (s Stfu) Encode(w bytes.Buffer, _ uint32) error {	117✔
36	if err := WriteChannelID(w, s.ChanID); err != nil {	117✔
37	return err	×
38	}	×
39
40	if err := WriteBool(w, s.Initiator); err != nil {	117✔
41	return err	×
42	}	×
43
44	return WriteBytes(w, s.ExtraData)	117✔
45	}
46
47	// Decode deserializes the serialized Stfu stored in the passed io.Reader
48	// into the target Stfu using the deserialization rules defined by the
49	// passed protocol version.
50	//
51	// This is a part of the lnwire.Message interface.
52	func (s *Stfu) Decode(r io.Reader, _ uint32) error {	135✔
53	if err := ReadElements(	135✔
54	r, &s.ChanID, &s.Initiator, &s.ExtraData,	135✔
55	); err != nil {	138✔
56	return err	3✔
57	}	3✔
58
59	// This is required to pass the fuzz test round trip equality check.
60	if len(s.ExtraData) == 0 {	166✔
61	s.ExtraData = nil	34✔
62	}	34✔
63
64	return nil	132✔
65	}
66
67	// MsgType returns the MessageType code which uniquely identifies this message
68	// as a Stfu on the wire.
69	//
70	// This is part of the lnwire.Message interface.
71	func (s *Stfu) MsgType() MessageType {	125✔
72	return MsgStfu	125✔
73	}	125✔
74
75	// SerializedSize returns the serialized size of the message in bytes.
76	//
77	// This is part of the lnwire.SizeableMessage interface.
78	func (s *Stfu) SerializedSize() (uint32, error) {	×
79	return MessageSerializedSize(s)	×
80	}	×
81
82	// A compile time check to ensure Stfu implements the
83	// lnwire.LinkUpdater interface.
84	var _ LinkUpdater = (*Stfu)(nil)
85
86	// TargetChanID returns the channel id of the link for which this message is
87	// intended.
88	//
89	// NOTE: Part of peer.LinkUpdater interface.
90	func (s *Stfu) TargetChanID() ChannelID {	2✔
91	return s.ChanID	2✔
92	}	2✔

lightningnetwork / lnd / 16588862317

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