rtcComponent.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_DETAIL_RTCCOMPONENT_HPP
#define RTCTK_COMPONENTFRAMEWORK_DETAIL_RTCCOMPONENT_HPP
 
#include <rtctk/componentFramework/exceptions.hpp>
#include <boost/core/demangle.hpp>
#include <boost/program_options.hpp>
#include <mal/Cii.hpp>
 
#include <iostream>
 
namespace rtctk::componentFramework::detail {
 
class HelpOnly : public rtctk::componentFramework::RtctkException {
public:
    HelpOnly(const std::string& help_text) : rtctk::componentFramework::RtctkException(help_text) {
    }
};
 
class ArgNotSet : public rtctk::componentFramework::RtctkException {
public:
    ArgNotSet(const std::string& arg_name)
        : rtctk::componentFramework::RtctkException("Mandatory argument '" + arg_name +
                                                    "' not set, use -h for help") {
    }
};
 
class Args {
public:
    Args(int argc, char** argv) : m_argc(argc), m_argv(argv) {
        Parse();
    }
 
    std::string GetComponentName() const {
        return vm["cid"].as<std::string>();
    }
 
    elt::mal::Uri GetServiceDiscEndpoint() const {
        return vm["sde"].as<elt::mal::Uri>();
    }
 
    std::optional<elt::mal::Uri> GetLogPropsFile() const {
        if (vm.count("lpf")) {
            return {vm["lpf"].as<elt::mal::Uri>()};
        } else {
            return std::nullopt;
        }
    }
 
    std::optional<elt::mal::Uri> GetModelExportFile() const {
        if (vm.count("emf")) {
            return {vm["emf"].as<elt::mal::Uri>()};
        } else {
            return std::nullopt;
        }
    }
 
private:
    void Parse() {
        namespace bpo = boost::program_options;
        using ::elt::mal::Uri;
 
        bpo::positional_options_description pos_opts_desc;
        pos_opts_desc.add("cid", 1);
        pos_opts_desc.add("sde", 1);
 
        bpo::options_description opts_desc("Options");
        opts_desc.add_options()
            ("help,h", "print help messages")
            ("cid,i", bpo::value<std::string>(), "component identity")
            ("sde,s", bpo::value<Uri>(), "service discovery endpoint (URI)")
            ("lpf,l", bpo::value<Uri>(), "log4cplus properties file (URI)")
            ("emf,e", bpo::value<Uri>(), "export state machine model to file (URI)");
 
        bpo::store(bpo::command_line_parser(m_argc, m_argv)
                       .options(opts_desc)
                       .positional(pos_opts_desc)
                       .run(),
                   vm);
 
        bpo::notify(vm);
 
        if (vm.count("help")) {
            std::stringstream ss;
            ss << opts_desc << std::endl;
            CII_THROW(HelpOnly, ss.str());
        }
 
        if (!vm.count("cid")) {
            CII_THROW(ArgNotSet, "component identity");
        }
 
        if (!vm.count("sde")) {
            CII_THROW(ArgNotSet, "service discovery endpoint");
        }
    }
 
    int m_argc;
    char** m_argv;
 
    boost::program_options::variables_map vm;
};
 
std::string GetTypeName(const std::type_info& tid) {
    return boost::core::demangle(tid.name());
}
 
}  // namespace rtctk::componentFramework::detail
 
#endif  // RTCTK_COMPONENTFRAMEWORK_DETAIL_RTCCOMPONENT_HPP