mirror of
https://github.com/AntelopeIO/spring.git
synced 2026-07-21 14:43:30 +00:00
Kevin Heifner
63 lines
2.3 KiB
C++
63 lines
2.3 KiB
C++
#include <eosio/test_control_api_plugin/test_control_api_plugin.hpp>
|
|
#include <eosio/chain/exceptions.hpp>
|
|
|
|
#include <fc/io/json.hpp>
|
|
|
|
namespace eosio {
|
|
|
|
static auto _test_control_api_plugin = application::register_plugin<test_control_api_plugin>();
|
|
|
|
using namespace eosio;
|
|
|
|
class test_control_api_plugin_impl {
|
|
public:
|
|
explicit test_control_api_plugin_impl(controller& db)
|
|
: db(db) {}
|
|
|
|
controller& db;
|
|
};
|
|
|
|
|
|
test_control_api_plugin::test_control_api_plugin() = default;
|
|
test_control_api_plugin::~test_control_api_plugin() = default;
|
|
|
|
void test_control_api_plugin::set_program_options(options_description&, options_description&) {}
|
|
void test_control_api_plugin::plugin_initialize(const variables_map&) {}
|
|
|
|
#define CALL_WITH_API_400(api_name, api_handle, api_namespace, call_name, http_response_code, params_type) \
|
|
{std::string("/v1/" #api_name "/" #call_name), \
|
|
api_category::test_control, \
|
|
[api_handle](string&&, string&& body, url_response_callback&& cb) mutable { \
|
|
try { \
|
|
auto params = parse_params<api_namespace::call_name ## _params, params_type>(body);\
|
|
fc::variant result( api_handle.call_name( std::move(params) ) ); \
|
|
cb(http_response_code, std::move(result)); \
|
|
} catch (...) { \
|
|
http_plugin::handle_exception(#api_name, #call_name, body, cb); \
|
|
} \
|
|
}}
|
|
|
|
#define TEST_CONTROL_RW_CALL(call_name, http_response_code, params_type) CALL_WITH_API_400(test_control, rw_api, test_control_apis::read_write, call_name, http_response_code, params_type)
|
|
|
|
void test_control_api_plugin::plugin_startup() {
|
|
my.reset(new test_control_api_plugin_impl(app().get_plugin<chain_plugin>().chain()));
|
|
auto rw_api = app().get_plugin<test_control_plugin>().get_read_write_api();
|
|
|
|
app().get_plugin<http_plugin>().add_api({
|
|
TEST_CONTROL_RW_CALL(kill_node_on_producer, 202, http_params_types::params_required)
|
|
}, appbase::exec_queue::read_write);
|
|
|
|
app().get_plugin<http_plugin>().add_api({
|
|
TEST_CONTROL_RW_CALL(throw_on, 202, http_params_types::params_required)
|
|
}, appbase::exec_queue::read_write);
|
|
|
|
app().get_plugin<http_plugin>().add_api({
|
|
TEST_CONTROL_RW_CALL(swap_action, 202, http_params_types::params_required)
|
|
}, appbase::exec_queue::read_write);
|
|
|
|
}
|
|
|
|
void test_control_api_plugin::plugin_shutdown() {}
|
|
|
|
}
|