Replace custom logging with log crate and custom format

Signed-off-by: trivernis <trivernis@protonmail.com>
axtloss/rework-partitioning
trivernis 3 years ago
parent f9b775eff1
commit f57e73e0c6
Signed by: Trivernis
GPG Key ID: DFFFCC2C7A02DB45

135
Cargo.lock generated

@ -2,6 +2,24 @@
# It is not intended for manual editing. # It is not intended for manual editing.
version = 3 version = 3
[[package]]
name = "aho-corasick"
version = "0.7.18"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1e37cfd5e7657ada45f742d6e99ca5788580b5c529dc78faf11ece6dc702656f"
dependencies = [
"memchr",
]
[[package]]
name = "ansi_term"
version = "0.12.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "d52a9bb7ec0cf484c551830a7ce27bd20d67eac647e1befb56b0be4ee39a55d2"
dependencies = [
"winapi",
]
[[package]] [[package]]
name = "atty" name = "atty"
version = "0.2.14" version = "0.2.14"
@ -25,6 +43,12 @@ version = "1.3.2"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a" checksum = "bef38d45163c2f1dde094a7dfd33ccf595c92905c8f8f4fdc18d06fb1037718a"
[[package]]
name = "cfg-if"
version = "1.0.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd"
[[package]] [[package]]
name = "clap" name = "clap"
version = "3.1.10" version = "3.1.10"
@ -64,6 +88,29 @@ dependencies = [
"os_str_bytes", "os_str_bytes",
] ]
[[package]]
name = "flexi_logger"
version = "0.22.3"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "969940c39bc718475391e53a3a59b0157e64929c80cf83ad5dde5f770ecdc423"
dependencies = [
"ansi_term",
"atty",
"glob",
"lazy_static",
"log",
"regex",
"rustversion",
"thiserror",
"time",
]
[[package]]
name = "glob"
version = "0.3.0"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "9b919933a397b79c37e33b77bb2aa3dc8eb6e165ad809e58ff75bc7db2e34574"
[[package]] [[package]]
name = "hashbrown" name = "hashbrown"
version = "0.11.2" version = "0.11.2"
@ -106,6 +153,9 @@ name = "jade"
version = "0.1.0" version = "0.1.0"
dependencies = [ dependencies = [
"clap", "clap",
"flexi_logger",
"lazy_static",
"log",
"serde", "serde",
"serde_json", "serde_json",
] ]
@ -122,6 +172,30 @@ version = "0.2.112"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1b03d17f364a3a042d5e5d46b053bbbf82c92c9430c592dd4c064dc6ee997125" checksum = "1b03d17f364a3a042d5e5d46b053bbbf82c92c9430c592dd4c064dc6ee997125"
[[package]]
name = "log"
version = "0.4.16"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "6389c490849ff5bc16be905ae24bc913a9c8892e19b2341dbc175e14c341c2b8"
dependencies = [
"cfg-if",
]
[[package]]
name = "memchr"
version = "2.4.1"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "308cc39be01b73d0d18f82a0e7b2a3df85245f84af96fdddc5d202d27e47b86a"
[[package]]
name = "num_threads"
version = "0.1.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "aba1801fb138d8e85e11d0fc70baf4fe1cdfffda7c6cd34a854905df588e5ed0"
dependencies = [
"libc",
]
[[package]] [[package]]
name = "os_str_bytes" name = "os_str_bytes"
version = "6.0.0" version = "6.0.0"
@ -170,6 +244,29 @@ dependencies = [
"proc-macro2", "proc-macro2",
] ]
[[package]]
name = "regex"
version = "1.5.5"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "1a11647b6b25ff05a515cb92c365cec08801e83423a235b51e231e1808747286"
dependencies = [
"aho-corasick",
"memchr",
"regex-syntax",
]
[[package]]
name = "regex-syntax"
version = "0.6.25"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f497285884f3fcff424ffc933e56d7cbca511def0c9831a7f9b5f6153e3cc89b"
[[package]]
name = "rustversion"
version = "1.0.6"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "f2cc38e8fa666e2de3c4aba7edeb5ffc5246c1c2ed0e3d17e560aeeba736b23f"
[[package]] [[package]]
name = "ryu" name = "ryu"
version = "1.0.9" version = "1.0.9"
@ -239,6 +336,44 @@ version = "0.15.0"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "b1141d4d61095b28419e22cb0bbf02755f5e54e0526f97f1e3d1d160e60885fb" checksum = "b1141d4d61095b28419e22cb0bbf02755f5e54e0526f97f1e3d1d160e60885fb"
[[package]]
name = "thiserror"
version = "1.0.30"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "854babe52e4df1653706b98fcfc05843010039b406875930a70e4d9644e5c417"
dependencies = [
"thiserror-impl",
]
[[package]]
name = "thiserror-impl"
version = "1.0.30"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "aa32fd3f627f367fe16f893e2597ae3c05020f8bba2666a4e6ea73d377e5714b"
dependencies = [
"proc-macro2",
"quote",
"syn",
]
[[package]]
name = "time"
version = "0.3.9"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c2702e08a7a860f005826c6815dcac101b19b5eb330c27fe4a5928fec1d20ddd"
dependencies = [
"itoa",
"libc",
"num_threads",
"time-macros",
]
[[package]]
name = "time-macros"
version = "0.2.4"
source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "42657b1a6f4d817cda8e7a0ace261fe0cc946cf3a80314390b22cc61ae080792"
[[package]] [[package]]
name = "unicode-xid" name = "unicode-xid"
version = "0.2.2" version = "0.2.2"

@ -11,3 +11,6 @@ edition = "2021"
clap = {version = "3.1.10", features = ["derive"] } clap = {version = "3.1.10", features = ["derive"] }
serde_json = "1.0.59" serde_json = "1.0.59"
serde = { version = "1.0.117", features = [ "derive" ] } serde = { version = "1.0.117", features = [ "derive" ] }
log = "0.4.16"
flexi_logger = {version = "0.22.3", features = ["colors"] }
lazy_static = "1.4.0"

@ -7,6 +7,9 @@ use std::path::PathBuf;
pub struct Opt { pub struct Opt {
#[clap(subcommand)] #[clap(subcommand)]
pub command: Command, pub command: Command,
#[clap(long, short, parse(from_occurrences))]
pub verbose: usize,
} }
#[derive(Debug, Subcommand)] #[derive(Debug, Subcommand)]

@ -3,7 +3,7 @@ use crate::internal::exec::*;
use crate::internal::*; use crate::internal::*;
pub fn install_desktop_setup(desktop_setup: DesktopSetup) { pub fn install_desktop_setup(desktop_setup: DesktopSetup) {
log(format!("Installing {:?}", desktop_setup)); log::debug!("Installing {:?}", desktop_setup);
match desktop_setup { match desktop_setup {
DesktopSetup::Onyx => install_onyx(), DesktopSetup::Onyx => install_onyx(),
DesktopSetup::Gnome => install_gnome(), DesktopSetup::Gnome => install_gnome(),
@ -166,7 +166,7 @@ fn install_onyx() {
} }
fn enable_dm(dm: &str) { fn enable_dm(dm: &str) {
log(format!("Enabling {}", dm)); log::debug!("Enabling {}", dm);
exec_eval( exec_eval(
exec_chroot("systemctl", vec![String::from("enable"), String::from(dm)]), exec_chroot("systemctl", vec![String::from("enable"), String::from(dm)]),
format!("Enable {}", dm).as_str(), format!("Enable {}", dm).as_str(),

@ -9,7 +9,7 @@ pub fn partition(device: PathBuf, mode: PartitionMode, efi: bool) {
} }
match mode { match mode {
PartitionMode::Auto => { PartitionMode::Auto => {
log(format!("automatically partitioning {device:?}")); log::debug!("automatically partitioning {device:?}");
if efi { if efi {
partition_with_efi(&device); partition_with_efi(&device);
} else { } else {
@ -17,7 +17,7 @@ pub fn partition(device: PathBuf, mode: PartitionMode, efi: bool) {
} }
} }
PartitionMode::Manual => { PartitionMode::Manual => {
log("Manual partitioning".to_string()); log::debug!("Manual partitioning");
} }
} }
if device.to_string_lossy().contains("nvme") { if device.to_string_lossy().contains("nvme") {

@ -54,9 +54,7 @@ pub fn read_config(configpath: PathBuf) {
let data = std::fs::read_to_string(&configpath); let data = std::fs::read_to_string(&configpath);
match &data { match &data {
Ok(_) => { Ok(_) => {
log(format!( log::debug!("[ \x1b[2;1;32mOK\x1b[0m ] Read config file {configpath:?}");
"[ \x1b[2;1;32mOK\x1b[0m ] Read config file {configpath:?}"
));
} }
Err(e) => { Err(e) => {
crash( crash(
@ -69,22 +67,16 @@ pub fn read_config(configpath: PathBuf) {
serde_json::from_str(&data.unwrap()); serde_json::from_str(&data.unwrap());
match &config { match &config {
Ok(_) => { Ok(_) => {
log(format!( log::debug!("[ \x1b[2;1;32mOK\x1b[0m ] Parse config file {configpath:?}",);
"[ \x1b[2;1;32mOK\x1b[0m ] Parse config file {configpath:?}",
));
} }
Err(e) => { Err(e) => {
crash(format!("Parse config file {configpath:?} ERROR: {}", e), 1); crash(format!("Parse config file {configpath:?} ERROR: {}", e), 1);
} }
} }
let config: Config = config.unwrap(); let config: Config = config.unwrap();
log::info!("Block device to use : /dev/{}", config.partition.device);
info(format!( log::info!("Partitioning mode : {:?}", config.partition.mode);
"Block device to use : /dev/{}", log::info!("Partitioning for EFI : {}", config.partition.efi);
config.partition.device
));
info(format!("Partitioning mode : {:?}", config.partition.mode));
info(format!("Partitioning for EFI : {}", config.partition.efi));
partition::partition( partition::partition(
PathBuf::from("/dev/").join(config.partition.device), PathBuf::from("/dev/").join(config.partition.device),
config.partition.mode, config.partition.mode,
@ -93,29 +85,23 @@ pub fn read_config(configpath: PathBuf) {
base::install_base_packages(); base::install_base_packages();
base::genfstab(); base::genfstab();
println!(); println!();
info(format!( log::info!("Installing bootloader : {}", config.bootloader.r#type);
"Installing bootloader : {}", log::info!("Installing bootloader to : {}", config.bootloader.location);
config.bootloader.r#type
));
info(format!(
"Installing bootloader to : {}",
config.bootloader.location
));
if config.bootloader.r#type == "grub-efi" { if config.bootloader.r#type == "grub-efi" {
base::install_bootloader_efi(PathBuf::from(config.bootloader.location)); base::install_bootloader_efi(PathBuf::from(config.bootloader.location));
} else if config.bootloader.r#type == "grub-legacy" { } else if config.bootloader.r#type == "grub-legacy" {
base::install_bootloader_legacy(PathBuf::from(config.bootloader.location)); base::install_bootloader_legacy(PathBuf::from(config.bootloader.location));
} }
println!(); println!();
info(format!("Adding Locales : {:?}", config.locale.locale)); log::info!("Adding Locales : {:?}", config.locale.locale);
info(format!("Using keymap : {}", config.locale.keymap)); log::info!("Using keymap : {}", config.locale.keymap);
info(format!("Setting timezone : {}", config.locale.timezone)); log::info!("Setting timezone : {}", config.locale.timezone);
locale::set_locale(config.locale.locale.join(" ")); locale::set_locale(config.locale.locale.join(" "));
locale::set_keyboard(config.locale.keymap.as_str()); locale::set_keyboard(config.locale.keymap.as_str());
locale::set_timezone(config.locale.timezone.as_str()); locale::set_timezone(config.locale.timezone.as_str());
println!(); println!();
info(format!("Hostname : {}", config.networking.hostname)); log::info!("Hostname : {}", config.networking.hostname);
info(format!("Enabling ipv6 : {}", config.networking.ipv6)); log::info!("Enabling ipv6 : {}", config.networking.ipv6);
network::set_hostname(config.networking.hostname.as_str()); network::set_hostname(config.networking.hostname.as_str());
network::create_hosts(); network::create_hosts();
if config.networking.ipv6 { if config.networking.ipv6 {
@ -124,15 +110,9 @@ pub fn read_config(configpath: PathBuf) {
println!(); println!();
println!("---------"); println!("---------");
for i in 0..config.users.len() { for i in 0..config.users.len() {
info(format!("Creating user : {}", config.users[i].name)); log::info!("Creating user : {}", config.users[i].name);
info(format!( log::info!("Setting use password : {}", config.users[i].password);
"Setting use password : {}", log::info!("Enabling root for user : {}", config.users[i].hasroot);
config.users[i].password
));
info(format!(
"Enabling root for user : {}",
config.users[i].hasroot
));
users::new_user( users::new_user(
config.users[i].name.as_str(), config.users[i].name.as_str(),
config.users[i].hasroot, config.users[i].hasroot,
@ -141,19 +121,19 @@ pub fn read_config(configpath: PathBuf) {
println!("---------"); println!("---------");
} }
println!(); println!();
info(format!("Setting root password : {}", config.rootpass)); log::info!("Setting root password : {}", config.rootpass);
users::root_pass(config.rootpass.as_str()); users::root_pass(config.rootpass.as_str());
println!(); println!();
info(format!("Installing desktop : {:?}", config.desktop)); log::info!("Installing desktop : {:?}", config.desktop);
if let Some(desktop) = &config.desktop { if let Some(desktop) = &config.desktop {
desktops::install_desktop_setup(*desktop); desktops::install_desktop_setup(*desktop);
} }
println!(); println!();
info(format!("Enabling timeshift : {}", config.timeshift)); log::info!("Enabling timeshift : {}", config.timeshift);
if config.timeshift { if config.timeshift {
base::setup_timeshift(); base::setup_timeshift();
} }
info(format!("Extra packages : {:?}", config.extra_packages)); log::info!("Extra packages : {:?}", config.extra_packages);
let mut extra_packages: Vec<&str> = Vec::new(); let mut extra_packages: Vec<&str> = Vec::new();
for i in 0..config.extra_packages.len() { for i in 0..config.extra_packages.len() {
extra_packages.push(config.extra_packages[i].as_str()); extra_packages.push(config.extra_packages[i].as_str());

@ -6,7 +6,7 @@ pub fn create_file(path: &str) {
let returncode = File::create(path); let returncode = File::create(path);
match returncode { match returncode {
Ok(_) => { Ok(_) => {
log(format!("[ \x1b[2;1;32mOK\x1b[0m ] Create {}", path)); log::info!("Create {}", path);
} }
Err(e) => { Err(e) => {
crash(format!("Create {}: Failed with error {}", path, e), 1); crash(format!("Create {}: Failed with error {}", path, e), 1);
@ -18,10 +18,7 @@ pub fn copy_file(path: &str, destpath: &str) {
let return_code = std::fs::copy(path, destpath); let return_code = std::fs::copy(path, destpath);
match return_code { match return_code {
Ok(_) => { Ok(_) => {
log(format!( log::info!("Copy {} to {}", path, destpath);
"[ \x1b[2;1;32mOK\x1b[0m ] Copy {} to {}",
path, destpath
));
} }
Err(e) => { Err(e) => {
crash( crash(
@ -33,11 +30,7 @@ pub fn copy_file(path: &str, destpath: &str) {
} }
pub fn append_file(path: &str, content: &str) -> std::io::Result<()> { pub fn append_file(path: &str, content: &str) -> std::io::Result<()> {
log(format!( log::info!("Append '{}' to file {}", content.trim_end(), path);
"[ \x1b[2;1;32mOK\x1b[0m ] Append '{}' to file {}",
content.trim_end(),
path
));
let mut file = OpenOptions::new().append(true).open(path)?; let mut file = OpenOptions::new().append(true).open(path)?;
file.write_all(content.as_bytes())?; file.write_all(content.as_bytes())?;
Ok(()) Ok(())

@ -5,43 +5,20 @@ pub mod install;
pub mod returncode_eval; pub mod returncode_eval;
pub mod strings; pub mod strings;
pub fn install(pkgs: Vec<&str>) { pub use install::install;
install::install(pkgs); pub use returncode_eval::*;
} pub use strings::crash;
pub fn crash<S: AsRef<str>>(a: S, b: i32) -> ! {
strings::crash(a.as_ref().to_string(), b);
}
pub fn log(a: String) {
strings::log(a);
}
pub fn info(a: String) {
strings::info(a);
}
pub fn files_eval(returncode: std::result::Result<(), std::io::Error>, logmsg: &str) {
returncode_eval::files_eval(returncode, logmsg);
}
pub fn exec_eval(
returncode: std::result::Result<std::process::ExitStatus, std::io::Error>,
logmsg: &str,
) {
returncode_eval::exec_eval(returncode, logmsg);
}
#[macro_export] #[macro_export]
macro_rules! uwu { macro_rules! uwu {
($x:expr) => {{ ($x:expr) => {{
let uwu: String = String::from_str($x).unwrap(); let uwu: String = $x.to_string();
let uwu = uwu.replace("l", "w"); uwu.replace("l", "w")
let uwu = uwu.replace("L", "W"); .replace("L", "W")
let uwu = uwu.replace("r", "w"); .replace("r", "w")
let uwu = uwu.replace("R", "W"); .replace("R", "W")
let uwu = uwu.replace("na", "nya"); .replace("na", "nya")
let uwu = uwu.replace("Na", "Nya"); .replace("Na", "Nya")
let uwu = uwu.replace("NA", "NYA"); .replace("NA", "NYA")
uwu
}}; }};
} }

@ -6,11 +6,11 @@ pub fn exec_eval(
) { ) {
match &return_code { match &return_code {
Ok(_) => { Ok(_) => {
log(format!("[ \x1b[2;1;32mOK\x1b[0m ] {}", logmsg)); log::info!("{}", logmsg);
} }
Err(e) => { Err(e) => {
crash( crash(
format!("[ \x1b[2;1;32mFAILED\x1b[0m ] {} ERROR: {}", logmsg, e), format!("{} ERROR: {}", logmsg, e),
return_code.unwrap_err().raw_os_error().unwrap(), return_code.unwrap_err().raw_os_error().unwrap(),
); );
} }
@ -20,11 +20,11 @@ pub fn exec_eval(
pub fn files_eval(return_code: std::result::Result<(), std::io::Error>, logmsg: &str) { pub fn files_eval(return_code: std::result::Result<(), std::io::Error>, logmsg: &str) {
match &return_code { match &return_code {
Ok(_) => { Ok(_) => {
log(format!("[ \x1b[2;1;32mOK\x1b[0m ] {}", logmsg)); log::info!("{}", logmsg);
} }
Err(e) => { Err(e) => {
crash( crash(
format!("[ \x1b[2;1;32mFAILED\x1b[0m ] {} ERROR: {}", logmsg, e), format!("{} ERROR: {}", logmsg, e),
return_code.unwrap_err().raw_os_error().unwrap(), return_code.unwrap_err().raw_os_error().unwrap(),
); );
} }

@ -1,47 +1,6 @@
use crate::uwu;
use std::env;
use std::process::exit; use std::process::exit;
use std::str::FromStr;
use std::time::UNIX_EPOCH;
pub fn crash(a: String, b: i32) -> ! { pub fn crash<S: AsRef<str>>(a: S, b: i32) -> ! {
let a = if env::var("JADE_UWU").unwrap_or_else(|_| "".to_string()) == "true" { log::error!("{}", a.as_ref());
uwu!(&a)
} else {
a
};
println!("{}", a);
exit(b); exit(b);
} }
pub fn log(a: String) {
let a = if env::var("JADE_UWU").unwrap_or_else(|_| "".to_string()) == "true"
&& env::var("JADE_UWU_DEBUG").unwrap_or_else(|_| "".to_string()) == "true"
{
uwu!(&a)
} else {
a
};
eprintln!(
"[ \x1b[2;1;33mLOG\x1b[0m ] {} {}",
std::time::SystemTime::now()
.duration_since(UNIX_EPOCH)
.unwrap()
.as_secs(),
a
);
}
pub fn info(a: String) {
let a = if env::var("JADE_UWU").unwrap_or_else(|_| "".to_string()) == "true" {
uwu!(&a)
} else {
a
};
eprintln!(
"[ \x1b[2;1;39mINFO\x1b[0m ] {} {}",
std::time::SystemTime::now()
.duration_since(UNIX_EPOCH)
.unwrap()
.as_secs(),
a
);
}

@ -0,0 +1,69 @@
use crate::uwu;
use flexi_logger::{style, DeferredNow, LogSpecification, Logger};
use lazy_static::lazy_static;
use log::{Level, LevelFilter};
use std::env;
use std::io::Write;
lazy_static! {
static ref UWU: bool = env::var("JADE_UWU").map(|v| v == "true").unwrap_or(false);
static ref UWU_DEBUG: bool = env::var("JADE_UWU_DEBUG")
.map(|v| v == "true")
.unwrap_or(false);
}
pub fn init(verbosity: usize) {
let log_specification = match verbosity {
0 => LogSpecification::builder()
.default(LevelFilter::Info)
.build(),
1 => LogSpecification::builder()
.default(LevelFilter::Debug)
.build(),
_ => LogSpecification::builder()
.default(LevelFilter::Trace)
.build(),
};
Logger::with(log_specification)
.format(format_log_entry)
.start()
.unwrap();
}
/// Formats a log entry with color
fn format_log_entry(
w: &mut dyn Write,
now: &mut DeferredNow,
record: &log::Record,
) -> std::io::Result<()> {
let msg = record.args().to_string();
let level = record.level();
let msg = apply_uwu(level, msg);
write!(
w,
"[ {} ] {} {}",
style(level).paint(level.to_string()),
now.now(),
msg
)
}
/// Applies uwu if the required environment variables are set
fn apply_uwu(level: Level, msg: String) -> String {
match level {
Level::Error | Level::Warn | Level::Info => {
if *UWU {
uwu!(msg)
} else {
msg
}
}
Level::Debug | Level::Trace => {
if *UWU_DEBUG {
uwu!(msg)
} else {
msg
}
}
}
}

@ -1,6 +1,7 @@
mod args; mod args;
mod functions; mod functions;
mod internal; mod internal;
mod logging;
use crate::args::{BootloaderSubcommand, Command, Opt, UsersSubcommand}; use crate::args::{BootloaderSubcommand, Command, Opt, UsersSubcommand};
use crate::functions::*; use crate::functions::*;
@ -8,6 +9,7 @@ use clap::Parser;
fn main() { fn main() {
let opt: Opt = Opt::parse(); let opt: Opt = Opt::parse();
logging::init(opt.verbose);
match opt.command { match opt.command {
Command::Partition(args) => { Command::Partition(args) => {
partition::partition(args.device, args.mode, args.efi); partition::partition(args.device, args.mode, args.efi);

Loading…
Cancel
Save