socket_transport.hpp

Go to the documentation of this file.

#pragma once
 
#include <asio.hpp>
#include <string>
 
#include "jsonrpc/transport/transport.hpp"
 
namespace jsonrpc::transport {
 
class SocketTransport : public Transport {
 public:
  SocketTransport(const std::string &host, uint16_t port, bool is_server);
 
  ~SocketTransport() override;
 
  SocketTransport(const SocketTransport &) = delete;
  auto operator=(const SocketTransport &) -> SocketTransport & = delete;
 
  SocketTransport(SocketTransport &&) = delete;
  auto operator=(SocketTransport &&) -> SocketTransport & = delete;
 
  void SendMessage(const std::string &message) override;
  auto ReceiveMessage() -> std::string override;
 
 protected:
  auto GetSocket() -> asio::ip::tcp::socket &;
 
 private:
  void Connect();
  void BindAndListen();
 
  asio::io_context io_context_;
  asio::ip::tcp::socket socket_;
  std::string host_;
  uint16_t port_;
  bool is_server_;
};
 
}  // namespace jsonrpc::transport