Cleanup cpu_load_bar func. Using lib.

Add license

Cargo.toml

@@ -1,9 +1,10 @@
 [package]
 name = "tmux-helper"
-version = "0.1.0"
+version = "0.2.0"
 authors = ["Ultra Desu <ultradesu@hexor.ru>"]
 edition = "2018"
 
 [dependencies]
 sys-info = "*"
 dbus = "*"
+chrono = "*"

LICENSE-WTFPL

@@ -0,0 +1,13 @@
+        DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE 
+                    Version 2, December 2004 
+
+ Copyright (C) 2004 Sam Hocevar <sam@hocevar.net> 
+
+ Everyone is permitted to copy and distribute verbatim or modified 
+ copies of this license document, and changing it is allowed as long 
+ as the name is changed. 
+
+            DO WHAT THE FUCK YOU WANT TO PUBLIC LICENSE 
+   TERMS AND CONDITIONS FOR COPYING, DISTRIBUTION AND MODIFICATION 
+
+  0. You just DO WHAT THE FUCK YOU WANT TO.

src/main.rs

@@ -1,17 +1,21 @@
+extern crate chrono;
 extern crate dbus;
+
 use crate::dbus::blocking::stdintf::org_freedesktop_dbus::Properties;
+use chrono::{DateTime, Local, Utc};
 use dbus::{arg, blocking::Connection};
-use std::{env, fs, time::Duration};
+use std::{env, time::Duration};
 use sys_info;
 
-const LOW: &str = "#[fg=colour2]";
+const LOW: &str = "#[fg=colour119]";
-const MID: &str = "#[fg=colour3]";
+const MID: &str = "#[fg=colour220]";
-const HIGH: &str = "#[fg=colour1]";
+const HIGH: &str = "#[fg=colour197]";
-const END: &str = "#[fg=colour7]";
+const END: &str = "#[fg=colour153]";
-const TRACK_NAME: &str = "#[fg=colour3]";
+const TRACK_NAME: &str = "#[fg=colour46]";
-const TRACK_ARTIST: &str = "#[fg=colour3]";
+const TRACK_ARTIST: &str = "#[fg=colour46]";
-const TRACK_TIME: &str = "#[bg=colour252 fg=colour235 bold]";
+const TRACK_TIME: &str = "#[fg=colour153]";
 
+#[derive(Debug, Clone)]
 struct TrackInfo {
     title: String,
     artist: String,
@@ -20,10 +24,6 @@ struct TrackInfo {
     status: String,
 }
 
-fn read_file(file_path: &str) -> String {
-    fs::read_to_string(file_path).expect("Cant read file.")
-}
-
 fn to_bar(value: i32, max: i32, low: f32, mid: f32) {
     let mut bar = "".to_string();
     let bar_sym = "▮".to_string();
@@ -55,71 +55,97 @@ fn mem_load_bar(bar_len: i32) {
     let len =
         ((memory.total - memory.avail) as f32 / (memory.total as f32) * bar_len as f32) as i32;
     to_bar(len, bar_len, 0.7, 0.9);
-    print!("{:.0} MiB", memory.avail / 1024);
+    print!("{:.0} MiB#[default]", memory.avail / 1024);
 }
 
 fn cpu_load_bar(bar_len: i32) {
-    let load = read_file("/proc/loadavg");
+    let cpu_count = match sys_info::cpu_num() {
-    let load_data = load.split_whitespace().collect::<Vec<&str>>();
+        Ok(c) => c,
-    let _cpu_count = read_file("/proc/cpuinfo");
+        Err(e) => panic!("{:?}", e),
-    let cpu_count = _cpu_count.matches("model name").count();
+    };
-    let one: f32 = load_data[0].parse().unwrap();
+    let la_one: f32 = match sys_info::loadavg() {
-    let len: f32 = one as f32 / cpu_count as f32 * bar_len as f32;
+        Ok(l) => l.one as f32,
+        Err(e) => panic!("{:?}", e),
+    };
+    let len: f32 = la_one as f32 / cpu_count as f32 * bar_len as f32;
     to_bar(len as i32, bar_len, 0.3, 0.7);
-    print!("{:.2} LA1", one);
+    print!("{:.2} LA1#[default]", la_one);
 }
 
-fn player_info(player: &str) -> Result<TrackInfo, Box<dyn std::error::Error>> {
+fn get_player() -> Result<Vec<String>, Box<dyn std::error::Error>> {
     let conn = Connection::new_session()?;
-    let mut service: String = "org.mpris.MediaPlayer2.".to_owned();
+    let proxy = conn.with_proxy("org.freedesktop.DBus", "/", Duration::from_millis(5000));
-    service.push_str(player);
+    let (names,): (Vec<String>,) = proxy.method_call("org.freedesktop.DBus", "ListNames", ())?;
-    let proxy = conn.with_proxy(
+    let mut players: Vec<String> = Vec::new();
-        service,
+    for name in names {
-        "/org/mpris/MediaPlayer2",
+        if name.contains("org.mpris.MediaPlayer2") {
-        Duration::from_millis(5000),
+            players.push(name);
-    );
-    let metadata: Box<dyn arg::RefArg> = proxy.get("org.mpris.MediaPlayer2.Player", "Metadata")?;
-    let mut iter = metadata.as_iter().unwrap();
-    let mut track_info = TrackInfo {
-        artist: "".to_string(),
-        title: "".to_string(),
-        position: "".to_string(),
-        duration: "".to_string(),
-        status: "".to_string(),
-    };
-    while let Some(key) = iter.next() {
-        if key.as_str() == Some("xesam:title") {
-            if let Some(title) = iter.next().unwrap().as_str() {
-                track_info.title = title.to_string();
-            }
         }
-        if key.as_str() == Some("mpris:length") {
+    }
-            if let Some(length) = iter.next().unwrap().as_i64() {
+
-                track_info.duration = format_time(length / 1000000);
+    Ok(players)
+}
+
+fn player_info(players: Vec<String>) -> Result<TrackInfo, Box<dyn std::error::Error>> {
+    let mut players_vec: Vec<TrackInfo> = Vec::new();
+    for player in players {
+        let mut track_info = TrackInfo {
+            artist: "".to_string(),
+            title: "".to_string(),
+            position: "".to_string(),
+            duration: "".to_string(),
+            status: "".to_string(),
+        };
+        let conn = Connection::new_session()?;
+        let proxy = conn.with_proxy(
+            player,
+            "/org/mpris/MediaPlayer2",
+            Duration::from_millis(5000),
+        );
+        let metadata: Box<dyn arg::RefArg> =
+            proxy.get("org.mpris.MediaPlayer2.Player", "Metadata")?;
+        let mut iter = metadata.as_iter().unwrap();
+        while let Some(key) = iter.next() {
+            if key.as_str() == Some("xesam:title") {
+                if let Some(title) = iter.next().unwrap().as_str() {
+                    track_info.title = title.to_string();
+                }
             }
-        }
+            if key.as_str() == Some("mpris:length") {
-        if key.as_str() == Some("xesam:artist") {
+                if let Some(length) = iter.next().unwrap().as_i64() {
-            if let Some(mut artists) = iter.next().unwrap().as_iter() {
+                    track_info.duration = format_time(length / 1000000);
-                while let Some(artist) = artists.next() {
+                }
-                    if let Some(mut line) = artist.as_iter() {
+            }
-                        track_info.artist = line.next().unwrap().as_str().unwrap().to_string();
+            if key.as_str() == Some("xesam:artist") {
+                if let Some(mut artists) = iter.next().unwrap().as_iter() {
+                    while let Some(artist) = artists.next() {
+                        if let Some(mut line) = artist.as_iter() {
+                            track_info.artist = line.next().unwrap().as_str().unwrap().to_string();
+                        }
                     }
                 }
             }
         }
+        let position: Box<dyn arg::RefArg> =
+            proxy.get("org.mpris.MediaPlayer2.Player", "Position")?;
+        track_info.position = format_time(position.as_i64().unwrap() / 1000000);
+        // ugly
+        let _status_text_box: Box<dyn arg::RefArg> =
+            proxy.get("org.mpris.MediaPlayer2.Player", "PlaybackStatus")?;
+        let _status_text = _status_text_box.as_str().unwrap();
+        match _status_text.as_ref() {
+            "Playing" => track_info.status = "▶".to_string(),
+            "Paused" => track_info.status = "⏸".to_string(),
+            _ => track_info.status = "⏹".to_string(),
+        };
+        players_vec.push(track_info);
     }
-    let position: Box<dyn arg::RefArg> = proxy.get("org.mpris.MediaPlayer2.Player", "Position")?;
+    for player in &players_vec {
-    track_info.position = format_time(position.as_i64().unwrap() / 1000000);
+        if player.status == "▶".to_string() {
-    // ugly
+            return Ok(player.clone());
-    let _status_text_box: Box<dyn arg::RefArg> =
+        }
-        proxy.get("org.mpris.MediaPlayer2.Player", "PlaybackStatus")?;
+    }
-    let _status_text = _status_text_box.as_str().unwrap();
+    Ok(players_vec[players_vec.len() - 1].clone())
-    match _status_text.as_ref() {
-        "Playing" => track_info.status = "▶".to_string(),
-        "Paused" => track_info.status = "⏸".to_string(),
-        _ => track_info.status = "⏹".to_string(),
-    };
-    Ok(track_info)
 }
 
 fn format_time(sec: i64) -> String {
@@ -129,9 +155,24 @@ fn format_time(sec: i64) -> String {
     result.to_string()
 }
 
+fn get_time(utc: bool, mut format: &str) {
+    // Format reference: https://docs.rs/chrono/0.4.10/chrono/format/strftime/index.html
+    if format.len() == 0 {
+        format = "%H:%M";
+    }
+    if utc {
+        let local_time = Local::now();
+        let utc_time = DateTime::<Utc>::from_utc(local_time.naive_utc(), Utc);
+        println!("{}", utc_time.format(format));
+    } else {
+        let local_time = Local::now();
+        println!("{}", local_time.format(format));
+    }
+}
+
 fn main() {
     let args: Vec<String> = env::args().collect();
-    let help_text: &str = "Available commands -mb, -cb";
+    let help_text: &str = "Available commands -mb, -cb, -tl <TIME FORMAT>, -tu <TIME FORMAT>, -p";
     match args.len() {
         1 => {
             panic!(help_text);
@@ -139,23 +180,56 @@ fn main() {
         2 => match args[1].as_ref() {
             "-cb" => cpu_load_bar(15),
             "-mb" => mem_load_bar(15),
-            "-p" => match player_info("cmus") {
+            "-tl" => get_time(false, ""),
+            "-tu" => get_time(true, ""),
+            "-p" => match player_info(get_player().unwrap()) {
                 Ok(mut track_info) => {
-                    let title_len = 30;
+                    let mut title_len = 30;
-                    let artist_len = 30;
+                    let mut artist_len = 30;
-                    if track_info.title.len() >= title_len {
+                    let mut separator: String = " — ".to_string();
-                        track_info.title.truncate(title_len);
+                    let max_shift = 6;
-                        track_info.title.push_str("..");
+                    if track_info.artist.chars().count() == 0 {
+                        separator = "".to_string();
+                        title_len += artist_len;
                     }
-                    if track_info.artist.len() >= artist_len {
+                    if artist_len + max_shift >= track_info.artist.chars().count() {
-                        track_info.artist.truncate(artist_len);
+                        artist_len = track_info.artist.chars().count()
-                        track_info.artist.push_str("..");
+                    }
+                    if track_info.artist.len() > artist_len {
+                        let mut artist: String = String::new();
+                        let mut counter = 0;
+                        for ch in track_info.artist.chars() {
+                            if counter == artist_len {
+                                artist.push_str("..");
+                                break;
+                            }
+                            artist.push(ch);
+                            counter += 1;
+                        }
+                        track_info.artist = artist;
+                    }
+                    if title_len + max_shift >= track_info.title.chars().count() {
+                        title_len = track_info.title.chars().count()
+                    }
+                    if track_info.title.len() > title_len {
+                        let mut title: String = String::new();
+                        let mut counter = 0;
+                        for ch in track_info.title.chars() {
+                            if counter == title_len {
+                                title.push_str("..");
+                                break;
+                            }
+                            title.push(ch);
+                            counter += 1;
+                        }
+                        track_info.title = title;
                     }
                     println!(
-                        "#[none]#[bold]{}{}{}#[none]{} - {}{} {}[{}/{}] {} {}",
+                        "#[none]#[bold]{}{}{}#[none]{}{}{}{} {}[{}/{}] {} {}#[default]",
                         TRACK_NAME,
                         track_info.title,
                         END,
+                        separator,
                         TRACK_ARTIST,
                         track_info.artist,
                         END,
@@ -170,6 +244,11 @@ fn main() {
             },
             _ => panic!(help_text),
         },
+        3 => match args[1].as_ref() {
+            "-tl" => get_time(false, args[2].as_ref()),
+            "-tu" => get_time(true, args[2].as_ref()),
+            _ => panic!(help_text),
+        },
         _ => {
             panic!(help_text);
         }