13999301927

Committed 21 Mar 2025 07:18PM UTC coverage: 68.989% (+9.9%) from 59.126%

Build # 13999301927

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #9623 from Roasbeef/size-msg-test-msg

Size msg test msg

Run Details

1461 of 1572 new or added lines in 43 files covered. (92.94%)

28 existing lines in 6 files now uncovered.

132898 of 192637 relevant lines covered (68.99%)

22200.59 hits per line

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

66.67

/lnwire/update_fail_malformed_htlc.go

package lnwire

import (
        "bytes"
        "crypto/sha256"
        "io"
)

// UpdateFailMalformedHTLC is sent by either the payment forwarder or by
// payment receiver to the payment sender in order to notify it that the onion
// blob can't be parsed. For that reason we send this message instead of
// obfuscate the onion failure.
type UpdateFailMalformedHTLC struct {
        // ChanID is the particular active channel that this
        // UpdateFailMalformedHTLC is bound to.
        ChanID ChannelID

        // ID references which HTLC on the remote node's commitment transaction
        // has timed out.
        ID uint64

        // ShaOnionBlob hash of the onion blob on which can't be parsed by the
        // node in the payment path.
        ShaOnionBlob [sha256.Size]byte

        // FailureCode the exact reason why onion blob haven't been parsed.
        FailureCode FailCode

        // 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 UpdateFailMalformedHTLC implements the
// lnwire.Message interface.
var _ Message = (*UpdateFailMalformedHTLC)(nil)

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

// Decode deserializes a serialized UpdateFailMalformedHTLC message stored in the passed
// io.Reader observing the specified protocol version.
//
// This is part of the lnwire.Message interface.
func (c *UpdateFailMalformedHTLC) Decode(r io.Reader, pver uint32) error {
        return ReadElements(r,
                &c.ChanID,
                &c.ID,
                c.ShaOnionBlob[:],
                &c.FailureCode,
                &c.ExtraData,
        )
}

// Encode serializes the target UpdateFailMalformedHTLC into the passed
// io.Writer observing the protocol version specified.
//
// This is part of the lnwire.Message interface.
func (c *UpdateFailMalformedHTLC) Encode(w *bytes.Buffer,
        pver uint32) error {

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

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

        if err := WriteBytes(w, c.ShaOnionBlob[:]); err != nil {
                return err
        }

        if err := WriteFailCode(w, c.FailureCode); 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 *UpdateFailMalformedHTLC) MsgType() MessageType {
        return MsgUpdateFailMalformedHTLC
}

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

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

1	package lnwire
2
3	import (
4	"bytes"
5	"crypto/sha256"
6	"io"
7	)
8
9	// UpdateFailMalformedHTLC is sent by either the payment forwarder or by
10	// payment receiver to the payment sender in order to notify it that the onion
11	// blob can't be parsed. For that reason we send this message instead of
12	// obfuscate the onion failure.
13	type UpdateFailMalformedHTLC struct {
14	// ChanID is the particular active channel that this
15	// UpdateFailMalformedHTLC is bound to.
16	ChanID ChannelID
17
18	// ID references which HTLC on the remote node's commitment transaction
19	// has timed out.
20	ID uint64
21
22	// ShaOnionBlob hash of the onion blob on which can't be parsed by the
23	// node in the payment path.
24	ShaOnionBlob [sha256.Size]byte
25
26	// FailureCode the exact reason why onion blob haven't been parsed.
27	FailureCode FailCode
28
29	// ExtraData is the set of data that was appended to this message to
30	// fill out the full maximum transport message size. These fields can
31	// be used to specify optional data such as custom TLV fields.
32	ExtraData ExtraOpaqueData
33	}
34
35	// A compile time check to ensure UpdateFailMalformedHTLC implements the
36	// lnwire.Message interface.
37	var _ Message = (*UpdateFailMalformedHTLC)(nil)
38
39	// A compile time check to ensure UpdateFailMalformedHTLC implements the
40	// lnwire.SizeableMessage interface.
41	var _ SizeableMessage = (*UpdateFailMalformedHTLC)(nil)
42
43	// Decode deserializes a serialized UpdateFailMalformedHTLC message stored in the passed
44	// io.Reader observing the specified protocol version.
45	//
46	// This is part of the lnwire.Message interface.
47	func (c *UpdateFailMalformedHTLC) Decode(r io.Reader, pver uint32) error {	138✔
48	return ReadElements(r,	138✔
49	&c.ChanID,	138✔
50	&c.ID,	138✔
51	c.ShaOnionBlob[:],	138✔
52	&c.FailureCode,	138✔
53	&c.ExtraData,	138✔
54	)	138✔
55	}	138✔
56
57	// Encode serializes the target UpdateFailMalformedHTLC into the passed
58	// io.Writer observing the protocol version specified.
59	//
60	// This is part of the lnwire.Message interface.
61	func (c UpdateFailMalformedHTLC) Encode(w bytes.Buffer,
62	pver uint32) error {	121✔
63		121✔
64	if err := WriteChannelID(w, c.ChanID); err != nil {	121✔
65	return err	×
66	}	×
67
68	if err := WriteUint64(w, c.ID); err != nil {	121✔
69	return err	×
70	}	×
71
72	if err := WriteBytes(w, c.ShaOnionBlob[:]); err != nil {	121✔
73	return err	×
74	}	×
75
76	if err := WriteFailCode(w, c.FailureCode); err != nil {	121✔
77	return err	×
78	}	×
79
80	return WriteBytes(w, c.ExtraData)	121✔
81	}
82
83	// MsgType returns the integer uniquely identifying this message type on the
84	// wire.
85	//
86	// This is part of the lnwire.Message interface.
87	func (c *UpdateFailMalformedHTLC) MsgType() MessageType {	130✔
88	return MsgUpdateFailMalformedHTLC	130✔
89	}	130✔
90
91	// SerializedSize returns the serialized size of the message in bytes.
92	//
93	// This is part of the lnwire.SizeableMessage interface.
NEW 94	func (c *UpdateFailMalformedHTLC) SerializedSize() (uint32, error) {	×
NEW 95	return MessageSerializedSize(c)	×
NEW 96	}	×
97
98	// TargetChanID returns the channel id of the link for which this message is
99	// intended.
100	//
101	// NOTE: Part of peer.LinkUpdater interface.
102	func (c *UpdateFailMalformedHTLC) TargetChanID() ChannelID {	3✔
103	return c.ChanID	3✔
104	}	3✔

lightningnetwork / lnd / 13999301927

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