mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2024-11-19 09:52:09 +01:00
Code Issues Packages Projects Releases Wiki Activity

Lnd probing: only update route with mpp record if we can (#4293)

Browse Source
This commit is contained in:
benthecarman 2022-04-27 08:34:04 -05:00 committed by GitHub
parent 6db1f26625
commit 16c13568a9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lnd-rpc/src/main/scala/org/bitcoins/lnd/rpc/internal/LndRouterClient.scala
View File

@ -73,15 +73,20 @@ trait LndRouterClient { self: LndRpcClient =>
}
def sendToRoute(invoice: LnInvoice, route: Route): Future[HTLCAttempt] = {
val milliSatoshis =
invoice.amount.map(MilliSatoshis(_)).getOrElse(MilliSatoshis.zero)
val last = route.hops.last
val secret = invoice.lnTags.secret.get.secret.bytes
val mpp =
MPPRecord(paymentAddr = secret, totalAmtMsat = milliSatoshis.toLong)
val update = last.copy(mppRecord = Some(mpp), tlvPayload = true)
val updatedHops = route.hops.init :+ update
val updatedRoute = route.copy(hops = updatedHops)
val updatedRoute = invoice.lnTags.secret match {
case Some(secretTag) =>
val milliSatoshis =
invoice.amount.map(MilliSatoshis(_)).getOrElse(MilliSatoshis.zero)
val last = route.hops.last
val secret = secretTag.secret.bytes
val mpp =
MPPRecord(paymentAddr = secret, totalAmtMsat = milliSatoshis.toLong)
val update = last.copy(mppRecord = Some(mpp), tlvPayload = true)
val updatedHops = route.hops.init :+ update
route.copy(hops = updatedHops)
case None => route
}
val request =
SendToRouteRequest(paymentHash = invoice.lnTags.paymentHash.bytes,