janek
/
mostr
1
0
Fork 1
Code Issues Pull Requests Releases Activity

refactor(main): define timeout delays as constants

This commit is contained in:
xeruf 2024-08-13 21:29:55 +03:00
parent 6cb2d47a8d
commit a059ff1c3e
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main.rs
View File

@ -31,6 +31,9 @@ mod task;
mod tasks; mod tasks;
mod kinds; mod kinds;
const UNDO_DELAY: u64 = 60;
const INACTVITY_DELAY: u64 = 200;
type Events = Vec<Event>; type Events = Vec<Event>;
#[derive(Debug, Clone)] #[derive(Debug, Clone)]
@ -54,7 +57,7 @@ impl EventSender {
{ {
// Always flush if oldest event older than a minute or newer than now // Always flush if oldest event older than a minute or newer than now
let borrow = self.queue.borrow(); let borrow = self.queue.borrow();
let min = Timestamp::now().sub(60u64); let min = Timestamp::now().sub(UNDO_DELAY);
if borrow.iter().any(|e| e.created_at < min || e.created_at > Timestamp::now()) { if borrow.iter().any(|e| e.created_at < min || e.created_at > Timestamp::now()) {
drop(borrow); drop(borrow);
debug!("Flushing event queue because it is older than a minute"); debug!("Flushing event queue because it is older than a minute");
@ -227,7 +230,7 @@ async fn main() {
loop { loop {
// TODO invalid acknowledgement from bucket relay slows sending down // TODO invalid acknowledgement from bucket relay slows sending down
match rx.recv_timeout(Duration::from_secs(200)) { match rx.recv_timeout(Duration::from_secs(INACTVITY_DELAY)) {
Ok((url, mut events)) => { Ok((url, mut events)) => {
if 1 == 2 { if 1 == 2 {
client.connect_relay("").await; client.connect_relay("").await;