jsonrpc::transport::SocketTransport Class Reference

Transport implementation using TCP/IP sockets. More...

#include <socket_transport.hpp>

Inheritance diagram for jsonrpc::transport::SocketTransport:

Collaboration diagram for jsonrpc::transport::SocketTransport:

Public Member Functions
	SocketTransport (const std::string &host, uint16_t port, bool is_server)
	Constructs a SocketTransport.
	~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
	Sends a message in string to the transport layer.
auto	ReceiveMessage () -> std::string override
	Receives a message from the transport layer.
Public Member Functions inherited from jsonrpc::transport::Transport
	Transport ()=default
virtual	~Transport ()=default
	Transport (const Transport &)=default
auto	operator= (const Transport &) -> Transport &=default
	Transport (Transport &&)=delete
auto	operator= (Transport &&) -> Transport &=delete

Protected Member Functions
auto	GetSocket () -> asio::ip::tcp::socket &

Detailed Description

Transport implementation using TCP/IP sockets.

This class provides transport functionality over TCP/IP sockets, supporting both client and server modes for communication over a network.

Definition at line 16 of file socket_transport.hpp.

Constructor & Destructor Documentation

SocketTransport() [1/3]

jsonrpc::transport::SocketTransport::SocketTransport	(	const std::string &	host,
		uint16_t	port,
		bool	is_server )

Constructs a SocketTransport.

Parameters

host	The host address (IP or domain name).
port	The port number.
isServer	True if the transport acts as a server; false if it acts as a client.

Definition at line 9 of file socket_transport.cpp.

    : socket_(io_context_), host_(host), port_(port), is_server_(is_server) {
  spdlog::info(
      "Initializing SocketTransport with host: {} and port: {}", host, port);
 
  if (is_server_) {
    BindAndListen();
  } else {
    Connect();
  }
}

~SocketTransport()

jsonrpc::transport::SocketTransport::~SocketTransport ( )

override

Definition at line 26 of file socket_transport.cpp.

                                  {
  spdlog::info("Closing socket and shutting down SocketTransport.");
  std::error_code ec;
  socket_.close(ec);
  if (ec) {
    spdlog::warn("Socket close error: {}", ec.message());
  }
  io_context_.stop();
}

SocketTransport() [2/3]

jsonrpc::transport::SocketTransport::SocketTransport ( const SocketTransport & )

delete

SocketTransport() [3/3]

jsonrpc::transport::SocketTransport::SocketTransport ( SocketTransport && )

delete

Member Function Documentation

GetSocket()

auto jsonrpc::transport::SocketTransport::GetSocket ( ) -> asio::ip::tcp::socket &

protected

Definition at line 22 of file socket_transport.cpp.

                                                     {
  return socket_;
}

Referenced by jsonrpc::transport::FramedSocketTransport::SendMessage().

Here is the caller graph for this function:

operator=() [1/2]

auto jsonrpc::transport::SocketTransport::operator= ( const SocketTransport & ) -> SocketTransport &=delete

delete

operator=() [2/2]

auto jsonrpc::transport::SocketTransport::operator= ( SocketTransport && ) -> SocketTransport &=delete

delete

ReceiveMessage()

auto jsonrpc::transport::SocketTransport::ReceiveMessage ( ) -> std::string

overridevirtual

Receives a message from the transport layer.

Returns

The JSON-RPC response as a string.

Implements jsonrpc::transport::Transport.

Definition at line 96 of file socket_transport.cpp.

                                                  {
  try {
    asio::streambuf buffer;
    asio::read_until(socket_, buffer, '\n');
    std::istream is(&buffer);
    std::string message;
    std::getline(is, message);
    spdlog::debug("Received message: {}", message);
    return message;
  } catch (const std::exception &e) {
    spdlog::error("Error receiving message: {}", e.what());
    socket_.close();
    return "";
  }
}

SendMessage()

void jsonrpc::transport::SocketTransport::SendMessage ( const std::string & message )

overridevirtual

Sends a message in string to the transport layer.

Parameters

request

The JSON-RPC request as a string.

Implements jsonrpc::transport::Transport.

Definition at line 86 of file socket_transport.cpp.

                                                          {
  try {
    asio::write(socket_, asio::buffer(message + "\n"));
    spdlog::debug("Sent message: {}", message);
  } catch (const std::exception &e) {
    spdlog::error("Error sending message: {}", e.what());
    throw std::runtime_error("Error sending message");
  }
}

---

The documentation for this class was generated from the following files:

• include/jsonrpc/transport/socket_transport.hpp
• src/transport/socket_transport.cpp