Skip to content

Commit 37e752e

Browse files
carlaKCcarlaKC
committed
ln+events+liquidity/refactor: rename FailedPayment to ReceiveRejected
Rename variant to be more specific to the current context - a FailedPayment could be a payment that we failed to dispatch or one that we rejected on receive.
1 parent 739ad69 commit 37e752e

14 files changed

+94
-94
lines changed

‎lightning/src/events/mod.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -502,7 +502,7 @@ pub enum HTLCHandlingType {
502502
/// * The counterparty node modified the HTLC in transit,
503503
/// * A probing attack where an intermediary node is trying to detect if we are the ultimate
504504
/// recipient for a payment.
505-
FailedPayment {
505+
ReceiveFailed {
506506
/// The payment hash of the payment we attempted to process.
507507
payment_hash: PaymentHash
508508
},
@@ -520,7 +520,7 @@ impl_writeable_tlv_based_enum_upgradable!(HTLCHandlingType,
520520
(0, requested_forward_scid, required),
521521
},
522522
(3, InvalidOnion) => {},
523-
(4, FailedPayment) => {
523+
(4, ReceiveFailed) => {
524524
(0, payment_hash, required),
525525
},
526526
);

‎lightning/src/ln/async_payments_tests.rs‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -172,7 +172,7 @@ fn invalid_keysend_payment_secret() {
172172
PassAlongPathArgs::new(&nodes[0], &expected_route[0], amt_msat, payment_hash, ev.clone())
173173
.with_payment_secret(invalid_payment_secret)
174174
.with_payment_preimage(keysend_preimage)
175-
.expect_failure(HTLCHandlingType::FailedPayment { payment_hash });
175+
.expect_failure(HTLCHandlingType::ReceiveFailed { payment_hash });
176176
do_pass_along_path(args);
177177

178178
let updates_2_1 = get_htlc_update_msgs!(nodes[2], nodes[1].node.get_our_node_id());
@@ -701,7 +701,7 @@ fn amount_doesnt_match_invreq() {
701701
let args = PassAlongPathArgs::new(&nodes[0], route[0], amt_msat, payment_hash, ev)
702702
.with_payment_preimage(keysend_preimage)
703703
.without_claimable_event()
704-
.expect_failure(HTLCHandlingType::FailedPayment { payment_hash });
704+
.expect_failure(HTLCHandlingType::ReceiveFailed { payment_hash });
705705
do_pass_along_path(args);
706706

707707
// Modify the invoice request stored in our outbounds to be the correct one, to make sure the
@@ -917,7 +917,7 @@ fn invalid_async_receive_with_retry<F1, F2>(
917917
nodes[2].node.fail_htlc_backwards(&payment_hash);
918918
expect_pending_htlcs_forwardable_conditions(
919919
nodes[2].node.get_and_clear_pending_events(),
920-
&[HTLCHandlingType::FailedPayment { payment_hash }],
920+
&[HTLCHandlingType::ReceiveFailed { payment_hash }],
921921
);
922922
nodes[2].node.process_pending_htlc_forwards();
923923
check_added_monitors!(nodes[2], 1);
@@ -937,7 +937,7 @@ fn invalid_async_receive_with_retry<F1, F2>(
937937
let args = PassAlongPathArgs::new(&nodes[0], route[0], amt_msat, payment_hash, ev)
938938
.with_payment_preimage(keysend_preimage)
939939
.without_claimable_event()
940-
.expect_failure(HTLCHandlingType::FailedPayment { payment_hash });
940+
.expect_failure(HTLCHandlingType::ReceiveFailed { payment_hash });
941941
do_pass_along_path(args);
942942
fail_blinded_htlc_backwards(payment_hash, 1, &[&nodes[0], &nodes[1], &nodes[2]], true);
943943

@@ -1103,7 +1103,7 @@ fn expired_static_invoice_payment_path() {
11031103
let args = PassAlongPathArgs::new(&nodes[0], route[0], amt_msat, payment_hash, ev)
11041104
.with_payment_preimage(keysend_preimage)
11051105
.without_claimable_event()
1106-
.expect_failure(HTLCHandlingType::FailedPayment { payment_hash });
1106+
.expect_failure(HTLCHandlingType::ReceiveFailed { payment_hash });
11071107
do_pass_along_path(args);
11081108
fail_blinded_htlc_backwards(payment_hash, 1, &[&nodes[0], &nodes[1], &nodes[2]], false);
11091109
nodes[2].logger.assert_log_contains(

‎lightning/src/ln/blinded_payment_tests.rs‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -830,7 +830,7 @@ fn three_hop_blinded_path_fail() {
830830

831831
nodes[3].node.fail_htlc_backwards(&payment_hash);
832832
expect_pending_htlcs_forwardable_conditions(
833-
nodes[3].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash }]
833+
nodes[3].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash }]
834834
);
835835
nodes[3].node.process_pending_htlc_forwards();
836836
check_added_monitors!(nodes[3], 1);
@@ -958,7 +958,7 @@ fn do_multi_hop_receiver_fail(check: ReceiveCheckFail) {
958958
);
959959
nodes[2].node.fail_htlc_backwards(&payment_hash);
960960
expect_pending_htlcs_forwardable_conditions(
961-
nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash }]
961+
nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash }]
962962
);
963963
nodes[2].node.process_pending_htlc_forwards();
964964
check_added_monitors!(nodes[2], 1);
@@ -998,7 +998,7 @@ fn do_multi_hop_receiver_fail(check: ReceiveCheckFail) {
998998
check_added_monitors!(nodes[2], 0);
999999
do_commitment_signed_dance(&nodes[2], &nodes[1], &payment_event_1_2.commitment_msg, true, true);
10001000
expect_pending_htlcs_forwardable!(nodes[2]);
1001-
expect_htlc_handling_failed_destinations!(nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash }]);
1001+
expect_htlc_handling_failed_destinations!(nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash }]);
10021002
check_added_monitors(&nodes[2], 1);
10031003
},
10041004
ReceiveCheckFail::ChannelCheck => {
@@ -1014,7 +1014,7 @@ fn do_multi_hop_receiver_fail(check: ReceiveCheckFail) {
10141014
nodes[2].node.handle_shutdown(nodes[1].node.get_our_node_id(), &node_1_shutdown);
10151015
commitment_signed_dance!(nodes[2], nodes[1], (), false, true, false, false);
10161016
expect_pending_htlcs_forwardable!(nodes[2]);
1017-
expect_htlc_handling_failed_destinations!(nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash }]);
1017+
expect_htlc_handling_failed_destinations!(nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash }]);
10181018
check_added_monitors(&nodes[2], 1);
10191019
},
10201020
ReceiveCheckFail::ProcessPendingHTLCsCheck => {
@@ -1024,15 +1024,15 @@ fn do_multi_hop_receiver_fail(check: ReceiveCheckFail) {
10241024
do_commitment_signed_dance(&nodes[2], &nodes[1], &payment_event_1_2.commitment_msg, true, true);
10251025
expect_pending_htlcs_forwardable!(nodes[2]);
10261026
expect_pending_htlcs_forwardable_and_htlc_handling_failed_ignore!(nodes[2],
1027-
vec![HTLCHandlingType::FailedPayment { payment_hash }]);
1027+
vec![HTLCHandlingType::ReceiveFailed { payment_hash }]);
10281028
check_added_monitors!(nodes[2], 1);
10291029
},
10301030
ReceiveCheckFail::PaymentConstraints => {
10311031
nodes[2].node.handle_update_add_htlc(nodes[1].node.get_our_node_id(), &payment_event_1_2.msgs[0]);
10321032
check_added_monitors!(nodes[2], 0);
10331033
do_commitment_signed_dance(&nodes[2], &nodes[1], &payment_event_1_2.commitment_msg, true, true);
10341034
expect_pending_htlcs_forwardable!(nodes[2]);
1035-
expect_htlc_handling_failed_destinations!(nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash }]);
1035+
expect_htlc_handling_failed_destinations!(nodes[2].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash }]);
10361036
check_added_monitors(&nodes[2], 1);
10371037
}
10381038
}
@@ -1121,7 +1121,7 @@ fn blinded_path_retries() {
11211121
($intro_node: expr) => {
11221122
nodes[3].node.fail_htlc_backwards(&payment_hash);
11231123
expect_pending_htlcs_forwardable_conditions(
1124-
nodes[3].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash }]
1124+
nodes[3].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash }]
11251125
);
11261126
nodes[3].node.process_pending_htlc_forwards();
11271127
check_added_monitors!(nodes[3], 1);
@@ -2435,7 +2435,7 @@ fn test_trampoline_forward_rejection() {
24352435
let args = PassAlongPathArgs::new(&nodes[0], route, amt_msat, payment_hash, first_message_event)
24362436
.with_payment_preimage(payment_preimage)
24372437
.without_claimable_event()
2438-
.expect_failure(HTLCHandlingType::FailedPayment { payment_hash });
2438+
.expect_failure(HTLCHandlingType::ReceiveFailed { payment_hash });
24392439
do_pass_along_path(args);
24402440

24412441
{

‎lightning/src/ln/chanmon_update_fail_tests.rs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -825,7 +825,7 @@ fn do_test_monitor_update_fail_raa(test_ignore_second_cs: bool) {
825825

826826
// Fail the payment backwards, failing the monitor update on nodes[1]'s receipt of the RAA
827827
nodes[2].node.fail_htlc_backwards(&payment_hash_1);
828-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[2], vec![HTLCHandlingType::FailedPayment { payment_hash: payment_hash_1 }]);
828+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[2], vec![HTLCHandlingType::ReceiveFailed { payment_hash: payment_hash_1 }]);
829829
check_added_monitors!(nodes[2], 1);
830830

831831
let updates = get_htlc_update_msgs!(nodes[2], nodes[1].node.get_our_node_id());
@@ -1731,7 +1731,7 @@ fn test_monitor_update_on_pending_forwards() {
17311731

17321732
let (_, payment_hash_1, ..) = route_payment(&nodes[0], &[&nodes[1], &nodes[2]], 1000000);
17331733
nodes[2].node.fail_htlc_backwards(&payment_hash_1);
1734-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[2], vec![HTLCHandlingType::FailedPayment { payment_hash: payment_hash_1 }]);
1734+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[2], vec![HTLCHandlingType::ReceiveFailed { payment_hash: payment_hash_1 }]);
17351735
check_added_monitors!(nodes[2], 1);
17361736

17371737
let cs_fail_update = get_htlc_update_msgs!(nodes[2], nodes[1].node.get_our_node_id());
@@ -2512,7 +2512,7 @@ fn do_test_reconnect_dup_htlc_claims(htlc_status: HTLCStatusAtDupClaim, second_f
25122512
};
25132513
if second_fails {
25142514
nodes[2].node.fail_htlc_backwards(&payment_hash);
2515-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[2], vec![HTLCHandlingType::FailedPayment { payment_hash }]);
2515+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[2], vec![HTLCHandlingType::ReceiveFailed { payment_hash }]);
25162516
check_added_monitors!(nodes[2], 1);
25172517
get_htlc_update_msgs!(nodes[2], nodes[1].node.get_our_node_id());
25182518
} else {

‎lightning/src/ln/channelmanager.rs‎

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -5758,7 +5758,7 @@ where
57585758
},
57595759
}
57605760
} else {
5761-
HTLCHandlingType::FailedPayment { payment_hash }
5761+
HTLCHandlingType::ReceiveFailed { payment_hash }
57625762
}
57635763
};
57645764

@@ -5932,7 +5932,7 @@ where
59325932
let reason = if $next_hop_unknown {
59335933
HTLCHandlingType::UnknownNextHop { requested_forward_scid: short_chan_id }
59345934
} else {
5935-
HTLCHandlingType::FailedPayment{ payment_hash }
5935+
HTLCHandlingType::ReceiveFailed{ payment_hash }
59365936
};
59375937

59385938
failed_forwards.push((htlc_source, payment_hash,
@@ -6268,7 +6268,7 @@ where
62686268
cltv_expiry: Some(cltv_expiry),
62696269
}), payment_hash,
62706270
HTLCFailReason::reason(LocalHTLCFailureReason::IncorrectPaymentDetails, err_data),
6271-
HTLCHandlingType::FailedPayment { payment_hash: $payment_hash },
6271+
HTLCHandlingType::ReceiveFailed { payment_hash: $payment_hash },
62726272
));
62736273
continue 'next_forwardable_htlc;
62746274
}
@@ -6826,7 +6826,7 @@ where
68266826
let source = HTLCSource::PreviousHopData(htlc_source.0.clone());
68276827
let failure_reason = LocalHTLCFailureReason::MPPTimeout;
68286828
let reason = HTLCFailReason::from_failure_code(failure_reason);
6829-
let receiver = HTLCHandlingType::FailedPayment { payment_hash: htlc_source.1 };
6829+
let receiver = HTLCHandlingType::ReceiveFailed { payment_hash: htlc_source.1 };
68306830
self.fail_htlc_backwards_internal(&source, &htlc_source.1, &reason, receiver);
68316831
}
68326832

@@ -6891,7 +6891,7 @@ where
68916891
for htlc in payment.htlcs {
68926892
let reason = self.get_htlc_fail_reason_from_failure_code(failure_code, &htlc);
68936893
let source = HTLCSource::PreviousHopData(htlc.prev_hop);
6894-
let receiver = HTLCHandlingType::FailedPayment { payment_hash: *payment_hash };
6894+
let receiver = HTLCHandlingType::ReceiveFailed { payment_hash: *payment_hash };
68956895
self.fail_htlc_backwards_internal(&source, &payment_hash, &reason, receiver);
68966896
}
68976897
}
@@ -7119,7 +7119,7 @@ where
71197119
for htlc in htlcs {
71207120
let reason = self.get_htlc_fail_reason_from_failure_code(FailureCode::InvalidOnionPayload(None), &htlc);
71217121
let source = HTLCSource::PreviousHopData(htlc.prev_hop);
7122-
let receiver = HTLCHandlingType::FailedPayment { payment_hash };
7122+
let receiver = HTLCHandlingType::ReceiveFailed { payment_hash };
71237123
self.fail_htlc_backwards_internal(&source, &payment_hash, &reason, receiver);
71247124
}
71257125
return;
@@ -7224,7 +7224,7 @@ where
72247224
let err_data = invalid_payment_err_data(htlc.value, self.best_block.read().unwrap().height);
72257225
let source = HTLCSource::PreviousHopData(htlc.prev_hop);
72267226
let reason = HTLCFailReason::reason(LocalHTLCFailureReason::IncorrectPaymentDetails, err_data);
7227-
let receiver = HTLCHandlingType::FailedPayment { payment_hash };
7227+
let receiver = HTLCHandlingType::ReceiveFailed { payment_hash };
72287228
self.fail_htlc_backwards_internal(&source, &payment_hash, &reason, receiver);
72297229
}
72307230
self.claimable_payments.lock().unwrap().pending_claiming_payments.remove(&payment_hash);
@@ -11815,7 +11815,7 @@ where
1181511815
let reason = LocalHTLCFailureReason::PaymentClaimBuffer;
1181611816
timed_out_htlcs.push((HTLCSource::PreviousHopData(htlc.prev_hop.clone()), payment_hash.clone(),
1181711817
HTLCFailReason::reason(reason, invalid_payment_err_data(htlc.value, height)),
11818-
HTLCHandlingType::FailedPayment { payment_hash: payment_hash.clone() }));
11818+
HTLCHandlingType::ReceiveFailed { payment_hash: payment_hash.clone() }));
1181911819
false
1182011820
} else { true }
1182111821
});
@@ -15099,7 +15099,7 @@ mod tests {
1509915099
check_added_monitors!(nodes[1], 0);
1510015100
commitment_signed_dance!(nodes[1], nodes[0], payment_event.commitment_msg, false);
1510115101
expect_pending_htlcs_forwardable!(nodes[1]);
15102-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::FailedPayment { payment_hash: our_payment_hash }]);
15102+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::ReceiveFailed { payment_hash: our_payment_hash }]);
1510315103
check_added_monitors!(nodes[1], 1);
1510415104
let updates = get_htlc_update_msgs!(nodes[1], nodes[0].node.get_our_node_id());
1510515105
assert!(updates.update_add_htlcs.is_empty());
@@ -15280,7 +15280,7 @@ mod tests {
1528015280
// We have to forward pending HTLCs twice - once tries to forward the payment forward (and
1528115281
// fails), the second will process the resulting failure and fail the HTLC backward
1528215282
expect_pending_htlcs_forwardable!(nodes[1]);
15283-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::FailedPayment { payment_hash }]);
15283+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::ReceiveFailed { payment_hash }]);
1528415284
check_added_monitors!(nodes[1], 1);
1528515285
let updates = get_htlc_update_msgs!(nodes[1], nodes[0].node.get_our_node_id());
1528615286
assert!(updates.update_add_htlcs.is_empty());
@@ -15325,7 +15325,7 @@ mod tests {
1532515325
check_added_monitors!(nodes[1], 0);
1532615326
commitment_signed_dance!(nodes[1], nodes[0], payment_event.commitment_msg, false);
1532715327
expect_pending_htlcs_forwardable!(nodes[1]);
15328-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::FailedPayment { payment_hash }]);
15328+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::ReceiveFailed { payment_hash }]);
1532915329
check_added_monitors!(nodes[1], 1);
1533015330
let updates = get_htlc_update_msgs!(nodes[1], nodes[0].node.get_our_node_id());
1533115331
assert!(updates.update_add_htlcs.is_empty());
@@ -15372,7 +15372,7 @@ mod tests {
1537215372
check_added_monitors!(nodes[1], 0);
1537315373
commitment_signed_dance!(nodes[1], nodes[0], payment_event.commitment_msg, false);
1537415374
expect_pending_htlcs_forwardable!(nodes[1]);
15375-
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::FailedPayment { payment_hash }]);
15375+
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(nodes[1], vec![HTLCHandlingType::ReceiveFailed { payment_hash }]);
1537615376
check_added_monitors!(nodes[1], 1);
1537715377
let updates = get_htlc_update_msgs!(nodes[1], nodes[0].node.get_our_node_id());
1537815378
assert!(updates.update_add_htlcs.is_empty());
@@ -15429,7 +15429,7 @@ mod tests {
1542915429
nodes[1].node.handle_update_add_htlc(nodes[0].node.get_our_node_id(), &updates.update_add_htlcs[0]);
1543015430
commitment_signed_dance!(nodes[1], nodes[0], &updates.commitment_signed, false);
1543115431
expect_pending_htlcs_forwardable!(nodes[1]);
15432-
expect_htlc_handling_failed_destinations!(nodes[1].node.get_and_clear_pending_events(), &[HTLCHandlingType::FailedPayment { payment_hash: mismatch_payment_hash }]);
15432+
expect_htlc_handling_failed_destinations!(nodes[1].node.get_and_clear_pending_events(), &[HTLCHandlingType::ReceiveFailed { payment_hash: mismatch_payment_hash }]);
1543315433
check_added_monitors(&nodes[1], 1);
1543415434
let _ = get_htlc_update_msgs!(nodes[1], nodes[0].node.get_our_node_id());
1543515435

‎lightning/src/ln/functional_test_utils.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2868,7 +2868,7 @@ pub fn send_probe_along_route<'a, 'b, 'c>(origin_node: &Node<'a, 'b, 'c>, expect
28682868
fail_payment_along_path(nodes_to_fail_payment.as_slice());
28692869
expect_htlc_handling_failed_destinations!(
28702870
path.last().unwrap().node.get_and_clear_pending_events(),
2871-
&[HTLCHandlingType::FailedPayment { payment_hash: *payment_hash }]
2871+
&[HTLCHandlingType::ReceiveFailed { payment_hash: *payment_hash }]
28722872
);
28732873
}
28742874
}
@@ -3182,7 +3182,7 @@ pub fn fail_payment_along_route<'a, 'b, 'c>(origin_node: &Node<'a, 'b, 'c>, expe
31823182
assert_eq!(path.last().unwrap().node.get_our_node_id(), expected_paths[0].last().unwrap().node.get_our_node_id());
31833183
}
31843184
expected_paths[0].last().unwrap().node.fail_htlc_backwards(&our_payment_hash);
3185-
let expected_destinations: Vec<HTLCHandlingType> = repeat(HTLCHandlingType::FailedPayment { payment_hash: our_payment_hash }).take(expected_paths.len()).collect();
3185+
let expected_destinations: Vec<HTLCHandlingType> = repeat(HTLCHandlingType::ReceiveFailed { payment_hash: our_payment_hash }).take(expected_paths.len()).collect();
31863186
expect_pending_htlcs_forwardable_and_htlc_handling_failed!(expected_paths[0].last().unwrap(), expected_destinations);
31873187

31883188
pass_failed_payment_back(origin_node, expected_paths, skip_last, our_payment_hash, PaymentFailureReason::RecipientRejected);

0 commit comments

Comments
 (0)