aboutsummaryrefslogtreecommitdiffhomepage
path: root/crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs
diff options
context:
space:
mode:
Diffstat (limited to 'crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs')
-rw-r--r--crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs30
1 files changed, 26 insertions, 4 deletions
diff --git a/crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs b/crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs
index a32c95d..e62b9ac 100644
--- a/crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs
+++ b/crates/shirabe-external-packages/src/symfony/console/helper/process_helper.rs
@@ -85,7 +85,13 @@ impl ProcessHelper {
ProcessHelperCmdElement::Process(_) => unreachable!(),
})
.collect();
- process = Process::new(command, None, None, None, Some(60.0));
+ process = Process::new(
+ command,
+ None,
+ None,
+ shirabe_php_shim::PhpMixed::Null,
+ Some(60.0),
+ )?;
cmd = vec![];
}
Some(ProcessHelperCmdElement::Process(_)) => {
@@ -124,7 +130,23 @@ impl ProcessHelper {
};
// PHP passes the remaining `$cmd` array as the `$env` argument to Process::run.
- process.run(callback);
+ let env: indexmap::IndexMap<String, shirabe_php_shim::PhpMixed> = cmd
+ .iter()
+ .enumerate()
+ .filter_map(|(i, element)| match element {
+ ProcessHelperCmdElement::String(s) => {
+ Some((i.to_string(), shirabe_php_shim::PhpMixed::String(s.clone())))
+ }
+ ProcessHelperCmdElement::Process(_) => None,
+ })
+ .collect();
+ let callback: Option<Box<dyn FnMut(&str, &str) -> bool>> = callback.map(|mut cb| {
+ Box::new(move |r#type: &str, buffer: &str| -> bool {
+ cb(r#type, buffer);
+ false
+ }) as Box<dyn FnMut(&str, &str) -> bool>
+ });
+ process.run(callback, env)?;
if verbosity <= output.borrow().get_verbosity() {
let message = if process.is_successful() {
@@ -183,7 +205,7 @@ impl ProcessHelper {
error: Option<&str>,
callback: Option<Box<dyn FnMut(&str, &str)>>,
) -> anyhow::Result<Process> {
- let process = self.run(
+ let mut process = self.run(
output,
cmd,
error,
@@ -192,7 +214,7 @@ impl ProcessHelper {
)?;
if !process.is_successful() {
- anyhow::bail!(ProcessFailedException::new(&process));
+ anyhow::bail!(ProcessFailedException::new(&mut process)?);
}
Ok(process)