You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
|
|
|
use std::{
|
|
|
|
ffi::OsString,
|
|
|
|
path::PathBuf,
|
|
|
|
process::{ExitStatus, Stdio},
|
|
|
|
};
|
|
|
|
|
|
|
|
use thiserror::Error;
|
|
|
|
use tokio::{io, process::Command};
|
|
|
|
|
|
|
|
pub struct MappedCommand {
|
|
|
|
path: PathBuf,
|
|
|
|
args: Vec<OsString>,
|
|
|
|
}
|
|
|
|
|
|
|
|
pub type CommandResult<T> = Result<T, CommandError>;
|
|
|
|
|
|
|
|
#[derive(Error, Debug)]
|
|
|
|
pub enum CommandError {
|
|
|
|
#[error(transparent)]
|
|
|
|
Io(#[from] io::Error),
|
|
|
|
|
|
|
|
#[error("The command {0:?} could not be found")]
|
|
|
|
NotFound(PathBuf),
|
|
|
|
}
|
|
|
|
|
|
|
|
impl MappedCommand {
|
|
|
|
pub fn new(path: PathBuf, args: Vec<OsString>) -> Self {
|
|
|
|
Self { path, args }
|
|
|
|
}
|
|
|
|
|
|
|
|
#[tracing::instrument(skip_all, level = "debug")]
|
|
|
|
pub async fn run(self) -> CommandResult<ExitStatus> {
|
|
|
|
if !self.path.exists() {
|
|
|
|
return Err(CommandError::NotFound(self.path));
|
|
|
|
}
|
|
|
|
let exit_status = Command::new(self.path)
|
|
|
|
.args(self.args)
|
|
|
|
.stdin(Stdio::inherit())
|
|
|
|
.stdout(Stdio::inherit())
|
|
|
|
.stderr(Stdio::inherit())
|
|
|
|
.spawn()?
|
|
|
|
.wait()
|
|
|
|
.await?;
|
|
|
|
|
|
|
|
Ok(exit_status)
|
|
|
|
}
|
|
|
|
}
|