twitch: send last 3 msg

Author: jkbz64

crates/server/src/health.rs

@@ -20,6 +20,8 @@ pub type HealthConnections = Arc<RwLock<BTreeMap<String, HealthConnection>>>;
 pub type HealthTargets = Arc<RwLock<HashSet<String>>>;
 pub type HealthStats = Arc<RwLock<BTreeMap<String, EndpointSample>>>;
 
+const MAX_CHAT_MESSAGES_PER_HEALTH_REPORT: usize = 3;
+
 #[derive(Clone, Copy, Default)]
 pub struct EndpointSample {
     pub bytes: u64,
@@ -158,7 +160,11 @@ fn build_health_report(
         endpoints,
         chat: twitch_chat
             .map(|chat| {
-                chat.recent_messages()
+                let mut messages = chat.recent_messages();
+                if messages.len() > MAX_CHAT_MESSAGES_PER_HEALTH_REPORT {
+                    messages.drain(0..messages.len() - MAX_CHAT_MESSAGES_PER_HEALTH_REPORT);
+                }
+                messages
                     .into_iter()
                     .map(|message| ChatMessage {
                         id: message.id,

crates/twitch-remote/src/lib.rs

@@ -42,6 +42,16 @@ impl TwitchChat {
         self.messages.read().iter().cloned().collect()
     }
 
+    pub fn messages_after(&self, last_id: u64, limit: usize) -> Vec<TwitchChatMessage> {
+        self.messages
+            .read()
+            .iter()
+            .filter(|message| message.id > last_id)
+            .take(limit)
+            .cloned()
+            .collect()
+    }
+
     fn push(&self, user: String, text: String) -> Result<()> {
         let id = self.next_id.fetch_add(1, Ordering::Relaxed);
         let unix_ms = SystemTime::now()