Function invoke_command

lib/dsc-lib/src/dscresources/command_resource.rs:894–930

(executable: &str, args: Option<Vec<String>>, input: Option<&str>, cwd: Option<&Path>, env: Option<HashMap<String, String>>, exit_codes: &ExitCodesMap)

///
#[allow(clippy::implicit_hasher)]
pub fn invoke_command(executable: &str, args: Option<Vec<String>>, input: Option<&str>, cwd: Option<&Path>, env: Option<HashMap<String, String>>, exit_codes: &ExitCodesMap) -> Result<(i32, String, String), DscError> {
    let executable = canonicalize_which(executable, cwd)?;

    let run_async = async {
        trace!("{}", t!("dscresources.commandResource.commandInvoke", executable = executable, args = args : {:?}));
        if let Some(cwd) = cwd {
            trace!("{}", t!("dscresources.commandResource.commandCwd", cwd = cwd.display()));
        }

        match run_process_async(&executable, args, input, cwd, env, exit_codes).await {
            Ok((code, stdout, stderr)) => {
                Ok((code, stdout, stderr))
            },
            Err(err) => {
                error!("{}", t!("dscresources.commandResource.runProcessError", executable = executable, error = err));
                Err(err)
            }
        }
    };

    // Try to use existing runtime first (e.g. from gRPC or MCP server)
    match tokio::runtime::Handle::try_current() {
        Ok(handle) => {
            tokio::task::block_in_place(|| {
                handle.block_on(run_async)
            })
        },
        // Otherwise create a new runtime
        Err(_) => {
            tokio::runtime::Builder::new_multi_thread()
                .enable_all()
                .build()
                .unwrap()
                .block_on(run_async)
        }
    }
}

/// Process the arguments for a command resource's get operation.
///