From a5d44de5c4cac9d266b7f24784c53e5e667b0991 Mon Sep 17 00:00:00 2001
From: Ashelyn Rose <git@ashen.earth>
Date: Mon, 7 Oct 2024 21:40:31 -0600
Subject: Handle case where system has no members

---
 src/system/aggregator.rs | 5 +++--
 src/system/mod.rs        | 4 ++++
 2 files changed, 7 insertions(+), 2 deletions(-)

(limited to 'src')

diff --git a/src/system/aggregator.rs b/src/system/aggregator.rs
index 8fbdfdd..52b1a8c 100644
--- a/src/system/aggregator.rs
+++ b/src/system/aggregator.rs
@@ -20,13 +20,14 @@ pub struct MessageAggregator {
 
 impl MessageAggregator {
     pub fn new(system_size: usize) -> Self {
-        let (tx, rx) = channel::<MessageEvent>(system_size * 2);
+        let buf_size = std::cmp::max(system_size * 2, 1);
+        let (tx, rx) = channel::<MessageEvent>(buf_size);
 
         Self {
             state: Arc::new(RwLock::new( AggregatorState {
                 tx,
                 rx,
-                message_cache: LruCache::new(NonZeroUsize::new(system_size * 2).unwrap()),
+                message_cache: LruCache::new(NonZeroUsize::new(buf_size).unwrap()),
                 system_emitter: None,
 
             }))
diff --git a/src/system/mod.rs b/src/system/mod.rs
index d993731..44c6da8 100644
--- a/src/system/mod.rs
+++ b/src/system/mod.rs
@@ -82,6 +82,10 @@ impl Manager {
             self.start_bot(member_id).await;
         }
 
+        if self.config.members.len() < 1 {
+            println!("WARNING: System {} has no configured members", &self.name);
+        }
+
         loop {
             match system_receiver.recv().await {
                 Some(SystemEvent::GatewayConnected(member_id, user_id)) => {
-- 
cgit 1.4.1