Skip to content

Commit 6aca2d3

Browse files
committed
Fix test_duplicate_htlc_different_direction_onchain
1 parent baf84c2 commit 6aca2d3

File tree

1 file changed

+11
-10
lines changed

1 file changed

+11
-10
lines changed

lightning/src/ln/functional_tests.rs

+11-10
Original file line numberDiff line numberDiff line change
@@ -1307,18 +1307,22 @@ fn test_duplicate_htlc_different_direction_onchain() {
13071307

13081308
let chan_1 = create_announced_chan_between_nodes(&nodes, 0, 1);
13091309

1310+
// post-bump fee (288 satoshis) + dust threshold for output type (294 satoshis) = 582
1311+
let payment_value_sats = 582;
1312+
let payment_value_msats = payment_value_sats * 1000;
1313+
13101314
// balancing
13111315
send_payment(&nodes[0], &vec!(&nodes[1])[..], 8000000);
13121316

13131317
let (payment_preimage, payment_hash, ..) = route_payment(&nodes[0], &vec!(&nodes[1])[..], 900_000);
13141318

1315-
let (route, _, _, _) = get_route_and_payment_hash!(nodes[1], nodes[0], 800_000);
1319+
let (route, _, _, _) = get_route_and_payment_hash!(nodes[1], nodes[0], payment_value_msats);
13161320
let node_a_payment_secret = nodes[0].node.create_inbound_payment_for_hash(payment_hash, None, 7200, None).unwrap();
1317-
send_along_route_with_secret(&nodes[1], route, &[&[&nodes[0]]], 800_000, payment_hash, node_a_payment_secret);
1321+
send_along_route_with_secret(&nodes[1], route, &[&[&nodes[0]]], payment_value_msats, payment_hash, node_a_payment_secret);
13181322

13191323
// Provide preimage to node 0 by claiming payment
13201324
nodes[0].node.claim_funds(payment_preimage);
1321-
expect_payment_claimed!(nodes[0], payment_hash, 800_000);
1325+
expect_payment_claimed!(nodes[0], payment_hash, payment_value_msats);
13221326
check_added_monitors!(nodes[0], 1);
13231327

13241328
// Broadcast node 1 commitment txn
@@ -1327,7 +1331,7 @@ fn test_duplicate_htlc_different_direction_onchain() {
13271331
assert_eq!(remote_txn[0].output.len(), 4); // 1 local, 1 remote, 1 htlc inbound, 1 htlc outbound
13281332
let mut has_both_htlcs = 0; // check htlcs match ones committed
13291333
for outp in remote_txn[0].output.iter() {
1330-
if outp.value.to_sat() == 800_000 / 1000 {
1334+
if outp.value.to_sat() == payment_value_sats {
13311335
has_both_htlcs += 1;
13321336
} else if outp.value.to_sat() == 900_000 / 1000 {
13331337
has_both_htlcs += 1;
@@ -1347,18 +1351,15 @@ fn test_duplicate_htlc_different_direction_onchain() {
13471351
check_spends!(claim_txn[1], remote_txn[0]);
13481352
check_spends!(claim_txn[2], remote_txn[0]);
13491353
let preimage_tx = &claim_txn[0];
1350-
let (preimage_bump_tx, timeout_tx) = if claim_txn[1].input[0].previous_output == preimage_tx.input[0].previous_output {
1351-
(&claim_txn[1], &claim_txn[2])
1352-
} else {
1353-
(&claim_txn[2], &claim_txn[1])
1354-
};
1354+
let timeout_tx = claim_txn.iter().skip(1).find(|t| t.input[0].previous_output != preimage_tx.input[0].previous_output).unwrap();
1355+
let preimage_bump_tx = claim_txn.iter().skip(1).find(|t| t.input[0].previous_output == preimage_tx.input[0].previous_output).unwrap();
13551356

13561357
assert_eq!(preimage_tx.input.len(), 1);
13571358
assert_eq!(preimage_bump_tx.input.len(), 1);
13581359

13591360
assert_eq!(preimage_tx.input.len(), 1);
13601361
assert_eq!(preimage_tx.input[0].witness.last().unwrap().len(), OFFERED_HTLC_SCRIPT_WEIGHT); // HTLC 1 <--> 0, preimage tx
1361-
assert_eq!(remote_txn[0].output[preimage_tx.input[0].previous_output.vout as usize].value.to_sat(), 800);
1362+
assert_eq!(remote_txn[0].output[preimage_tx.input[0].previous_output.vout as usize].value.to_sat(), payment_value_sats);
13621363

13631364
assert_eq!(timeout_tx.input.len(), 1);
13641365
assert_eq!(timeout_tx.input[0].witness.last().unwrap().len(), ACCEPTED_HTLC_SCRIPT_WEIGHT); // HTLC 0 <--> 1, timeout tx

0 commit comments

Comments
 (0)