config.hxx

Go to the documentation of this file.

 
#ifndef __FDP_CONFIG_HXX__
#define __FDP_CONFIG_HXX__
 
#include <string>
#include <ghc/filesystem.hpp>
#include <yaml-cpp/yaml.h>
#include <map>
#include <regex>
#include <ghc/filesystem.hpp>
#include <stdio.h>
 
#include "fdp/objects/metadata.hxx"
#include "fdp/registry/api.hxx"
#include "fdp/objects/api_object.hxx"
#include "fdp/objects/io_object.hxx"
 
namespace FairDataPipeline {
    class Config {
        public:
            typedef std::shared_ptr< Config > sptr;
 
            typedef std::map< std::string, IOObject > map_type;
 
        private:            
            const ghc::filesystem::path config_file_path_;
            const ghc::filesystem::path config_dir_;
            const ghc::filesystem::path script_file_path_;
            YAML::Node config_data_;            
            std::string api_url_;
            std::string token_;
            API::sptr api_;
 
            ApiObject::sptr user_;
            ApiObject::sptr author_;
 
            ApiObject::sptr config_storage_root_;
            ApiObject::sptr config_storage_location_;
            ApiObject::sptr config_file_type_;
            ApiObject::sptr config_obj_;
 
            ApiObject::sptr script_storage_root_;
            ApiObject::sptr script_storage_location_;
            ApiObject::sptr script_file_type_;
            ApiObject::sptr script_obj_;
 
            ApiObject::sptr code_repo_storage_root_;
            ApiObject::sptr code_repo_storage_location_;
            ApiObject::sptr code_repo_obj_;
 
            ApiObject::sptr code_run_;
            
            map_type writes_;
            map_type reads_;
 
            map_type outputs_;
            map_type inputs_;
 
            RESTAPI rest_api_location_ = RESTAPI::LOCAL;
 
            bool config_has_writes() const;
            bool config_has_reads() const;
            
            void initialise(RESTAPI api_location);
            void validate_config(ghc::filesystem::path yaml_path, RESTAPI api_location);
            Config(const ghc::filesystem::path &config_file_path,
                    const ghc::filesystem::path &script_file_path,
                    const std::string &token,
                    RESTAPI api_location);
 
 
        public:
 
            static Config::sptr construct(const ghc::filesystem::path &config_file_path,
                    const ghc::filesystem::path &script_file_path,
                    const std::string &token,
                    RESTAPI api_location);
 
 
            ~Config();
            
            YAML::Node meta_data_() const;
            YAML::Node config_writes_() const;
 
            YAML::Node config_reads_() const;
 
            bool has_reads() const;
            bool has_writes() const;
            bool has_outputs() const;
            bool has_inputs() const;
 
            ghc::filesystem::path get_config_file_path() const {return config_file_path_;}
            ghc::filesystem::path get_script_file_path() const {return script_file_path_;}
 
            std::string get_token() const {return token_;}
 
            std::string get_api_url() const {return api_url_;}
            ghc::filesystem::path get_data_store() const;
 
            std::string get_default_input_namespace() const;
 
            std::string get_default_output_namespace() const;
 
            std::string get_config_directory() const;
 
            std::string get_code_run_uuid() const;
 
            ghc::filesystem::path link_write( const std::string &data_product);
 
            ghc::filesystem::path link_read(const std::string& data_product);
 
            void finalise();
 
            static YAML::Node parse_yaml(ghc::filesystem::path yaml_path);
            
            YAML::Node get_config_data() const {return config_data_;}
 
             API::sptr get_api() const {return api_;}
 
            RESTAPI get_rest_api_location() const {return rest_api_location_;}
 
    };
};
#endif