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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98

use crate::api::{ApiProvider, ApiServerStatus};
use crate::error::ServerManagerError;
use std::time::{Duration, Instant};

#[derive(Debug, Clone, PartialEq)]
pub enum ServerState {
    Starting,
    Running,
    Stopping,
    Stopped,
    Crashed,
    Unknown,
}

impl From<&str> for ServerState {
    fn from(state: &str) -> Self {
        match state.to_lowercase().as_str() {
            "starting" => ServerState::Starting,
            "running" => ServerState::Running,
            "stopping" => ServerState::Stopping,
            "stopped" => ServerState::Stopped,
            "offline" => ServerState::Stopped,
            "crashed" => ServerState::Crashed,
            _ => ServerState::Unknown,
        }
    }
}

#[derive(Debug, Clone)]
pub struct ServerStatus {
    pub server_id: String,
    pub state: ServerState,
    pub last_checked: Instant,
    pub uptime: Option<Duration>,
    pub last_crash_time: Option<Instant>,
    pub crash_count: u32,
}

impl ServerStatus {
    pub fn new(server_id: &str) -> Self {
        ServerStatus {
            server_id: server_id.to_string(),
            state: ServerState::Unknown,
            last_checked: Instant::now(),
            uptime: None,
            last_crash_time: None,
            crash_count: 0,
        }
    }

    pub fn update_state(&mut self, new_state: ServerState) {
        if new_state == ServerState::Crashed && self.state != ServerState::Crashed {
            self.last_crash_time = Some(Instant::now());
            self.crash_count += 1;
        }

        if self.state != ServerState::Running && new_state == ServerState::Running {
            self.uptime = Some(Duration::from_secs(0));
        } else if self.state == ServerState::Running
            && new_state == ServerState::Running
            && let Some(current_uptime) = self.uptime
        {
            let elapsed = self.last_checked.elapsed();
            self.uptime = Some(current_uptime + elapsed);
        }

        self.state = new_state;
        self.last_checked = Instant::now();
    }

    pub fn is_crashed(&self) -> bool {
        self.state == ServerState::Crashed
    }

    pub fn is_running(&self) -> bool {
        self.state == ServerState::Running
    }
}

impl From<ApiServerStatus> for ServerStatus {
    fn from(api_status: ApiServerStatus) -> Self {
        let mut status = ServerStatus::new(&api_status.id);
        status.update_state(api_status.status);
        status
    }
}

pub async fn check_status<T: ApiProvider>(
    api: &T,
    server_id: &str,
) -> Result<ServerStatus, ServerManagerError> {
    let api_status = api.get_server_status(server_id).await?;

    let mut status = ServerStatus::from(api_status);
    status.server_id = server_id.to_string();

    Ok(status)
}