Skip to content

Commit ede8324

Browse files
committed
Move Channel::channel_id and some other methods to ChannelContext impl
This is one of a series of commits to make sure methods are moved by chunks so they are easily reviewable in diffs. Unfortunately they are not purely move-only as fields need to be updated for things to compile, but these should be quite clear. This commit also uses the `context` field where needed for compilation and tests to pass due to the above change.
1 parent 1ee0a66 commit ede8324

File tree

6 files changed

+497
-496
lines changed

6 files changed

+497
-496
lines changed

lightning/src/ln/channel.rs

Lines changed: 325 additions & 324 deletions
Large diffs are not rendered by default.

lightning/src/ln/channelmanager.rs

Lines changed: 159 additions & 159 deletions
Large diffs are not rendered by default.

lightning/src/ln/functional_test_utils.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2237,10 +2237,10 @@ pub fn do_claim_payment_along_route<'a, 'b, 'c>(origin_node: &Node<'a, 'b, 'c>,
22372237
let peer_state = per_peer_state.get(&$prev_node.node.get_our_node_id())
22382238
.unwrap().lock().unwrap();
22392239
let channel = peer_state.channel_by_id.get(&next_msgs.as_ref().unwrap().0.channel_id).unwrap();
2240-
if let Some(prev_config) = channel.prev_config() {
2240+
if let Some(prev_config) = channel.context.prev_config() {
22412241
prev_config.forwarding_fee_base_msat
22422242
} else {
2243-
channel.config().forwarding_fee_base_msat
2243+
channel.context.config().forwarding_fee_base_msat
22442244
}
22452245
};
22462246
expect_payment_forwarded!($node, $next_node, $prev_node, Some(fee as u64), false, false);

lightning/src/ln/functional_tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6172,7 +6172,7 @@ fn test_update_add_htlc_bolt2_receiver_check_amount_received_more_than_min() {
61726172
let per_peer_state = nodes[0].node.per_peer_state.read().unwrap();
61736173
let chan_lock = per_peer_state.get(&nodes[1].node.get_our_node_id()).unwrap().lock().unwrap();
61746174
let channel = chan_lock.channel_by_id.get(&chan.2).unwrap();
6175-
htlc_minimum_msat = channel.get_holder_htlc_minimum_msat();
6175+
htlc_minimum_msat = channel.context.get_holder_htlc_minimum_msat();
61766176
}
61776177

61786178
let (route, our_payment_hash, _, our_payment_secret) = get_route_and_payment_hash!(nodes[0], nodes[1], htlc_minimum_msat);

lightning/src/ln/onion_route_tests.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -510,7 +510,7 @@ fn test_onion_failure() {
510510
let short_channel_id = channels[1].0.contents.short_channel_id;
511511
let amt_to_forward = nodes[1].node.per_peer_state.read().unwrap().get(&nodes[2].node.get_our_node_id())
512512
.unwrap().lock().unwrap().channel_by_id.get(&channels[1].2).unwrap()
513-
.get_counterparty_htlc_minimum_msat() - 1;
513+
.context.get_counterparty_htlc_minimum_msat() - 1;
514514
let mut bogus_route = route.clone();
515515
let route_len = bogus_route.paths[0].hops.len();
516516
bogus_route.paths[0].hops[route_len-1].fee_msat = amt_to_forward;

lightning/src/ln/payment_tests.rs

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -607,9 +607,9 @@ fn do_retry_with_no_persist(confirm_before_reload: bool) {
607607
let mut peer_state = per_peer_state.get(&nodes[2].node.get_our_node_id())
608608
.unwrap().lock().unwrap();
609609
let mut channel = peer_state.channel_by_id.get_mut(&chan_id_2).unwrap();
610-
let mut new_config = channel.config();
610+
let mut new_config = channel.context.config();
611611
new_config.forwarding_fee_base_msat += 100_000;
612-
channel.update_config(&new_config);
612+
channel.context.update_config(&new_config);
613613
new_route.paths[0].hops[0].fee_msat += 100_000;
614614
}
615615

@@ -1409,7 +1409,7 @@ fn test_trivial_inflight_htlc_tracking(){
14091409
let chan_1_used_liquidity = inflight_htlcs.used_liquidity_msat(
14101410
&NodeId::from_pubkey(&nodes[0].node.get_our_node_id()) ,
14111411
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()),
1412-
channel_1.get_short_channel_id().unwrap()
1412+
channel_1.context.get_short_channel_id().unwrap()
14131413
);
14141414
assert_eq!(chan_1_used_liquidity, None);
14151415
}
@@ -1421,7 +1421,7 @@ fn test_trivial_inflight_htlc_tracking(){
14211421
let chan_2_used_liquidity = inflight_htlcs.used_liquidity_msat(
14221422
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()) ,
14231423
&NodeId::from_pubkey(&nodes[2].node.get_our_node_id()),
1424-
channel_2.get_short_channel_id().unwrap()
1424+
channel_2.context.get_short_channel_id().unwrap()
14251425
);
14261426

14271427
assert_eq!(chan_2_used_liquidity, None);
@@ -1446,7 +1446,7 @@ fn test_trivial_inflight_htlc_tracking(){
14461446
let chan_1_used_liquidity = inflight_htlcs.used_liquidity_msat(
14471447
&NodeId::from_pubkey(&nodes[0].node.get_our_node_id()) ,
14481448
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()),
1449-
channel_1.get_short_channel_id().unwrap()
1449+
channel_1.context.get_short_channel_id().unwrap()
14501450
);
14511451
// First hop accounts for expected 1000 msat fee
14521452
assert_eq!(chan_1_used_liquidity, Some(501000));
@@ -1459,7 +1459,7 @@ fn test_trivial_inflight_htlc_tracking(){
14591459
let chan_2_used_liquidity = inflight_htlcs.used_liquidity_msat(
14601460
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()) ,
14611461
&NodeId::from_pubkey(&nodes[2].node.get_our_node_id()),
1462-
channel_2.get_short_channel_id().unwrap()
1462+
channel_2.context.get_short_channel_id().unwrap()
14631463
);
14641464

14651465
assert_eq!(chan_2_used_liquidity, Some(500000));
@@ -1485,7 +1485,7 @@ fn test_trivial_inflight_htlc_tracking(){
14851485
let chan_1_used_liquidity = inflight_htlcs.used_liquidity_msat(
14861486
&NodeId::from_pubkey(&nodes[0].node.get_our_node_id()) ,
14871487
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()),
1488-
channel_1.get_short_channel_id().unwrap()
1488+
channel_1.context.get_short_channel_id().unwrap()
14891489
);
14901490
assert_eq!(chan_1_used_liquidity, None);
14911491
}
@@ -1497,7 +1497,7 @@ fn test_trivial_inflight_htlc_tracking(){
14971497
let chan_2_used_liquidity = inflight_htlcs.used_liquidity_msat(
14981498
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()) ,
14991499
&NodeId::from_pubkey(&nodes[2].node.get_our_node_id()),
1500-
channel_2.get_short_channel_id().unwrap()
1500+
channel_2.context.get_short_channel_id().unwrap()
15011501
);
15021502
assert_eq!(chan_2_used_liquidity, None);
15031503
}
@@ -1538,7 +1538,7 @@ fn test_holding_cell_inflight_htlcs() {
15381538
let used_liquidity = inflight_htlcs.used_liquidity_msat(
15391539
&NodeId::from_pubkey(&nodes[0].node.get_our_node_id()) ,
15401540
&NodeId::from_pubkey(&nodes[1].node.get_our_node_id()),
1541-
channel.get_short_channel_id().unwrap()
1541+
channel.context.get_short_channel_id().unwrap()
15421542
);
15431543

15441544
assert_eq!(used_liquidity, Some(2000000));

0 commit comments

Comments
 (0)