use floodgate (#124)

Cargo.toml

@@ -31,3 +31,4 @@ humantime = "2.1.0"
 reqwest = "0.11.12"
 thiserror = "1.0.37"
 sentry = "0.29.0"
+floodgate = "0.4.0"

src/client/cooldowns.rs

@@ -1,20 +1,24 @@
+use std::sync::Arc;
+
+use floodgate::FixedMapping;
 use twilight_model::id::{marker::ChannelMarker, Id};
 
-use crate::{constants, utils::cooldowns::FixedMapping};
+use crate::constants;
 
 pub struct Cooldowns {
     // restricts per-channel
-    pub autostar_send: FixedMapping<Id<ChannelMarker>>,
+    pub autostar_send: Arc<FixedMapping<Id<ChannelMarker>>>,
 }
 
 impl Cooldowns {
     pub fn new() -> Self {
-        Self {
-            autostar_send: FixedMapping::new(
-                constants::AUTOSTAR_COOLDOWN.0,
-                constants::AUTOSTAR_COOLDOWN.1,
-            ),
-        }
+        let autostar_send = Arc::new(FixedMapping::new(
+            constants::AUTOSTAR_COOLDOWN.0,
+            constants::AUTOSTAR_COOLDOWN.1,
+        ));
+        FixedMapping::start(autostar_send.clone(), None);
+
+        Self { autostar_send }
     }
 }
 

src/constants.rs

@@ -11,7 +11,7 @@ pub const MAX_MESSAGES: u32 = 10_000;
 pub const MAX_NAMES: u32 = 100;
 
 // Cooldowns
-pub const AUTOSTAR_COOLDOWN: (u32, Duration) = (5, Duration::from_secs(20));
+pub const AUTOSTAR_COOLDOWN: (u64, Duration) = (5, Duration::from_secs(20));
 
 // Common Validation
 pub const MAX_NAME_LENGTH: u32 = 32;

src/core/autostar.rs

@@ -28,9 +28,8 @@ pub async fn handle(bot: &StarboardBot, event: &MessageCreate) -> StarboardResul
     if bot
         .cooldowns
         .autostar_send
-        .trigger(event.channel_id)
-        .await
-        .is_none()
+        .trigger(&event.channel_id)
+        .is_some()
     {
         return Ok(());
     }

src/utils/mod.rs

@@ -1,5 +1,4 @@
 pub mod async_dash;
-pub mod cooldowns;
 pub mod dashset_lock;
 pub mod dm;
 pub mod embed;