Function main

app/src/main.rs:61–207

()

}

pub fn main() -> io::Result<()> {
    println!("{ASCII_BANNER}");

    CryptoProvider::install_default(rustls::crypto::aws_lc_rs::default_provider())
        .expect("Cannot install rustls crypto provider");

    // Load env variable from .env file
    dotenv().ok();

    // Init tracing subscriber
    tracing_subscriber::fmt()
        .with_env_filter(EnvFilter::from_default_env())
        .fmt_fields(
            tracing_subscriber::fmt::format::debug_fn(|writer, field, value| write!(writer, "{field}: {value:?}"))
                .delimited(", "),
        )
        .with_ansi(true)
        .with_thread_names(true)
        .with_timer(UtcTime::rfc_3339())
        .init();

    let deployed_engine_version = load_deployed_engine_version(build_info::ENGINE_VERSION, build_info::SHORT_COMMIT);
    let engine_id = env::var("ID").unwrap_or_else(|_| generate_id().to_string());
    let version_file = env::var("BIN_VERSION_FILE").expect("BIN_VERSION_FILE is mandatory");
    let test_cluster_env_var = env::var("TEST_CLUSTER");
    let lib_root_dir = env::var("LIB_ROOT_DIR").unwrap_or_else(|_| "lib".to_string());
    let aws_apn_id = env::var("QOVERY_AWS_APN_ID").unwrap_or_else(|_| "not-set".to_string());
    let docker_host = env::var("DOCKER_HOST").map(|val| Url::parse(&val).unwrap()).ok();
    let workspace_root_dir =
        env::var("WORKSPACE_ROOT_DIR").unwrap_or_else(|_| home_dir().unwrap().to_string_lossy().into_owned());

    let logger: Box<dyn Logger> = Box::new(CompositeLogger::new(vec![Box::new(StdIoLogger::new())]));
    let metrics_registry = Box::new(StdMetricsRegistry::new(Box::new(StdMsgPublisher::new())));

    info!("engine id: {}", engine_id.as_str());
    info!("engine version : {}", deployed_engine_version);
    info!(
        "running from current directory: {}",
        env::current_dir().unwrap().to_str().unwrap()
    );
    info!("lib root dir: {}/", lib_root_dir.as_str());
    info!("workspace root dir: {}", workspace_root_dir.as_str());

    match check_libs_directory(lib_root_dir.clone()) {
        Ok(_) => info!("Libs directory is not empty"),
        Err(e) => {
            error!("Error while initializing the Engine {}", e);
            process::exit(1);
        }
    }

    //checking if version file exist
    match Path::new(&version_file).exists() {
        true => info!("Version file is accessible"),
        _ => {
            error!("Error while initializing the Engine, version file is not accessible");
            process::exit(1);
        }