parsec-interface 0.27.0

Parsec interface library to communicate using the wire protocol
Documentation
// Copyright 2020 Contributors to the Parsec project.
// SPDX-License-Identifier: Apache-2.0

// This one is hard to avoid.
#![allow(clippy::multiple_crate_versions)]

use std::io::Result;

// Replace the committed protobuf files with the generated one.
#[cfg(feature = "regenerate-protobuf")]
fn generate_proto_sources() -> Result<()> {
    use std::fs::read_dir;
    use std::io::{Error, ErrorKind};
    use std::path::Path;
    use std::process::Command;

    let path = String::from("parsec-operations/protobuf");
    let dir_entries = read_dir(Path::new(&path))?;
    let files: Result<Vec<String>> = dir_entries
        .map(|protos_file| {
            protos_file?
                .path()
                .into_os_string()
                .into_string()
                .map_err(|_| {
                    Error::new(
                        ErrorKind::InvalidData,
                        "conversion from OsString to String failed",
                    )
                })
        })
        // Fail the entire operation if there was an error.
        .collect();
    let proto_files: Vec<String> = files?
        .into_iter()
        .filter(|string| string.ends_with(".proto"))
        .collect();
    let files_slices: Vec<&str> = proto_files.iter().map(|file| &file[..]).collect();

    prost_build::compile_protos(&files_slices, &[&path])?;

    // Copy all files generated in src/operations_protobuf/generated_ops
    let status = Command::new("bash")
        .arg("-c")
        .arg(format!(
            "cp {}/*.rs src/operations_protobuf/generated_ops",
            std::env::var("OUT_DIR").expect("OUT_DIR env var is empty")
        ))
        .status()?;

    if !status.success() {
        Err(Error::new(
            ErrorKind::InvalidData,
            "failed copying generated protobuf files",
        ))
    } else {
        Ok(())
    }
}

fn main() -> Result<()> {
    #[cfg(feature = "regenerate-protobuf")]
    generate_proto_sources()?;

    Ok(())
}