infrarust_server_manager 1.6.3

A Minecraft server manager that handles API monitoring and system commands
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

use crate::api::ApiProvider;
use crate::error::ServerManagerError;
use crate::monitor::status::ServerStatus;
use std::time::{Duration, Instant};

const DEFAULT_CRASH_THRESHOLD: u32 = 3;
const DEFAULT_CRASH_WINDOW: Duration = Duration::from_secs(300); // 5 minutes

#[derive(Debug, Clone)]
pub struct CrashDetector {
    crash_threshold: u32,
    crash_window: Duration,
    last_check: Instant,
}

impl Default for CrashDetector {
    fn default() -> Self {
        Self {
            crash_threshold: DEFAULT_CRASH_THRESHOLD,
            crash_window: DEFAULT_CRASH_WINDOW,
            last_check: Instant::now(),
        }
    }
}

impl CrashDetector {
    pub fn new(crash_threshold: u32, crash_window: Duration) -> Self {
        Self {
            crash_threshold,
            crash_window,
            last_check: Instant::now(),
        }
    }

    pub fn is_in_crash_loop(&self, status: &ServerStatus) -> bool {
        if status.crash_count >= self.crash_threshold
            && let Some(last_crash) = status.last_crash_time
        {
            let elapsed_since_crash = last_crash.elapsed();
            return elapsed_since_crash <= self.crash_window;
        }
        false
    }

    pub fn reset(&mut self) {
        self.last_check = Instant::now();
    }
}

pub async fn detect_crash_loop<T: ApiProvider>(
    api: &T,
    server_id: &str,
    detector: &CrashDetector,
) -> Result<bool, ServerManagerError> {
    let status = crate::monitor::status::check_status(api, server_id).await?;
    Ok(detector.is_in_crash_loop(&status))
}