ddtRemoteControl.hpp

Go to the documentation of this file.

// @copyright
// (c) Copyright ESO 2021
// All Rights Reserved
// ESO (eso.org) is an Intergovernmental Organization, and therefore special
// legal conditions apply.
//
// @file ddtRemoteControl.hpp
// @brief DDT Remote Control. Remote control interface for the DDT GUIs
//
// Library class for the remote control interface
//
// @author Carsten Mannel, CGI
// @since  2021/04/14
//
 
#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_ \
        */