json_rpc.h

Go to the documentation of this file.

 
#ifndef PKG_RPC_JSON_RPC_H_INCLUDED
#define PKG_RPC_JSON_RPC_H_INCLUDED
 
#include <rpc/rpc_server.h>
 
#include <jsonrpccpp/client/iclientconnector.h>
#include <jsonrpccpp/server/abstractserverconnector.h>
 
namespace rpc {

class cJSONConversions {
public:
    static Json::Value result_to_json(a_util::result::Result nResult);
#ifndef PKGRPC_NO_TOSTRING
    static std::string to_string(uint64_t nValue);
    static std::string to_string(int64_t nValue);
#endif // PKGRPC_NO_TOSTRING
    static a_util::result::Result json_to_result(const Json::Value& oValue);
    static uint64_t stoull(const std::string& strValue);
    static int64_t stoll(const std::string& strValue);
};

template <typename Stub, typename Connector, typename ConnectorInitializer>
class jsonrpc_remote_object : private Connector, public Stub {
public:
    jsonrpc_remote_object(const ConnectorInitializer& oInitializer);
 
protected:
    Stub& GetStub() const;
};

template <typename Stub, typename Interface, typename Connector, typename ConnectorInitializer>
class jsonrpc_remote_interface
    : private jsonrpc_remote_object<Stub, Connector, ConnectorInitializer>,
      protected cJSONConversions,
      public Interface {
public:
    jsonrpc_remote_interface(const ConnectorInitializer& oInitializer);
 
protected:
    Stub& GetStub() const;
};

class cServerConnector : public jsonrpc::AbstractServerConnector {
public:
    bool StartListening();
    bool StopListening();
    bool SendResponse(const std::string& response, void* addInfo);
    bool OnRequest(const std::string& request, IResponse* response);
};

template <typename ServerStub, typename Connector = cServerConnector>
class jsonrpc_object_server : protected Connector,
                              protected ServerStub,
                              public IRPCObject,
                              protected cJSONConversions {
public:
    jsonrpc_object_server();
 
public:
    virtual a_util::result::Result HandleCall(const char* strRequest,
                                              size_t nRequestSize,
                                              IResponse& oResponse);
};
 
} // namespace rpc
 
#endif // PKG_RPC_HTTP_RPC_PROTOCOL_H_INCLUDED
 
#include <rpc/detail/json_rpc_impl.h>