jsonrpc::endpoint::Dispatcher Class Reference

#include <dispatcher.hpp>

Collaboration diagram for jsonrpc::endpoint::Dispatcher:

Public Types
using	MethodCallHandler
using	NotificationHandler

Public Member Functions
	Dispatcher (asio::any_io_executor executor, std::shared_ptr< spdlog::logger > logger=nullptr)
	Dispatcher (const Dispatcher &)=delete
	Dispatcher (Dispatcher &&)=delete
auto	operator= (const Dispatcher &) -> Dispatcher &=delete
auto	operator= (Dispatcher &&) -> Dispatcher &=delete
virtual	~Dispatcher ()=default
auto	Logger () -> std::shared_ptr< spdlog::logger >
void	RegisterMethodCall (const std::string &method, const MethodCallHandler &handler)
void	RegisterNotification (const std::string &method, const NotificationHandler &handler)
auto	DispatchRequest (std::string request) -> asio::awaitable< std::optional< std::string > >

Detailed Description

Definition at line 18 of file dispatcher.hpp.

Member Typedef Documentation

MethodCallHandler

using jsonrpc::endpoint::Dispatcher::MethodCallHandler

Initial value:

 std::function<asio::awaitable<nlohmann::json>(
      const std::optional<nlohmann::json>&)>

Definition at line 20 of file dispatcher.hpp.

NotificationHandler

using jsonrpc::endpoint::Dispatcher::NotificationHandler

Initial value:

 std::function<asio::awaitable<void>(
      const std::optional<nlohmann::json>&)>

Definition at line 22 of file dispatcher.hpp.

Constructor & Destructor Documentation

Dispatcher() [1/3]

jsonrpc::endpoint::Dispatcher::Dispatcher ( asio::any_io_executor executor, std::shared_ptr< spdlog::logger > logger = nullptr )

explicit

Definition at line 12 of file dispatcher.cpp.

    : executor_(std::move(executor)),
      logger_(logger ? logger : spdlog::default_logger()) {
}

Dispatcher() [2/3]

jsonrpc::endpoint::Dispatcher::Dispatcher ( const Dispatcher & )

delete

Dispatcher() [3/3]

jsonrpc::endpoint::Dispatcher::Dispatcher ( Dispatcher && )

delete

~Dispatcher()

virtual jsonrpc::endpoint::Dispatcher::~Dispatcher ( )

virtualdefault

Member Function Documentation

DispatchRequest()

auto jsonrpc::endpoint::Dispatcher::DispatchRequest

(

std::string

request

)

-> asio::awaitable<std::optional<std::string>>

Definition at line 28 of file dispatcher.cpp.

                                             {
  auto root = nlohmann::json::parse(request, nullptr, false);
  if (root.is_discarded()) {
    co_return Response::CreateError(RpcErrorCode::kParseError).ToJson().dump();
  }
 
  // Single request
  if (root.is_object()) {
    auto request = Request::FromJson(root);
    if (!request.has_value()) {
      co_return Response::CreateError(request.error()).ToJson().dump();
    }
 
    auto response = co_await DispatchSingleRequest(request.value());
    if (response.has_value()) {
      co_return response.value().ToJson().dump();
    }
    co_return std::nullopt;
  }
 
  // Batch request
  if (root.is_array()) {
    if (root.empty()) {
      co_return Response::CreateError(RpcErrorCode::kInvalidRequest)
          .ToJson()
          .dump();
    }
 
    std::vector<Request> requests;
    std::vector<Response> responses;
    for (const auto& element : root) {
      auto request = Request::FromJson(element);
      if (!request.has_value()) {
        responses.push_back(Response::CreateError(request.error()));
        continue;
      }
      requests.push_back(request.value());
    }
 
    auto dispatched = co_await DispatchBatchRequest(requests);
    for (const auto& response : dispatched) {
      responses.push_back(response);
    }
 
    co_return nlohmann::json(responses).dump();
  }
 
  co_return Response::CreateError(RpcErrorCode::kInvalidRequest)
      .ToJson()
      .dump();
}

References jsonrpc::endpoint::Response::CreateError(), and jsonrpc::endpoint::Request::FromJson().

Here is the call graph for this function:

Logger()

auto jsonrpc::endpoint::Dispatcher::Logger ( ) -> std::shared_ptr<spdlog::logger>

inline

Definition at line 35 of file dispatcher.hpp.

                                               {
    return logger_;
  }

operator=() [1/2]

auto jsonrpc::endpoint::Dispatcher::operator= ( const Dispatcher & ) -> Dispatcher &=delete

delete

operator=() [2/2]

auto jsonrpc::endpoint::Dispatcher::operator= ( Dispatcher && ) -> Dispatcher &=delete

delete

RegisterMethodCall()

void jsonrpc::endpoint::Dispatcher::RegisterMethodCall	(	const std::string &	method,
		const MethodCallHandler &	handler )

Definition at line 18 of file dispatcher.cpp.

                                                               {
  method_handlers_[method] = handler;
}

Referenced by jsonrpc::endpoint::RpcEndpoint::RegisterMethodCall().

Here is the caller graph for this function:

RegisterNotification()

void jsonrpc::endpoint::Dispatcher::RegisterNotification	(	const std::string &	method,
		const NotificationHandler &	handler )

Definition at line 23 of file dispatcher.cpp.

                                                                 {
  notification_handlers_[method] = handler;
}

Referenced by jsonrpc::endpoint::RpcEndpoint::RegisterNotification().

Here is the caller graph for this function:

---

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

• include/jsonrpc/endpoint/dispatcher.hpp
• src/endpoint/dispatcher.cpp