Neshura/aob-lemmy-bot
Neshura/aob-lemmy-bot
1
0
Fork 0
Code Issues 9 Pull requests Projects 1 Releases 62 Packages Wiki Activity Actions

Deduplicate Config reload logging

Browse source
This commit is contained in:
Neshura 2023-12-18 11:24:02 +01:00
parent 080b0bf4d8
commit 5ba963305c
Signed by: Neshura
GPG key ID: B6983AAA6B9A7A6C
1 changed files with 13 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/bot/mod.rs
View file

@ -69,7 +69,10 @@ pub(crate) async fn run(data: Arc<RwLock<SharedData>>) {
Ok(data) => data, Ok(data) => data,
Err(e) => panic!("{}", e), Err(e) => panic!("{}", e),
}; };
write.messages.push(Message::Info("Config reloaded".to_string())); let message = Message::Info("Config reloaded".to_string());
if !write.messages.contains(&message) {
write.messages.push(message);
};
} }
} }
@ -102,9 +105,12 @@ pub(crate) async fn run(data: Arc<RwLock<SharedData>>) {
continue continue
} }
}; };
drop(read); let message = Message::Info("Communities reloaded".to_string());
let mut write = data.write().await; if !read.messages.contains(&message) {
write.messages.push(Message::Info("Communities reloaded".to_string())); drop(read);
let mut write = data.write().await;
write.messages.push(message);
};
last_reload = Utc::now(); last_reload = Utc::now();
} }
} }
@ -199,10 +205,11 @@ async fn handle_series(
{ {
let read = data.read().await; let read = data.read().await;
if read.post_history.check_for_post(series.slug.as_str(), post_part_info.as_string().as_str(), post_lemmy_info.title.as_str()) { if read.post_history.check_for_post(series.slug.as_str(), post_part_info.as_string().as_str(), post_lemmy_info.title.as_str()) {
if !read.messages.contains(&Message::Info(format!("Skipping '{}' since already posted", post_lemmy_info.title))) { let message = Message::Info(format!("Skipping '{}' since already posted", post_lemmy_info.title));
if !read.messages.contains(&message) {
drop(read); drop(read);
let mut write = data.write().await; let mut write = data.write().await;
write.messages.push(Message::Info(format!("Skipping '{}' since already posted", post_lemmy_info.title))); write.messages.push(message);
}; };
post_list.remove(index); post_list.remove(index);
continue continue