@@ -14,10 +14,10 @@ use chain::{BestBlock, Confirm, Listen, Watch, keysinterface::KeysInterface};
14
14
use chain:: channelmonitor:: ChannelMonitor ;
15
15
use chain:: transaction:: OutPoint ;
16
16
use ln:: { PaymentPreimage , PaymentHash , PaymentSecret } ;
17
- use ln:: channelmanager:: { ChainParameters , ChannelManager , ChannelManagerReadArgs , RAACommitmentOrder , PaymentSendFailure , PaymentId , MIN_CLTV_EXPIRY_DELTA } ;
17
+ use ln:: channelmanager:: { self , ChainParameters , ChannelManager , ChannelManagerReadArgs , RAACommitmentOrder , PaymentSendFailure , PaymentId , MIN_CLTV_EXPIRY_DELTA } ;
18
18
use routing:: gossip:: { P2PGossipSync , NetworkGraph , NetworkUpdate } ;
19
19
use routing:: router:: { PaymentParameters , Route , get_route} ;
20
- use ln:: features:: { InitFeatures , InvoiceFeatures } ;
20
+ use ln:: features:: InitFeatures ;
21
21
use ln:: msgs;
22
22
use ln:: msgs:: { ChannelMessageHandler , RoutingMessageHandler } ;
23
23
use util:: enforcing_trait_impls:: EnforcingSigner ;
@@ -686,7 +686,7 @@ pub fn open_zero_conf_channel<'a, 'b, 'c, 'd>(initiator: &'a Node<'b, 'c, 'd>, r
686
686
initiator. node . create_channel ( receiver. node . get_our_node_id ( ) , 100_000 , 10_001 , 42 , initiator_config) . unwrap ( ) ;
687
687
let open_channel = get_event_msg ! ( initiator, MessageSendEvent :: SendOpenChannel , receiver. node. get_our_node_id( ) ) ;
688
688
689
- receiver. node . handle_open_channel ( & initiator. node . get_our_node_id ( ) , InitFeatures :: known ( ) , & open_channel) ;
689
+ receiver. node . handle_open_channel ( & initiator. node . get_our_node_id ( ) , channelmanager :: provided_init_features ( ) , & open_channel) ;
690
690
let events = receiver. node . get_and_clear_pending_events ( ) ;
691
691
assert_eq ! ( events. len( ) , 1 ) ;
692
692
match events[ 0 ] {
@@ -698,7 +698,7 @@ pub fn open_zero_conf_channel<'a, 'b, 'c, 'd>(initiator: &'a Node<'b, 'c, 'd>, r
698
698
699
699
let accept_channel = get_event_msg ! ( receiver, MessageSendEvent :: SendAcceptChannel , initiator. node. get_our_node_id( ) ) ;
700
700
assert_eq ! ( accept_channel. minimum_depth, 0 ) ;
701
- initiator. node . handle_accept_channel ( & receiver. node . get_our_node_id ( ) , InitFeatures :: known ( ) , & accept_channel) ;
701
+ initiator. node . handle_accept_channel ( & receiver. node . get_our_node_id ( ) , channelmanager :: provided_init_features ( ) , & accept_channel) ;
702
702
703
703
let ( temporary_channel_id, tx, _) = create_funding_transaction ( & initiator, & receiver. node . get_our_node_id ( ) , 100_000 , 42 ) ;
704
704
initiator. node . funding_transaction_generated ( & temporary_channel_id, & receiver. node . get_our_node_id ( ) , tx. clone ( ) ) . unwrap ( ) ;
@@ -1051,7 +1051,7 @@ pub fn close_channel<'a, 'b, 'c>(outbound_node: &Node<'a, 'b, 'c>, inbound_node:
1051
1051
let ( tx_a, tx_b) ;
1052
1052
1053
1053
node_a. close_channel ( channel_id, & node_b. get_our_node_id ( ) ) . unwrap ( ) ;
1054
- node_b. handle_shutdown ( & node_a. get_our_node_id ( ) , & InitFeatures :: known ( ) , & get_event_msg ! ( struct_a, MessageSendEvent :: SendShutdown , node_b. get_our_node_id( ) ) ) ;
1054
+ node_b. handle_shutdown ( & node_a. get_our_node_id ( ) , & channelmanager :: provided_init_features ( ) , & get_event_msg ! ( struct_a, MessageSendEvent :: SendShutdown , node_b. get_our_node_id( ) ) ) ;
1055
1055
1056
1056
let events_1 = node_b. get_and_clear_pending_msg_events ( ) ;
1057
1057
assert ! ( events_1. len( ) >= 1 ) ;
@@ -1076,7 +1076,7 @@ pub fn close_channel<'a, 'b, 'c>(outbound_node: &Node<'a, 'b, 'c>, inbound_node:
1076
1076
} )
1077
1077
} ;
1078
1078
1079
- node_a. handle_shutdown ( & node_b. get_our_node_id ( ) , & InitFeatures :: known ( ) , & shutdown_b) ;
1079
+ node_a. handle_shutdown ( & node_b. get_our_node_id ( ) , & channelmanager :: provided_init_features ( ) , & shutdown_b) ;
1080
1080
let ( as_update, bs_update) = if close_inbound_first {
1081
1081
assert ! ( node_a. get_and_clear_pending_msg_events( ) . is_empty( ) ) ;
1082
1082
node_a. handle_closing_signed ( & node_b. get_our_node_id ( ) , & closing_signed_b. unwrap ( ) ) ;
@@ -1269,7 +1269,7 @@ macro_rules! get_route {
1269
1269
macro_rules! get_route_and_payment_hash {
1270
1270
( $send_node: expr, $recv_node: expr, $recv_value: expr) => { {
1271
1271
let payment_params = $crate:: routing:: router:: PaymentParameters :: from_node_id( $recv_node. node. get_our_node_id( ) )
1272
- . with_features( $crate:: ln:: features :: InvoiceFeatures :: known ( ) ) ;
1272
+ . with_features( $crate:: ln:: channelmanager :: provided_invoice_features ( ) ) ;
1273
1273
$crate:: get_route_and_payment_hash!( $send_node, $recv_node, payment_params, $recv_value, TEST_FINAL_CLTV )
1274
1274
} } ;
1275
1275
( $send_node: expr, $recv_node: expr, $payment_params: expr, $recv_value: expr, $cltv: expr) => { {
@@ -1853,7 +1853,7 @@ pub const TEST_FINAL_CLTV: u32 = 70;
1853
1853
1854
1854
pub fn route_payment < ' a , ' b , ' c > ( origin_node : & Node < ' a , ' b , ' c > , expected_route : & [ & Node < ' a , ' b , ' c > ] , recv_value : u64 ) -> ( PaymentPreimage , PaymentHash , PaymentSecret ) {
1855
1855
let payment_params = PaymentParameters :: from_node_id ( expected_route. last ( ) . unwrap ( ) . node . get_our_node_id ( ) )
1856
- . with_features ( InvoiceFeatures :: known ( ) ) ;
1856
+ . with_features ( channelmanager :: provided_invoice_features ( ) ) ;
1857
1857
let route = get_route ! ( origin_node, payment_params, recv_value, TEST_FINAL_CLTV ) . unwrap ( ) ;
1858
1858
assert_eq ! ( route. paths. len( ) , 1 ) ;
1859
1859
assert_eq ! ( route. paths[ 0 ] . len( ) , expected_route. len( ) ) ;
@@ -1867,7 +1867,7 @@ pub fn route_payment<'a, 'b, 'c>(origin_node: &Node<'a, 'b, 'c>, expected_route:
1867
1867
1868
1868
pub fn route_over_limit < ' a , ' b , ' c > ( origin_node : & Node < ' a , ' b , ' c > , expected_route : & [ & Node < ' a , ' b , ' c > ] , recv_value : u64 ) {
1869
1869
let payment_params = PaymentParameters :: from_node_id ( expected_route. last ( ) . unwrap ( ) . node . get_our_node_id ( ) )
1870
- . with_features ( InvoiceFeatures :: known ( ) ) ;
1870
+ . with_features ( channelmanager :: provided_invoice_features ( ) ) ;
1871
1871
let network_graph = origin_node. network_graph . read_only ( ) ;
1872
1872
let scorer = test_utils:: TestScorer :: with_penalty ( 0 ) ;
1873
1873
let seed = [ 0u8 ; 32 ] ;
@@ -2047,7 +2047,7 @@ pub fn create_node_cfgs<'a>(node_count: usize, chanmon_cfgs: &'a Vec<TestChanMon
2047
2047
chain_monitor,
2048
2048
keys_manager : & chanmon_cfgs[ i] . keys_manager ,
2049
2049
node_seed : seed,
2050
- features : InitFeatures :: known ( ) ,
2050
+ features : channelmanager :: provided_init_features ( ) ,
2051
2051
network_graph : NetworkGraph :: new ( chanmon_cfgs[ i] . chain_source . genesis_hash , & chanmon_cfgs[ i] . logger ) ,
2052
2052
} ) ;
2053
2053
}
@@ -2382,9 +2382,9 @@ macro_rules! handle_chan_reestablish_msgs {
2382
2382
/// pending_htlc_adds includes both the holding cell and in-flight update_add_htlcs, whereas
2383
2383
/// for claims/fails they are separated out.
2384
2384
pub fn reconnect_nodes < ' a , ' b , ' c > ( node_a : & Node < ' a , ' b , ' c > , node_b : & Node < ' a , ' b , ' c > , send_channel_ready : ( bool , bool ) , pending_htlc_adds : ( i64 , i64 ) , pending_htlc_claims : ( usize , usize ) , pending_htlc_fails : ( usize , usize ) , pending_cell_htlc_claims : ( usize , usize ) , pending_cell_htlc_fails : ( usize , usize ) , pending_raa : ( bool , bool ) ) {
2385
- node_a. node . peer_connected ( & node_b. node . get_our_node_id ( ) , & msgs:: Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
2385
+ node_a. node . peer_connected ( & node_b. node . get_our_node_id ( ) , & msgs:: Init { features : channelmanager :: provided_init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
2386
2386
let reestablish_1 = get_chan_reestablish_msgs ! ( node_a, node_b) ;
2387
- node_b. node . peer_connected ( & node_a. node . get_our_node_id ( ) , & msgs:: Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
2387
+ node_b. node . peer_connected ( & node_a. node . get_our_node_id ( ) , & msgs:: Init { features : channelmanager :: provided_init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
2388
2388
let reestablish_2 = get_chan_reestablish_msgs ! ( node_b, node_a) ;
2389
2389
2390
2390
if send_channel_ready. 0 {
0 commit comments