1 use std
::{ fs
, time
::SystemTime
};
2 use sysinfo
::{ ProcessExt
, SystemExt
};
3 use chrono
::{ DateTime
, offset
::Local
};
5 #[derive(Clone, Debug)]
6 pub struct MinecraftExe
{
8 load_average_5min
: f64, // [%].
10 world_size
: u64, // [B].
11 active_players
: Vec
<String
>,
12 last_backup
: Option
<SystemTime
>,
16 pub fn format_memory(&self) -> String
{
17 format_byte_size(self.memory
* 1024, 2)
20 pub fn format_load_average(&self) -> String
{
21 format!("{:.2} %", self.load_average_5min
)
24 pub fn format_uptime(&self) -> String
{
25 let mins
= self.uptime
/ 60;
26 let hours
= mins
/ 60;
27 let days
= hours
/ 24;
28 format!("{}d {}h {}min", days
, hours
- 24 * days
, mins
- 60 * hours
)
31 pub fn format_world_size(&self) -> String
{
32 format_byte_size(self.world_size
, 2)
35 pub fn format_active_players(&self) -> String
{
36 if self.active_players
.len() == 0 {
37 String
::from("<none>")
39 self.active_players
.join(", ")
43 pub fn format_last_backup(&self) -> String
{
44 match self.last_backup
{
46 let datetime
: DateTime
<Local
> = t
.into();
47 datetime
.format("%d/%m/%Y %T").to_string()
49 None
=> String
::from("?")
54 const BINARY_PREFIXES
: [&str; 8] = ["B", "KiB", "MiB", "GiB", "TiB", "PiB", "EiB", "ZiB"];
56 fn format_byte_size(bytes
: u64, precision
: usize) -> String
{
58 let mut size
: u64 = 1;
59 size
*= 1024u64.pow(i
as u32);
62 return format!("{} {}", std
::cmp
::max(0u64, bytes
), BINARY_PREFIXES
[i
]);
64 else if bytes
< 1024 * size
{
65 return format!("{:.prec$} {}", bytes
as f64 / size
as f64, BINARY_PREFIXES
[i
], prec
= precision
);
72 const MINECRAFT_PROCESS_NAME
: &str = "java";
74 struct StatusFromRcon
{
78 fn get_status_from_rcon(rcon_password
: &str) -> StatusFromRcon
{
79 let mut client
= minecraft_client_rs
::Client
::new("127.0.0.1:25575".to_string()).unwrap();
82 match client
.authenticate(rcon_password
.to_string()) {
86 match client
.send_command("list".to_string()) {
88 match resp
.body
.find('
:'
) {
89 Some(i
) if i
< resp
.body
.len() -1 =>
90 resp
.body
[i
+ 1..resp
.body
.len()]
92 .map(|nick
| nick
.trim().to_string())
93 .filter(|nick
| !nick
.is_empty())
98 println!("Error from 'list' command");
105 println!("Authentication error");
106 StatusFromRcon
{ players
: Vec
::new() }
110 client
.close().unwrap();
115 fn get_last_backup_datetime(backup_path
: &str) -> Option
<SystemTime
> {
117 fs
::read_dir(backup_path
).ok()?
.filter_map(
120 if dir
.path().is_file() { Some(dir
.metadata().ok()?
.modified().ok()?
) } else { None
}
123 .collect
::<Vec
<SystemTime
>>();
127 Some(times
.last()?
.clone())
130 pub fn get_minecraft_executable_information(world_path
: &str, backup_path
: &str, rcon_password
: &str) -> Option
<MinecraftExe
> {
131 let mut system
= sysinfo
::System
::new_all();
132 system
.refresh_system();
133 let processes
= system
.get_process_by_name(MINECRAFT_PROCESS_NAME
);
135 // TODO: find the correct process by checking the correct jar name in parameters.
136 if processes
.len() >= 1 {
137 let process
= processes
.first().unwrap();
139 let world_size
= match fs_extra
::dir
::get_size(world_path
) { Ok(l
) => l
, Err(_
) => 0u64 };
141 let status_from_rcon
= get_status_from_rcon(rcon_password
);
145 memory
: process
.memory() / 3, // Because the Java garbage collector ZGC reports three times more the real memory usage: https://stackoverflow.com/a/62934057/212675
146 load_average_5min
: system
.get_load_average().five
/ system
.get_processors().len() as f64 * 100.,
147 uptime
: std
::time
::SystemTime
::now().duration_since(std
::time
::UNIX_EPOCH
).unwrap().as_secs() - process
.start_time(),
149 active_players
: status_from_rcon
.players
,
150 last_backup
: get_last_backup_datetime(backup_path
)