cmdsImpl.hpp

Go to the documentation of this file.

#ifndef IFWSLM_CMDS_IMPL_HPP
#define IFWSLM_CMDS_IMPL_HPP
 
#include "events.rad.hpp"
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
#include <Ifwslmif.hpp>
 
namespace ifw::slm {
 
class SecondaryLoopManagerCmdsImpl : public ifwslmif::AsyncSecondaryLoopManagerCmds {
public:
  explicit SecondaryLoopManagerCmdsImpl(rad::SMAdapter& sm) : m_sm(sm) {
      RAD_TRACE(GetLogger());
  }
 
  virtual ~SecondaryLoopManagerCmdsImpl() {
      RAD_TRACE(GetLogger());
  }
 
private:
    template<typename EventType>
    elt::mal::future<std::string> PostLoopCommand(
            const elt::mal::shared_vector<const int32_t>& loops) {
        RAD_TRACE(GetLogger());
        std::array<int32_t, 9> arr;
        for (size_t i = 0; i < arr.size(); ++i) {
            arr[i] = loops[i];
        }
        auto ev = std::make_shared<EventType>(arr);
        m_sm.PostEvent(ev);
        return ev->GetPayload().GetReplyFuture();
    }
 
public:
  virtual elt::mal::future<std::string> CloseLoop(const elt::mal::shared_vector<const int32_t>& loops) override {
      return PostLoopCommand<Events::CloseLoop>(loops);
  }
 
  virtual elt::mal::future<std::string> OpenLoop(const elt::mal::shared_vector<const int32_t>& loops) override {
      return PostLoopCommand<Events::OpenLoop>(loops);
  }
 
  virtual elt::mal::future<std::string> ResumeLoop(const elt::mal::shared_vector<const int32_t>& loops) override {
      return PostLoopCommand<Events::ResumeLoop>(loops);
  }
 
  virtual elt::mal::future<std::string> SuspendLoop(const elt::mal::shared_vector<const int32_t>& loops) override {
      return PostLoopCommand<Events::SuspendLoop>(loops);
  }
 
  virtual elt::mal::future<std::string> RunSlm() override {
      RAD_TRACE(GetLogger());
      auto ev = std::make_shared<Events::RunSlm>();
      m_sm.PostEvent(ev);
      return ev->GetPayload().GetReplyFuture();
  }
 
  virtual elt::mal::future<std::string> StopSlm() override {
      RAD_TRACE(GetLogger());
      auto ev = std::make_shared<Events::StopSlm>();
      m_sm.PostEvent(ev);
      return ev->GetPayload().GetReplyFuture();
  }
 
private:
  rad::SMAdapter& m_sm;
};
 
}  // namespace ifw::slm
#endif  // IFWSLM_CMDS_IMPL_HPP