Function run_command_with_stdin

packages/server/src/android.rs:1470–1575

(
    program: PathBuf,
    args: [&str; N],
    stdin_input: Option<&[u8]>,
)

}

fn run_command_with_stdin<const N: usize>(
    program: PathBuf,
    args: [&str; N],
    stdin_input: Option<&[u8]>,
) -> Result<Vec<u8>, AppError> {
    if !program.exists() {
        return Err(AppError::native(format!(
            "Android SDK binary not found at {}.",
            program.display()
        )));
    }
    let sdk_root = sdk_root();
    let mut command = Command::new(&program);
    command
        .args(args)
        .env("ANDROID_HOME", &sdk_root)
        .env("ANDROID_SDK_ROOT", &sdk_root);
    if let Some(java_home) = java_home() {
        command.env("JAVA_HOME", java_home);
    }
    let mut child = command
        .stdin(if stdin_input.is_some() {
            Stdio::piped()
        } else {
            Stdio::null()
        })
        .stdout(Stdio::piped())
        .stderr(Stdio::piped())
        .spawn()
        .map_err(|error| {
            AppError::native(format!("Unable to run {}: {error}", program.display()))
        })?;
    if let Some(input) = stdin_input {
        let mut stdin = child.stdin.take().ok_or_else(|| {
            AppError::native(format!("Unable to open stdin for {}.", program.display()))
        })?;
        stdin.write_all(input).map_err(|error| {
            AppError::native(format!(
                "Unable to write stdin for {}: {error}",
                program.display()
            ))
        })?;
    }
    let stdout = child.stdout.take().ok_or_else(|| {
        AppError::native(format!(
            "Unable to capture stdout from {}.",
            program.display()
        ))
    })?;
    let stderr = child.stderr.take().ok_or_else(|| {
        AppError::native(format!(
            "Unable to capture stderr from {}.",
            program.display()
        ))
    })?;
    let stdout_reader = thread::spawn(move || read_command_stream(stdout));
    let stderr_reader = thread::spawn(move || read_command_stream(stderr));
    let deadline = Instant::now() + ANDROID_COMMAND_TIMEOUT;