commandRequestor.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_COMMANDREQUESTOR_HPP
#define RTCTK_COMPONENTFRAMEWORK_COMMANDREQUESTOR_HPP
 
#include <Rtctkif.hpp>
 
#include <mal/Cii.hpp>
#include <mal/utility/Uri.hpp>
 
#include <chrono>
#include <memory>
#include <optional>
 
namespace rtctk::componentFramework {
 
class CommandRequestor {
public:
    CommandRequestor(const elt::mal::Uri& uri,
                     std::optional<std::chrono::milliseconds> timeout = std::nullopt);
 
    virtual ~CommandRequestor() = default;
 
    std::string SendCommandSync(std::string const& id, std::string const& args);
    elt::mal::future<std::string>
    SendCommandAsync(std::string const& id, std::string const& args);
 
protected:
    template <typename T>
    std::unique_ptr<T> MakeInterface(std::string const& name) {
        return m_factory.getClient<T>(elt::mal::Uri(m_uri + name), m_qos, m_props);
    }
 
    void RegisterCommand(std::string const& id,
                         std::function<elt::mal::future<std::string>(std::string const&)> fun);
 
private:
    std::string m_uri;
    elt::mal::Mal::Properties m_props;
    elt::mal::CiiFactory& m_factory;
    std::vector<std::shared_ptr<elt::mal::rr::qos::QoS>> m_qos;
 
    std::map<std::string, std::function<elt::mal::future<std::string>(std::string const&)>> m_cmds;
 
    std::unique_ptr<stdif::StdCmdsAsync> stdif;
    std::unique_ptr<rtctkif::UpdateCmdsAsync> ucif;
    std::unique_ptr<rtctkif::FuncCmdsAsync> fcif;
    std::unique_ptr<rtctkif::MeasCmdsAsync> mcif;
    std::unique_ptr<rtctkif::OptCmdsAsync> ocif;
    std::unique_ptr<rtctkif::LoopCmdsAsync> lcif;
    std::unique_ptr<rtctkif::SuspCmdsAsync> lsif;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_COMMANDREQUESTOR_HPP