Skip to content

Commit 91c1d1b

Browse files
committed
Correct expect_payment_forwarded upstream channel checking
`expect_payment_forwarded` takes a bool to indicate that the inbound channel on which we received a forwarded payment has been closed, but then ignores it in favor of looking at the fee in the event. While this is generally correct, in cases where we process an event after a channel was closed, which was generated before a channel closed this is incorrect. Instead, we examine the bool we already passed and use that.
1 parent 0a34845 commit 91c1d1b

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

lightning/src/ln/functional_test_utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1997,7 +1997,7 @@ macro_rules! expect_payment_forwarded {
19971997
outbound_amount_forwarded_msat: _
19981998
} => {
19991999
assert_eq!(fee_earned_msat, $expected_fee);
2000-
if fee_earned_msat.is_some() {
2000+
if !$upstream_force_closed {
20012001
// Is the event prev_channel_id in one of the channels between the two nodes?
20022002
assert!($node.node.list_channels().iter().any(|x| x.counterparty.node_id == $prev_node.node.get_our_node_id() && x.channel_id == prev_channel_id.unwrap()));
20032003
}

lightning/src/ln/functional_tests.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8777,7 +8777,8 @@ fn do_test_onchain_htlc_settlement_after_close(broadcast_alice: bool, go_onchain
87778777
assert_eq!(carol_updates.update_fulfill_htlcs.len(), 1);
87788778

87798779
nodes[1].node.handle_update_fulfill_htlc(&nodes[2].node.get_our_node_id(), &carol_updates.update_fulfill_htlcs[0]);
8780-
expect_payment_forwarded!(nodes[1], nodes[0], nodes[2], if go_onchain_before_fulfill || force_closing_node == 1 { None } else { Some(1000) }, false, false);
8780+
let went_onchain = go_onchain_before_fulfill || force_closing_node == 1;
8781+
expect_payment_forwarded!(nodes[1], nodes[0], nodes[2], if went_onchain { None } else { Some(1000) }, went_onchain, false);
87818782
// If Alice broadcasted but Bob doesn't know yet, here he prepares to tell her about the preimage.
87828783
if !go_onchain_before_fulfill && broadcast_alice {
87838784
let events = nodes[1].node.get_and_clear_pending_msg_events();

lightning/src/ln/payment_tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -611,7 +611,7 @@ fn do_retry_with_no_persist(confirm_before_reload: bool) {
611611
nodes[1].node.handle_update_fulfill_htlc(&nodes[2].node.get_our_node_id(), &htlc_fulfill_updates.update_fulfill_htlcs[0]);
612612
check_added_monitors!(nodes[1], 1);
613613
commitment_signed_dance!(nodes[1], nodes[2], htlc_fulfill_updates.commitment_signed, false);
614-
expect_payment_forwarded!(nodes[1], nodes[0], nodes[2], None, false, false);
614+
expect_payment_forwarded!(nodes[1], nodes[0], nodes[2], None, true, false);
615615

616616
if confirm_before_reload {
617617
let best_block = nodes[0].blocks.lock().unwrap().last().unwrap().clone();

0 commit comments

Comments
 (0)