stdCmdsImpl.hpp

Go to the documentation of this file.

#ifndef FCF_DEVMGR_COMMON_STD_CMDS_IMPL_HPP_
#define FCF_DEVMGR_COMMON_STD_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 StdCmdsImpl : public fcfif::AsyncStdCmds {
public:
    StdCmdsImpl(rad::SMAdapter& sm) : mSM(sm) {
        RAD_LOG_TRACE();
    }

    virtual ~StdCmdsImpl() {
        RAD_LOG_TRACE();
    }

    virtual elt::mal::future<std::string> Exit() override {
        RAD_LOG_TRACE();
        Events::Exit* ev = new Events::Exit();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> Init() override {
        RAD_LOG_TRACE();
        Events::Init* ev = new Events::Init();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> Stop() override {
        RAD_LOG_TRACE();
        Events::Stop* ev = new Events::Stop();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> Reset() override {
        RAD_LOG_TRACE();
        Events::Reset* ev = new Events::Reset();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> State() override {
        RAD_LOG_TRACE();
        Events::State* ev = new Events::State();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> Status(const std::vector<std::string>& devices) override {
        RAD_LOG_TRACE();
        Events::Status* ev = new Events::Status(devices);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> Enable() override {
        RAD_LOG_TRACE();
        Events::Enable* ev = new Events::Enable();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> Disable() override {
        RAD_LOG_TRACE();
        Events::Disable* ev = new Events::Disable();
        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> 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::FcsUnion>>& 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> BeginAcq(const std::string& prefix) override {
        RAD_LOG_TRACE();
        Events::BeginAcq* ev = new Events::BeginAcq(prefix);
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

    virtual elt::mal::future<std::string> EndAcq() override {
        RAD_LOG_TRACE();
        Events::EndAcq* ev = new Events::EndAcq();
        mSM.PostEvent(rad::UniqueEvent(ev));
        return ev->GetPayload().GetReplyFuture();
    }

private:
    rad::SMAdapter& mSM;
};

}  // namespace server

#endif  // FCF_DEVMGR_COMMON_STD_CMDS_IMPL_HPP_