highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-03-26 17:52:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

routing: add first hop TLVs to ExtraData

Browse Source
This commit is contained in:
Olaoluwa Osuntokun 2024-04-26 16:39:56 -07:00
parent cbdcdac213
commit cf80b7cd9c
No known key found for this signature in database
GPG Key ID: 3BBD59E99B280306
1 changed files with 8 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
routing/payment_lifecycle.go
View File

@ -1,7 +1,6 @@
package routing
import (
"bytes"
"errors"
"fmt"
"time"
@ -11,6 +10,7 @@ import (
sphinx "github.com/lightningnetwork/lightning-onion"
"github.com/lightningnetwork/lnd/channeldb"
"github.com/lightningnetwork/lnd/channeldb/models"
"github.com/lightningnetwork/lnd/fn"
"github.com/lightningnetwork/lnd/htlcswitch"
"github.com/lightningnetwork/lnd/lntypes"
"github.com/lightningnetwork/lnd/lnwire"
@ -678,18 +678,15 @@ func (p *paymentLifecycle) sendAttempt(
PaymentHash: *attempt.Hash,
}
buffer := new(bytes.Buffer)
if err := p.firstHopTLVs.Encode(buffer); err != nil {
return p.failAttempt(attempt.AttemptID, err)
// If we had any first hop TLVs, then we'll encode that here now.
firstHopTLVs := tlv.MapToRecords(p.firstHopTLVs)
wireTLVs := fn.Map(func(r tlv.Record) tlv.RecordProducer {
return &r
}, firstHopTLVs)
if err := htlcAdd.ExtraData.PackRecords(wireTLVs...); err != nil {
return nil, err
}
recordsBytes := buffer.Bytes()
tlvRecord := tlv.NewPrimitiveRecord[lnwire.CustomRecordsBlobTlvType](
recordsBytes,
)
htlcAdd.CustomRecordsBlob = tlv.SomeRecordT(tlvRecord)
// Generate the raw encoded sphinx packet to be included along
// with the htlcAdd message that we send directly to the
// switch.