@@ -319,8 +319,8 @@ where
319
319
320
320
let blinding_secret_bytes = self . entropy_source . get_secure_random_bytes ( ) ;
321
321
let blinding_secret = SecretKey :: from_slice ( & blinding_secret_bytes[ ..] ) . expect ( "RNG is busted" ) ;
322
- let ( introduction_node_id , blinding_point) = if intermediate_nodes . len ( ) != 0 {
323
- ( intermediate_nodes [ 0 ] , PublicKey :: from_secret_key ( & self . secp_ctx , & blinding_secret) )
322
+ let ( first_node_id , blinding_point) = if let Some ( node_id ) = intermediate_nodes . first ( ) {
323
+ ( * node_id , PublicKey :: from_secret_key ( & self . secp_ctx , & blinding_secret) )
324
324
} else {
325
325
match destination {
326
326
Destination :: Node ( pk) => ( pk, PublicKey :: from_secret_key ( & self . secp_ctx , & blinding_secret) ) ,
@@ -337,8 +337,8 @@ where
337
337
packet_payloads, packet_keys, prng_seed) . map_err ( |( ) | SendError :: TooBigPacket ) ?;
338
338
339
339
let mut pending_per_peer_msgs = self . pending_messages . lock ( ) . unwrap ( ) ;
340
- if outbound_buffer_full ( & introduction_node_id , & pending_per_peer_msgs) { return Err ( SendError :: BufferFull ) }
341
- match pending_per_peer_msgs. entry ( introduction_node_id ) {
340
+ if outbound_buffer_full ( & first_node_id , & pending_per_peer_msgs) { return Err ( SendError :: BufferFull ) }
341
+ match pending_per_peer_msgs. entry ( first_node_id ) {
342
342
hash_map:: Entry :: Vacant ( _) => Err ( SendError :: InvalidFirstHop ) ,
343
343
hash_map:: Entry :: Occupied ( mut e) => {
344
344
e. get_mut ( ) . push_back ( msgs:: OnionMessage { blinding_point, onion_routing_packet } ) ;
0 commit comments