logos-messaging/libchat
1
0
Fork 0
mirror of https://github.com/logos-messaging/libchat.git synced 2026-06-28 03:59:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

change log level

Browse Source
This commit is contained in:
Jazz Turner-Baggs 2026-06-02 17:51:56 -07:00
parent 0bfdf70a7c
commit 8112a83356
No known key found for this signature in database
2 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/core_client/src/conversation/group_v2.rs
View File

@ -34,7 +34,7 @@ use prost::Message;
use rand::{self, Rng};
use std::sync::{Arc, Mutex};
use std::time::Duration;
use tracing::info;
use tracing::{debug, info};
use crate::AccountId;
use crate::conversation::{ConversationIdRef, ExternalServices, ServiceContext};
@ -90,7 +90,7 @@ impl BufferDs {
) -> Result<(), ChatError> {
// Swap the Vec out; Own then existing and replace with a new empty vec.
for pkt in self.queue.drain(..) {
info!(
debug!(
app = pkt.app_id.as_slice(),
convo = pkt.conversation_id,
topic = pkt.subtopic,

8
core/integration_tests_core/tests/dev_tests.rs
View File

@ -1,7 +1,7 @@
use std::cell::RefCell;
use std::ops::{Deref, DerefMut};
use std::rc::Rc;
use tracing::info;
use tracing::{debug, info};
use components::{EphemeralRegistry, LocalBroadcaster, MemStore};
@ -174,9 +174,8 @@ impl ManualWakeupService {
.is_some_and(|Reverse(w)| w.expiry <= self.now)
{
let Reverse(w) = self.pending.pop().unwrap();
info!(now = self.now, w.convo_id, "Popping");
debug!(now = self.now, w.convo_id, "Popping");
fired.push(w.convo_id);
dbg!(&self);
}
fired
}
@ -194,7 +193,7 @@ impl ManualWakeupService {
impl WakeupService for ManualWakeupService {
fn wakeup_in(&mut self, secs: u32, convo_id: libchat::ConversationId) {
info!(now = self.now, secs, convo_id, "Pushing");
debug!(now = self.now, secs, convo_id, "Pushing");
self.pending.push(Reverse(WakeupRecord {
expiry: self.now + secs,
convo_id: convo_id.to_string(),
@ -276,7 +275,6 @@ impl WakeupProvider {
.map_or(vec![], |client| client.ws().tick(secs))
};
for convo_id in fired {
info!("FIRED");
if let Some(client) = self.client_slot.borrow().as_ref() {
client.on_wakeup(&convo_id).unwrap();
}