f pre-wrap

lightning/src/onion_message/messenger.rs

@@ -914,10 +914,11 @@ where
 	CMH::Target: CustomOnionMessageHandler,
 {
 	fn handle_onion_message(&self, peer_node_id: &PublicKey, msg: &OnionMessage) {
+		let logger = WithContext::from(&self.logger, Some(*peer_node_id), None);
 		match self.peel_onion_message(msg) {
 			Ok(PeeledOnion::Receive(message, path_id, reply_path)) => {
 				log_trace!(
-					WithContext::from(&self.logger, Some(*peer_node_id), None),
+					logger,
 					"Received an onion message with path_id {:02x?} and {} reply_path: {:?}",
 					path_id, if reply_path.is_some() { "a" } else { "no" }, message);
 
@@ -946,7 +947,7 @@ where
 				let mut message_recipients = self.message_recipients.lock().unwrap();
 				if outbound_buffer_full(&next_node_id, &message_recipients) {
 					log_trace!(
-						WithContext::from(&self.logger, Some(*peer_node_id), None),
+						logger,
 						"Dropping forwarded onion message to peer {}: outbound buffer full",
 						next_node_id);
 					return
@@ -962,25 +963,19 @@ where
 						e.get(), OnionMessageRecipient::ConnectedPeer(..)
 					) => {
 						e.get_mut().enqueue_message(onion_message);
-						log_trace!(
-							WithContext::from(&self.logger, Some(*peer_node_id), None),
-							"Forwarding an onion message to peer {}",
-							next_node_id);
+						log_trace!(logger, "Forwarding an onion message to peer {}", next_node_id);
 					},
 					_ => {
 						log_trace!(
-							WithContext::from(&self.logger, Some(*peer_node_id), None),
+							logger,
 							"Dropping forwarded onion message to disconnected peer {}",
 							next_node_id);
 						return
 					},
 				}
 			},
 			Err(e) => {
-				log_error!(
-					WithContext::from(&self.logger, Some(*peer_node_id), None),
-					"Failed to process onion message {:?}",
-					e);
+				log_error!(logger, "Failed to process onion message {:?}", e);
 			}
 		}
 	}