mirror of
https://github.com/lightningnetwork/lnd.git
synced 2025-02-23 22:46:40 +01:00
Merge pull request #9359 from NishantBansal2003/fix-timeout
routerrpc: add a default value for timeout_seconds in SendPaymentV2
This commit is contained in:
commit
27df4af53e
28 changed files with 30 additions and 71 deletions
|
@ -94,6 +94,10 @@
|
||||||
are now [sorted](https://github.com/lightningnetwork/lnd/pull/9337) based on
|
are now [sorted](https://github.com/lightningnetwork/lnd/pull/9337) based on
|
||||||
the `InvoiceHTLC.HtlcIndex`.
|
the `InvoiceHTLC.HtlcIndex`.
|
||||||
|
|
||||||
|
* [routerrpc.SendPaymentV2](https://github.com/lightningnetwork/lnd/pull/9359)
|
||||||
|
RPC method now applies a default timeout of 60 seconds when the
|
||||||
|
`timeout_seconds` field is not set or is explicitly set to 0.
|
||||||
|
|
||||||
## lncli Additions
|
## lncli Additions
|
||||||
|
|
||||||
* [A pre-generated macaroon root key can now be specified in `lncli create` and
|
* [A pre-generated macaroon root key can now be specified in `lncli create` and
|
||||||
|
|
|
@ -118,7 +118,6 @@ func testSendPaymentAMPInvoiceCase(ht *lntest.HarnessTest,
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: addInvoiceResp.PaymentRequest,
|
PaymentRequest: addInvoiceResp.PaymentRequest,
|
||||||
PaymentAddr: externalPayAddr,
|
PaymentAddr: externalPayAddr,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
Amp: true,
|
Amp: true,
|
||||||
}
|
}
|
||||||
|
@ -400,7 +399,6 @@ func testSendPaymentAMP(ht *lntest.HarnessTest) {
|
||||||
Dest: mts.bob.PubKey[:],
|
Dest: mts.bob.PubKey[:],
|
||||||
Amt: int64(paymentAmt),
|
Amt: int64(paymentAmt),
|
||||||
FinalCltvDelta: chainreg.DefaultBitcoinTimeLockDelta,
|
FinalCltvDelta: chainreg.DefaultBitcoinTimeLockDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
Amp: true,
|
Amp: true,
|
||||||
}
|
}
|
||||||
|
|
|
@ -150,7 +150,6 @@ func testChannelUnsettledBalance(ht *lntest.HarnessTest) {
|
||||||
Amt: int64(payAmt),
|
Amt: int64(payAmt),
|
||||||
PaymentHash: ht.Random32Bytes(),
|
PaymentHash: ht.Random32Bytes(),
|
||||||
FinalCltvDelta: finalCltvDelta,
|
FinalCltvDelta: finalCltvDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
|
|
@ -111,7 +111,6 @@ func runChannelForceClosureTest(ht *lntest.HarnessTest,
|
||||||
Amt: int64(paymentAmt),
|
Amt: int64(paymentAmt),
|
||||||
PaymentHash: ht.Random32Bytes(),
|
PaymentHash: ht.Random32Bytes(),
|
||||||
FinalCltvDelta: finalCltvDelta,
|
FinalCltvDelta: finalCltvDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -811,7 +810,6 @@ func testFailingChannel(ht *lntest.HarnessTest) {
|
||||||
// won't work as the channel cannot be found.
|
// won't work as the channel cannot be found.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: resp.PaymentRequest,
|
PaymentRequest: resp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAndAssertStatus(alice, req, lnrpc.Payment_IN_FLIGHT)
|
ht.SendPaymentAndAssertStatus(alice, req, lnrpc.Payment_IN_FLIGHT)
|
||||||
|
|
|
@ -141,7 +141,6 @@ func testUpdateChannelPolicy(ht *lntest.HarnessTest) {
|
||||||
// not be able to find a path during routing.
|
// not be able to find a path during routing.
|
||||||
payReq := &routerrpc.SendPaymentRequest{
|
payReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: resp.PaymentRequest,
|
PaymentRequest: resp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertFail(
|
ht.SendPaymentAssertFail(
|
||||||
|
|
|
@ -73,7 +73,6 @@ func coopCloseWithHTLCs(ht *lntest.HarnessTest) {
|
||||||
// HTLC for it.
|
// HTLC for it.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: resp.PaymentRequest,
|
PaymentRequest: resp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitSat: 1000000,
|
FeeLimitSat: 1000000,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAndAssertStatus(bob, req, lnrpc.Payment_IN_FLIGHT)
|
ht.SendPaymentAndAssertStatus(bob, req, lnrpc.Payment_IN_FLIGHT)
|
||||||
|
@ -166,7 +165,6 @@ func coopCloseWithHTLCsWithRestart(ht *lntest.HarnessTest) {
|
||||||
// for it.
|
// for it.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: resp.PaymentRequest,
|
PaymentRequest: resp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitSat: 1000000,
|
FeeLimitSat: 1000000,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAndAssertStatus(bob, req, lnrpc.Payment_IN_FLIGHT)
|
ht.SendPaymentAndAssertStatus(bob, req, lnrpc.Payment_IN_FLIGHT)
|
||||||
|
|
|
@ -42,7 +42,6 @@ func testHoldInvoiceForceClose(ht *lntest.HarnessTest) {
|
||||||
// single htlc.
|
// single htlc.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: bobInvoice.PaymentRequest,
|
PaymentRequest: bobInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
|
|
@ -108,7 +108,6 @@ func testHoldInvoicePersistence(ht *lntest.HarnessTest) {
|
||||||
for _, payReq := range payReqs {
|
for _, payReq := range payReqs {
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: payReq,
|
PaymentRequest: payReq,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitSat: 1000000,
|
FeeLimitSat: 1000000,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -128,7 +128,6 @@ func testHtlcTimeoutResolverExtractPreimageRemote(ht *lntest.HarnessTest) {
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: eveInvoice.PaymentRequest,
|
PaymentRequest: eveInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -267,7 +266,6 @@ func testHtlcTimeoutResolverExtractPreimageLocal(ht *lntest.HarnessTest) {
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
|
|
@ -61,7 +61,6 @@ func testMaxHtlcPathfind(ht *lntest.HarnessTest) {
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
Amt: 1000,
|
Amt: 1000,
|
||||||
Dest: alice.PubKey[:],
|
Dest: alice.PubKey[:],
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitSat: 1000000,
|
FeeLimitSat: 1000000,
|
||||||
MaxParts: 10,
|
MaxParts: 10,
|
||||||
Amp: true,
|
Amp: true,
|
||||||
|
@ -130,7 +129,6 @@ func acceptHoldInvoice(ht *lntest.HarnessTest, idx int, sender,
|
||||||
|
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitSat: 1000000,
|
FeeLimitSat: 1000000,
|
||||||
}
|
}
|
||||||
payStream := sender.RPC.SendPayment(sendReq)
|
payStream := sender.RPC.SendPayment(sendReq)
|
||||||
|
|
|
@ -178,7 +178,6 @@ func testSphinxReplayPersistence(ht *lntest.HarnessTest) {
|
||||||
// to the above generated invoice.
|
// to the above generated invoice.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceResp.PaymentRequest,
|
PaymentRequest: invoiceResp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
payStream := fred.RPC.SendPayment(req)
|
payStream := fred.RPC.SendPayment(req)
|
||||||
|
@ -607,7 +606,6 @@ func testRejectHTLC(ht *lntest.HarnessTest) {
|
||||||
// lnd with --rejecthtlc.
|
// lnd with --rejecthtlc.
|
||||||
paymentReq := &routerrpc.SendPaymentRequest{
|
paymentReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: resp.PaymentRequest,
|
PaymentRequest: resp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertFail(
|
ht.SendPaymentAssertFail(
|
||||||
|
|
|
@ -63,7 +63,6 @@ func testSendMultiPathPayment(ht *lntest.HarnessTest) {
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: payReq,
|
PaymentRequest: payReq,
|
||||||
MaxParts: 10,
|
MaxParts: 10,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
payment := ht.SendPaymentAssertSettled(mts.alice, sendReq)
|
payment := ht.SendPaymentAssertSettled(mts.alice, sendReq)
|
||||||
|
|
|
@ -134,7 +134,6 @@ func testHtlcErrorPropagation(ht *lntest.HarnessTest) {
|
||||||
Dest: carol.PubKey[:],
|
Dest: carol.PubKey[:],
|
||||||
Amt: payAmt,
|
Amt: payAmt,
|
||||||
FinalCltvDelta: int32(carolPayReq.CltvExpiry),
|
FinalCltvDelta: int32(carolPayReq.CltvExpiry),
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
MaxParts: 1,
|
MaxParts: 1,
|
||||||
}
|
}
|
||||||
|
@ -203,7 +202,6 @@ func testHtlcErrorPropagation(ht *lntest.HarnessTest) {
|
||||||
// 10k satoshis are expected.
|
// 10k satoshis are expected.
|
||||||
Amt: int64(htlcAmt.ToSatoshis()),
|
Amt: int64(htlcAmt.ToSatoshis()),
|
||||||
FinalCltvDelta: int32(carolPayReq.CltvExpiry),
|
FinalCltvDelta: int32(carolPayReq.CltvExpiry),
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
MaxParts: 1,
|
MaxParts: 1,
|
||||||
}
|
}
|
||||||
|
@ -251,7 +249,6 @@ func testHtlcErrorPropagation(ht *lntest.HarnessTest) {
|
||||||
|
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice2.PaymentRequest,
|
PaymentRequest: carolInvoice2.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
MaxParts: 1,
|
MaxParts: 1,
|
||||||
}
|
}
|
||||||
|
@ -287,7 +284,6 @@ func testHtlcErrorPropagation(ht *lntest.HarnessTest) {
|
||||||
|
|
||||||
sendReq = &routerrpc.SendPaymentRequest{
|
sendReq = &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice3.PaymentRequest,
|
PaymentRequest: carolInvoice3.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
MaxParts: 1,
|
MaxParts: 1,
|
||||||
}
|
}
|
||||||
|
@ -336,7 +332,6 @@ func testHtlcErrorPropagation(ht *lntest.HarnessTest) {
|
||||||
|
|
||||||
req = &routerrpc.SendPaymentRequest{
|
req = &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
MaxParts: 1,
|
MaxParts: 1,
|
||||||
}
|
}
|
||||||
|
|
|
@ -372,7 +372,6 @@ func runLocalClaimOutgoingHTLC(ht *lntest.HarnessTest,
|
||||||
Amt: int64(dustHtlcAmt),
|
Amt: int64(dustHtlcAmt),
|
||||||
PaymentHash: dustPayHash,
|
PaymentHash: dustPayHash,
|
||||||
FinalCltvDelta: finalCltvDelta,
|
FinalCltvDelta: finalCltvDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
RouteHints: routeHints,
|
RouteHints: routeHints,
|
||||||
}
|
}
|
||||||
|
@ -383,7 +382,6 @@ func runLocalClaimOutgoingHTLC(ht *lntest.HarnessTest,
|
||||||
Amt: int64(htlcAmt),
|
Amt: int64(htlcAmt),
|
||||||
PaymentHash: payHash,
|
PaymentHash: payHash,
|
||||||
FinalCltvDelta: finalCltvDelta,
|
FinalCltvDelta: finalCltvDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
RouteHints: routeHints,
|
RouteHints: routeHints,
|
||||||
}
|
}
|
||||||
|
@ -726,7 +724,6 @@ func runMultiHopReceiverPreimageClaim(ht *lntest.HarnessTest,
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -1093,7 +1090,6 @@ func runLocalForceCloseBeforeHtlcTimeout(ht *lntest.HarnessTest,
|
||||||
Amt: int64(htlcAmt),
|
Amt: int64(htlcAmt),
|
||||||
PaymentHash: payHash,
|
PaymentHash: payHash,
|
||||||
FinalCltvDelta: finalCltvDelta,
|
FinalCltvDelta: finalCltvDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
RouteHints: routeHints,
|
RouteHints: routeHints,
|
||||||
}
|
}
|
||||||
|
@ -1415,7 +1411,6 @@ func runRemoteForceCloseBeforeHtlcTimeout(ht *lntest.HarnessTest,
|
||||||
|
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -1685,7 +1680,6 @@ func runLocalClaimIncomingHTLC(ht *lntest.HarnessTest,
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -1998,7 +1992,6 @@ func runLocalClaimIncomingHTLCLeased(ht *lntest.HarnessTest,
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -2349,7 +2342,6 @@ func runLocalPreimageClaim(ht *lntest.HarnessTest,
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -2655,7 +2647,6 @@ func runLocalPreimageClaimLeased(ht *lntest.HarnessTest,
|
||||||
// will not immediately settle the payment.
|
// will not immediately settle the payment.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -3104,7 +3095,6 @@ func runHtlcAggregation(ht *lntest.HarnessTest,
|
||||||
for _, carolInvoice := range carolInvoices {
|
for _, carolInvoice := range carolInvoices {
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: carolInvoice.PaymentRequest,
|
PaymentRequest: carolInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(alice, req)
|
ht.SendPaymentAssertInflight(alice, req)
|
||||||
|
@ -3114,7 +3104,6 @@ func runHtlcAggregation(ht *lntest.HarnessTest,
|
||||||
for _, aliceInvoice := range aliceInvoices {
|
for _, aliceInvoice := range aliceInvoices {
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: aliceInvoice.PaymentRequest,
|
PaymentRequest: aliceInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertInflight(carol, req)
|
ht.SendPaymentAssertInflight(carol, req)
|
||||||
|
|
|
@ -674,7 +674,6 @@ func testUpdateOnFunderPendingOpenChannels(ht *lntest.HarnessTest) {
|
||||||
// in-flight instead of being failed by Alice.
|
// in-flight instead of being failed by Alice.
|
||||||
bobReq := &routerrpc.SendPaymentRequest{
|
bobReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
bobStream := bob.RPC.SendPayment(bobReq)
|
bobStream := bob.RPC.SendPayment(bobReq)
|
||||||
|
@ -750,7 +749,6 @@ func testUpdateOnFundeePendingOpenChannels(ht *lntest.HarnessTest) {
|
||||||
// in-flight instead of being failed by Bob.
|
// in-flight instead of being failed by Bob.
|
||||||
aliceReq := &routerrpc.SendPaymentRequest{
|
aliceReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: bobInvoice.PaymentRequest,
|
PaymentRequest: bobInvoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
aliceStream := alice.RPC.SendPayment(aliceReq)
|
aliceStream := alice.RPC.SendPayment(aliceReq)
|
||||||
|
|
|
@ -1086,7 +1086,6 @@ func sendPaymentInterceptAndCancel(ht *lntest.HarnessTest,
|
||||||
go func() {
|
go func() {
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitSat: 100000,
|
FeeLimitSat: 100000,
|
||||||
Cancelable: true,
|
Cancelable: true,
|
||||||
}
|
}
|
||||||
|
|
|
@ -37,7 +37,6 @@ func testQuiescence(ht *lntest.HarnessTest) {
|
||||||
Amt: 100,
|
Amt: 100,
|
||||||
PaymentHash: ht.Random32Bytes(),
|
PaymentHash: ht.Random32Bytes(),
|
||||||
FinalCltvDelta: finalCltvDelta,
|
FinalCltvDelta: finalCltvDelta,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -552,7 +552,6 @@ func (b *blindedForwardTest) drainCarolLiquidity(incoming bool) {
|
||||||
pmtClient := sendingNode.RPC.SendPayment(
|
pmtClient := sendingNode.RPC.SendPayment(
|
||||||
&routerrpc.SendPaymentRequest{
|
&routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -957,7 +956,6 @@ func testMPPToSingleBlindedPath(ht *lntest.HarnessTest) {
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceResp.PaymentRequest,
|
PaymentRequest: invoiceResp.PaymentRequest,
|
||||||
MaxParts: 10,
|
MaxParts: 10,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
payment := ht.SendPaymentAssertSettled(alice, sendReq)
|
payment := ht.SendPaymentAssertSettled(alice, sendReq)
|
||||||
|
@ -1302,7 +1300,6 @@ func testMPPToMultipleBlindedPaths(ht *lntest.HarnessTest) {
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceResp.PaymentRequest,
|
PaymentRequest: invoiceResp.PaymentRequest,
|
||||||
MaxParts: 10,
|
MaxParts: 10,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
payment := ht.SendPaymentAssertSettled(alice, sendReq)
|
payment := ht.SendPaymentAssertSettled(alice, sendReq)
|
||||||
|
|
|
@ -1429,7 +1429,6 @@ func testRouteFeeCutoff(ht *lntest.HarnessTest) {
|
||||||
|
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceResp.PaymentRequest,
|
PaymentRequest: invoiceResp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
switch limit := feeLimit.Limit.(type) {
|
switch limit := feeLimit.Limit.(type) {
|
||||||
|
@ -1529,7 +1528,6 @@ func testFeeLimitAfterQueryRoutes(ht *lntest.HarnessTest) {
|
||||||
invoiceResp := carol.RPC.AddInvoice(invoice)
|
invoiceResp := carol.RPC.AddInvoice(invoice)
|
||||||
sendReq := &routerrpc.SendPaymentRequest{
|
sendReq := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceResp.PaymentRequest,
|
PaymentRequest: invoiceResp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: 0,
|
FeeLimitMsat: 0,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -85,7 +85,6 @@ func testSingleHopInvoice(ht *lntest.HarnessTest) {
|
||||||
DestCustomRecords: map[uint64][]byte{
|
DestCustomRecords: map[uint64][]byte{
|
||||||
record.KeySendType: keySendPreimage[:],
|
record.KeySendType: keySendPreimage[:],
|
||||||
},
|
},
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertSettled(alice, req)
|
ht.SendPaymentAssertSettled(alice, req)
|
||||||
|
|
|
@ -136,7 +136,6 @@ func testSweepCPFPAnchorOutgoingTimeout(ht *lntest.HarnessTest) {
|
||||||
// Let Alice pay the invoices.
|
// Let Alice pay the invoices.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -463,7 +462,6 @@ func testSweepCPFPAnchorIncomingTimeout(ht *lntest.HarnessTest) {
|
||||||
// Let Alice pay the invoices.
|
// Let Alice pay the invoices.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -820,12 +818,10 @@ func testSweepHTLCs(ht *lntest.HarnessTest) {
|
||||||
// Let Alice pay the invoices.
|
// Let Alice pay the invoices.
|
||||||
req1 := &routerrpc.SendPaymentRequest{
|
req1 := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceSettle.PaymentRequest,
|
PaymentRequest: invoiceSettle.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
req2 := &routerrpc.SendPaymentRequest{
|
req2 := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoiceHold.PaymentRequest,
|
PaymentRequest: invoiceHold.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -1318,7 +1314,6 @@ func testSweepCommitOutputAndAnchor(ht *lntest.HarnessTest) {
|
||||||
// succeeded.
|
// succeeded.
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: resp.PaymentRequest,
|
PaymentRequest: resp.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertSettled(alice, req)
|
ht.SendPaymentAssertSettled(alice, req)
|
||||||
|
|
|
@ -45,7 +45,6 @@ func testTrackPayments(ht *lntest.HarnessTest) {
|
||||||
paymentClient := alice.RPC.SendPayment(
|
paymentClient := alice.RPC.SendPayment(
|
||||||
&routerrpc.SendPaymentRequest{
|
&routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -116,7 +115,6 @@ func testTrackPaymentsCompatible(ht *lntest.HarnessTest) {
|
||||||
paymentClient := alice.RPC.SendPayment(
|
paymentClient := alice.RPC.SendPayment(
|
||||||
&routerrpc.SendPaymentRequest{
|
&routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: invoice.PaymentRequest,
|
PaymentRequest: invoice.PaymentRequest,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
|
@ -657,7 +657,6 @@ func generateBackups(ht *lntest.HarnessTest, srcNode,
|
||||||
send := func(node *node.HarnessNode, payReq string) {
|
send := func(node *node.HarnessNode, payReq string) {
|
||||||
req := &routerrpc.SendPaymentRequest{
|
req := &routerrpc.SendPaymentRequest{
|
||||||
PaymentRequest: payReq,
|
PaymentRequest: payReq,
|
||||||
TimeoutSeconds: 60,
|
|
||||||
FeeLimitMsat: noFeeLimitMsat,
|
FeeLimitMsat: noFeeLimitMsat,
|
||||||
}
|
}
|
||||||
ht.SendPaymentAssertSettled(node, req)
|
ht.SendPaymentAssertSettled(node, req)
|
||||||
|
|
|
@ -427,10 +427,11 @@ type SendPaymentRequest struct {
|
||||||
// that case it is required to set the amt field as well. If no payment request
|
// that case it is required to set the amt field as well. If no payment request
|
||||||
// is specified, the following fields are required: dest, amt and payment_hash.
|
// is specified, the following fields are required: dest, amt and payment_hash.
|
||||||
PaymentRequest string `protobuf:"bytes,5,opt,name=payment_request,json=paymentRequest,proto3" json:"payment_request,omitempty"`
|
PaymentRequest string `protobuf:"bytes,5,opt,name=payment_request,json=paymentRequest,proto3" json:"payment_request,omitempty"`
|
||||||
// An upper limit on the amount of time we should spend when attempting to
|
// An optional limit, expressed in seconds, on the time to wait before
|
||||||
// fulfill the payment. This is expressed in seconds. If we cannot make a
|
// attempting the first HTLC. Once HTLCs are in flight, the payment will
|
||||||
// successful payment within this time frame, an error will be returned.
|
// not be aborted until the HTLCs are either settled or failed. If the field
|
||||||
// This field must be non-zero.
|
// is not set or is explicitly set to zero, the default value of 60 seconds
|
||||||
|
// will be applied.
|
||||||
TimeoutSeconds int32 `protobuf:"varint,6,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
|
TimeoutSeconds int32 `protobuf:"varint,6,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
|
||||||
// The maximum number of satoshis that will be paid as a fee of the payment.
|
// The maximum number of satoshis that will be paid as a fee of the payment.
|
||||||
// If this field is left to the default value of 0, only zero-fee routes will
|
// If this field is left to the default value of 0, only zero-fee routes will
|
||||||
|
|
|
@ -227,10 +227,11 @@ message SendPaymentRequest {
|
||||||
string payment_request = 5;
|
string payment_request = 5;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
An upper limit on the amount of time we should spend when attempting to
|
An optional limit, expressed in seconds, on the time to wait before
|
||||||
fulfill the payment. This is expressed in seconds. If we cannot make a
|
attempting the first HTLC. Once HTLCs are in flight, the payment will
|
||||||
successful payment within this time frame, an error will be returned.
|
not be aborted until the HTLCs are either settled or failed. If the field
|
||||||
This field must be non-zero.
|
is not set or is explicitly set to zero, the default value of 60 seconds
|
||||||
|
will be applied.
|
||||||
*/
|
*/
|
||||||
int32 timeout_seconds = 6;
|
int32 timeout_seconds = 6;
|
||||||
|
|
||||||
|
|
|
@ -1894,7 +1894,7 @@
|
||||||
"timeout_seconds": {
|
"timeout_seconds": {
|
||||||
"type": "integer",
|
"type": "integer",
|
||||||
"format": "int32",
|
"format": "int32",
|
||||||
"description": "An upper limit on the amount of time we should spend when attempting to\nfulfill the payment. This is expressed in seconds. If we cannot make a\nsuccessful payment within this time frame, an error will be returned.\nThis field must be non-zero."
|
"description": "An optional limit, expressed in seconds, on the time to wait before\nattempting the first HTLC. Once HTLCs are in flight, the payment will\nnot be aborted until the HTLCs are either settled or failed. If the field\nis not set or is explicitly set to zero, the default value of 60 seconds\nwill be applied."
|
||||||
},
|
},
|
||||||
"fee_limit_sat": {
|
"fee_limit_sat": {
|
||||||
"type": "string",
|
"type": "string",
|
||||||
|
|
|
@ -878,11 +878,6 @@ func (r *RouterBackend) extractIntentFromSendRequest(
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
// Set payment attempt timeout.
|
|
||||||
if rpcPayReq.TimeoutSeconds == 0 {
|
|
||||||
return nil, errors.New("timeout_seconds must be specified")
|
|
||||||
}
|
|
||||||
|
|
||||||
customRecords := record.CustomSet(rpcPayReq.DestCustomRecords)
|
customRecords := record.CustomSet(rpcPayReq.DestCustomRecords)
|
||||||
if err := customRecords.Validate(); err != nil {
|
if err := customRecords.Validate(); err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|
|
@ -40,6 +40,10 @@ const (
|
||||||
// routeFeeLimitSat is the maximum routing fee that we allow to occur
|
// routeFeeLimitSat is the maximum routing fee that we allow to occur
|
||||||
// when estimating a routing fee.
|
// when estimating a routing fee.
|
||||||
routeFeeLimitSat = 100_000_000
|
routeFeeLimitSat = 100_000_000
|
||||||
|
|
||||||
|
// DefaultPaymentTimeout is the default value of time we should spend
|
||||||
|
// when attempting to fulfill the payment.
|
||||||
|
DefaultPaymentTimeout int32 = 60
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
|
@ -344,6 +348,11 @@ func (r *ServerShell) CreateSubServer(configRegistry lnrpc.SubServerConfigDispat
|
||||||
func (s *Server) SendPaymentV2(req *SendPaymentRequest,
|
func (s *Server) SendPaymentV2(req *SendPaymentRequest,
|
||||||
stream Router_SendPaymentV2Server) error {
|
stream Router_SendPaymentV2Server) error {
|
||||||
|
|
||||||
|
// Set payment request attempt timeout.
|
||||||
|
if req.TimeoutSeconds == 0 {
|
||||||
|
req.TimeoutSeconds = DefaultPaymentTimeout
|
||||||
|
}
|
||||||
|
|
||||||
payment, err := s.cfg.RouterBackend.extractIntentFromSendRequest(req)
|
payment, err := s.cfg.RouterBackend.extractIntentFromSendRequest(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|
Loading…
Add table
Reference in a new issue