producer_api_plugin.cpp

Go to the documentation of this file.

#include <sysio/producer_api_plugin/producer_api_plugin.hpp>
#include <sysio/chain/exceptions.hpp>
 
#include <fc/variant.hpp>
#include <fc/io/json.hpp>
 
#include <chrono>
 
namespace sysio { namespace detail {
  struct producer_api_plugin_response {
     std::string result;
  };
}}
 
FC_REFLECT(sysio::detail::producer_api_plugin_response, (result));
 
namespace sysio {
 
static appbase::abstract_plugin& _producer_api_plugin = app().register_plugin<producer_api_plugin>();
 
using namespace sysio;
 
struct async_result_visitor : public fc::visitor<fc::variant> {
   template<typename T>
   fc::variant operator()(const T& v) const {
      return fc::variant(v);
   }
};
 
#define CALL_WITH_400(api_name, api_handle, call_name, INVOKE, http_response_code) \
{std::string("/v1/" #api_name "/" #call_name), \
   [&api_handle](string, string body, url_response_callback cb) mutable { \
          try { \
             INVOKE \
             cb(http_response_code, fc::variant(result)); \
          } catch (...) { \
             http_plugin::handle_exception(#api_name, #call_name, body, cb); \
          } \
       }}
 
#define CALL_ASYNC(api_name, api_handle, call_name, call_result, INVOKE, http_response_code) \
{std::string("/v1/" #api_name "/" #call_name), \
   [&api_handle](string, string body, url_response_callback cb) mutable { \
      if (body.empty()) body = "{}"; \
      auto next = [cb, body](const std::variant<fc::exception_ptr, call_result>& result){\
         if (std::holds_alternative<fc::exception_ptr>(result)) {\
            try {\
               std::get<fc::exception_ptr>(result)->dynamic_rethrow_exception();\
            } catch (...) {\
               http_plugin::handle_exception(#api_name, #call_name, body, cb);\
            }\
         } else {\
            cb(http_response_code, std::visit(async_result_visitor(), result));\
         }\
      };\
      INVOKE\
   }\
}
 
#define INVOKE_R_R(api_handle, call_name, in_param) \
     auto params = parse_params<in_param, http_params_types::params_required>(body);\
     auto result = api_handle.call_name(std::move(params));
 
#define INVOKE_R_R_II(api_handle, call_name, in_param) \
     auto params = parse_params<in_param, http_params_types::possible_no_params>(body);\
     auto result = api_handle.call_name(std::move(params));
 
#define INVOKE_R_V(api_handle, call_name) \
     body = parse_params<std::string, http_params_types::no_params>(body); \
     auto result = api_handle.call_name();
 
#define INVOKE_R_V_ASYNC(api_handle, call_name)\
     api_handle.call_name(next);
 
#define INVOKE_V_R(api_handle, call_name, in_param) \
     auto params = parse_params<in_param, http_params_types::params_required>(body);\
     api_handle.call_name(std::move(params)); \
     sysio::detail::producer_api_plugin_response result{"ok"};
 
#define INVOKE_V_V(api_handle, call_name) \
     body = parse_params<std::string, http_params_types::no_params>(body); \
     api_handle.call_name(); \
     sysio::detail::producer_api_plugin_response result{"ok"};
 
 
void producer_api_plugin::plugin_startup() {
   ilog("starting producer_api_plugin");
   // lifetime of plugin is lifetime of application
   auto& producer = app().get_plugin<producer_plugin>();
 
   app().get_plugin<http_plugin>().add_api({
       CALL_WITH_400(producer, producer, pause,
            INVOKE_V_V(producer, pause), 201),
       CALL_WITH_400(producer, producer, resume,
            INVOKE_V_V(producer, resume), 201),
       CALL_WITH_400(producer, producer, paused,
            INVOKE_R_V(producer, paused), 201),
       CALL_WITH_400(producer, producer, get_runtime_options,
            INVOKE_R_V(producer, get_runtime_options), 201),
       CALL_WITH_400(producer, producer, update_runtime_options,
            INVOKE_V_R(producer, update_runtime_options, producer_plugin::runtime_options), 201),
       CALL_WITH_400(producer, producer, add_greylist_accounts,
            INVOKE_V_R(producer, add_greylist_accounts, producer_plugin::greylist_params), 201),
       CALL_WITH_400(producer, producer, remove_greylist_accounts,
            INVOKE_V_R(producer, remove_greylist_accounts, producer_plugin::greylist_params), 201),
       CALL_WITH_400(producer, producer, get_greylist,
            INVOKE_R_V(producer, get_greylist), 201),
       CALL_WITH_400(producer, producer, get_whitelist_blacklist,
            INVOKE_R_V(producer, get_whitelist_blacklist), 201),
       CALL_WITH_400(producer, producer, set_whitelist_blacklist,
            INVOKE_V_R(producer, set_whitelist_blacklist, producer_plugin::whitelist_blacklist), 201),
       CALL_WITH_400(producer, producer, get_integrity_hash,
            INVOKE_R_V(producer, get_integrity_hash), 201),
       CALL_ASYNC(producer, producer, create_snapshot, producer_plugin::snapshot_information,
            INVOKE_R_V_ASYNC(producer, create_snapshot), 201),
       CALL_WITH_400(producer, producer, get_scheduled_protocol_feature_activations,
            INVOKE_R_V(producer, get_scheduled_protocol_feature_activations), 201),
       CALL_WITH_400(producer, producer, schedule_protocol_feature_activations,
            INVOKE_V_R(producer, schedule_protocol_feature_activations, producer_plugin::scheduled_protocol_feature_activations), 201),
       CALL_WITH_400(producer, producer, get_supported_protocol_features,
            INVOKE_R_R_II(producer, get_supported_protocol_features,
                                 producer_plugin::get_supported_protocol_features_params), 201),
       CALL_WITH_400(producer, producer, get_account_ram_corrections,
            INVOKE_R_R(producer, get_account_ram_corrections, producer_plugin::get_account_ram_corrections_params), 201),
   }, appbase::priority::medium_high);
}
 
void producer_api_plugin::plugin_initialize(const variables_map& options) {
   try {
      const auto& _http_plugin = app().get_plugin<http_plugin>();
      if( !_http_plugin.is_on_loopback()) {
         wlog( "\n"
               "**********SECURITY WARNING**********\n"
               "*                                  *\n"
               "* --        Producer API        -- *\n"
               "* - EXPOSED to the LOCAL NETWORK - *\n"
               "* - USE ONLY ON SECURE NETWORKS! - *\n"
               "*                                  *\n"
               "************************************\n" );
 
      }
   } FC_LOG_AND_RETHROW()
}
 
 
#undef INVOKE_R_R
#undef INVOKE_R_V
#undef INVOKE_V_R
#undef INVOKE_V_V
#undef CALL
 
}