Skip to content

Commit 7ded524

Browse files
committed
logging every sent receive onion message
1 parent d2242f6 commit 7ded524

File tree

1 file changed

+25
-2
lines changed

1 file changed

+25
-2
lines changed

lightning/src/onion_message/messenger.rs

Lines changed: 25 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -516,8 +516,23 @@ where
516516
pub fn send_onion_message<T: OnionMessageContents>(
517517
&self, path: OnionMessagePath, contents: T, reply_path: Option<BlindedPath>
518518
) -> Result<(), SendError> {
519-
let (first_node_id, onion_msg) = create_onion_message(
520-
&self.entropy_source, &self.node_signer, &self.secp_ctx, path, contents, reply_path
519+
520+
match &message {
521+
OnionMessageContents::Offers(ref offers_msg) => {
522+
log_trace!(self.logger , "Sending onion message (Offers): {:?}", offers_msg);
523+
}
524+
OnionMessageContents::Custom(ref custom_msg) => {
525+
log_trace!(self.logger , "Sending onion message : {}", custom_msg.tlv_type());
526+
}
527+
};
528+
529+
let (introduction_node_id, onion_msg) = Self::create_onion_message(
530+
&self.entropy_source,
531+
&self.node_signer,
532+
&self.secp_ctx,
533+
path,
534+
message,
535+
reply_path
521536
)?;
522537

523538
let mut pending_per_peer_msgs = self.pending_messages.lock().unwrap();
@@ -570,6 +585,14 @@ where
570585
};
571586

572587
log_trace!(self.logger, "Sending onion message {}", log_suffix);
588+
match &response {
589+
OnionMessageContents::Offers(ref offers_msg) => {
590+
log_trace!(self.logger, "Respoding to onion message {:?} with path_id {:02x?}", offers_msg , path_id);
591+
}
592+
OnionMessageContents::Custom(ref custom_msg) => {
593+
log_trace!(self.logger, "Respoding to onion message {} with path_id {:02x?}", custom_msg.tlv_type() , path_id);
594+
}
595+
};
573596

574597
if let Err(e) = self.send_onion_message(path, contents, reply_path) {
575598
log_trace!(self.logger, "Failed sending onion message {}: {:?}", log_suffix, e);

0 commit comments

Comments
 (0)