mq-bridge 0.2.13

An asynchronous message bridging library connecting Kafka, MQTT, AMQP, NATS, MongoDB, HTTP, and more.
Documentation
fn main() -> Result<(), Box<dyn std::error::Error>> {
    if std::env::var("CARGO_FEATURE_IBM_MQ").is_ok() {
        // Ensure rebuild when these environment variables change
        println!("cargo:rerun-if-env-changed=MQ_INSTALLATION_PATH");
        println!("cargo:rerun-if-env-changed=MQ_HOME");

        let mq_home = std::env::var("MQ_INSTALLATION_PATH")
            .or_else(|_| std::env::var("MQ_HOME"))
            .unwrap_or_else(|_| "/opt/mqm".to_string());

        // Use lib64 on 64-bit systems, lib otherwise
        let lib_dir = if cfg!(target_pointer_width = "64") {
            "lib64"
        } else {
            "lib"
        };
        let lib_path = format!("{}/{}", mq_home, lib_dir);

        println!("cargo:rustc-link-search=native={}", lib_path);
        // In production, you might prefer setting LD_LIBRARY_PATH instead of hardcoding rpath,
        // but rpath is convenient for containerized deployments.
        if cfg!(target_family = "unix") {
            println!("cargo:rustc-link-arg=-Wl,-rpath,{}", lib_path);
        }
    }
    // Only compile protos if the grpc feature is enabled and the build dependency is present.
    // Note: Cargo features for build-dependencies are separate, but we check the env var
    // to see if the feature was requested for the package.
    #[cfg(feature = "grpc")]
    {
        std::env::set_var("PROTOC", protoc_bin_vendored::protoc_bin_path().unwrap());
        println!("cargo:rerun-if-changed=src/endpoints/grpc.proto");
        tonic_prost_build::configure()
            .compile_protos(&["src/endpoints/grpc.proto"], &["src/endpoints"])?;
    }
    Ok(())
}