Allow configuring the log level, default to Debug

Author: tnull

bindings/ldk_node.udl

@@ -7,6 +7,7 @@ dictionary Config {
 	Network network;
 	NetAddress? listening_address;
 	u32 default_cltv_expiry_delta;
+	LogLevel log_level;
 };
 
 interface Builder {
@@ -156,6 +157,15 @@ dictionary PeerDetails {
 	boolean is_connected;
 };
 
+enum LogLevel {
+	"Gossip",
+	"Trace",
+	"Debug",
+	"Info",
+	"Warn",
+	"Error",
+};
+
 [Custom]
 typedef string Txid;
 

src/lib.rs

@@ -90,7 +90,6 @@ mod wallet;
 pub use bip39;
 pub use bitcoin;
 pub use lightning;
-use lightning::ln::msgs::RoutingMessageHandler;
 pub use lightning_invoice;
 
 pub use error::Error as NodeError;
@@ -120,11 +119,13 @@ use lightning::chain::{chainmonitor, BestBlock, Confirm, Watch};
 use lightning::ln::channelmanager::{
 	self, ChainParameters, ChannelManagerReadArgs, PaymentId, RecipientOnionFields, Retry,
 };
+use lightning::ln::msgs::RoutingMessageHandler;
 use lightning::ln::peer_handler::{IgnoringMessageHandler, MessageHandler};
 use lightning::ln::{PaymentHash, PaymentPreimage, PaymentSecret};
 use lightning::routing::scoring::{ProbabilisticScorer, ProbabilisticScoringParameters};
 
 use lightning::util::config::{ChannelHandshakeConfig, ChannelHandshakeLimits, UserConfig};
+pub use lightning::util::logger::Level as LogLevel;
 use lightning::util::ser::ReadableArgs;
 
 use lightning_background_processor::process_events_async;
@@ -194,6 +195,10 @@ pub struct Config {
 	pub listening_address: Option<NetAddress>,
 	/// The default CLTV expiry delta to be used for payments.
 	pub default_cltv_expiry_delta: u32,
+	/// The level at which we log messages.
+	///
+	/// Any messages below this level will be excluded from the logs.
+	pub log_level: LogLevel,
 }
 
 impl Default for Config {
@@ -204,6 +209,7 @@ impl Default for Config {
 			network: Network::Regtest,
 			listening_address: Some("0.0.0.0:9735".parse().unwrap()),
 			default_cltv_expiry_delta: 144,
+			log_level: LogLevel::Debug,
 		}
 	}
 }
@@ -320,6 +326,12 @@ impl Builder {
 		self
 	}
 
+	/// Sets the level at which [`Node`] will log messages.
+	pub fn set_log_level(&mut self, level: LogLevel) -> &mut Self {
+		self.config.log_level = level;
+		self
+	}
+
 	/// Builds a [`Node`] instance with a [`FilesystemStore`] backend and according to the options
 	/// previously configured.
 	pub fn build(&self) -> Arc<Node<FilesystemStore>> {
@@ -342,7 +354,7 @@ impl Builder {
 
 		// Initialize the Logger
 		let log_file_path = format!("{}/ldk_node.log", config.storage_dir_path);
-		let logger = Arc::new(FilesystemLogger::new(log_file_path));
+		let logger = Arc::new(FilesystemLogger::new(log_file_path, config.log_level));
 
 		// Initialize the on-chain wallet and chain access
 		let seed_bytes = if let Some(entropy_source_config) = &self.entropy_source_config {

src/logger.rs

@@ -1,27 +1,32 @@
 pub(crate) use lightning::util::logger::Logger;
-use lightning::util::logger::Record;
-use lightning::util::ser::Writer;
 pub(crate) use lightning::{log_error, log_info, log_trace};
 
+use lightning::util::logger::{Level, Record};
+use lightning::util::ser::Writer;
+
 use chrono::Utc;
 
 use std::fs;
 use std::path::Path;
 
 pub(crate) struct FilesystemLogger {
 	file_path: String,
+	level: Level,
 }
 
 impl FilesystemLogger {
-	pub(crate) fn new(file_path: String) -> Self {
+	pub(crate) fn new(file_path: String, level: Level) -> Self {
 		if let Some(parent_dir) = Path::new(&file_path).parent() {
 			fs::create_dir_all(parent_dir).unwrap();
 		}
-		Self { file_path }
+		Self { file_path, level }
 	}
 }
 impl Logger for FilesystemLogger {
 	fn log(&self, record: &Record) {
+		if record.level < self.level {
+			return;
+		}
 		let raw_log = record.args.to_string();
 		let log = format!(
 			"{} {:<5} [{}:{}] {}\n",

src/test/utils.rs

@@ -266,6 +266,8 @@ pub fn random_config(esplora_url: &str) -> Config {
 	let listening_address_str = format!("127.0.0.1:{}", rand_port);
 	config.listening_address = Some(listening_address_str.parse().unwrap());
 
+	config.log_level = Level::Trace;
+
 	config
 }