[INIT] started helper functions (incomplete)
This commit is contained in:
parent
5ec7210dc6
commit
27b504012e
2 changed files with 44 additions and 0 deletions
40
src/helpers.rs
Normal file
40
src/helpers.rs
Normal file
|
@ -0,0 +1,40 @@
|
|||
|
||||
use std::time::Instant;
|
||||
pub struct RateLimiter {
|
||||
channels_attr: Vec<RlAttributes>,
|
||||
}
|
||||
|
||||
|
||||
struct RlAttributes {
|
||||
channel: String,
|
||||
enabled: bool,
|
||||
start_time: Instant,
|
||||
msg_counter: u32,
|
||||
}
|
||||
|
||||
|
||||
|
||||
impl RateLimiter {
|
||||
pub fn new() -> Self {
|
||||
Self {
|
||||
channels_attr: vec![],
|
||||
}
|
||||
}
|
||||
|
||||
pub fn sending_msg_to(&mut self, channelname: String) -> bool {
|
||||
self.channels_attr.push(RlAttributes {
|
||||
channel: channelname,
|
||||
enabled: true,
|
||||
start_time: Instant::now(),
|
||||
msg_counter: 0,
|
||||
});
|
||||
|
||||
let chanRateLimiter = self.channels_attr
|
||||
.into_iter()
|
||||
.filter(|r| r.channel == "Hello")
|
||||
.collect();
|
||||
|
||||
chanRateLimiter.is_empty()
|
||||
|
||||
}
|
||||
}
|
|
@ -1,3 +1,5 @@
|
|||
|
||||
|
||||
use twitch_irc::login::StaticLoginCredentials;
|
||||
use twitch_irc::ClientConfig;
|
||||
use twitch_irc::SecureTCPTransport;
|
||||
|
@ -7,6 +9,8 @@ use std::env;
|
|||
use std::time::Instant;
|
||||
use rand::Rng;
|
||||
|
||||
// mod helpers;
|
||||
|
||||
#[tokio::main]
|
||||
pub async fn main() {
|
||||
let login_name = "modulatingforcebot".to_owned();
|
||||
|
|
Loading…
Reference in a new issue