use crate::cmd::{cfg_spinner, run_stage};
use crate::errors::*;
use crate::install::Tools;
use crate::parse::Opts;
use crate::thread::{spawn_thread, ThreadHandle};
use console::{style, Emoji};
use indicatif::{MultiProgress, ProgressBar};
use std::path::PathBuf;
static TINKERING: Emoji<'_, '_> = Emoji("🔧", "");
macro_rules! handle_exit_code {
($code:expr) => {
let (_, _, code) = $code;
if code != 0 {
return ::std::result::Result::Ok(code);
}
};
}
#[allow(clippy::type_complexity)]
pub fn tinker_internal(
dir: PathBuf,
spinners: &MultiProgress,
num_steps: u8,
tools: &Tools,
global_opts: &Opts,
) -> Result<
ThreadHandle<impl FnOnce() -> Result<i32, ExecutionError>, Result<i32, ExecutionError>>,
Error,
> {
let tools = tools.clone();
let Opts {
cargo_engine_args, ..
} = global_opts.clone();
let tk_msg = format!(
"{} {} Running plugin tinkers",
style(format!("[1/{}]", num_steps)).bold().dim(),
TINKERING
);
let tk_spinner = spinners.insert(0, ProgressBar::new_spinner());
let tk_spinner = cfg_spinner(tk_spinner, &tk_msg);
let tk_target = dir;
let tk_thread = spawn_thread(
move || {
handle_exit_code!(run_stage(
vec![&format!("{} run {}", tools.cargo_engine, cargo_engine_args)],
&tk_target,
&tk_spinner,
&tk_msg,
vec![
("PERSEUS_ENGINE_OPERATION", "tinker"),
("CARGO_TARGET_DIR", "dist/target_engine"),
("RUSTFLAGS", "--cfg=engine"),
("CARGO_TERM_COLOR", "always")
]
)?);
Ok(0)
},
global_opts.sequential,
);
Ok(tk_thread)
}
pub fn tinker(dir: PathBuf, tools: &Tools, global_opts: &Opts) -> Result<i32, Error> {
let spinners = MultiProgress::new();
let tk_thread = tinker_internal(dir, &spinners, 1, tools, global_opts)?;
let tk_res = tk_thread
.join()
.map_err(|_| ExecutionError::ThreadWaitFailed)??;
if tk_res != 0 {
return Ok(tk_res);
}
Ok(0)
}