lnwire+htlcswitch: only use references for failure messages

Methods on failure message types used to be defined on value receivers.
This allowed assignment of a failure message to ForwardingError both as
a value and as a pointer. This is error-prone, especially when using a
type switch.

In this commit the failure message methods are changed so that they
target pointer receivers.

Two instances where a value was assigned instead of a reference are
fixed.
This commit is contained in:
Joost Jager 2019-07-03 12:51:13 +02:00
parent 418fe364de
commit c6f9517e48
No known key found for this signature in database
GPG Key ID: A61B9D4C393C59C7
4 changed files with 36 additions and 36 deletions

@ -1214,7 +1214,7 @@ func (l *channelLink) processHodlEvent(hodlEvent invoices.HodlEvent,
) )
case invoices.CancelExpiryTooSoon: case invoices.CancelExpiryTooSoon:
failure = lnwire.FailFinalExpiryTooSoon{} failure = &lnwire.FailFinalExpiryTooSoon{}
default: default:
return fmt.Errorf("unknown cancel reason: %v", return fmt.Errorf("unknown cancel reason: %v",

@ -981,7 +981,7 @@ func (s *Switch) parseFailedPayment(deobfuscator ErrorDecrypter,
return &ForwardingError{ return &ForwardingError{
FailureSourceIdx: 0, FailureSourceIdx: 0,
ExtraMsg: userErr, ExtraMsg: userErr,
FailureMessage: lnwire.FailPermanentChannelFailure{}, FailureMessage: &lnwire.FailPermanentChannelFailure{},
} }
// A regular multi-hop payment error that we'll need to // A regular multi-hop payment error that we'll need to

@ -162,14 +162,14 @@ type FailInvalidRealm struct{}
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailInvalidRealm) Error() string { func (f *FailInvalidRealm) Error() string {
return f.Code().String() return f.Code().String()
} }
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailInvalidRealm) Code() FailCode { func (f *FailInvalidRealm) Code() FailCode {
return CodeInvalidRealm return CodeInvalidRealm
} }
@ -181,14 +181,14 @@ type FailTemporaryNodeFailure struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailTemporaryNodeFailure) Code() FailCode { func (f *FailTemporaryNodeFailure) Code() FailCode {
return CodeTemporaryNodeFailure return CodeTemporaryNodeFailure
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailTemporaryNodeFailure) Error() string { func (f *FailTemporaryNodeFailure) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -201,14 +201,14 @@ type FailPermanentNodeFailure struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailPermanentNodeFailure) Code() FailCode { func (f *FailPermanentNodeFailure) Code() FailCode {
return CodePermanentNodeFailure return CodePermanentNodeFailure
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailPermanentNodeFailure) Error() string { func (f *FailPermanentNodeFailure) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -222,14 +222,14 @@ type FailRequiredNodeFeatureMissing struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailRequiredNodeFeatureMissing) Code() FailCode { func (f *FailRequiredNodeFeatureMissing) Code() FailCode {
return CodeRequiredNodeFeatureMissing return CodeRequiredNodeFeatureMissing
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailRequiredNodeFeatureMissing) Error() string { func (f *FailRequiredNodeFeatureMissing) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -242,14 +242,14 @@ type FailPermanentChannelFailure struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailPermanentChannelFailure) Code() FailCode { func (f *FailPermanentChannelFailure) Code() FailCode {
return CodePermanentChannelFailure return CodePermanentChannelFailure
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailPermanentChannelFailure) Error() string { func (f *FailPermanentChannelFailure) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -263,14 +263,14 @@ type FailRequiredChannelFeatureMissing struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailRequiredChannelFeatureMissing) Code() FailCode { func (f *FailRequiredChannelFeatureMissing) Code() FailCode {
return CodeRequiredChannelFeatureMissing return CodeRequiredChannelFeatureMissing
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailRequiredChannelFeatureMissing) Error() string { func (f *FailRequiredChannelFeatureMissing) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -283,14 +283,14 @@ type FailUnknownNextPeer struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailUnknownNextPeer) Code() FailCode { func (f *FailUnknownNextPeer) Code() FailCode {
return CodeUnknownNextPeer return CodeUnknownNextPeer
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailUnknownNextPeer) Error() string { func (f *FailUnknownNextPeer) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -306,14 +306,14 @@ type FailIncorrectPaymentAmount struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailIncorrectPaymentAmount) Code() FailCode { func (f *FailIncorrectPaymentAmount) Code() FailCode {
return CodeIncorrectPaymentAmount return CodeIncorrectPaymentAmount
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailIncorrectPaymentAmount) Error() string { func (f *FailIncorrectPaymentAmount) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -344,21 +344,21 @@ func NewFailUnknownPaymentHash(amt MilliSatoshi) *FailUnknownPaymentHash {
} }
// Amount is the value of the extended HTLC. // Amount is the value of the extended HTLC.
func (f FailUnknownPaymentHash) Amount() MilliSatoshi { func (f *FailUnknownPaymentHash) Amount() MilliSatoshi {
return f.amount return f.amount
} }
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailUnknownPaymentHash) Code() FailCode { func (f *FailUnknownPaymentHash) Code() FailCode {
return CodeUnknownPaymentHash return CodeUnknownPaymentHash
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailUnknownPaymentHash) Error() string { func (f *FailUnknownPaymentHash) Error() string {
return fmt.Sprintf("UnknownPaymentHash(amt=%v)", f.amount) return fmt.Sprintf("UnknownPaymentHash(amt=%v)", f.amount)
} }
@ -398,14 +398,14 @@ type FailFinalExpiryTooSoon struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailFinalExpiryTooSoon) Code() FailCode { func (f *FailFinalExpiryTooSoon) Code() FailCode {
return CodeFinalExpiryTooSoon return CodeFinalExpiryTooSoon
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailFinalExpiryTooSoon) Error() string { func (f *FailFinalExpiryTooSoon) Error() string {
return f.Code().String() return f.Code().String()
} }
@ -425,7 +425,7 @@ type FailInvalidOnionVersion struct {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailInvalidOnionVersion) Error() string { func (f *FailInvalidOnionVersion) Error() string {
return fmt.Sprintf("InvalidOnionVersion(onion_sha=%x)", f.OnionSHA256[:]) return fmt.Sprintf("InvalidOnionVersion(onion_sha=%x)", f.OnionSHA256[:])
} }
@ -492,7 +492,7 @@ func (f *FailInvalidOnionHmac) Encode(w io.Writer, pver uint32) error {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailInvalidOnionHmac) Error() string { func (f *FailInvalidOnionHmac) Error() string {
return fmt.Sprintf("InvalidOnionHMAC(onion_sha=%x)", f.OnionSHA256[:]) return fmt.Sprintf("InvalidOnionHMAC(onion_sha=%x)", f.OnionSHA256[:])
} }
@ -534,7 +534,7 @@ func (f *FailInvalidOnionKey) Encode(w io.Writer, pver uint32) error {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailInvalidOnionKey) Error() string { func (f *FailInvalidOnionKey) Error() string {
return fmt.Sprintf("InvalidOnionKey(onion_sha=%x)", f.OnionSHA256[:]) return fmt.Sprintf("InvalidOnionKey(onion_sha=%x)", f.OnionSHA256[:])
} }
@ -604,7 +604,7 @@ func (f *FailTemporaryChannelFailure) Code() FailCode {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailTemporaryChannelFailure) Error() string { func (f *FailTemporaryChannelFailure) Error() string {
if f.Update == nil { if f.Update == nil {
return f.Code().String() return f.Code().String()
} }
@ -688,7 +688,7 @@ func (f *FailAmountBelowMinimum) Code() FailCode {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailAmountBelowMinimum) Error() string { func (f *FailAmountBelowMinimum) Error() string {
return fmt.Sprintf("AmountBelowMinimum(amt=%v, update=%v", f.HtlcMsat, return fmt.Sprintf("AmountBelowMinimum(amt=%v, update=%v", f.HtlcMsat,
spew.Sdump(f.Update)) spew.Sdump(f.Update))
} }
@ -756,7 +756,7 @@ func (f *FailFeeInsufficient) Code() FailCode {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailFeeInsufficient) Error() string { func (f *FailFeeInsufficient) Error() string {
return fmt.Sprintf("FeeInsufficient(htlc_amt==%v, update=%v", f.HtlcMsat, return fmt.Sprintf("FeeInsufficient(htlc_amt==%v, update=%v", f.HtlcMsat,
spew.Sdump(f.Update)) spew.Sdump(f.Update))
} }
@ -945,7 +945,7 @@ func (f *FailChannelDisabled) Code() FailCode {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailChannelDisabled) Error() string { func (f *FailChannelDisabled) Error() string {
return fmt.Sprintf("ChannelDisabled(flags=%v, update=%v", f.Flags, return fmt.Sprintf("ChannelDisabled(flags=%v, update=%v", f.Flags,
spew.Sdump(f.Update)) spew.Sdump(f.Update))
} }
@ -993,7 +993,7 @@ type FailFinalIncorrectCltvExpiry struct {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailFinalIncorrectCltvExpiry) Error() string { func (f *FailFinalIncorrectCltvExpiry) Error() string {
return fmt.Sprintf("FinalIncorrectCltvExpiry(expiry=%v)", f.CltvExpiry) return fmt.Sprintf("FinalIncorrectCltvExpiry(expiry=%v)", f.CltvExpiry)
} }
@ -1038,7 +1038,7 @@ type FailFinalIncorrectHtlcAmount struct {
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailFinalIncorrectHtlcAmount) Error() string { func (f *FailFinalIncorrectHtlcAmount) Error() string {
return fmt.Sprintf("FinalIncorrectHtlcAmount(amt=%v)", return fmt.Sprintf("FinalIncorrectHtlcAmount(amt=%v)",
f.IncomingHTLCAmount) f.IncomingHTLCAmount)
} }
@ -1081,14 +1081,14 @@ type FailExpiryTooFar struct{}
// Code returns the failure unique code. // Code returns the failure unique code.
// //
// NOTE: Part of the FailureMessage interface. // NOTE: Part of the FailureMessage interface.
func (f FailExpiryTooFar) Code() FailCode { func (f *FailExpiryTooFar) Code() FailCode {
return CodeExpiryTooFar return CodeExpiryTooFar
} }
// Returns a human readable string describing the target FailureMessage. // Returns a human readable string describing the target FailureMessage.
// //
// NOTE: Implements the error interface. // NOTE: Implements the error interface.
func (f FailExpiryTooFar) Error() string { func (f *FailExpiryTooFar) Error() string {
return f.Code().String() return f.Code().String()
} }

@ -177,7 +177,7 @@ func TestFailUnknownPaymentHashOptionalAmount(t *testing.T) {
// Creation an error that is a non-pointer will allow us to skip the // Creation an error that is a non-pointer will allow us to skip the
// type assertion for the Serializable interface. As a result, the // type assertion for the Serializable interface. As a result, the
// amount body won't be written. // amount body won't be written.
onionError := FailUnknownPaymentHash{} onionError := &FailUnknownPaymentHash{}
var b bytes.Buffer var b bytes.Buffer
if err := EncodeFailure(&b, onionError, 0); err != nil { if err := EncodeFailure(&b, onionError, 0); err != nil {
@ -189,7 +189,7 @@ func TestFailUnknownPaymentHashOptionalAmount(t *testing.T) {
t.Fatalf("unable to decode error: %v", err) t.Fatalf("unable to decode error: %v", err)
} }
if !reflect.DeepEqual(onionError, onionError) { if !reflect.DeepEqual(onionError, onionError2) {
t.Fatalf("expected %v, got %v", spew.Sdump(onionError), t.Fatalf("expected %v, got %v", spew.Sdump(onionError),
spew.Sdump(onionError2)) spew.Sdump(onionError2))
} }