Electroneum
http_server_handlers_map2.h File Reference
Include dependency graph for http_server_handlers_map2.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Macros

#define ELECTRONEUM_DEFAULT_LOG_CATEGORY   "net.http"
 
#define CHAIN_HTTP_TO_MAP2(context_type)
 
#define BEGIN_URI_MAP2()
 
#define MAP_URI2(pattern, callback)   else if(std::string::npos != query_info.m_URI.find(pattern)) return callback(query_info, response_info, &m_conn_context);
 
#define MAP_URI_AUTO_XML2(s_pattern, callback_f, command_type)
 
#define MAP_URI_AUTO_JON2_IF(s_pattern, callback_f, command_type, cond)
 
#define MAP_URI_AUTO_JON2(s_pattern, callback_f, command_type)   MAP_URI_AUTO_JON2_IF(s_pattern, callback_f, command_type, true)
 
#define MAP_URI_AUTO_BIN2(s_pattern, callback_f, command_type)
 
#define CHAIN_URI_MAP2(callback)   else {callback(query_info, response_info, m_conn_context);handled = true;}
 
#define END_URI_MAP2()   return handled;}
 
#define BEGIN_JSON_RPC_MAP(uri)
 
#define PREPARE_OBJECTS_FROM_JSON(command_type)
 
#define FINALIZE_OBJECTS_TO_JSON(method_name)
 
#define MAP_JON_RPC_WE_IF(method_name, callback_f, command_type, cond)
 
#define MAP_JON_RPC_WE(method_name, callback_f, command_type)   MAP_JON_RPC_WE_IF(method_name, callback_f, command_type, true)
 
#define MAP_JON_RPC_WERI(method_name, callback_f, command_type)
 
#define MAP_JON_RPC(method_name, callback_f, command_type)
 
#define END_JSON_RPC_MAP()
 

Macro Definition Documentation

◆ BEGIN_JSON_RPC_MAP

#define BEGIN_JSON_RPC_MAP (   uri)
Value:
else if(query_info.m_URI == uri) \
{ \
uint64_t ticks = epee::misc_utils::get_tick_count(); \
epee::serialization::portable_storage ps; \
if(!ps.load_from_json(query_info.m_body)) \
{ \
boost::value_initialized<epee::json_rpc::error_response> rsp; \
static_cast<epee::json_rpc::error_response&>(rsp).jsonrpc = "2.0"; \
static_cast<epee::json_rpc::error_response&>(rsp).error.code = -32700; \
static_cast<epee::json_rpc::error_response&>(rsp).error.message = "Parse error"; \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(rsp), response_info.m_body); \
return true; \
} \
ps.get_value("id", id_, nullptr); \
std::string callback_name; \
if(!ps.get_value("method", callback_name, nullptr)) \
{ \
rsp.jsonrpc = "2.0"; \
rsp.error.code = -32600; \
rsp.error.message = "Invalid Request"; \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(rsp), response_info.m_body); \
return true; \
} \
if(false) return true;
uint64_t get_tick_count()
::std::string string
Definition: gtest-port.h:1097
boost::variant< uint64_t, uint32_t, uint16_t, uint8_t, int64_t, int32_t, int16_t, int8_t, double, bool, std::string, section, array_entry > storage_entry
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
return true
error
Tracks LMDB error codes.
Definition: error.h:44
response< dummy_result, error > error_response

Definition at line 120 of file http_server_handlers_map2.h.

◆ BEGIN_URI_MAP2

#define BEGIN_URI_MAP2 ( )
Value:
template<class t_context> bool handle_http_request_map(const epee::net_utils::http::http_request_info& query_info, \
t_context& m_conn_context) { \
bool handled = false; \
if(false) return true;
return true

Definition at line 51 of file http_server_handlers_map2.h.

◆ CHAIN_HTTP_TO_MAP2

#define CHAIN_HTTP_TO_MAP2 (   context_type)
Value:
bool handle_http_request(const epee::net_utils::http::http_request_info& query_info, \
context_type& m_conn_context) \
{\
MINFO("HTTP [" << m_conn_context.m_remote_address.host_str() << "] " << query_info.m_http_method_str << " " << query_info.m_URI); \
response.m_response_code = 200; \
response.m_response_comment = "Ok"; \
if(!handle_http_request_map(query_info, response, m_conn_context)) \
{response.m_response_code = 404;response.m_response_comment = "Not found";} \
return true; \
}
epee::misc_utils::struct_init< response_t > response

Definition at line 38 of file http_server_handlers_map2.h.

◆ CHAIN_URI_MAP2

#define CHAIN_URI_MAP2 (   callback)    else {callback(query_info, response_info, m_conn_context);handled = true;}

Definition at line 115 of file http_server_handlers_map2.h.

◆ ELECTRONEUM_DEFAULT_LOG_CATEGORY

#define ELECTRONEUM_DEFAULT_LOG_CATEGORY   "net.http"

Definition at line 35 of file http_server_handlers_map2.h.

◆ END_JSON_RPC_MAP

#define END_JSON_RPC_MAP ( )
Value:
rsp.id = id_; \
rsp.jsonrpc = "2.0"; \
rsp.error.code = -32601; \
rsp.error.message = "Method not found"; \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(rsp), response_info.m_body); \
return true; \
}
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
epee::serialization::storage_entry id

Definition at line 232 of file http_server_handlers_map2.h.

◆ END_URI_MAP2

#define END_URI_MAP2 ( )    return handled;}

Definition at line 117 of file http_server_handlers_map2.h.

◆ FINALIZE_OBJECTS_TO_JSON

#define FINALIZE_OBJECTS_TO_JSON (   method_name)
Value:
epee::serialization::store_t_to_json(resp, response_info.m_body); \
uint64_t ticks3 = epee::misc_utils::get_tick_count(); \
response_info.m_mime_tipe = "application/json"; \
response_info.m_header_info.m_content_type = " application/json"; \
MDEBUG( query_info.m_URI << "[" << method_name << "] processed with " << ticks1-ticks << "/"<< ticks2-ticks1 << "/" << ticks3-ticks2 << "ms");
uint64_t get_tick_count()
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
unsigned __int64 uint64_t
Definition: stdint.h:136

Definition at line 169 of file http_server_handlers_map2.h.

◆ MAP_JON_RPC

#define MAP_JON_RPC (   method_name,
  callback_f,
  command_type 
)
Value:
else if(callback_name == method_name) \
{ \
PREPARE_OBJECTS_FROM_JSON(command_type) \
MINFO(m_conn_context << "calling RPC method " << method_name); \
if(!callback_f(req.params, resp.result, &m_conn_context)) \
{ \
fail_resp.jsonrpc = "2.0"; \
fail_resp.id = req.id; \
fail_resp.error.code = -32603; \
fail_resp.error.message = "Internal error"; \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(fail_resp), response_info.m_body); \
return true; \
} \
FINALIZE_OBJECTS_TO_JSON(method_name) \
return true;\
}
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
#define AUTO_VAL_INIT(v)
Definition: misc_language.h:53
response< dummy_result, error > error_response

Definition at line 213 of file http_server_handlers_map2.h.

◆ MAP_JON_RPC_WE

#define MAP_JON_RPC_WE (   method_name,
  callback_f,
  command_type 
)    MAP_JON_RPC_WE_IF(method_name, callback_f, command_type, true)

Definition at line 194 of file http_server_handlers_map2.h.

◆ MAP_JON_RPC_WE_IF

#define MAP_JON_RPC_WE_IF (   method_name,
  callback_f,
  command_type,
  cond 
)
Value:
else if((callback_name == method_name) && (cond)) \
{ \
PREPARE_OBJECTS_FROM_JSON(command_type) \
fail_resp.jsonrpc = "2.0"; \
fail_resp.id = req.id; \
MINFO(m_conn_context << "Calling RPC method " << method_name); \
if(!callback_f(req.params, resp.result, fail_resp.error, &m_conn_context)) \
{ \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(fail_resp), response_info.m_body); \
return true; \
} \
FINALIZE_OBJECTS_TO_JSON(method_name) \
return true;\
}
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
#define AUTO_VAL_INIT(v)
Definition: misc_language.h:53
response< dummy_result, error > error_response

Definition at line 177 of file http_server_handlers_map2.h.

◆ MAP_JON_RPC_WERI

#define MAP_JON_RPC_WERI (   method_name,
  callback_f,
  command_type 
)
Value:
else if(callback_name == method_name) \
{ \
PREPARE_OBJECTS_FROM_JSON(command_type) \
fail_resp.jsonrpc = "2.0"; \
fail_resp.id = req.id; \
MINFO(m_conn_context << "calling RPC method " << method_name); \
if(!callback_f(req.params, resp.result, fail_resp.error, response_info, &m_conn_context)) \
{ \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(fail_resp), response_info.m_body); \
return true; \
} \
FINALIZE_OBJECTS_TO_JSON(method_name) \
return true;\
}
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
#define AUTO_VAL_INIT(v)
Definition: misc_language.h:53
response< dummy_result, error > error_response

Definition at line 196 of file http_server_handlers_map2.h.

◆ MAP_URI2

#define MAP_URI2 (   pattern,
  callback 
)    else if(std::string::npos != query_info.m_URI.find(pattern)) return callback(query_info, response_info, &m_conn_context);

Definition at line 57 of file http_server_handlers_map2.h.

◆ MAP_URI_AUTO_BIN2

#define MAP_URI_AUTO_BIN2 (   s_pattern,
  callback_f,
  command_type 
)
Value:
else if(query_info.m_URI == s_pattern) \
{ \
handled = true; \
uint64_t ticks = misc_utils::get_tick_count(); \
boost::value_initialized<command_type::request> req; \
bool parse_res = epee::serialization::load_t_from_binary(static_cast<command_type::request&>(req), epee::strspan<uint8_t>(query_info.m_body)); \
CHECK_AND_ASSERT_MES(parse_res, false, "Failed to parse bin body data, body size=" << query_info.m_body.size()); \
uint64_t ticks1 = misc_utils::get_tick_count(); \
boost::value_initialized<command_type::response> resp;\
MINFO(m_conn_context << "calling " << s_pattern); \
if(!callback_f(static_cast<command_type::request&>(req), static_cast<command_type::response&>(resp), &m_conn_context)) \
{ \
LOG_ERROR("Failed to " << #callback_f << "()"); \
response_info.m_response_code = 500; \
response_info.m_response_comment = "Internal Server Error"; \
return true; \
} \
uint64_t ticks2 = misc_utils::get_tick_count(); \
epee::serialization::store_t_to_binary(static_cast<command_type::response&>(resp), response_info.m_body); \
uint64_t ticks3 = epee::misc_utils::get_tick_count(); \
response_info.m_mime_tipe = " application/octet-stream"; \
response_info.m_header_info.m_content_type = " application/octet-stream"; \
MDEBUG( s_pattern << "() processed with " << ticks1-ticks << "/"<< ticks2-ticks1 << "/" << ticks3-ticks2 << "ms"); \
}
bool store_t_to_binary(t_struct &str_in, std::string &binary_buff, size_t indent=0)
uint64_t get_tick_count()
bool load_t_from_binary(t_struct &out, const epee::span< const uint8_t > binary_buff)

Definition at line 89 of file http_server_handlers_map2.h.

◆ MAP_URI_AUTO_JON2

#define MAP_URI_AUTO_JON2 (   s_pattern,
  callback_f,
  command_type 
)    MAP_URI_AUTO_JON2_IF(s_pattern, callback_f, command_type, true)

Definition at line 87 of file http_server_handlers_map2.h.

◆ MAP_URI_AUTO_JON2_IF

#define MAP_URI_AUTO_JON2_IF (   s_pattern,
  callback_f,
  command_type,
  cond 
)
Value:
else if((query_info.m_URI == s_pattern) && (cond)) \
{ \
handled = true; \
uint64_t ticks = misc_utils::get_tick_count(); \
boost::value_initialized<command_type::request> req; \
bool parse_res = epee::serialization::load_t_from_json(static_cast<command_type::request&>(req), query_info.m_body); \
CHECK_AND_ASSERT_MES(parse_res, false, "Failed to parse json: \r\n" << query_info.m_body); \
uint64_t ticks1 = epee::misc_utils::get_tick_count(); \
boost::value_initialized<command_type::response> resp;\
MINFO(m_conn_context << "calling " << s_pattern); \
if(!callback_f(static_cast<command_type::request&>(req), static_cast<command_type::response&>(resp), &m_conn_context)) \
{ \
LOG_ERROR("Failed to " << #callback_f << "()"); \
response_info.m_response_code = 500; \
response_info.m_response_comment = "Internal Server Error"; \
return true; \
} \
uint64_t ticks2 = epee::misc_utils::get_tick_count(); \
epee::serialization::store_t_to_json(static_cast<command_type::response&>(resp), response_info.m_body); \
uint64_t ticks3 = epee::misc_utils::get_tick_count(); \
response_info.m_mime_tipe = "application/json"; \
response_info.m_header_info.m_content_type = " application/json"; \
MDEBUG( s_pattern << " processed with " << ticks1-ticks << "/"<< ticks2-ticks1 << "/" << ticks3-ticks2 << "ms"); \
}
uint64_t get_tick_count()
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
bool load_t_from_json(t_struct &out, const std::string &json_buff)

Definition at line 61 of file http_server_handlers_map2.h.

◆ MAP_URI_AUTO_XML2

#define MAP_URI_AUTO_XML2 (   s_pattern,
  callback_f,
  command_type 
)

Definition at line 59 of file http_server_handlers_map2.h.

◆ PREPARE_OBJECTS_FROM_JSON

#define PREPARE_OBJECTS_FROM_JSON (   command_type)
Value:
handled = true; \
boost::value_initialized<epee::json_rpc::request<command_type::request> > req_; \
epee::json_rpc::request<command_type::request>& req = static_cast<epee::json_rpc::request<command_type::request>&>(req_);\
if(!req.load(ps)) \
{ \
fail_resp.jsonrpc = "2.0"; \
fail_resp.id = req.id; \
fail_resp.error.code = -32602; \
fail_resp.error.message = "Invalid params"; \
epee::serialization::store_t_to_json(static_cast<epee::json_rpc::error_response&>(fail_resp), response_info.m_body); \
return true; \
} \
uint64_t ticks1 = epee::misc_utils::get_tick_count(); \
boost::value_initialized<epee::json_rpc::response<command_type::response, epee::json_rpc::dummy_error> > resp_; \
epee::json_rpc::response<command_type::response, epee::json_rpc::dummy_error>& resp = static_cast<epee::json_rpc::response<command_type::response, epee::json_rpc::dummy_error> &>(resp_); \
resp.jsonrpc = "2.0"; \
resp.id = req.id;
uint64_t get_tick_count()
bool store_t_to_json(t_struct &str_in, std::string &json_buff, size_t indent=0, bool insert_newlines=true)
#define AUTO_VAL_INIT(v)
Definition: misc_language.h:53
response< dummy_result, error > error_response

Definition at line 149 of file http_server_handlers_map2.h.