@@ -815,6 +815,13 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
815
815
SecretKey :: from_slice ( & Sha256 :: from_engine ( ephemeral_hash) . into_inner ( ) ) . expect ( "You broke SHA-256!" )
816
816
}
817
817
818
+ fn init_features ( & self , their_node_id : & PublicKey ) -> InitFeatures {
819
+ self . message_handler . chan_handler . provided_init_features ( their_node_id)
820
+ | self . message_handler . route_handler . provided_init_features ( their_node_id)
821
+ | self . message_handler . onion_message_handler . provided_init_features ( their_node_id)
822
+ | self . custom_message_handler . provided_init_features ( their_node_id)
823
+ }
824
+
818
825
/// Indicates a new outbound connection has been established to a node with the given `node_id`
819
826
/// and an optional remote network address.
820
827
///
@@ -1210,10 +1217,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
1210
1217
1211
1218
peer. set_their_node_id ( their_node_id) ;
1212
1219
insert_node_id ! ( ) ;
1213
- let features = self . message_handler . chan_handler . provided_init_features ( & their_node_id)
1214
- | self . message_handler . route_handler . provided_init_features ( & their_node_id)
1215
- | self . message_handler . onion_message_handler . provided_init_features ( & their_node_id)
1216
- | self . custom_message_handler . provided_init_features ( & their_node_id) ;
1220
+ let features = self . init_features ( & their_node_id) ;
1217
1221
let resp = msgs:: Init { features, remote_network_address : filter_addresses ( peer. their_net_address . clone ( ) ) } ;
1218
1222
self . enqueue_message ( peer, & resp) ;
1219
1223
peer. awaiting_pong_timer_tick_intervals = 0 ;
@@ -1225,10 +1229,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, OM: Deref, L: Deref, CM
1225
1229
peer. pending_read_is_header = true ;
1226
1230
peer. set_their_node_id ( their_node_id) ;
1227
1231
insert_node_id ! ( ) ;
1228
- let features = self . message_handler . chan_handler . provided_init_features ( & their_node_id)
1229
- | self . message_handler . route_handler . provided_init_features ( & their_node_id)
1230
- | self . message_handler . onion_message_handler . provided_init_features ( & their_node_id)
1231
- | self . custom_message_handler . provided_init_features ( & their_node_id) ;
1232
+ let features = self . init_features ( & their_node_id) ;
1232
1233
let resp = msgs:: Init { features, remote_network_address : filter_addresses ( peer. their_net_address . clone ( ) ) } ;
1233
1234
self . enqueue_message ( peer, & resp) ;
1234
1235
peer. awaiting_pong_timer_tick_intervals = 0 ;
0 commit comments