HMC/handmade-revolt-backend
6
0
Fork 0
forked from jmug/stoatchat
Code Pull Requests Actions Packages Releases 2 Activity

chore: increase verbosity for ack logging

Browse Source
This commit is contained in:
izzy
2025-05-14 11:46:56 +01:00
parent 4f13f5899b
commit 99a80f723d
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
crates/core/database/src/tasks/ack.rs
View File

@@ -113,7 +113,7 @@ pub async fn handle_ack_event(
} }
AckEvent::ProcessMessage { messages } => { AckEvent::ProcessMessage { messages } => {
let mut users: HashSet<&String> = HashSet::new(); let mut users: HashSet<&String> = HashSet::new();
debug!( info!(
"Processing {} messages from channel {}", "Processing {} messages from channel {}",
messages.len(), messages.len(),
messages[0].1.channel messages[0].1.channel
@@ -124,7 +124,7 @@ pub async fn handle_ack_event(
users.extend(recipents.iter()); users.extend(recipents.iter());
}); });
debug!("Found {} users to notify.", users.len()); info!("Found {} users to notify.", users.len());
for user in users { for user in users {
let message_ids: Vec<String> = messages let message_ids: Vec<String> = messages
@@ -142,7 +142,7 @@ pub async fn handle_ack_event(
db.add_mention_to_unread(channel, user, &message_ids) db.add_mention_to_unread(channel, user, &message_ids)
.await?; .await?;
} }
debug!("Added {} mentions for user {}", message_ids.len(), &user); info!("Added {} mentions for user {}", message_ids.len(), &user);
} }
let mut mass_mentions = vec![]; let mut mass_mentions = vec![];
@@ -231,7 +231,7 @@ pub async fn worker(db: Database, amqp: AMQP) {
revolt_config::capture_error(&err); revolt_config::capture_error(&err);
error!("{err:?} for {event:?}. ({user:?}, {channel})"); error!("{err:?} for {event:?}. ({user:?}, {channel})");
} else { } else {
debug!("User {user:?} ack in {channel} with {event:?}"); info!("User {user:?} ack in {channel} with {event:?}");
} }
} }
} }
@@ -246,6 +246,8 @@ pub async fn worker(db: Database, amqp: AMQP) {
mut event, mut event,
}) = Q.try_pop() }) = Q.try_pop()
{ {
info!("Took next ack from queue, now {} remaining", Q.len());
let key: (Option<String>, String, u8) = ( let key: (Option<String>, String, u8) = (
user, user,
channel, channel,