Limit the number of items to notify each time. (#30)

src/main.rs

@@ -102,6 +102,7 @@ async fn run<T: Notifier>(source: SourcePtr, mut notifier: T) {
     let mut last_update = Local::now();
     let interval = source.interval();
     let retry_config = ConstantBuilder::default();
+    let each_notify = notifier.num_items_each_notify();
 
     loop {
         tokio::time::sleep(interval).await;
@@ -122,7 +123,13 @@ async fn run<T: Notifier>(source: SourcePtr, mut notifier: T) {
                 });
 
                 // notify
-                notifier.notify(&source.name(), new_items.clone()).await?;
+                if each_notify == 0 {
+                    notifier.notify(&source.name(), new_items.clone()).await?;
+                } else {
+                    for chunk in new_items.chunks(each_notify) {
+                        notifier.notify(&source.name(), chunk.to_vec()).await?;
+                    }
+                }
             }
         };
 

src/notifier/mod.rs

@@ -24,4 +24,11 @@ use crate::Result;
 #[async_trait::async_trait]
 pub trait Notifier: Sync + Send + Clone {
     async fn notify(&mut self, source: &str, items: Vec<Item>) -> Result<()>;
+
+    /// The number of items to be notified each time.
+    ///
+    /// If it is 0, all items will be notified at once.
+    fn num_items_each_notify(&self) -> usize {
+        0
+    }
 }

src/notifier/qq_guild.rs

@@ -92,6 +92,10 @@ impl Notifier for QQGuildNotifier {
         }
         Ok(())
     }
+
+    fn num_items_each_notify(&self) -> usize {
+        5
+    }
 }
 
 impl QQGuildNotifier {