Function using_json_path_parameter

app/src/main.rs:210–329

the engine can be launch using a json file given in parameter

(
    logger: Box<dyn Logger>,
    deploy_from_file: String,
    workspace_root_dir: String,
    lib_root_dir: String,
    aws_apn_id: String,
    test_cluster: bool,
    deployment_type: TaskSelector

// the engine can be launch using a json file given in parameter
pub fn using_json_path_parameter(
    logger: Box<dyn Logger>,
    deploy_from_file: String,
    workspace_root_dir: String,
    lib_root_dir: String,
    aws_apn_id: String,
    test_cluster: bool,
    deployment_type: TaskSelector,
    docker: Arc<Docker>,
    deployed_engine_version: DeployedEngineVersion,
    metrics_registry: Box<dyn MetricsRegistry>,
) -> Result<(), Error> {
    // check if file json config file exist
    if !Path::new(&deploy_from_file).exists() {
        error!("{} : No such file or directory", deploy_from_file);
        process::exit(1);
    }
    info!("Using {} configuration file", deploy_from_file);

    let file = BufReader::new(File::open(deploy_from_file)?);

    let task: Box<dyn Task> = match deployment_type {
        TaskSelector::Blueprint => {
            let mut deserialized_request = serde_json::Deserializer::from_reader(file);
            let mut request: BlueprintEngineRequest = serde_path_to_error::deserialize(&mut deserialized_request)
                .map_err(|err| {
                    error!("Impossible to parse json file: {}", err);
                    process::exit(1);
                })
                .unwrap();
            request.test_cluster = test_cluster;
            Box::new(BlueprintTask::new(
                request,
                workspace_root_dir,
                lib_root_dir,
                aws_apn_id,
                deployed_engine_version.clone(),
                docker,
                logger,
                metrics_registry,
                Box::new(FakeQoveryApi {}),
                None,
            ))
        }
        TaskSelector::Environment => {
            let mut deserialized_req = serde_json::Deserializer::from_reader(file);
            let mut request: EnvironmentEngineRequest = serde_path_to_error::deserialize(&mut deserialized_req)
                .map_err(|err| {
                    error!("Impossible to parse json file: {}", err);
                    process::exit(1);
                })
                .unwrap();

            request.test_cluster = test_cluster;
            Box::new(EnvironmentTask::new(
                request,
                workspace_root_dir,
                deployed_engine_version.clone(),