Test that no Balance appears for missing HTLCs in revoked txn

This adds an additional test in
`test_revoked_counterparty_commitment_balances` to ensure that an
HTLC which is missing from a revoked commitment transaction does
not appear as a `Balance` in `get_claimebla_balances`.

Author: TheBlueMatt

lightning/src/ln/functional_test_utils.rs

@@ -1485,13 +1485,11 @@ macro_rules! expect_payment_failed {
 	};
 }
 
-pub fn expect_payment_failed_conditions<'a, 'b, 'c, 'd, 'e>(
-	node: &'a Node<'b, 'c, 'd>, expected_payment_hash: PaymentHash, expected_rejected_by_dest: bool,
-	conditions: PaymentFailedConditions<'e>
+pub fn expect_payment_failed_conditions_event<'a, 'b, 'c, 'd, 'e>(
+	node: &'a Node<'b, 'c, 'd>, payment_failed_event: Event, expected_payment_hash: PaymentHash,
+	expected_rejected_by_dest: bool, conditions: PaymentFailedConditions<'e>
 ) {
-	let mut events = node.node.get_and_clear_pending_events();
-	assert_eq!(events.len(), 1);
-	let expected_payment_id = match events.pop().unwrap() {
+	let expected_payment_id = match payment_failed_event {
 		Event::PaymentPathFailed { payment_hash, rejected_by_dest, path, retry, payment_id, network_update,
 			#[cfg(test)]
 			error_code,
@@ -1551,6 +1549,15 @@ pub fn expect_payment_failed_conditions<'a, 'b, 'c, 'd, 'e>(
 	}
 }
 
+pub fn expect_payment_failed_conditions<'a, 'b, 'c, 'd, 'e>(
+	node: &'a Node<'b, 'c, 'd>, expected_payment_hash: PaymentHash, expected_rejected_by_dest: bool,
+	conditions: PaymentFailedConditions<'e>
+) {
+	let mut events = node.node.get_and_clear_pending_events();
+	assert_eq!(events.len(), 1);
+	expect_payment_failed_conditions_event(node, events.pop().unwrap(), expected_payment_hash, expected_rejected_by_dest, conditions);
+}
+
 pub fn send_along_route_with_secret<'a, 'b, 'c>(origin_node: &Node<'a, 'b, 'c>, route: Route, expected_paths: &[&[&Node<'a, 'b, 'c>]], recv_value: u64, our_payment_hash: PaymentHash, our_payment_secret: PaymentSecret) -> PaymentId {
 	let payment_id = origin_node.node.send_payment(&route, our_payment_hash, &Some(our_payment_secret)).unwrap();
 	check_added_monitors!(origin_node, expected_paths.len());

lightning/src/ln/monitor_tests.rs

@@ -775,12 +775,14 @@ fn do_test_revoked_counterparty_commitment_balances(confirm_htlc_spend_first: bo
 	let funding_outpoint = OutPoint { txid: funding_tx.txid(), index: 0 };
 	assert_eq!(funding_outpoint.to_channel_id(), chan_id);
 
-	// We create four HTLCs for B to claim against A's revoked commitment transaction:
+	// We create five HTLCs for B to claim against A's revoked commitment transaction:
 	//
 	// (1) one for which A is the originator and B knows the preimage
 	// (2) one for which B is the originator where the HTLC has since timed-out
 	// (3) one for which B is the originator but where the HTLC has not yet timed-out
 	// (4) one dust HTLC which is lost in the channel closure
+	// (5) one that actually isn't in the revoked commitment transaction at all, but was added in
+	//     later commitment transaction updates
 	//
 	// Though they could all be claimed in a single claim transaction, due to CLTV timeouts they
 	// are all currently claimed in separate transactions, which helps us test as we can claim
@@ -804,16 +806,8 @@ fn do_test_revoked_counterparty_commitment_balances(confirm_htlc_spend_first: bo
 
 	let chan_feerate = get_feerate!(nodes[0], chan_id) as u64;
 
-	{
-		let mut feerate = chanmon_cfgs[0].fee_estimator.sat_per_kw.lock().unwrap();
-		*feerate += 1;
-	}
-	nodes[0].node.timer_tick_occurred();
-	check_added_monitors!(nodes[0], 1);
-
-	let fee_update = get_htlc_update_msgs!(nodes[0], nodes[1].node.get_our_node_id());
-	nodes[1].node.handle_update_fee(&nodes[0].node.get_our_node_id(), &fee_update.update_fee.unwrap());
-	commitment_signed_dance!(nodes[1], nodes[0], fee_update.commitment_signed, false);
+	let missing_htlc_cltv_timeout = nodes[0].best_block_info().1 + TEST_FINAL_CLTV + 1; // Note ChannelManager adds one to CLTV timeouts for safety
+	let missing_htlc_payment_hash = route_payment(&nodes[1], &[&nodes[0]], 2_000_000).1;
 
 	nodes[1].node.claim_funds(claimed_payment_preimage);
 	expect_payment_claimed!(nodes[1], claimed_payment_hash, 3_000_000);
@@ -839,7 +833,10 @@ fn do_test_revoked_counterparty_commitment_balances(confirm_htlc_spend_first: bo
 	// Prior to channel closure, B considers the preimage HTLC as its own, and otherwise only
 	// lists the two on-chain timeout-able HTLCs as claimable balances.
 	assert_eq!(sorted_vec(vec![Balance::ClaimableOnChannelClose {
-			claimable_amount_satoshis: 100_000 - 5_000 - 4_000 - 3 + 3_000,
+			claimable_amount_satoshis: 100_000 - 5_000 - 4_000 - 3 - 2_000 + 3_000,
+		}, Balance::MaybeClaimableHTLCAwaitingTimeout {
+			claimable_amount_satoshis: 2_000,
+			claimable_height: missing_htlc_cltv_timeout,
 		}, Balance::MaybeClaimableHTLCAwaitingTimeout {
 			claimable_amount_satoshis: 4_000,
 			claimable_height: htlc_cltv_timeout,
@@ -958,7 +955,14 @@ fn do_test_revoked_counterparty_commitment_balances(confirm_htlc_spend_first: bo
 
 	connect_blocks(&nodes[1], 1);
 	test_spendable_output(&nodes[1], &as_revoked_txn[0]);
-	expect_payment_failed!(nodes[1], dust_payment_hash, true);
+
+	let mut payment_failed_events = nodes[1].node.get_and_clear_pending_events();
+	expect_payment_failed_conditions_event(&nodes[1], payment_failed_events.pop().unwrap(),
+		dust_payment_hash, true, PaymentFailedConditions::new());
+	expect_payment_failed_conditions_event(&nodes[1], payment_failed_events.pop().unwrap(),
+		missing_htlc_payment_hash, true, PaymentFailedConditions::new());
+	assert!(payment_failed_events.is_empty());
+
 	connect_blocks(&nodes[1], 1);
 	test_spendable_output(&nodes[1], &claim_txn[if confirm_htlc_spend_first { 2 } else { 3 }]);
 	connect_blocks(&nodes[1], 1);