pipe_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 PipeTransport : public Transport {
 public:
  PipeTransport(const std::string &socket_path, bool is_server);
 
  ~PipeTransport() override;
 
  PipeTransport(const PipeTransport &) = delete;
  auto operator=(const PipeTransport &) -> PipeTransport & = delete;
 
  PipeTransport(PipeTransport &&) = delete;
  auto operator=(PipeTransport &&) -> PipeTransport & = delete;
 
  void SendMessage(const std::string &message) override;
  auto ReceiveMessage() -> std::string override;
 
 protected:
  auto GetSocket() -> asio::local::stream_protocol::socket &;
 
 private:
  void RemoveExistingSocketFile();
  void Connect();
  void BindAndListen();
 
  asio::io_context io_context_;
  asio::local::stream_protocol::socket socket_;
  std::string socket_path_;
  bool is_server_;
};
 
}  // namespace jsonrpc::transport