use std::time::SystemTime;
#[cfg(feature = "log")] pub mod log_crate {
pub use log::{set_max_level, LevelFilter, SetLoggerError};
}
use crate::{default_logger, sync::*, Logger, Record};
#[derive(Default)]
pub struct LogCrateProxy {
logger: ArcSwapOption<Logger>,
}
impl LogCrateProxy {
#[must_use]
pub(crate) fn new() -> Self {
Self::default()
}
pub fn swap_logger(&self, logger: Option<Arc<Logger>>) -> Option<Arc<Logger>> {
self.logger.swap(logger)
}
pub fn set_logger(&self, logger: Option<Arc<Logger>>) {
self.swap_logger(logger);
}
#[must_use]
fn logger(&self) -> Arc<Logger> {
self.logger.load_full().unwrap_or_else(default_logger)
}
}
impl log::Log for LogCrateProxy {
fn enabled(&self, metadata: &log::Metadata) -> bool {
self.logger().should_log(metadata.level().into())
}
fn log(&self, record: &log::Record) {
let logger = self.logger();
let record = Record::from_log_crate_record(&logger, record, SystemTime::now());
logger.log(&record)
}
fn flush(&self) {
self.logger().flush()
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::test_utils::*;
#[test]
fn proxy() {
crate::init_log_crate_proxy().unwrap();
log::set_max_level(log::LevelFilter::Debug);
let sink = Arc::new(CounterSink::new());
crate::log_crate_proxy().set_logger(Some(Arc::new(
test_logger_builder().sink(sink.clone()).build().unwrap(),
)));
assert_eq!(sink.log_count(), 0);
log::info!("hello");
log::error!("world");
assert_eq!(sink.log_count(), 2);
assert_eq!(
sink.payloads(),
vec!["hello".to_string(), "world".to_string()]
);
}
}