Skip to content

Commit 7ed3790

Browse files
benthecarmanbenthecarman
committed
Support creating coinbase funding transactions in tests
1 parent 956188b commit 7ed3790

File tree

7 files changed

+39
-30
lines changed

7 files changed

+39
-30
lines changed

‎lightning/src/ln/chanmon_update_fail_tests.rs‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1870,7 +1870,7 @@ fn do_during_funding_monitor_fail(confirm_a_first: bool, restore_b_before_conf:
18701870
nodes[1].node.handle_open_channel(&nodes[0].node.get_our_node_id(), &get_event_msg!(nodes[0], MessageSendEvent::SendOpenChannel, nodes[1].node.get_our_node_id()));
18711871
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id()));
18721872

1873-
let (temporary_channel_id, funding_tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 43);
1873+
let (temporary_channel_id, funding_tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 43, false);
18741874

18751875
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), funding_tx.clone()).unwrap();
18761876
check_added_monitors!(nodes[0], 0);
@@ -2836,7 +2836,7 @@ fn do_test_outbound_reload_without_init_mon(use_0conf: bool) {
28362836

28372837
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id()));
28382838

2839-
let (temporary_channel_id, funding_tx, ..) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 43);
2839+
let (temporary_channel_id, funding_tx, ..) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 43, false);
28402840

28412841
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), funding_tx.clone()).unwrap();
28422842
check_added_monitors!(nodes[0], 0);
@@ -2926,7 +2926,7 @@ fn do_test_inbound_reload_without_init_mon(use_0conf: bool, lock_commitment: boo
29262926

29272927
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id()));
29282928

2929-
let (temporary_channel_id, funding_tx, ..) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 43);
2929+
let (temporary_channel_id, funding_tx, ..) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 43, false);
29302930

29312931
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), funding_tx.clone()).unwrap();
29322932
check_added_monitors!(nodes[0], 0);

‎lightning/src/ln/channel.rs‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -5144,16 +5144,16 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
51445144
Err(_) => panic!("Block was bogus - either height was > 16 million, had > 16 million transactions, or had > 65k outputs"),
51455145
}
51465146
}
5147-
}
51485147

5149-
// if this is a coinbase transaction and not a 0-conf channel
5150-
// we should update our min_depth to 100 to handle coinbase maturity
5151-
if tx.is_coin_base() &&
5152-
self.minimum_depth.unwrap_or(0) > 0 &&
5153-
self.minimum_depth.unwrap_or(0) < COINBASE_MATURITY {
5154-
self.minimum_depth = Some(COINBASE_MATURITY);
5155-
}
5148+
// if this is a coinbase transaction and not a 0-conf channel
5149+
// we should update our min_depth to 100 to handle coinbase maturity
5150+
if tx.is_coin_base() &&
5151+
self.minimum_depth.unwrap_or(0) > 0 &&
5152+
self.minimum_depth.unwrap_or(0) < COINBASE_MATURITY {
5153+
self.minimum_depth = Some(COINBASE_MATURITY);
5154+
}
51565155

5156+
}
51575157
// If we allow 1-conf funding, we may need to check for channel_ready here and
51585158
// send it immediately instead of waiting for a best_block_updated call (which
51595159
// may have already happened for this block).

‎lightning/src/ln/channelmanager.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -8502,7 +8502,7 @@ mod tests {
85028502
let accept_channel = get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id());
85038503
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_channel);
85048504

8505-
let (temporary_channel_id, tx, _funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 1_000_000, 42);
8505+
let (temporary_channel_id, tx, _funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 1_000_000, 42, false);
85068506
let channel_id = &tx.txid().into_inner();
85078507
{
85088508
// Ensure that the `id_to_peer` map is empty until either party has received the
@@ -8679,7 +8679,7 @@ mod tests {
86798679

86808680
if idx == 0 {
86818681
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_channel);
8682-
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100_000, 42);
8682+
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100_000, 42, false);
86838683
funding_tx = Some(tx.clone());
86848684
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx).unwrap();
86858685
let funding_created_msg = get_event_msg!(nodes[0], MessageSendEvent::SendFundingCreated, nodes[1].node.get_our_node_id());

‎lightning/src/ln/functional_test_utils.rs‎

Lines changed: 15 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ use alloc::rc::Rc;
4747
use crate::sync::{Arc, Mutex, LockTestExt};
4848
use core::mem;
4949
use core::iter::repeat;
50-
use bitcoin::{PackedLockTime, TxMerkleNode};
50+
use bitcoin::{PackedLockTime, TxIn, TxMerkleNode};
5151

5252
pub const CHAN_CONFIRM_DEPTH: u32 = 10;
5353

@@ -875,7 +875,7 @@ macro_rules! reload_node {
875875
};
876876
}
877877

878-
pub fn create_funding_transaction<'a, 'b, 'c>(node: &Node<'a, 'b, 'c>, expected_counterparty_node_id: &PublicKey, expected_chan_value: u64, expected_user_chan_id: u128) -> ([u8; 32], Transaction, OutPoint) {
878+
pub fn create_funding_transaction<'a, 'b, 'c>(node: &Node<'a, 'b, 'c>, expected_counterparty_node_id: &PublicKey, expected_chan_value: u64, expected_user_chan_id: u128, coinbase: bool) -> ([u8; 32], Transaction, OutPoint) {
879879
let chan_id = *node.network_chan_count.borrow();
880880

881881
let events = node.node.get_and_clear_pending_events();
@@ -886,7 +886,16 @@ pub fn create_funding_transaction<'a, 'b, 'c>(node: &Node<'a, 'b, 'c>, expected_
886886
assert_eq!(*channel_value_satoshis, expected_chan_value);
887887
assert_eq!(user_channel_id, expected_user_chan_id);
888888

889-
let tx = Transaction { version: chan_id as i32, lock_time: PackedLockTime::ZERO, input: Vec::new(), output: vec![TxOut {
889+
let input = if coinbase {
890+
vec![TxIn {
891+
previous_output: bitcoin::OutPoint::null(),
892+
..Default::default()
893+
}]
894+
} else {
895+
Vec::new()
896+
};
897+
898+
let tx = Transaction { version: chan_id as i32, lock_time: PackedLockTime::ZERO, input, output: vec![TxOut {
890899
value: *channel_value_satoshis, script_pubkey: output_script.clone(),
891900
}]};
892901
let funding_outpoint = OutPoint { txid: tx.txid(), index: 0 };
@@ -896,7 +905,7 @@ pub fn create_funding_transaction<'a, 'b, 'c>(node: &Node<'a, 'b, 'c>, expected_
896905
}
897906
}
898907
pub fn sign_funding_transaction<'a, 'b, 'c>(node_a: &Node<'a, 'b, 'c>, node_b: &Node<'a, 'b, 'c>, channel_value: u64, expected_temporary_channel_id: [u8; 32]) -> Transaction {
899-
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(node_a, &node_b.node.get_our_node_id(), channel_value, 42);
908+
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(node_a, &node_b.node.get_our_node_id(), channel_value, 42, false);
900909
assert_eq!(temporary_channel_id, expected_temporary_channel_id);
901910

902911
assert!(node_a.node.funding_transaction_generated(&temporary_channel_id, &node_b.node.get_our_node_id(), tx.clone()).is_ok());
@@ -959,7 +968,7 @@ pub fn open_zero_conf_channel<'a, 'b, 'c, 'd>(initiator: &'a Node<'b, 'c, 'd>, r
959968
assert_eq!(accept_channel.minimum_depth, 0);
960969
initiator.node.handle_accept_channel(&receiver.node.get_our_node_id(), &accept_channel);
961970

962-
let (temporary_channel_id, tx, _) = create_funding_transaction(&initiator, &receiver.node.get_our_node_id(), 100_000, 42);
971+
let (temporary_channel_id, tx, _) = create_funding_transaction(&initiator, &receiver.node.get_our_node_id(), 100_000, 42, false);
963972
initiator.node.funding_transaction_generated(&temporary_channel_id, &receiver.node.get_our_node_id(), tx.clone()).unwrap();
964973
let funding_created = get_event_msg!(initiator, MessageSendEvent::SendFundingCreated, receiver.node.get_our_node_id());
965974

@@ -1122,7 +1131,7 @@ pub fn create_unannounced_chan_between_nodes_with_value<'a, 'b, 'c, 'd>(nodes: &
11221131
let accept_channel = get_event_msg!(nodes[b], MessageSendEvent::SendAcceptChannel, nodes[a].node.get_our_node_id());
11231132
nodes[a].node.handle_accept_channel(&nodes[b].node.get_our_node_id(), &accept_channel);
11241133

1125-
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[a], &nodes[b].node.get_our_node_id(), channel_value, 42);
1134+
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[a], &nodes[b].node.get_our_node_id(), channel_value, 42, false);
11261135
nodes[a].node.funding_transaction_generated(&temporary_channel_id, &nodes[b].node.get_our_node_id(), tx.clone()).unwrap();
11271136
nodes[b].node.handle_funding_created(&nodes[a].node.get_our_node_id(), &get_event_msg!(nodes[a], MessageSendEvent::SendFundingCreated, nodes[b].node.get_our_node_id()));
11281137
check_added_monitors!(nodes[b], 1);

‎lightning/src/ln/functional_tests.rs‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -528,7 +528,7 @@ fn do_test_sanity_on_in_flight_opens(steps: u8) {
528528
if steps & 0x0f == 2 { return; }
529529
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_channel);
530530

531-
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42);
531+
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42, false);
532532

533533
if steps & 0x0f == 3 { return; }
534534
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).unwrap();
@@ -3590,7 +3590,7 @@ fn test_peer_disconnected_before_funding_broadcasted() {
35903590
let accept_channel = get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id());
35913591
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_channel);
35923592

3593-
let (temporary_channel_id, tx, _funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 1_000_000, 42);
3593+
let (temporary_channel_id, tx, _funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 1_000_000, 42, false);
35943594
assert_eq!(temporary_channel_id, expected_temporary_channel_id);
35953595

35963596
assert!(nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).is_ok());
@@ -7919,7 +7919,7 @@ fn test_reject_funding_before_inbound_channel_accepted() {
79197919
};
79207920
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_chan_msg);
79217921

7922-
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42);
7922+
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42, false);
79237923

79247924
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).unwrap();
79257925
let funding_created_msg = get_event_msg!(nodes[0], MessageSendEvent::SendFundingCreated, nodes[1].node.get_our_node_id());
@@ -8591,7 +8591,7 @@ fn test_pre_lockin_no_chan_closed_update() {
85918591
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_chan_msg);
85928592

85938593
// Move the first channel through the funding flow...
8594-
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42);
8594+
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42, false);
85958595

85968596
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).unwrap();
85978597
check_added_monitors!(nodes[0], 0);
@@ -8928,7 +8928,7 @@ fn test_duplicate_chan_id() {
89288928
}
89298929

89308930
// Move the first channel through the funding flow...
8931-
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42);
8931+
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42, false);
89328932

89338933
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).unwrap();
89348934
check_added_monitors!(nodes[0], 0);
@@ -8975,7 +8975,7 @@ fn test_duplicate_chan_id() {
89758975
let open_chan_2_msg = get_event_msg!(nodes[0], MessageSendEvent::SendOpenChannel, nodes[1].node.get_our_node_id());
89768976
nodes[1].node.handle_open_channel(&nodes[0].node.get_our_node_id(), &open_chan_2_msg);
89778977
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id()));
8978-
create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42); // Get and check the FundingGenerationReady event
8978+
create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42, false); // Get and check the FundingGenerationReady event
89798979

89808980
let funding_created = {
89818981
let per_peer_state = nodes[0].node.per_peer_state.read().unwrap();
@@ -9117,7 +9117,7 @@ fn test_invalid_funding_tx() {
91179117
nodes[1].node.handle_open_channel(&nodes[0].node.get_our_node_id(), &get_event_msg!(nodes[0], MessageSendEvent::SendOpenChannel, nodes[1].node.get_our_node_id()));
91189118
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &get_event_msg!(nodes[1], MessageSendEvent::SendAcceptChannel, nodes[0].node.get_our_node_id()));
91199119

9120-
let (temporary_channel_id, mut tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100_000, 42);
9120+
let (temporary_channel_id, mut tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100_000, 42, false);
91219121

91229122
// Create a witness program which can be spent by a 4-empty-stack-elements witness and which is
91239123
// 136 bytes long. This matches our "accepted HTLC preimage spend" matching, previously causing
@@ -9647,7 +9647,7 @@ fn do_test_max_dust_htlc_exposure(dust_outbound_balance: bool, exposure_breach_e
96479647

96489648
let opt_anchors = false;
96499649

9650-
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 1_000_000, 42);
9650+
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 1_000_000, 42, false);
96519651

96529652
if on_holder_tx {
96539653
let mut node_0_per_peer_lock;

‎lightning/src/ln/priv_short_conf_tests.rs‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -359,7 +359,7 @@ fn test_inbound_scid_privacy() {
359359
let accept_channel = get_event_msg!(nodes[2], MessageSendEvent::SendAcceptChannel, nodes[1].node.get_our_node_id());
360360
nodes[1].node.handle_accept_channel(&nodes[2].node.get_our_node_id(), &accept_channel);
361361

362-
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[1], &nodes[2].node.get_our_node_id(), 100_000, 42);
362+
let (temporary_channel_id, tx, _) = create_funding_transaction(&nodes[1], &nodes[2].node.get_our_node_id(), 100_000, 42, false);
363363
nodes[1].node.funding_transaction_generated(&temporary_channel_id, &nodes[2].node.get_our_node_id(), tx.clone()).unwrap();
364364
nodes[2].node.handle_funding_created(&nodes[1].node.get_our_node_id(), &get_event_msg!(nodes[1], MessageSendEvent::SendFundingCreated, nodes[2].node.get_our_node_id()));
365365
check_added_monitors!(nodes[2], 1);
@@ -598,7 +598,7 @@ fn test_0conf_channel_with_async_monitor() {
598598
assert_eq!(accept_channel.minimum_depth, 0);
599599
nodes[0].node.handle_accept_channel(&nodes[1].node.get_our_node_id(), &accept_channel);
600600

601-
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42);
601+
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&nodes[0], &nodes[1].node.get_our_node_id(), 100000, 42, false);
602602
nodes[0].node.funding_transaction_generated(&temporary_channel_id, &nodes[1].node.get_our_node_id(), tx.clone()).unwrap();
603603
let funding_created = get_event_msg!(nodes[0], MessageSendEvent::SendFundingCreated, nodes[1].node.get_our_node_id());
604604

‎lightning/src/ln/reload_tests.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ fn test_manager_serialize_deserialize_events() {
238238
node_b.node.handle_open_channel(&node_a.node.get_our_node_id(), &get_event_msg!(node_a, MessageSendEvent::SendOpenChannel, node_b.node.get_our_node_id()));
239239
node_a.node.handle_accept_channel(&node_b.node.get_our_node_id(), &get_event_msg!(node_b, MessageSendEvent::SendAcceptChannel, node_a.node.get_our_node_id()));
240240

241-
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&node_a, &node_b.node.get_our_node_id(), channel_value, 42);
241+
let (temporary_channel_id, tx, funding_output) = create_funding_transaction(&node_a, &node_b.node.get_our_node_id(), channel_value, 42, false);
242242

243243
node_a.node.funding_transaction_generated(&temporary_channel_id, &node_b.node.get_our_node_id(), tx.clone()).unwrap();
244244
check_added_monitors!(node_a, 0);

0 commit comments

Comments
 (0)