X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning%2Fsrc%2Futil%2Fmacro_logger.rs;h=dba63663471d48e9181ed25d1e460c4c304b0153;hb=1a870fe8aae5fcbb0f974d47f4c6b4f531ffa3a9;hp=1f68542773e462bd9623f24d27562d0d11339caa;hpb=53052234959a3c0a7323a194c351c4ba9b46339b;p=rust-lightning diff --git a/lightning/src/util/macro_logger.rs b/lightning/src/util/macro_logger.rs index 1f685427..dba63663 100644 --- a/lightning/src/util/macro_logger.rs +++ b/lightning/src/util/macro_logger.rs @@ -1,6 +1,7 @@ use chain::transaction::OutPoint; use bitcoin_hashes::sha256d::Hash as Sha256dHash; +use bitcoin::blockdata::transaction::Transaction; use secp256k1::key::PublicKey; use ln::router::Route; @@ -89,6 +90,44 @@ macro_rules! log_route { } } +pub(crate) struct DebugTx<'a>(pub &'a Transaction); +impl<'a> std::fmt::Display for DebugTx<'a> { + fn fmt(&self, f: &mut std::fmt::Formatter) -> Result<(), std::fmt::Error> { + if self.0.input.len() >= 1 && self.0.input.iter().any(|i| !i.witness.is_empty()) { + if self.0.input.len() == 1 && self.0.input[0].witness.last().unwrap().len() == 71 && + (self.0.input[0].sequence >> 8*3) as u8 == 0x80 { + write!(f, "commitment tx")?; + } else if self.0.input.len() == 1 && self.0.input[0].witness.last().unwrap().len() == 71 { + write!(f, "closing tx")?; + } else if self.0.input.len() == 1 && self.0.input[0].witness.last().unwrap().len() == 133 && + self.0.input[0].witness.len() == 5 { + write!(f, "HTLC-timeout tx")?; + } else if self.0.input.len() == 1 && + (self.0.input[0].witness.last().unwrap().len() == 138 || self.0.input[0].witness.last().unwrap().len() == 139) && + self.0.input[0].witness.len() == 5 { + write!(f, "HTLC-success tx")?; + } else { + for inp in &self.0.input { + if !inp.witness.is_empty() { + if inp.witness.last().unwrap().len() == 133 { write!(f, "preimage-")?; break } + else if inp.witness.last().unwrap().len() == 138 { write!(f, "timeout-")?; break } + } + } + write!(f, "tx")?; + } + } else { + write!(f, "INVALID TRANSACTION")?; + } + Ok(()) + } +} + +macro_rules! log_tx { + ($obj: expr) => { + ::util::macro_logger::DebugTx(&$obj) + } +} + macro_rules! log_internal { ($self: ident, $lvl:expr, $($arg:tt)+) => ( &$self.logger.log(&::util::logger::Record::new($lvl, format_args!($($arg)+), module_path!(), file!(), line!()));