appCmdsImpl.hpp

Go to the documentation of this file.

 
#ifndef FCF_DEVMGR_COMMON_APP_CMDS_IMPL_HPP_
#define FCF_DEVMGR_COMMON_APP_CMDS_IMPL_HPP_
 
#include "fcf/devmgr/common/events.rad.hpp"
 
#include <rad/logger.hpp>
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
namespace fcf::devmgr::common {
 
class AppCmdsImpl : public fcfif::AsyncAppCmds {
public:
    AppCmdsImpl(rad::SMAdapter& sm) : mSM(sm) {
        RAD_LOG_TRACE();
    }
 
    virtual ~AppCmdsImpl() {
        RAD_LOG_TRACE();
    }
 
    virtual elt::mal::future<std::string> DevStatus(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::DevStatus* ev = new Events::DevStatus(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> Config() override {
        RAD_LOG_TRACE();
        Events::Config* ev = new Events::Config();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> GetConfig() override {
        RAD_LOG_TRACE();
 
        Events::GetConfig* ev = new Events::GetConfig();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> SetLog(const std::string& level) override {
        RAD_LOG_TRACE();
        Events::SetLog* ev = new Events::SetLog(level);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> Simulate(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::Simulate* ev = new Events::Simulate(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> StopSim(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::StopSim* ev = new Events::StopSim(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> Ignore(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::Ignore* ev = new Events::Ignore(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> StopIgn(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::StopIgn* ev = new Events::StopIgn(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> HwInit(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::HwInit* ev = new Events::HwInit(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> HwEnable(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::HwEnable* ev = new Events::HwEnable(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> HwDisable(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::HwDisable* ev = new Events::HwDisable(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> HwReset(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::HwReset* ev = new Events::HwReset(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> Setup(const std::vector<std::shared_ptr<fcfif::SetupElem>>& buffer) override {
        RAD_LOG_TRACE();
        Events::Setup* ev = new Events::Setup(buffer);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> Recover() override {
        RAD_LOG_TRACE();
        Events::Recover* ev = new Events::Recover();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> DevNames() override {
        RAD_LOG_TRACE();
        Events::DevNames* ev = new Events::DevNames();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> DevInfo() override {
        RAD_LOG_TRACE();
        Events::DevInfo* ev = new Events::DevInfo();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
    virtual elt::mal::future<std::string> DevConfig(const std::string& devname) override {
        RAD_LOG_TRACE();
        Events::DevConfig* ev = new Events::DevConfig(devname);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }
 
private:
    rad::SMAdapter& mSM;
};
 
}  // namespace server
 
#endif  // FCF_DEVMGR_COMMON_APP_CMDS_IMPL_HPP_