djsundog/ffplayout
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ignore hyper logging, check last two messages

Browse Source
This commit is contained in:
jb-alvarado 2022-06-19 22:02:28 +02:00
parent 5534ca049a
commit 03dc21c6a3
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/utils/logging.rs
View File

@ -92,7 +92,7 @@ pub struct LogMailer {
level: LevelFilter, level: LevelFilter,
pub config: Config, pub config: Config,
messages: Arc<Mutex<Vec<String>>>, messages: Arc<Mutex<Vec<String>>>,
last_message: Arc<Mutex<String>>, last_messages: Arc<Mutex<Vec<String>>>,
} }
impl LogMailer { impl LogMailer {
@ -105,7 +105,7 @@ impl LogMailer {
level: log_level, level: log_level,
config, config,
messages, messages,
last_message: Arc::new(Mutex::new(String::new())), last_messages: Arc::new(Mutex::new(vec![String::new()])),
}) })
} }
} }
@ -118,12 +118,15 @@ impl Log for LogMailer {
fn log(&self, record: &Record<'_>) { fn log(&self, record: &Record<'_>) {
if self.enabled(record.metadata()) { if self.enabled(record.metadata()) {
let rec = record.args().to_string(); let rec = record.args().to_string();
let mut last_msg = self.last_message.lock().unwrap(); let mut last_msgs = self.last_messages.lock().unwrap();
// put message only to mail queue when it differs from last message // put message only to mail queue when it differs from last message
// this we do to prevent spamming the mail box // this we do to prevent spamming the mail box
if *last_msg != rec { if !last_msgs.contains(&rec) {
*last_msg = rec.clone(); if last_msgs.len() > 2 {
last_msgs.clear()
}
last_msgs.push(rec.clone());
let local: DateTime<Local> = Local::now(); let local: DateTime<Local> = Local::now();
let time_stamp = local.format("[%Y-%m-%d %H:%M:%S%.3f]"); let time_stamp = local.format("[%Y-%m-%d %H:%M:%S%.3f]");
let level = record.level().to_string().to_uppercase(); let level = record.level().to_string().to_uppercase();
@ -182,6 +185,7 @@ pub fn init_logging(
let mut log_config = ConfigBuilder::new() let mut log_config = ConfigBuilder::new()
.set_thread_level(LevelFilter::Off) .set_thread_level(LevelFilter::Off)
.set_target_level(LevelFilter::Off) .set_target_level(LevelFilter::Off)
.add_filter_ignore_str("hyper")
.add_filter_ignore_str("sqlx") .add_filter_ignore_str("sqlx")
.add_filter_ignore_str("reqwest") .add_filter_ignore_str("reqwest")
.set_level_padding(LevelPadding::Left) .set_level_padding(LevelPadding::Left)