diff --git a/src/session/session.rs b/src/session/session.rs index 558dac3..94ffe7d 100644 --- a/src/session/session.rs +++ b/src/session/session.rs @@ -204,6 +204,13 @@ impl Session { } self.last_active_at = now; + // Sync message_count to Storage + if persist { + if let Err(e) = self.persist_session_meta().await { + tracing::warn!("failed to persist session meta: {}", e); + } + } + Ok(()) }