itest: accept NO_ROUTE or TIMEOUT in testLocalClaimOutgoingHTLC

Fix flaky test due to race between channel closure propagation and
payment timeout. Both failure reasons are correct depending on timing.
This commit is contained in:
ziggie committed 2025-12-19 00:27:20 +01:00
1 parent 91423ee519
commit c493f7d9dd
2 files changed
+50 -10

No files matched your search

+16 -10
View File
@@ -517,19 +517,25 @@ func runLocalClaimOutgoingHTLC(ht *lntest.HarnessTest,
// Now that Bob has claimed his HTLCs, Alice should mark the two
// payments as failed.
//
// Alice will mark this payment as failed with no route as the only
// route she has is Alice->Bob->Carol. This won't be the case if she
// has a second route, as another attempt will be tried.
//
// TODO(yy): we should instead mark this payment as timed out if she has
// a second route to try this payment, which is the timeout set by Alice
// when sending the payment.
expectedReason := lnrpc.PaymentFailureReason_FAILURE_REASON_NO_ROUTE
p := ht.AssertPaymentFailureReason(alice, preimage, expectedReason)
// Alice's payment can fail with either NO_ROUTE or TIMEOUT depending
// on timing. There's a race between:
// 1. The channel closure propagating to Alice's graph (-> NO_ROUTE)
// 2. The payment attempt timeout firing (-> TIMEOUT)
// Both failure reasons are correct.
p := ht.AssertPaymentFailureReasonAny(alice, preimage,
lnrpc.PaymentFailureReason_FAILURE_REASON_NO_ROUTE,
lnrpc.PaymentFailureReason_FAILURE_REASON_TIMEOUT,
)
// The HTLC-level failure code should be PERMANENT_CHANNEL_FAILURE
// regardless of which payment-level failure reason we got.
require.Equal(ht, lnrpc.Failure_PERMANENT_CHANNEL_FAILURE,
p.Htlcs[0].Failure.Code)
p = ht.AssertPaymentFailureReason(alice, preimageDust, expectedReason)
p = ht.AssertPaymentFailureReasonAny(alice, preimageDust,
lnrpc.PaymentFailureReason_FAILURE_REASON_NO_ROUTE,
lnrpc.PaymentFailureReason_FAILURE_REASON_TIMEOUT,
)
require.Equal(ht, lnrpc.Failure_PERMANENT_CHANNEL_FAILURE,
p.Htlcs[0].Failure.Code)
}
+34
View File
@@ -1648,6 +1648,40 @@ func (h *HarnessTest) AssertPaymentFailureReason(
return payment
}
// AssertPaymentFailureReasonAny asserts that the given node lists a payment
// with the given preimage which has one of the expected failure reasons.
func (h *HarnessTest) AssertPaymentFailureReasonAny(
hn *node.HarnessNode, preimage lntypes.Preimage,
reasons ...lnrpc.PaymentFailureReason) *lnrpc.Payment {
var payment *lnrpc.Payment
payHash := preimage.Hash()
err := wait.NoError(func() error {
p, err := h.findPayment(hn, payHash.String())
if err != nil {
return err
}
payment = p
// Check if the payment failure reason matches any of the
// expected reasons.
for _, reason := range reasons {
if reason == p.FailureReason {
return nil
}
}
return fmt.Errorf("payment: %v failure reason not match, "+
"want one of %v, got %s(%d)", payHash, reasons,
p.FailureReason, p.FailureReason)
}, DefaultTimeout)
require.NoError(h, err, "timeout checking payment failure reason")
return payment
}
// AssertActiveNodesSynced asserts all active nodes have synced to the chain.
func (h *HarnessTest) AssertActiveNodesSynced() {
for _, node := range h.manager.activeNodes {