mirror of
https://github.com/house-of-vanity/rexec.git
synced 2025-07-08 01:04:07 +00:00
Compare commits
1 Commits
Author | SHA1 | Date | |
---|---|---|---|
3bebb65dc0 |
2
Cargo.lock
generated
2
Cargo.lock
generated
@ -1111,7 +1111,7 @@ checksum = "436b050e76ed2903236f032a59761c1eb99e1b0aead2c257922771dab1fc8c78"
|
||||
|
||||
[[package]]
|
||||
name = "rexec"
|
||||
version = "1.3.1"
|
||||
version = "1.3.0"
|
||||
dependencies = [
|
||||
"brace-expand",
|
||||
"clap 4.3.4",
|
||||
|
@ -1,6 +1,6 @@
|
||||
[package]
|
||||
name = "rexec"
|
||||
version = "1.3.1"
|
||||
version = "1.3.0"
|
||||
readme = "https://github.com/house-of-vanity/rexec#readme"
|
||||
edition = "2021"
|
||||
description = "Parallel SSH executor"
|
||||
|
20
src/main.rs
20
src/main.rs
@ -25,7 +25,7 @@ use regex::Regex;
|
||||
#[command(author = "AB ab@hexor.ru", version, about = "Parallel SSH executor in Rust", long_about = None)]
|
||||
struct Args {
|
||||
/// 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,
|
||||
|
||||
/// 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 stdout_thread = thread::spawn(move || {
|
||||
let reader = BufReader::new(stdout);
|
||||
let prefix = format!("{}", "║".green());
|
||||
let prefix = format!("{}", "│".green());
|
||||
|
||||
for line in reader.lines() {
|
||||
match line {
|
||||
Ok(line) => println!(
|
||||
"{} {} {} {}",
|
||||
prefix,
|
||||
display_name_stdout.yellow(),
|
||||
prefix,
|
||||
line
|
||||
),
|
||||
Ok(line) => println!("{} {} - {}", prefix, display_name_stdout.yellow(), line),
|
||||
Err(_) => break,
|
||||
}
|
||||
}
|
||||
@ -349,13 +343,7 @@ fn execute_ssh_command(
|
||||
|
||||
for line in reader.lines() {
|
||||
match line {
|
||||
Ok(line) => println!(
|
||||
"{} {} {} {}",
|
||||
prefix,
|
||||
display_name_stderr.yellow(),
|
||||
prefix,
|
||||
line
|
||||
),
|
||||
Ok(line) => println!("{} {} - {}", prefix, display_name_stderr.yellow(), line),
|
||||
Err(_) => break,
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user