ddtRemoteControl.hpp

Go to the documentation of this file.

 
#ifndef DATAVISUALISATION_REMOTECONTROL_SRC_INCLUDE_DDT_DDTREMOTECONTROL_HPP_
#define DATAVISUALISATION_REMOTECONTROL_SRC_INCLUDE_DDT_DDTREMOTECONTROL_HPP_
 
#include <Ddtremotecontrolicd.hpp>
#include <boost/signals2/signal.hpp>
#include <future>
#include <iostream>
#include <mal/Cii.hpp>
#include <mal/rr/ServerAmi.hpp>
#include <mal/rr/ServerContextProvider.hpp>
#include <mal/rr/qos/ReplyTime.hpp>
#include <mal/utility/LoadMal.hpp>
#include <string>
 
#include "ddt/ddtConstants.hpp"
#include "ddt/ddtLogger.hpp"
 
namespace mal = ::elt::mal;
namespace remotecontrol = ::elt::ddt::remotecontrol;

typedef boost::signals2::signal<void(const std::string&, const std::string&,
                                     const std::vector<std::string>&)>
    signal_remote;

typedef signal_remote::slot_type slot_remote;
 
namespace ddt {
 
class DdtRemoteControl
    : public virtual remotecontrol::AsyncRemoteControlRegistration {
 public:
  explicit DdtRemoteControl(const std::string server_uri,
                            DdtLogger* ddt_logger);

  virtual ~DdtRemoteControl();

  void StartRemoteControlServer();

  mal::future<std::string> HandleRemoteCommand(
      const std::string& image_widget_name, const std::string& command_name,
      const std::vector<std::string>& command_arguments) override;

  void ProcessResponse(const std::string& response);

  signal_remote remote_command_signal;
 
 protected:
  DdtLogger* logger;
 
 private:
  void Init(const std::string server_uri, DdtLogger* ddt_logger);

  const std::string ListCommands();

  void ServerThread();
 
  std::string uri_string;
  std::unique_ptr<::elt::mal::rr::Server> server;
 
  const std::string SERVICE = "RemoteControl";
  const std::string URI_PATH = "/viewer";
 
  boost::promise<std::string>* promise;
  std::atomic<bool> server_busy;
};
 
}  // namespace ddt
 
#endif /* DATAVISUALISATION_REMOTECONTROL_SRC_INCLUDE_DDT_DDTREMOTECONTROL_HPP_ \
        */