rpc: Allow submitting tx as hex blob over ZMQ

This commit is contained in:
Nathan Dorfman 2019-02-15 23:28:15 -07:00
parent 31bdf7bd11
commit be6f426a3f
4 changed files with 59 additions and 6 deletions

View file

@ -263,20 +263,43 @@ namespace rpc
void DaemonHandler::handle(const SendRawTx::Request& req, SendRawTx::Response& res) void DaemonHandler::handle(const SendRawTx::Request& req, SendRawTx::Response& res)
{ {
auto tx_blob = cryptonote::tx_to_blob(req.tx); handleTxBlob(cryptonote::tx_to_blob(req.tx), req.relay, res);
}
void DaemonHandler::handle(const SendRawTxHex::Request& req, SendRawTxHex::Response& res)
{
std::string tx_blob;
if(!epee::string_tools::parse_hexstr_to_binbuff(req.tx_as_hex, tx_blob))
{
MERROR("[SendRawTxHex]: Failed to parse tx from hexbuff: " << req.tx_as_hex);
res.status = Message::STATUS_FAILED;
res.error_details = "Invalid hex";
return;
}
handleTxBlob(tx_blob, req.relay, res);
}
void DaemonHandler::handleTxBlob(const std::string& tx_blob, bool relay, SendRawTx::Response& res)
{
if (!m_p2p.get_payload_object().is_synchronized())
{
res.status = Message::STATUS_FAILED;
res.error_details = "Not ready to accept transactions; try again later";
return;
}
cryptonote_connection_context fake_context = AUTO_VAL_INIT(fake_context); cryptonote_connection_context fake_context = AUTO_VAL_INIT(fake_context);
tx_verification_context tvc = AUTO_VAL_INIT(tvc); tx_verification_context tvc = AUTO_VAL_INIT(tvc);
if(!m_core.handle_incoming_tx(tx_blob, tvc, false, false, !req.relay) || tvc.m_verifivation_failed) if(!m_core.handle_incoming_tx(tx_blob, tvc, false, false, !relay) || tvc.m_verifivation_failed)
{ {
if (tvc.m_verifivation_failed) if (tvc.m_verifivation_failed)
{ {
LOG_PRINT_L0("[on_send_raw_tx]: tx verification failed"); MERROR("[SendRawTx]: tx verification failed");
} }
else else
{ {
LOG_PRINT_L0("[on_send_raw_tx]: Failed to process tx"); MERROR("[SendRawTx]: Failed to process tx");
} }
res.status = Message::STATUS_FAILED; res.status = Message::STATUS_FAILED;
res.error_details = ""; res.error_details = "";
@ -328,9 +351,9 @@ namespace rpc
return; return;
} }
if(!tvc.m_should_be_relayed || !req.relay) if(!tvc.m_should_be_relayed || !relay)
{ {
LOG_PRINT_L0("[on_send_raw_tx]: tx accepted, but not relayed"); MERROR("[SendRawTx]: tx accepted, but not relayed");
res.error_details = "Not relayed"; res.error_details = "Not relayed";
res.relayed = false; res.relayed = false;
res.status = Message::STATUS_OK; res.status = Message::STATUS_OK;
@ -830,6 +853,7 @@ namespace rpc
REQ_RESP_TYPES_MACRO(request_type, KeyImagesSpent, req_json, resp_message, handle); REQ_RESP_TYPES_MACRO(request_type, KeyImagesSpent, req_json, resp_message, handle);
REQ_RESP_TYPES_MACRO(request_type, GetTxGlobalOutputIndices, req_json, resp_message, handle); REQ_RESP_TYPES_MACRO(request_type, GetTxGlobalOutputIndices, req_json, resp_message, handle);
REQ_RESP_TYPES_MACRO(request_type, SendRawTx, req_json, resp_message, handle); REQ_RESP_TYPES_MACRO(request_type, SendRawTx, req_json, resp_message, handle);
REQ_RESP_TYPES_MACRO(request_type, SendRawTxHex, req_json, resp_message, handle);
REQ_RESP_TYPES_MACRO(request_type, GetInfo, req_json, resp_message, handle); REQ_RESP_TYPES_MACRO(request_type, GetInfo, req_json, resp_message, handle);
REQ_RESP_TYPES_MACRO(request_type, StartMining, req_json, resp_message, handle); REQ_RESP_TYPES_MACRO(request_type, StartMining, req_json, resp_message, handle);
REQ_RESP_TYPES_MACRO(request_type, StopMining, req_json, resp_message, handle); REQ_RESP_TYPES_MACRO(request_type, StopMining, req_json, resp_message, handle);

View file

@ -68,6 +68,8 @@ class DaemonHandler : public RpcHandler
void handle(const SendRawTx::Request& req, SendRawTx::Response& res); void handle(const SendRawTx::Request& req, SendRawTx::Response& res);
void handle(const SendRawTxHex::Request& req, SendRawTxHex::Response& res);
void handle(const StartMining::Request& req, StartMining::Response& res); void handle(const StartMining::Request& req, StartMining::Response& res);
void handle(const GetInfo::Request& req, GetInfo::Response& res); void handle(const GetInfo::Request& req, GetInfo::Response& res);
@ -136,6 +138,8 @@ class DaemonHandler : public RpcHandler
bool getBlockHeaderByHash(const crypto::hash& hash_in, cryptonote::rpc::BlockHeaderResponse& response); bool getBlockHeaderByHash(const crypto::hash& hash_in, cryptonote::rpc::BlockHeaderResponse& response);
void handleTxBlob(const std::string& tx_blob, bool relay, SendRawTx::Response& res);
cryptonote::core& m_core; cryptonote::core& m_core;
t_p2p& m_p2p; t_p2p& m_p2p;
}; };

View file

@ -42,6 +42,7 @@ const char* const GetTransactions::name = "get_transactions";
const char* const KeyImagesSpent::name = "key_images_spent"; const char* const KeyImagesSpent::name = "key_images_spent";
const char* const GetTxGlobalOutputIndices::name = "get_tx_global_output_indices"; const char* const GetTxGlobalOutputIndices::name = "get_tx_global_output_indices";
const char* const SendRawTx::name = "send_raw_tx"; const char* const SendRawTx::name = "send_raw_tx";
const char* const SendRawTxHex::name = "send_raw_tx_hex";
const char* const StartMining::name = "start_mining"; const char* const StartMining::name = "start_mining";
const char* const StopMining::name = "stop_mining"; const char* const StopMining::name = "stop_mining";
const char* const MiningStatus::name = "mining_status"; const char* const MiningStatus::name = "mining_status";
@ -292,6 +293,22 @@ void SendRawTx::Response::fromJson(rapidjson::Value& val)
GET_FROM_JSON_OBJECT(val, relayed, relayed); GET_FROM_JSON_OBJECT(val, relayed, relayed);
} }
rapidjson::Value SendRawTxHex::Request::toJson(rapidjson::Document& doc) const
{
auto val = Message::toJson(doc);
INSERT_INTO_JSON_OBJECT(val, doc, tx_as_hex, tx_as_hex);
INSERT_INTO_JSON_OBJECT(val, doc, relay, relay);
return val;
}
void SendRawTxHex::Request::fromJson(rapidjson::Value& val)
{
GET_FROM_JSON_OBJECT(val, tx_as_hex, tx_as_hex);
GET_FROM_JSON_OBJECT(val, relay, relay);
}
rapidjson::Value StartMining::Request::toJson(rapidjson::Document& doc) const rapidjson::Value StartMining::Request::toJson(rapidjson::Document& doc) const
{ {
auto val = Message::toJson(doc); auto val = Message::toJson(doc);

View file

@ -171,6 +171,14 @@ BEGIN_RPC_MESSAGE_CLASS(SendRawTx);
END_RPC_MESSAGE_RESPONSE; END_RPC_MESSAGE_RESPONSE;
END_RPC_MESSAGE_CLASS; END_RPC_MESSAGE_CLASS;
BEGIN_RPC_MESSAGE_CLASS(SendRawTxHex);
BEGIN_RPC_MESSAGE_REQUEST;
RPC_MESSAGE_MEMBER(std::string, tx_as_hex);
RPC_MESSAGE_MEMBER(bool, relay);
END_RPC_MESSAGE_REQUEST;
using Response = SendRawTx::Response;
END_RPC_MESSAGE_CLASS;
BEGIN_RPC_MESSAGE_CLASS(StartMining); BEGIN_RPC_MESSAGE_CLASS(StartMining);
BEGIN_RPC_MESSAGE_REQUEST; BEGIN_RPC_MESSAGE_REQUEST;
RPC_MESSAGE_MEMBER(std::string, miner_address); RPC_MESSAGE_MEMBER(std::string, miner_address);