X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=src%2Futil%2Ftest_utils.rs;h=52e44f92abca02f5fa14e77dc97ecf3b21f728de;hb=673912e7695be6b2cbfe03c38ddd37cb1b5a4655;hp=9646754f2d0097f51358cf5be9d86c8519acfcd4;hpb=b8b7cb238da7b9ba3443d0cf87df11052185a87e;p=rust-lightning diff --git a/src/util/test_utils.rs b/src/util/test_utils.rs index 9646754f..52e44f92 100644 --- a/src/util/test_utils.rs +++ b/src/util/test_utils.rs @@ -5,6 +5,7 @@ use ln::channelmonitor; use ln::msgs; use ln::msgs::{HandleError}; use util::events; +use util::logger::{Logger, Level, Record}; use bitcoin::blockdata::transaction::Transaction; @@ -114,6 +115,7 @@ impl msgs::ChannelMessageHandler for TestChannelMessageHandler { Err(HandleError { err: "", action: None }) } fn peer_disconnected(&self, _their_node_id: &PublicKey, _no_connection_possible: bool) {} + fn handle_error(&self, _their_node_id: &PublicKey, _msg: &msgs::ErrorMessage) {} } impl events::EventsProvider for TestChannelMessageHandler { @@ -134,14 +136,37 @@ impl TestRoutingMessageHandler { } impl msgs::RoutingMessageHandler for TestRoutingMessageHandler { - fn handle_node_announcement(&self, _msg: &msgs::NodeAnnouncement) -> Result<(), HandleError> { + fn handle_node_announcement(&self, _msg: &msgs::NodeAnnouncement) -> Result { Err(HandleError { err: "", action: None }) } fn handle_channel_announcement(&self, _msg: &msgs::ChannelAnnouncement) -> Result { Err(HandleError { err: "", action: None }) } - fn handle_channel_update(&self, _msg: &msgs::ChannelUpdate) -> Result<(), HandleError> { + fn handle_channel_update(&self, _msg: &msgs::ChannelUpdate) -> Result { Err(HandleError { err: "", action: None }) } fn handle_htlc_fail_channel_update(&self, _update: &msgs::HTLCFailChannelUpdate) {} } + +pub struct TestLogger { + level: Level, +} + +impl TestLogger { + pub fn new() -> TestLogger { + TestLogger { + level: Level::Trace, + } + } + pub fn enable(&mut self, level: Level) { + self.level = level; + } +} + +impl Logger for TestLogger { + fn log(&self, record: &Record) { + if self.level >= record.level { + println!("{:<5} [{} : {}, {}] {}", record.level.to_string(), record.module_path, record.file, record.line, record.args); + } + } +}