factory.hh

Go to the documentation of this file.

#pragma once

#include "message.hh"
#include <boost/asio/streambuf.hpp>
#include <boost/asio.hpp>
#include <string>
#include <memory>

namespace eclipse {
namespace messages {

Message* load_message (boost::asio::streambuf&);
Message* load_message (std::string&);
std::string* save_message (Message*);

void send_message(boost::asio::ip::tcp::socket*, eclipse::messages::Message*);

template <typename T>
auto read_reply(boost::asio::ip::tcp::socket* socket) {
  using namespace boost::asio;
  char header[17] = {0};
  header[16] = '\0';
  boost::asio::streambuf buf;

  read(*socket, buffer(header, 16));
  size_t size_of_msg = atoi(header);

  size_t l = read(*socket, buf.prepare(size_of_msg));

  Message* msg = nullptr;
  buf.commit(l);
  msg = load_message(buf);
  buf.consume(l);
  T* m = dynamic_cast<T*>(msg);
  return std::unique_ptr<T>(m);
}

} /* messages */ 
}