requestHandler.h

Go to the documentation of this file.

#ifndef REQUEST_HANDLER_H
#define REQUEST_HANDLER_H


#include <QString>


#include <rad/MsgRequestor.hpp>
#include <rad/Helper.hpp>
#include <rad/Logger.hpp>

#include <devmgr/modif/requests.pb.h>

template <typename TYPEREQ, typename TYPEREP>
class RequestHandler
{


public:
  RequestHandler() {};

  ~RequestHandler() {};

public slots:

  bool SendSynch(const std::string endpoint, TYPEREQ req, const long replyTimeout)
  {
    rad::MsgRequestor<TYPEREQ, TYPEREP> requestor(endpoint, rad::Helper::CreateIdentity(),
                                                  mIOS, std::bind(&RequestHandler::ReplyCallback,
                                                                  this, std::placeholders::_1,
                                                                  std::placeholders::_2));
    size_t nbytes = requestor.Send(req, replyTimeout);
    if (nbytes < 0) {
        RAD_LOG_ERROR() << "ERROR sending command.";
        return false;
      }

    try {
      mIOS.run();
    } catch (...) {
      RAD_LOG_ERROR() << "ERROR running IOS.";
      return false;
    }
    return true;
  };

private:
  void ReplyCallback(const std::error_code& errCode, TYPEREP rep)
  {
    if (!errCode) {
        std::cout << rep.reply() << std::endl;
//        if (rep.has_aborted())
//          {
//          RAD_LOG_ERROR() << "aborted: " << rep.reply();
//          }
//        if (rep.has_error())
//          {
//          RAD_LOG_ERROR() << "error: " << rep.reply();
//          }
//        if (rep.has_timeout())
//          {
//          RAD_LOG_ERROR() << "timeout reached:" << rep.reply();
//          }

        //        QString temp = QString::fromStdString(rep.reply());
        //        bool a = temp.QString::toUpper().contains("ERROR");
        //        if (a)
        //m_window->statusBar()->setStyleSheet("color: redwaf in");
        //        else
        //m_window->statusBar()->setStyleSheet("color: blue");
        //m_window->statusBar()->showMessage(QString::fromStdString(rep.reply()));
      }
    mIOS.stop();
  };

  boost::asio::io_service mIOS;
};





#endif // SETUP_OBJECT_H