mirror of https://github.com/BTCPrivate/lnd.git
lnwire: add update_fee message type.
This commit is contained in:
parent
9c16319e0d
commit
a3836d5241
|
@ -523,6 +523,12 @@ func TestLightningWireProtocol(t *testing.T) {
|
||||||
return mainScenario(&m)
|
return mainScenario(&m)
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
msgType: MsgUpdateFee,
|
||||||
|
scenario: func(m UpdateFee) bool {
|
||||||
|
return mainScenario(&m)
|
||||||
|
},
|
||||||
|
},
|
||||||
{
|
{
|
||||||
msgType: MsgChannelAnnouncement,
|
msgType: MsgChannelAnnouncement,
|
||||||
scenario: func(m ChannelAnnouncement) bool {
|
scenario: func(m ChannelAnnouncement) bool {
|
||||||
|
|
|
@ -39,6 +39,7 @@ const (
|
||||||
MsgUpdateFailHTLC = 131
|
MsgUpdateFailHTLC = 131
|
||||||
MsgCommitSig = 132
|
MsgCommitSig = 132
|
||||||
MsgRevokeAndAck = 133
|
MsgRevokeAndAck = 133
|
||||||
|
MsgUpdateFee = 137
|
||||||
MsgChannelAnnouncement = 256
|
MsgChannelAnnouncement = 256
|
||||||
MsgNodeAnnouncement = 257
|
MsgNodeAnnouncement = 257
|
||||||
MsgChannelUpdate = 258
|
MsgChannelUpdate = 258
|
||||||
|
@ -149,6 +150,8 @@ func makeEmptyMessage(msgType MessageType) (Message, error) {
|
||||||
msg = &CommitSig{}
|
msg = &CommitSig{}
|
||||||
case MsgRevokeAndAck:
|
case MsgRevokeAndAck:
|
||||||
msg = &RevokeAndAck{}
|
msg = &RevokeAndAck{}
|
||||||
|
case MsgUpdateFee:
|
||||||
|
msg = &UpdateFee{}
|
||||||
case MsgError:
|
case MsgError:
|
||||||
msg = &Error{}
|
msg = &Error{}
|
||||||
case MsgChannelAnnouncement:
|
case MsgChannelAnnouncement:
|
||||||
|
|
|
@ -0,0 +1,69 @@
|
||||||
|
package lnwire
|
||||||
|
|
||||||
|
import (
|
||||||
|
"io"
|
||||||
|
|
||||||
|
"github.com/roasbeef/btcutil"
|
||||||
|
)
|
||||||
|
|
||||||
|
// UpdateFee is the message the channel initiator sends to the other peer if
|
||||||
|
// the channel commitment fee needs to be updated.
|
||||||
|
type UpdateFee struct {
|
||||||
|
// ChanID is the channel that this UpdateFee is meant for.
|
||||||
|
ChanID ChannelID
|
||||||
|
|
||||||
|
// FeePerKw is the fee-per-kw on commit transactions that the sender of
|
||||||
|
// this message wants to use for this channel.
|
||||||
|
FeePerKw btcutil.Amount
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewUpdateFee creates a new UpdateFee message.
|
||||||
|
func NewUpdateFee(chanID ChannelID, feePerKw btcutil.Amount) *UpdateFee {
|
||||||
|
return &UpdateFee{
|
||||||
|
ChanID: chanID,
|
||||||
|
FeePerKw: feePerKw,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// A compile time check to ensure UpdateFee implements the lnwire.Message
|
||||||
|
// interface.
|
||||||
|
var _ Message = (*UpdateFee)(nil)
|
||||||
|
|
||||||
|
// Decode deserializes a serialized UpdateFee message stored in the
|
||||||
|
// passed io.Reader observing the specified protocol version.
|
||||||
|
//
|
||||||
|
// This is part of the lnwire.Message interface.
|
||||||
|
func (c *UpdateFee) Decode(r io.Reader, pver uint32) error {
|
||||||
|
return readElements(r,
|
||||||
|
&c.ChanID,
|
||||||
|
&c.FeePerKw,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Encode serializes the target UpdateFee into the passed io.Writer
|
||||||
|
// observing the protocol version specified.
|
||||||
|
//
|
||||||
|
// This is part of the lnwire.Message interface.
|
||||||
|
func (c *UpdateFee) Encode(w io.Writer, pver uint32) error {
|
||||||
|
return writeElements(w,
|
||||||
|
c.ChanID,
|
||||||
|
c.FeePerKw,
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
// MsgType returns the integer uniquely identifying this message type on the
|
||||||
|
// wire.
|
||||||
|
//
|
||||||
|
// This is part of the lnwire.Message interface.
|
||||||
|
func (c *UpdateFee) MsgType() MessageType {
|
||||||
|
return MsgUpdateFee
|
||||||
|
}
|
||||||
|
|
||||||
|
// MaxPayloadLength returns the maximum allowed payload size for a
|
||||||
|
// UpdateFee complete message observing the specified protocol version.
|
||||||
|
//
|
||||||
|
// This is part of the lnwire.Message interface.
|
||||||
|
func (c *UpdateFee) MaxPayloadLength(uint32) uint32 {
|
||||||
|
// 32 + 8
|
||||||
|
return 40
|
||||||
|
}
|
Loading…
Reference in New Issue