rtcComponent.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_DETAIL_RTCCOMPONENT_HPP
#define RTCTK_COMPONENTFRAMEWORK_DETAIL_RTCCOMPONENT_HPP
 
#include <mal/Cii.hpp>
#include <boost/program_options.hpp>
#include <boost/core/demangle.hpp>
#include <iostream>
 
namespace rtctk::componentFramework::detail {
 
class HelpOnly : public std::runtime_error
{
  public:
    HelpOnly(const std::string& help_text)
    : std::runtime_error(help_text) {}
};
 
class ArgNotSet : public std::runtime_error
{
  public:
    ArgNotSet(const std::string& arg_name)
    : std::runtime_error("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;
        }
    }
 
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")
            ("lpf,l", bpo::value<Uri>(), "logging properties file");
 
        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;
            throw HelpOnly(ss.str());
        }
 
        if (!vm.count("cid")) {
            throw ArgNotSet("component identity");
        }
 
        if (!vm.count("sde")) {
            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());
}
 
} // closing namespace
 
#endif