test lazy_static sys

ffplayout-api/examples/stat.rs

@@ -0,0 +1,15 @@
+use std::thread::sleep;
+use std::time::Duration;
+
+use ffplayout_api::utils::system;
+use ffplayout_lib::utils::PlayoutConfig;
+
+fn main() {
+    loop {
+        let system_stat = system::stat(PlayoutConfig::default());
+        print!("{esc}[2J{esc}[1;1H", esc = 27 as char);
+        println!("{system_stat:#?}");
+
+        sleep(Duration::from_secs(1))
+    }
+}

ffplayout-api/src/api/routes.rs

@@ -50,7 +50,7 @@ use crate::utils::{
     playout_config, public_path, read_log_file, read_playout_config, system, Role,
 };
 use crate::{
-    auth::{create_jwt, Claims},
+    api::auth::{create_jwt, Claims},
     utils::control::ProcessControl,
 };
 use ffplayout_lib::{

ffplayout-api/src/lib.rs

@@ -0,0 +1,15 @@
+use clap::Parser;
+use lazy_static::lazy_static;
+use std::sync::Mutex;
+use sysinfo::{System, SystemExt};
+
+pub mod api;
+pub mod db;
+pub mod utils;
+
+use utils::args_parse::Args;
+
+lazy_static! {
+    pub static ref ARGS: Args = Args::parse();
+    pub static ref SYS: Mutex<System> = Mutex::new(System::new_all());
+}

ffplayout-api/src/main.rs

@@ -12,8 +12,6 @@ use actix_files::Files;
 #[cfg(not(debug_assertions))]
 use actix_web_static_files::ResourceFiles;
 
-use clap::Parser;
-use lazy_static::lazy_static;
 use path_clean::PathClean;
 use simplelog::*;
 
@@ -23,8 +21,9 @@ pub mod utils;
 
 use api::{auth, routes::*};
 use db::{db_pool, models::LoginUser};
-use utils::{args_parse::Args, control::ProcessControl, db_path, init_config, run_args};
+use utils::{control::ProcessControl, db_path, init_config, run_args};
 
+use ffplayout_api::{ARGS, SYS};
 use ffplayout_lib::utils::{init_logging, PlayoutConfig};
 
 #[cfg(not(debug_assertions))]
@@ -48,10 +47,6 @@ async fn validator(
     }
 }
 
-lazy_static! {
-    static ref ARGS: Args = Args::parse();
-}
-
 #[actix_web::main]
 async fn main() -> std::io::Result<()> {
     let mut config = PlayoutConfig::new(None);

ffplayout-api/src/utils/system.rs

@@ -1,30 +1,31 @@
-use std::cmp;
+// use std::cmp;
 
 use local_ip_address::list_afinet_netifas;
 use serde::Serialize;
-use sysinfo::{CpuExt, DiskExt, NetworkExt, System, SystemExt};
+use sysinfo::{CpuExt, DiskExt, NetworkExt, SystemExt};
 
+use crate::SYS;
 use ffplayout_lib::utils::PlayoutConfig;
 
-pub fn byte_convert(num: f64) -> String {
-    let negative = if num.is_sign_positive() { "" } else { "-" };
-    let num = num.abs();
-    let units = ["B", "kiB", "MiB", "GiB", "TiB", "PiB", "EiB", "ZiB", "YiB"];
-    if num < 1_f64 {
-        return format!("{negative}{num} B");
-    }
-    let delimiter = 1024_f64;
-    let exponent = cmp::min(
-        (num.ln() / delimiter.ln()).floor() as i32,
-        (units.len() - 1) as i32,
-    );
-    let pretty_bytes = format!("{:.3}", num / delimiter.powi(exponent))
-        .parse::<f64>()
-        .unwrap()
-        * 1_f64;
-    let unit = units[exponent as usize];
-    format!("{negative}{pretty_bytes} {unit}")
-}
+// pub fn byte_convert(num: f64) -> String {
+//     let negative = if num.is_sign_positive() { "" } else { "-" };
+//     let num = num.abs();
+//     let units = ["B", "kiB", "MiB", "GiB", "TiB", "PiB", "EiB", "ZiB", "YiB"];
+//     if num < 1_f64 {
+//         return format!("{negative}{num} B");
+//     }
+//     let delimiter = 1024_f64;
+//     let exponent = cmp::min(
+//         (num.ln() / delimiter.ln()).floor() as i32,
+//         (units.len() - 1) as i32,
+//     );
+//     let pretty_bytes = format!("{:.3}", num / delimiter.powi(exponent))
+//         .parse::<f64>()
+//         .unwrap()
+//         * 1_f64;
+//     let unit = units[exponent as usize];
+//     format!("{negative}{pretty_bytes} {unit}")
+// }
 
 #[derive(Debug, Serialize)]
 pub struct Cpu {
@@ -35,8 +36,8 @@ pub struct Cpu {
 #[derive(Debug, Default, Serialize)]
 pub struct Storage {
     pub path: String,
-    pub total: String,
-    pub used: String,
+    pub total: u64,
+    pub used: u64,
 }
 
 #[derive(Debug, Serialize)]
@@ -48,18 +49,18 @@ pub struct Load {
 
 #[derive(Debug, Serialize)]
 pub struct Memory {
-    pub total: String,
-    pub used: String,
-    pub free: String,
+    pub total: u64,
+    pub used: u64,
+    pub free: u64,
 }
 
 #[derive(Debug, Default, Serialize)]
 pub struct Network {
     pub name: String,
-    pub current_in: String,
-    pub total_in: String,
-    pub current_out: String,
-    pub total_out: String,
+    pub current_in: u64,
+    pub total_in: u64,
+    pub current_out: u64,
+    pub total_out: u64,
 }
 
 #[derive(Debug, Serialize)]
@@ -71,9 +72,9 @@ pub struct MySystem {
 
 #[derive(Debug, Serialize)]
 pub struct Swap {
-    pub total: String,
-    pub used: String,
-    pub free: String,
+    pub total: u64,
+    pub used: u64,
+    pub free: u64,
 }
 
 #[derive(Debug, Serialize)]
@@ -88,8 +89,8 @@ pub struct SystemStat {
 }
 
 pub fn stat(config: PlayoutConfig) -> SystemStat {
+    let mut sys = SYS.lock().unwrap();
     let network_interfaces = list_afinet_netifas().unwrap();
-    let mut sys = System::new_all();
     let mut usage = 0.0;
     let mut interfaces = vec![];
 
@@ -121,8 +122,8 @@ pub fn stat(config: PlayoutConfig) -> SystemStat {
             && config.storage.path.starts_with(disk.mount_point())
         {
             storage.path = disk.name().to_string_lossy().to_string();
-            storage.total = byte_convert(disk.total_space() as f64);
-            storage.used = byte_convert(disk.available_space() as f64);
+            storage.total = disk.total_space();
+            storage.used = disk.available_space();
         }
     }
 
@@ -134,9 +135,9 @@ pub fn stat(config: PlayoutConfig) -> SystemStat {
     };
 
     let memory = Memory {
-        total: byte_convert(sys.total_memory() as f64),
-        used: byte_convert(sys.used_memory() as f64),
-        free: byte_convert((sys.total_memory() - sys.used_memory()) as f64),
+        total: sys.total_memory(),
+        used: sys.used_memory(),
+        free: sys.total_memory() - sys.used_memory(),
     };
 
     let mut network = Network::default();
@@ -144,17 +145,17 @@ pub fn stat(config: PlayoutConfig) -> SystemStat {
     for (interface_name, data) in sys.networks() {
         if !interfaces.is_empty() && interface_name == interfaces[0].0 {
             network.name = interface_name.clone();
-            network.current_in = byte_convert(data.received() as f64);
-            network.total_in = byte_convert(data.total_received() as f64);
-            network.current_out = byte_convert(data.transmitted() as f64);
-            network.total_out = byte_convert(data.total_transmitted() as f64);
+            network.current_in = data.received();
+            network.total_in = data.total_received();
+            network.current_out = data.transmitted();
+            network.total_out = data.total_transmitted();
         }
     }
 
     let swap = Swap {
-        total: byte_convert(sys.total_swap() as f64),
-        used: byte_convert(sys.used_swap() as f64),
-        free: byte_convert((sys.total_swap() - sys.used_swap()) as f64),
+        total: sys.total_swap(),
+        used: sys.used_swap(),
+        free: sys.total_swap() - sys.used_swap(),
     };
 
     let system = MySystem {