1 Commits

Author SHA1 Message Date
3bebb65dc0 Format Rust code using rustfmt 2025-06-27 11:15:08 +00:00
3 changed files with 6 additions and 18 deletions

2
Cargo.lock generated
View File

@ -1111,7 +1111,7 @@ checksum = "436b050e76ed2903236f032a59761c1eb99e1b0aead2c257922771dab1fc8c78"
[[package]] [[package]]
name = "rexec" name = "rexec"
version = "1.3.1" version = "1.3.0"
dependencies = [ dependencies = [
"brace-expand", "brace-expand",
"clap 4.3.4", "clap 4.3.4",

View File

@ -1,6 +1,6 @@
[package] [package]
name = "rexec" name = "rexec"
version = "1.3.1" version = "1.3.0"
readme = "https://github.com/house-of-vanity/rexec#readme" readme = "https://github.com/house-of-vanity/rexec#readme"
edition = "2021" edition = "2021"
description = "Parallel SSH executor" description = "Parallel SSH executor"

View File

@ -25,7 +25,7 @@ use regex::Regex;
#[command(author = "AB ab@hexor.ru", version, about = "Parallel SSH executor in Rust", long_about = None)] #[command(author = "AB ab@hexor.ru", version, about = "Parallel SSH executor in Rust", long_about = None)]
struct Args { struct Args {
/// Username for SSH connections (defaults to current system user) /// Username for SSH connections (defaults to current system user)
#[arg(short = 'u', short = 'l', long, default_value_t = whoami::username())] #[arg(short, long, default_value_t = whoami::username())]
username: String, username: String,
/// Flag to use known_hosts file for server discovery instead of pattern expansion /// Flag to use known_hosts file for server discovery instead of pattern expansion
@ -324,17 +324,11 @@ fn execute_ssh_command(
let display_name_stdout = display_name.clone(); let display_name_stdout = display_name.clone();
let stdout_thread = thread::spawn(move || { let stdout_thread = thread::spawn(move || {
let reader = BufReader::new(stdout); let reader = BufReader::new(stdout);
let prefix = format!("{}", "".green()); let prefix = format!("{}", "".green());
for line in reader.lines() { for line in reader.lines() {
match line { match line {
Ok(line) => println!( Ok(line) => println!("{} {} - {}", prefix, display_name_stdout.yellow(), line),
"{} {} {} {}",
prefix,
display_name_stdout.yellow(),
prefix,
line
),
Err(_) => break, Err(_) => break,
} }
} }
@ -349,13 +343,7 @@ fn execute_ssh_command(
for line in reader.lines() { for line in reader.lines() {
match line { match line {
Ok(line) => println!( Ok(line) => println!("{} {} - {}", prefix, display_name_stderr.yellow(), line),
"{} {} {} {}",
prefix,
display_name_stderr.yellow(),
prefix,
line
),
Err(_) => break, Err(_) => break,
} }
} }