Peerplays_Blockchain/peerplays-fc
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
peerplays-fc/include/fc/rpc/json_connection.hpp

319 lines
13 KiB
C++
Raw Normal View History

Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
#pragma once
#include <fc/io/buffered_iostream.hpp>
#include <fc/variant_object.hpp>
#include <fc/thread/future.hpp>
#include <fc/log/logger.hpp>
#include <functional>
namespace fc { namespace rpc {
namespace detail { class json_connection_impl; }
/**
* @brief Implements JSON-RPC 2.0 over a set of io streams
*
* Each JSON RPC message is expected to be on its own line, violators
* will be prosecuted to the fullest extent of the law.
*/
class json_connection
{
public:
typedef std::function<variant(const variants&)> method;
typedef std::function<variant(const variant_object&)> named_param_method;
Merge pull request #21 from pmconrad/variant_fix Variant fix
2018-03-19 16:35:57 +00:00
json_connection( fc::buffered_istream_ptr in, fc::buffered_ostream_ptr out, uint32_t max_depth );
Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
~json_connection();
/**
* Starts processing messages from input
*/
future<void> exec();
Fix crashes when destroying json_connection, tcp_socket Also, create on_close callback on json_connection, so clients can know when the connection has failed.
2015-02-12 15:54:18 +00:00
bool is_open();
void close();
void set_on_disconnected_callback(std::function<void(fc::exception_ptr)> callback);
Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
logger get_logger()const;
void set_logger( const logger& l );
/**
* @name server interface
*
* Adding methods to the interface allows the remote side
* to call them.
*/
///@{
void add_method( const fc::string& name, method );
more windows related changes, check what I was thinking with that BOOST1_51 when not in a hurry, maybe it should just be removed now
2013-08-11 02:11:59 +00:00
void add_named_param_method( const fc::string& name, named_param_method );
Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
void remove_method( const fc::string& name );
//@}
/**
* @name client interface
*/
///@{
void notice( const fc::string& method );
void notice( const fc::string& method, const variants& args );
void notice( const fc::string& method, const variant_object& named_args );
/// args will be handled as named params
future<variant> async_call( const fc::string& method,
const variant_object& args );
future<variant> async_call( const fc::string& method, mutable_variant_object args );
/// Sending in an array of variants will be handled as positional arguments
future<variant> async_call( const fc::string& method,
const variants& args );
future<variant> async_call( const fc::string& method );
future<variant> async_call( const fc::string& method,
const variant& a1 );
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2 );
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3 );
- Add four-argument version of json-rpc call function - fix bug in json parser that prevented correct parsing of a true/false/null at the end of input - prevent infinite recursion in a json helper function
2014-04-21 18:34:46 +00:00
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4 );
Add 5 and 6 argument versions of json rpc call functions
2014-05-29 19:54:13 +00:00
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5 );
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6 );
adding support for 7 arg rpc calls
2014-06-07 02:46:28 +00:00
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7
);
support for 8 param rpc calls
2014-07-04 21:23:47 +00:00
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
const variant& a8
);
adding support for 10 arg rpc calls
2014-11-10 23:29:05 +00:00
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
const variant& a8,
const variant& a9
);
future<variant> async_call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
const variant& a8,
const variant& a9,
const variant& a10
);
support for 8 param rpc calls
2014-07-04 21:23:47 +00:00
Add missing synchronous call overload to json_connection
2014-06-17 17:16:57 +00:00
template<typename Result>
Result call( const fc::string& method,
const variants& args,
microseconds timeout = microseconds::maximum())
{
return async_call( method, args ).wait(timeout).as<Result>();
}
Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3 ).wait(timeout).as<Result>();
}
- Add four-argument version of json-rpc call function - fix bug in json parser that prevented correct parsing of a true/false/null at the end of input - prevent infinite recursion in a json helper function
2014-04-21 18:34:46 +00:00
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3, a4).wait(timeout).as<Result>();
}
Add 5 and 6 argument versions of json rpc call functions
2014-05-29 19:54:13 +00:00
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3, a4, a5).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3, a4, a5, a6).wait(timeout).as<Result>();
}
adding support for 7 arg rpc calls
2014-06-07 02:46:28 +00:00
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
microseconds timeout = microseconds::maximum())
{
Add call() for 8-10 parameters, fix typo for 7 parameters
2014-12-02 16:25:32 +00:00
return async_call( method, a1, a2, a3, a4, a5, a6, a7).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
const variant& a8,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3, a4, a5, a6, a7, a8).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
const variant& a8,
const variant& a9,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3, a4, a5, a6, a7, a8, a9).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
const variant& a3,
const variant& a4,
const variant& a5,
const variant& a6,
const variant& a7,
const variant& a8,
const variant& a9,
const variant& a10,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2, a3, a4, a5, a6, a7, a8, a9, a10).wait(timeout).as<Result>();
adding support for 7 arg rpc calls
2014-06-07 02:46:28 +00:00
}
Add 5 and 6 argument versions of json rpc call functions
2014-05-29 19:54:13 +00:00
Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
const variant& a2,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1, a2 ).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
const variant& a1,
microseconds timeout = microseconds::maximum())
{
return async_call( method, a1 ).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
variant_object a1,
microseconds timeout = microseconds::maximum())
{
return async_call( method, fc::move(a1) ).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method,
mutable_variant_object a1,
microseconds timeout = microseconds::maximum())
{
return async_call( method, variant_object( fc::move(a1) ) ).wait(timeout).as<Result>();
}
template<typename Result>
Result call( const fc::string& method, microseconds timeout = microseconds::maximum() )
{
return async_call( method ).wait(timeout).as<Result>();
}
/// Sending in a variant_object will be issued as named parameters
variant call( const fc::string& method, const variant_object& named_args );
///@}
Merge pull request #21 from pmconrad/variant_fix Variant fix
2018-03-19 16:35:57 +00:00
protected:
const uint32_t _max_conversion_depth; // for nested structures, json, variant etc.
Updating FC with changes from phoenix-int
2013-06-05 19:19:00 +00:00
private:
std::unique_ptr<detail::json_connection_impl> my;
};
typedef std::shared_ptr<json_connection> json_connection_ptr;
}} // fc::rpc
Reference in a new issue Copy permalink