2024-02-05 19:22:15 +00:00
|
|
|
/*
|
|
|
|
* This file is part of the Monero P2Pool <https://github.com/SChernykh/p2pool>
|
|
|
|
* Copyright (c) 2021-2024 SChernykh <https://github.com/SChernykh>
|
|
|
|
*
|
|
|
|
* This program is free software: you can redistribute it and/or modify
|
|
|
|
* it under the terms of the GNU General Public License as published by
|
|
|
|
* the Free Software Foundation, version 3.
|
|
|
|
*
|
|
|
|
* This program is distributed in the hope that it will be useful, but
|
|
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
|
|
* General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU General Public License
|
|
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
*/
|
|
|
|
|
|
|
|
#include "common.h"
|
|
|
|
#include "merge_mining_client.h"
|
|
|
|
#include "merge_mining_client_json_rpc.h"
|
|
|
|
#include "p2pool.h"
|
|
|
|
#include "params.h"
|
|
|
|
#include "json_rpc_request.h"
|
|
|
|
#include "json_parsers.h"
|
|
|
|
#include <rapidjson/document.h>
|
|
|
|
|
|
|
|
LOG_CATEGORY(MergeMiningClientJSON_RPC)
|
|
|
|
|
|
|
|
namespace p2pool {
|
|
|
|
|
|
|
|
MergeMiningClientJSON_RPC::MergeMiningClientJSON_RPC(p2pool* pool, const std::string& host, const std::string& wallet)
|
|
|
|
: m_host(host)
|
|
|
|
, m_port(80)
|
|
|
|
, m_auxWallet(wallet)
|
|
|
|
, m_ping(0.0)
|
|
|
|
, m_pool(pool)
|
|
|
|
, m_loop{}
|
|
|
|
, m_loopThread{}
|
|
|
|
, m_timer{}
|
|
|
|
, m_getJobRunning(false)
|
|
|
|
, m_shutdownAsync{}
|
|
|
|
{
|
|
|
|
const size_t k = host.find_last_of(':');
|
|
|
|
if (k != std::string::npos) {
|
|
|
|
m_host = host.substr(0, k);
|
|
|
|
m_port = std::stoul(host.substr(k + 1), nullptr, 10);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (m_host.empty() || (m_port == 0) || (m_port >= 65536)) {
|
|
|
|
LOGERR(1, "Invalid host " << host);
|
|
|
|
throw std::exception();
|
|
|
|
}
|
|
|
|
|
|
|
|
int err = uv_loop_init(&m_loop);
|
|
|
|
if (err) {
|
|
|
|
LOGERR(1, "failed to create event loop, error " << uv_err_name(err));
|
|
|
|
throw std::exception();
|
|
|
|
}
|
|
|
|
|
|
|
|
// Init loop user data before running it
|
|
|
|
GetLoopUserData(&m_loop);
|
|
|
|
|
|
|
|
err = uv_async_init(&m_loop, &m_shutdownAsync, on_shutdown);
|
|
|
|
if (err) {
|
|
|
|
LOGERR(1, "uv_async_init failed, error " << uv_err_name(err));
|
|
|
|
uv_loop_close(&m_loop);
|
|
|
|
throw std::exception();
|
|
|
|
}
|
|
|
|
m_shutdownAsync.data = this;
|
|
|
|
|
|
|
|
err = uv_timer_init(&m_loop, &m_timer);
|
|
|
|
if (err) {
|
|
|
|
LOGERR(1, "failed to create timer, error " << uv_err_name(err));
|
|
|
|
uv_loop_close(&m_loop);
|
|
|
|
throw std::exception();
|
|
|
|
}
|
|
|
|
m_timer.data = this;
|
|
|
|
|
|
|
|
uv_rwlock_init_checked(&m_lock);
|
|
|
|
|
|
|
|
err = uv_thread_create(&m_loopThread, loop, this);
|
|
|
|
if (err) {
|
|
|
|
LOGERR(1, "failed to start event loop thread, error " << uv_err_name(err));
|
|
|
|
uv_loop_close(&m_loop);
|
|
|
|
throw std::exception();
|
|
|
|
}
|
|
|
|
|
|
|
|
merge_mining_get_chain_id();
|
|
|
|
}
|
|
|
|
|
|
|
|
MergeMiningClientJSON_RPC::~MergeMiningClientJSON_RPC()
|
|
|
|
{
|
|
|
|
uv_async_send(&m_shutdownAsync);
|
|
|
|
uv_thread_join(&m_loopThread);
|
|
|
|
|
|
|
|
uv_rwlock_destroy(&m_lock);
|
|
|
|
|
|
|
|
LOGINFO(1, "stopped");
|
|
|
|
}
|
|
|
|
|
|
|
|
void MergeMiningClientJSON_RPC::on_timer()
|
|
|
|
{
|
|
|
|
MinerData data = m_pool->miner_data();
|
2024-05-16 16:10:04 +00:00
|
|
|
merge_mining_get_aux_block(data.height, data.prev_id, m_auxWallet);
|
2024-02-05 19:22:15 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void MergeMiningClientJSON_RPC::merge_mining_get_chain_id()
|
|
|
|
{
|
|
|
|
const std::string req = "{\"jsonrpc\":\"2.0\",\"id\":\"0\",\"method\":\"merge_mining_get_chain_id\"}";
|
|
|
|
|
|
|
|
JSONRPCRequest::call(m_host, m_port, req, std::string(), m_pool->params().m_socks5Proxy,
|
|
|
|
[this](const char* data, size_t size, double ping) {
|
|
|
|
WriteLock lock(m_lock);
|
|
|
|
|
|
|
|
if (parse_merge_mining_get_chain_id(data, size)) {
|
|
|
|
if (ping > 0.0) {
|
|
|
|
m_ping = ping;
|
|
|
|
}
|
|
|
|
|
|
|
|
LOGINFO(1, m_host << ':' << m_port << " uses chain_id " << log::LightCyan() << m_chainParams.aux_id);
|
|
|
|
LOGINFO(1, m_host << ':' << m_port << " ping is " << m_ping << " ms");
|
|
|
|
|
|
|
|
// Chain ID received successfully, we can start polling for new mining jobs now
|
|
|
|
const int err = uv_timer_start(&m_timer, on_timer, 0, 500);
|
|
|
|
if (err) {
|
|
|
|
LOGERR(1, "failed to start timer, error " << uv_err_name(err));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
},
|
|
|
|
[this](const char* data, size_t size, double) {
|
|
|
|
if (size > 0) {
|
|
|
|
LOGERR(1, "couldn't get merge mining id from " << m_host << ':' << m_port << ", error " << log::const_buf(data, size));
|
|
|
|
}
|
|
|
|
}, &m_loop);
|
|
|
|
}
|
|
|
|
|
|
|
|
bool MergeMiningClientJSON_RPC::parse_merge_mining_get_chain_id(const char* data, size_t size)
|
|
|
|
{
|
|
|
|
auto err = [this](const char* msg) {
|
|
|
|
LOGWARN(3, "merge_mining_get_chain_id RPC call failed: " << msg << ". Trying again in 1 second.");
|
|
|
|
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
|
|
|
|
merge_mining_get_chain_id();
|
|
|
|
return false;
|
|
|
|
};
|
|
|
|
|
|
|
|
rapidjson::Document doc;
|
|
|
|
|
|
|
|
if (doc.Parse(data, size).HasParseError() || !doc.IsObject()) {
|
|
|
|
return err("parsing failed");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (doc.HasMember("error")) {
|
|
|
|
return err(doc["error"].IsString() ? doc["error"].GetString() : "an unknown error occurred");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!doc.HasMember("result")) {
|
|
|
|
return err("\"result\" field not found");
|
|
|
|
}
|
|
|
|
|
|
|
|
const auto& result = doc["result"];
|
|
|
|
|
|
|
|
if (!result.IsObject() || !result.HasMember("chain_id")) {
|
|
|
|
return err("couldn't parse result");
|
|
|
|
}
|
|
|
|
|
|
|
|
const auto& chain_id = result["chain_id"];
|
|
|
|
|
|
|
|
if (!chain_id.IsString() || !from_hex(chain_id.GetString(), chain_id.GetStringLength(), m_chainParams.aux_id)) {
|
|
|
|
return err("invalid chain_id");
|
|
|
|
}
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2024-05-16 16:10:04 +00:00
|
|
|
void MergeMiningClientJSON_RPC::merge_mining_get_aux_block(uint64_t height, const hash& prev_id, const std::string& wallet)
|
2024-02-05 19:22:15 +00:00
|
|
|
{
|
|
|
|
if (m_getJobRunning) {
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
m_getJobRunning = true;
|
|
|
|
|
|
|
|
char buf[log::Stream::BUF_SIZE + 1];
|
|
|
|
// cppcheck-suppress uninitvar
|
|
|
|
log::Stream s(buf);
|
|
|
|
|
|
|
|
hash aux_hash;
|
|
|
|
{
|
|
|
|
ReadLock lock(m_lock);
|
|
|
|
aux_hash = m_chainParams.aux_hash;
|
|
|
|
}
|
|
|
|
|
2024-05-16 16:10:04 +00:00
|
|
|
s << "{\"jsonrpc\":\"2.0\",\"id\":\"0\",\"method\":\"merge_mining_get_aux_block\",\"params\":{"
|
2024-02-05 19:22:15 +00:00
|
|
|
<< "\"address\":\"" << wallet << '"'
|
|
|
|
<< ",\"aux_hash\":\"" << aux_hash << '"'
|
|
|
|
<< ",\"height\":" << height
|
|
|
|
<< ",\"prev_id\":\"" << prev_id << '"'
|
|
|
|
<< "}}";
|
|
|
|
|
|
|
|
JSONRPCRequest::call(m_host, m_port, std::string(buf, s.m_pos), std::string(), m_pool->params().m_socks5Proxy,
|
|
|
|
[this](const char* data, size_t size, double) {
|
|
|
|
bool changed = false;
|
|
|
|
hash chain_id;
|
|
|
|
|
|
|
|
{
|
|
|
|
WriteLock lock(m_lock);
|
2024-05-16 16:10:04 +00:00
|
|
|
if (parse_merge_mining_get_aux_block(data, size, changed)) {
|
2024-02-05 19:22:15 +00:00
|
|
|
chain_id = m_chainParams.aux_id;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (changed && !chain_id.empty()) {
|
|
|
|
m_pool->update_aux_data(chain_id);
|
|
|
|
}
|
|
|
|
},
|
|
|
|
[this](const char* data, size_t size, double) {
|
|
|
|
if (size > 0) {
|
|
|
|
LOGERR(3, "couldn't get merge mining job from " << m_host << ':' << m_port << ", error " << log::const_buf(data, size));
|
|
|
|
}
|
|
|
|
m_getJobRunning = false;
|
|
|
|
}, &m_loop);
|
|
|
|
}
|
|
|
|
|
2024-05-16 16:10:04 +00:00
|
|
|
bool MergeMiningClientJSON_RPC::parse_merge_mining_get_aux_block(const char* data, size_t size, bool& changed)
|
2024-02-05 19:22:15 +00:00
|
|
|
{
|
|
|
|
auto err = [](const char* msg) {
|
2024-05-16 16:10:04 +00:00
|
|
|
LOGWARN(3, "merge_mining_get_aux_block RPC call failed: " << msg);
|
2024-02-05 19:22:15 +00:00
|
|
|
return false;
|
|
|
|
};
|
|
|
|
|
|
|
|
rapidjson::Document doc;
|
|
|
|
|
|
|
|
if (doc.Parse(data, size).HasParseError() || !doc.IsObject()) {
|
|
|
|
return err("parsing failed");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (doc.HasMember("error")) {
|
|
|
|
return err(doc["error"].IsString() ? doc["error"].GetString() : "an unknown error occurred");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!doc.HasMember("result")) {
|
|
|
|
return err("\"result\" field not found");
|
|
|
|
}
|
|
|
|
|
|
|
|
const auto& result = doc["result"];
|
|
|
|
|
|
|
|
if (!result.IsObject()) {
|
|
|
|
return err("couldn't parse result");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!result.HasMember("aux_hash")) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
const auto& aux_hash = result["aux_hash"];
|
|
|
|
|
|
|
|
hash h;
|
|
|
|
if (!aux_hash.IsString() || !from_hex(aux_hash.GetString(), aux_hash.GetStringLength(), h)) {
|
|
|
|
return err("invalid aux_hash");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (h == m_chainParams.aux_hash) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
std::vector<uint8_t> aux_blob;
|
|
|
|
|
|
|
|
if (!result.HasMember("aux_blob") || !result["aux_blob"].IsString() || !from_hex(result["aux_blob"].GetString(), result["aux_blob"].GetStringLength(), aux_blob)) {
|
|
|
|
return err("invalid aux_blob");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!result.HasMember("aux_diff") || !result["aux_diff"].IsUint64()) {
|
|
|
|
return err("invalid aux_diff");
|
|
|
|
}
|
|
|
|
|
|
|
|
m_chainParams.aux_blob = std::move(aux_blob);
|
|
|
|
m_chainParams.aux_hash = h;
|
|
|
|
m_chainParams.aux_diff.lo = result["aux_diff"].GetUint64();
|
|
|
|
m_chainParams.aux_diff.hi = 0;
|
|
|
|
|
|
|
|
changed = true;
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2024-05-10 14:53:47 +00:00
|
|
|
void MergeMiningClientJSON_RPC::submit_solution(const BlockTemplate* /*block_tpl*/, const uint8_t (&/*hashing_blob*/)[128], size_t /*nonce_offset*/, const hash& /*seed_hash*/, const std::vector<uint8_t>& blob, const std::vector<hash>& merkle_proof, uint32_t merkle_proof_path)
|
2024-02-05 19:22:15 +00:00
|
|
|
{
|
|
|
|
ReadLock lock(m_lock);
|
|
|
|
|
|
|
|
std::vector<char> buf((m_chainParams.aux_blob.size() + HASH_SIZE + blob.size()) * 2 + merkle_proof.size() * (HASH_SIZE * 2 + 3) + 256);
|
|
|
|
log::Stream s(buf.data(), buf.size());
|
|
|
|
|
|
|
|
s << "{\"jsonrpc\":\"2.0\",\"id\":\"0\",\"method\":\"merge_mining_submit_solution\",\"params\":{"
|
|
|
|
<< "\"aux_blob\":\"" << log::hex_buf(m_chainParams.aux_blob.data(), m_chainParams.aux_blob.size()) << '"'
|
|
|
|
<< ",\"aux_hash\":\"" << m_chainParams.aux_hash << '"'
|
|
|
|
<< ",\"blob\":\"" << log::hex_buf(blob.data(), blob.size()) << '"'
|
|
|
|
<< ",\"merkle_proof\":[";
|
|
|
|
|
|
|
|
for (size_t i = 0, n = merkle_proof.size(); i < n; ++i) {
|
|
|
|
if (i > 0) {
|
|
|
|
s << ',';
|
|
|
|
}
|
|
|
|
s << '"' << merkle_proof[i] << '"';
|
|
|
|
}
|
|
|
|
|
2024-05-10 14:53:47 +00:00
|
|
|
s << "],\"path\":" << merkle_proof_path << "}}";
|
2024-02-05 19:22:15 +00:00
|
|
|
|
|
|
|
JSONRPCRequest::call(m_host, m_port, std::string(buf.data(), s.m_pos), std::string(), m_pool->params().m_socks5Proxy,
|
|
|
|
[this](const char* data, size_t size, double) {
|
|
|
|
parse_merge_mining_submit_solution(data, size);
|
|
|
|
},
|
|
|
|
[this](const char* data, size_t size, double) {
|
|
|
|
if (size > 0) {
|
|
|
|
LOGERR(3, "couldn't submit merge mining solution to " << m_host << ':' << m_port << ", error " << log::const_buf(data, size));
|
|
|
|
}
|
|
|
|
}, &m_loop);
|
|
|
|
}
|
|
|
|
|
|
|
|
bool MergeMiningClientJSON_RPC::get_params(ChainParameters& out_params) const
|
|
|
|
{
|
|
|
|
ReadLock lock(m_lock);
|
|
|
|
|
|
|
|
if (m_chainParams.aux_id.empty() || m_chainParams.aux_diff.empty()) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
out_params = m_chainParams;
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool MergeMiningClientJSON_RPC::parse_merge_mining_submit_solution(const char* data, size_t size)
|
|
|
|
{
|
|
|
|
auto err = [this](const char* msg) {
|
|
|
|
LOGWARN(3, "merge_mining_submit_solution to " << m_host << ':' << m_port << " failed: " << msg);
|
|
|
|
return false;
|
|
|
|
};
|
|
|
|
|
|
|
|
rapidjson::Document doc;
|
|
|
|
|
|
|
|
if (doc.Parse(data, size).HasParseError() || !doc.IsObject()) {
|
|
|
|
return err("parsing failed");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (doc.HasMember("error")) {
|
|
|
|
return err(doc["error"].IsString() ? doc["error"].GetString() : "an unknown error occurred");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!doc.HasMember("result")) {
|
|
|
|
return err("\"result\" field not found");
|
|
|
|
}
|
|
|
|
|
|
|
|
const auto& result = doc["result"];
|
|
|
|
|
|
|
|
if (!result.IsObject()) {
|
|
|
|
return err("couldn't parse result");
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!result.HasMember("status") || !result["status"].IsString()) {
|
|
|
|
return err("invalid status");
|
|
|
|
}
|
|
|
|
|
|
|
|
const char* status = result["status"].GetString();
|
|
|
|
LOGINFO(0, log::LightGreen() << "merge_mining_submit_solution to " << m_host << ':' << m_port << ": " << status);
|
|
|
|
|
|
|
|
// Get new mining job
|
|
|
|
on_timer();
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
void MergeMiningClientJSON_RPC::loop(void* data)
|
|
|
|
{
|
|
|
|
LOGINFO(1, "event loop started");
|
|
|
|
|
|
|
|
MergeMiningClientJSON_RPC* client = static_cast<MergeMiningClientJSON_RPC*>(data);
|
|
|
|
|
|
|
|
int err = uv_run(&client->m_loop, UV_RUN_DEFAULT);
|
|
|
|
if (err) {
|
|
|
|
LOGWARN(1, "uv_run returned " << err);
|
|
|
|
}
|
|
|
|
|
|
|
|
err = uv_loop_close(&client->m_loop);
|
|
|
|
if (err) {
|
|
|
|
LOGWARN(1, "uv_loop_close returned error " << uv_err_name(err));
|
|
|
|
}
|
|
|
|
|
|
|
|
LOGINFO(1, "event loop stopped");
|
|
|
|
}
|
|
|
|
|
|
|
|
void MergeMiningClientJSON_RPC::on_shutdown()
|
|
|
|
{
|
|
|
|
uv_timer_stop(&m_timer);
|
|
|
|
uv_close(reinterpret_cast<uv_handle_t*>(&m_timer), nullptr);
|
|
|
|
}
|
|
|
|
|
|
|
|
} // namespace p2pool
|