mirror of
https://codeberg.org/nahuhh/wownero
synced 2026-03-05 14:17:35 -05:00
85db1734e7
There are quite a few variables in the code that are no longer (or perhaps never were) in use. These were discovered by enabling compiler warnings for unused variables and cleaning them up. In most cases where the unused variables were the result of a function call the call was left but the variable assignment removed, unless it was obvious that it was a simple getter with no side effects.
2547 lines
82 KiB
C++
2547 lines
82 KiB
C++
// Copyright (c) 2014-2020, The Monero Project
|
|
//
|
|
// All rights reserved.
|
|
//
|
|
// Redistribution and use in source and binary forms, with or without modification, are
|
|
// permitted provided that the following conditions are met:
|
|
//
|
|
// 1. Redistributions of source code must retain the above copyright notice, this list of
|
|
// conditions and the following disclaimer.
|
|
//
|
|
// 2. Redistributions in binary form must reproduce the above copyright notice, this list
|
|
// of conditions and the following disclaimer in the documentation and/or other
|
|
// materials provided with the distribution.
|
|
//
|
|
// 3. Neither the name of the copyright holder nor the names of its contributors may be
|
|
// used to endorse or promote products derived from this software without specific
|
|
// prior written permission.
|
|
//
|
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
|
|
// EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
|
// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
|
|
// THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
|
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
|
|
// STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
|
|
// THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
//
|
|
// Parts of this file are originally copyright (c) 2012-2013 The Cryptonote developers
|
|
|
|
#include "string_tools.h"
|
|
#include "common/password.h"
|
|
#include "common/scoped_message_writer.h"
|
|
#include "common/pruning.h"
|
|
#include "daemon/rpc_command_executor.h"
|
|
#include "rpc/core_rpc_server_commands_defs.h"
|
|
#include "cryptonote_core/cryptonote_core.h"
|
|
#include "cryptonote_basic/difficulty.h"
|
|
#include "cryptonote_basic/hardfork.h"
|
|
#include "rpc/rpc_payment_signature.h"
|
|
#include "rpc/rpc_version_str.h"
|
|
#include <boost/format.hpp>
|
|
#include <ctime>
|
|
#include <string>
|
|
|
|
#undef MONERO_DEFAULT_LOG_CATEGORY
|
|
#define MONERO_DEFAULT_LOG_CATEGORY "daemon"
|
|
|
|
namespace daemonize {
|
|
|
|
namespace {
|
|
const char *get_address_type_name(epee::net_utils::address_type address_type)
|
|
{
|
|
switch (address_type)
|
|
{
|
|
default:
|
|
case epee::net_utils::address_type::invalid: return "invalid";
|
|
case epee::net_utils::address_type::ipv4: return "IPv4";
|
|
case epee::net_utils::address_type::ipv6: return "IPv6";
|
|
case epee::net_utils::address_type::i2p: return "I2P";
|
|
case epee::net_utils::address_type::tor: return "Tor";
|
|
}
|
|
}
|
|
|
|
std::string print_float(float f, int prec)
|
|
{
|
|
char buf[16];
|
|
snprintf(buf, sizeof(buf), "%*.*f", prec, prec, f);
|
|
return buf;
|
|
}
|
|
|
|
void print_peer(std::string const & prefix, cryptonote::peer const & peer, bool pruned_only, bool publicrpc_only)
|
|
{
|
|
if (pruned_only && peer.pruning_seed == 0)
|
|
return;
|
|
if (publicrpc_only && peer.rpc_port == 0)
|
|
return;
|
|
|
|
time_t now;
|
|
time(&now);
|
|
time_t last_seen = static_cast<time_t>(peer.last_seen);
|
|
|
|
std::string elapsed = peer.last_seen == 0 ? "never" : epee::misc_utils::get_time_interval_string(now - last_seen);
|
|
std::string id_str = epee::string_tools::pad_string(epee::string_tools::to_string_hex(peer.id), 16, '0', true);
|
|
std::string port_str;
|
|
epee::string_tools::xtype_to_string(peer.port, port_str);
|
|
std::string addr_str = peer.host + ":" + port_str;
|
|
std::string rpc_port = peer.rpc_port ? std::to_string(peer.rpc_port) : "-";
|
|
std::string rpc_credits_per_hash = peer.rpc_credits_per_hash ? print_float(peer.rpc_credits_per_hash / RPC_CREDITS_PER_HASH_SCALE, 2) : "-";
|
|
std::string pruning_seed = epee::string_tools::to_string_hex(peer.pruning_seed);
|
|
tools::msg_writer() << boost::format("%-10s %-25s %-25s %-5s %-5s %-4s %s") % prefix % id_str % addr_str % rpc_port % rpc_credits_per_hash % pruning_seed % elapsed;
|
|
}
|
|
|
|
void print_block_header(cryptonote::block_header_response const & header)
|
|
{
|
|
tools::success_msg_writer()
|
|
<< "timestamp: " << boost::lexical_cast<std::string>(header.timestamp) << " (" << tools::get_human_readable_timestamp(header.timestamp) << ")" << std::endl
|
|
<< "previous hash: " << header.prev_hash << std::endl
|
|
<< "nonce: " << boost::lexical_cast<std::string>(header.nonce) << std::endl
|
|
<< "is orphan: " << header.orphan_status << std::endl
|
|
<< "height: " << boost::lexical_cast<std::string>(header.height) << std::endl
|
|
<< "depth: " << boost::lexical_cast<std::string>(header.depth) << std::endl
|
|
<< "hash: " << header.hash << std::endl
|
|
<< "difficulty: " << cryptonote::difficulty_type(header.wide_difficulty) << std::endl
|
|
<< "cumulative difficulty: " << cryptonote::difficulty_type(header.wide_cumulative_difficulty) << std::endl
|
|
<< "POW hash: " << header.pow_hash << std::endl
|
|
<< "block size: " << header.block_size << std::endl
|
|
<< "block weight: " << header.block_weight << std::endl
|
|
<< "long term weight: " << header.long_term_weight << std::endl
|
|
<< "num txes: " << header.num_txes << std::endl
|
|
<< "reward: " << cryptonote::print_money(header.reward) << std::endl
|
|
<< "miner tx hash: " << header.miner_tx_hash;
|
|
}
|
|
|
|
std::string get_human_time_ago(time_t t, time_t now)
|
|
{
|
|
if (t == now)
|
|
return "now";
|
|
time_t dt = t > now ? t - now : now - t;
|
|
std::string s;
|
|
if (dt < 90)
|
|
s = boost::lexical_cast<std::string>(dt) + " seconds";
|
|
else if (dt < 90 * 60)
|
|
s = boost::lexical_cast<std::string>(dt/60) + " minutes";
|
|
else if (dt < 36 * 3600)
|
|
s = boost::lexical_cast<std::string>(dt/3600) + " hours";
|
|
else
|
|
s = boost::lexical_cast<std::string>(dt/(3600*24)) + " days";
|
|
return s + " " + (t > now ? "in the future" : "ago");
|
|
}
|
|
|
|
std::string get_time_hms(time_t t)
|
|
{
|
|
unsigned int hours, minutes, seconds;
|
|
char buffer[24];
|
|
hours = t / 3600;
|
|
t %= 3600;
|
|
minutes = t / 60;
|
|
t %= 60;
|
|
seconds = t;
|
|
snprintf(buffer, sizeof(buffer), "%02u:%02u:%02u", hours, minutes, seconds);
|
|
return std::string(buffer);
|
|
}
|
|
|
|
std::string make_error(const std::string &base, const std::string &status)
|
|
{
|
|
if (status == CORE_RPC_STATUS_OK)
|
|
return base;
|
|
return base + " -- " + status;
|
|
}
|
|
}
|
|
|
|
t_rpc_command_executor::t_rpc_command_executor(
|
|
uint32_t ip
|
|
, uint16_t port
|
|
, const boost::optional<tools::login>& login
|
|
, const epee::net_utils::ssl_options_t& ssl_options
|
|
, bool is_rpc
|
|
, cryptonote::core_rpc_server* rpc_server
|
|
)
|
|
: m_rpc_client(NULL), m_rpc_server(rpc_server)
|
|
{
|
|
if (is_rpc)
|
|
{
|
|
boost::optional<epee::net_utils::http::login> http_login{};
|
|
if (login)
|
|
http_login.emplace(login->username, login->password.password());
|
|
m_rpc_client = new tools::t_rpc_client(ip, port, std::move(http_login), ssl_options);
|
|
}
|
|
else
|
|
{
|
|
if (rpc_server == NULL)
|
|
{
|
|
throw std::runtime_error("If not calling commands via RPC, rpc_server pointer must be non-null");
|
|
}
|
|
}
|
|
|
|
m_is_rpc = is_rpc;
|
|
}
|
|
|
|
t_rpc_command_executor::~t_rpc_command_executor()
|
|
{
|
|
if (m_rpc_client != NULL)
|
|
{
|
|
delete m_rpc_client;
|
|
}
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_peer_list(bool white, bool gray, size_t limit, bool pruned_only, bool publicrpc_only) {
|
|
cryptonote::COMMAND_RPC_GET_PEER_LIST::request req;
|
|
cryptonote::COMMAND_RPC_GET_PEER_LIST::response res;
|
|
|
|
std::string failure_message = "Couldn't retrieve peer list";
|
|
|
|
req.include_blocked = true;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_peer_list", failure_message.c_str()))
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_peer_list(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << failure_message;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if (white)
|
|
{
|
|
auto peer = res.white_list.cbegin();
|
|
const auto end = limit ? peer + std::min(limit, res.white_list.size()) : res.white_list.cend();
|
|
for (; peer != end; ++peer)
|
|
{
|
|
print_peer("white", *peer, pruned_only, publicrpc_only);
|
|
}
|
|
}
|
|
|
|
if (gray)
|
|
{
|
|
auto peer = res.gray_list.cbegin();
|
|
const auto end = limit ? peer + std::min(limit, res.gray_list.size()) : res.gray_list.cend();
|
|
for (; peer != end; ++peer)
|
|
{
|
|
print_peer("gray", *peer, pruned_only, publicrpc_only);
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_peer_list_stats() {
|
|
cryptonote::COMMAND_RPC_GET_PEER_LIST::request req;
|
|
cryptonote::COMMAND_RPC_GET_PEER_LIST::response res;
|
|
|
|
std::string failure_message = "Couldn't retrieve peer list";
|
|
|
|
req.public_only = false;
|
|
req.include_blocked = true;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_peer_list", failure_message.c_str()))
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_peer_list(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << failure_message;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer()
|
|
<< "White list size: " << res.white_list.size() << "/" << P2P_LOCAL_WHITE_PEERLIST_LIMIT << " (" << res.white_list.size() * 100.0 / P2P_LOCAL_WHITE_PEERLIST_LIMIT << "%)" << std::endl
|
|
<< "Gray list size: " << res.gray_list.size() << "/" << P2P_LOCAL_GRAY_PEERLIST_LIMIT << " (" << res.gray_list.size() * 100.0 / P2P_LOCAL_GRAY_PEERLIST_LIMIT << "%)";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::save_blockchain() {
|
|
cryptonote::COMMAND_RPC_SAVE_BC::request req;
|
|
cryptonote::COMMAND_RPC_SAVE_BC::response res;
|
|
|
|
std::string fail_message = "Couldn't save blockchain";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/save_bc", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_save_bc(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Blockchain saved";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::show_hash_rate() {
|
|
cryptonote::COMMAND_RPC_SET_LOG_HASH_RATE::request req;
|
|
cryptonote::COMMAND_RPC_SET_LOG_HASH_RATE::response res;
|
|
req.visible = true;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/set_log_hash_rate", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_log_hash_rate(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Hash rate logging is on";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::hide_hash_rate() {
|
|
cryptonote::COMMAND_RPC_SET_LOG_HASH_RATE::request req;
|
|
cryptonote::COMMAND_RPC_SET_LOG_HASH_RATE::response res;
|
|
req.visible = false;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/set_log_hash_rate", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_log_hash_rate(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Hash rate logging is off";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::show_difficulty() {
|
|
cryptonote::COMMAND_RPC_GET_INFO::request req;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response res;
|
|
|
|
std::string fail_message = "Problem fetching info";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/getinfo", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_info(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message.c_str(), res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "BH: " << res.height
|
|
<< ", TH: " << res.top_block_hash
|
|
<< ", DIFF: " << cryptonote::difficulty_type(res.wide_difficulty)
|
|
<< ", CUM_DIFF: " << cryptonote::difficulty_type(res.wide_cumulative_difficulty)
|
|
<< ", HR: " << cryptonote::difficulty_type(res.wide_difficulty) / res.target << " H/s";
|
|
|
|
return true;
|
|
}
|
|
|
|
static void get_metric_prefix(cryptonote::difficulty_type hr, double& hr_d, char& prefix)
|
|
{
|
|
if (hr < 1000)
|
|
{
|
|
prefix = 0;
|
|
return;
|
|
}
|
|
static const char metric_prefixes[] = { 'k', 'M', 'G', 'T', 'P', 'E', 'Z', 'Y' };
|
|
for (size_t i = 0; i < sizeof(metric_prefixes); ++i)
|
|
{
|
|
if (hr < 1000000)
|
|
{
|
|
hr_d = hr.convert_to<double>() / 1000;
|
|
prefix = metric_prefixes[i];
|
|
return;
|
|
}
|
|
hr /= 1000;
|
|
}
|
|
prefix = 0;
|
|
}
|
|
|
|
static std::string get_mining_speed(cryptonote::difficulty_type hr)
|
|
{
|
|
double hr_d;
|
|
char prefix;
|
|
get_metric_prefix(hr, hr_d, prefix);
|
|
if (prefix == 0) return (boost::format("%.0f H/s") % hr).str();
|
|
return (boost::format("%.2f %cH/s") % hr_d % prefix).str();
|
|
}
|
|
|
|
static std::string get_fork_extra_info(uint64_t t, uint64_t now, uint64_t block_time)
|
|
{
|
|
uint64_t blocks_per_day = 86400 / block_time;
|
|
|
|
if (t == now)
|
|
return " (forking now)";
|
|
|
|
if (t > now)
|
|
{
|
|
uint64_t dblocks = t - now;
|
|
if (dblocks <= 30)
|
|
return (boost::format(" (next fork in %u blocks)") % (unsigned)dblocks).str();
|
|
if (dblocks <= blocks_per_day / 2)
|
|
return (boost::format(" (next fork in %.1f hours)") % (dblocks / (float)(blocks_per_day / 24))).str();
|
|
if (dblocks <= blocks_per_day * 30)
|
|
return (boost::format(" (next fork in %.1f days)") % (dblocks / (float)blocks_per_day)).str();
|
|
return "";
|
|
}
|
|
return "";
|
|
}
|
|
|
|
static float get_sync_percentage(uint64_t height, uint64_t target_height)
|
|
{
|
|
target_height = target_height ? target_height < height ? height : target_height : height;
|
|
float pc = 100.0f * height / target_height;
|
|
if (height < target_height && pc > 99.9f)
|
|
return 99.9f; // to avoid 100% when not fully synced
|
|
return pc;
|
|
}
|
|
static float get_sync_percentage(const cryptonote::COMMAND_RPC_GET_INFO::response &ires)
|
|
{
|
|
return get_sync_percentage(ires.height, ires.target_height);
|
|
}
|
|
|
|
bool t_rpc_command_executor::show_status() {
|
|
cryptonote::COMMAND_RPC_GET_INFO::request ireq;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response ires;
|
|
cryptonote::COMMAND_RPC_HARD_FORK_INFO::request hfreq;
|
|
cryptonote::COMMAND_RPC_HARD_FORK_INFO::response hfres;
|
|
cryptonote::COMMAND_RPC_MINING_STATUS::request mreq;
|
|
cryptonote::COMMAND_RPC_MINING_STATUS::response mres;
|
|
epee::json_rpc::error error_resp;
|
|
bool has_mining_info = true;
|
|
|
|
std::string fail_message = "Problem fetching info";
|
|
|
|
hfreq.version = 0;
|
|
bool mining_busy = false;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(ireq, ires, "/getinfo", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
if (!m_rpc_client->json_rpc_request(hfreq, hfres, "hard_fork_info", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
// mining info is only available non unrestricted RPC mode
|
|
has_mining_info = m_rpc_client->rpc_request(mreq, mres, "/mining_status", fail_message.c_str());
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_info(ireq, ires) || ires.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, ires.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_hard_fork_info(hfreq, hfres, error_resp) || hfres.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, hfres.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_mining_status(mreq, mres))
|
|
{
|
|
tools::fail_msg_writer() << fail_message.c_str();
|
|
return true;
|
|
}
|
|
|
|
if (mres.status == CORE_RPC_STATUS_BUSY)
|
|
{
|
|
mining_busy = true;
|
|
}
|
|
else if (mres.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, mres.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
std::time_t uptime = std::time(nullptr) - ires.start_time;
|
|
uint64_t net_height = ires.target_height > ires.height ? ires.target_height : ires.height;
|
|
std::string bootstrap_msg;
|
|
if (ires.was_bootstrap_ever_used)
|
|
{
|
|
bootstrap_msg = ", bootstrapping from " + ires.bootstrap_daemon_address;
|
|
if (ires.untrusted)
|
|
{
|
|
bootstrap_msg += (boost::format(", local height: %llu (%.1f%%)") % ires.height_without_bootstrap % get_sync_percentage(ires.height_without_bootstrap, net_height)).str();
|
|
}
|
|
else
|
|
{
|
|
bootstrap_msg += " was used before";
|
|
}
|
|
}
|
|
|
|
std::stringstream str;
|
|
str << boost::format("Height: %llu/%llu (%.1f%%) on %s%s, %s, net hash %s, v%u%s, %u(out)+%u(in) connections")
|
|
% (unsigned long long)ires.height
|
|
% (unsigned long long)net_height
|
|
% get_sync_percentage(ires)
|
|
% (ires.testnet ? "testnet" : ires.stagenet ? "stagenet" : "mainnet")
|
|
% bootstrap_msg
|
|
% (!has_mining_info ? "mining info unavailable" : mining_busy ? "syncing" : mres.active ? ( ( mres.is_background_mining_enabled ? "smart " : "" ) + std::string("mining at ") + get_mining_speed(mres.speed)) : "not mining")
|
|
% get_mining_speed(cryptonote::difficulty_type(ires.wide_difficulty) / ires.target)
|
|
% (unsigned)hfres.version
|
|
% get_fork_extra_info(hfres.earliest_height, net_height, ires.target)
|
|
% (unsigned)ires.outgoing_connections_count
|
|
% (unsigned)ires.incoming_connections_count
|
|
;
|
|
|
|
// restricted RPC does not disclose start time
|
|
if (ires.start_time)
|
|
{
|
|
str << boost::format(", uptime %ud %uh %um %us")
|
|
% (unsigned int)floor(uptime / 60.0 / 60.0 / 24.0)
|
|
% (unsigned int)floor(fmod((uptime / 60.0 / 60.0), 24.0))
|
|
% (unsigned int)floor(fmod((uptime / 60.0), 60.0))
|
|
% (unsigned int)fmod(uptime, 60.0)
|
|
;
|
|
}
|
|
|
|
tools::success_msg_writer() << str.str();
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::mining_status() {
|
|
cryptonote::COMMAND_RPC_MINING_STATUS::request mreq;
|
|
cryptonote::COMMAND_RPC_MINING_STATUS::response mres;
|
|
epee::json_rpc::error error_resp;
|
|
bool has_mining_info = true;
|
|
|
|
std::string fail_message = "Problem fetching info";
|
|
|
|
bool mining_busy = false;
|
|
if (m_is_rpc)
|
|
{
|
|
// mining info is only available non unrestricted RPC mode
|
|
has_mining_info = m_rpc_client->rpc_request(mreq, mres, "/mining_status", fail_message.c_str());
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_mining_status(mreq, mres))
|
|
{
|
|
tools::fail_msg_writer() << fail_message.c_str();
|
|
return true;
|
|
}
|
|
|
|
if (mres.status == CORE_RPC_STATUS_BUSY)
|
|
{
|
|
mining_busy = true;
|
|
}
|
|
else if (mres.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, mres.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (!has_mining_info)
|
|
{
|
|
tools::fail_msg_writer() << "Mining info unavailable";
|
|
return true;
|
|
}
|
|
|
|
if (mining_busy || !mres.active)
|
|
{
|
|
tools::msg_writer() << "Not currently mining";
|
|
}
|
|
else
|
|
{
|
|
tools::msg_writer() << "Mining at " << get_mining_speed(mres.speed) << " with " << mres.threads_count << " threads";
|
|
}
|
|
|
|
tools::msg_writer() << "PoW algorithm: " << mres.pow_algorithm;
|
|
if (mres.active || mres.is_background_mining_enabled)
|
|
{
|
|
tools::msg_writer() << "Mining address: " << mres.address;
|
|
}
|
|
|
|
if (mres.is_background_mining_enabled)
|
|
{
|
|
tools::msg_writer() << "Smart mining enabled:";
|
|
tools::msg_writer() << " Target: " << (unsigned)mres.bg_target << "% CPU";
|
|
tools::msg_writer() << " Idle threshold: " << (unsigned)mres.bg_idle_threshold << "% CPU";
|
|
tools::msg_writer() << " Min idle time: " << (unsigned)mres.bg_min_idle_seconds << " seconds";
|
|
tools::msg_writer() << " Ignore battery: " << (mres.bg_ignore_battery ? "yes" : "no");
|
|
}
|
|
|
|
if (!mining_busy && mres.active && mres.speed > 0 && mres.block_target > 0 && mres.difficulty > 0)
|
|
{
|
|
double ratio = mres.speed * mres.block_target / (double)mres.difficulty;
|
|
uint64_t daily = 86400ull / mres.block_target * mres.block_reward * ratio;
|
|
uint64_t monthly = 86400ull / mres.block_target * 30.5 * mres.block_reward * ratio;
|
|
uint64_t yearly = 86400ull / mres.block_target * 356 * mres.block_reward * ratio;
|
|
tools::msg_writer() << "Expected: " << cryptonote::print_money(daily) << " monero daily, "
|
|
<< cryptonote::print_money(monthly) << " monero monthly, " << cryptonote::print_money(yearly) << " yearly";
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_connections() {
|
|
cryptonote::COMMAND_RPC_GET_CONNECTIONS::request req;
|
|
cryptonote::COMMAND_RPC_GET_CONNECTIONS::response res;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "get_connections", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_connections(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << std::setw(30) << std::left << "Remote Host"
|
|
<< std::setw(8) << "Type"
|
|
<< std::setw(6) << "SSL"
|
|
<< std::setw(20) << "Peer id"
|
|
<< std::setw(20) << "Support Flags"
|
|
<< std::setw(30) << "Recv/Sent (inactive,sec)"
|
|
<< std::setw(25) << "State"
|
|
<< std::setw(20) << "Livetime(sec)"
|
|
<< std::setw(12) << "Down (kB/s)"
|
|
<< std::setw(14) << "Down(now)"
|
|
<< std::setw(10) << "Up (kB/s)"
|
|
<< std::setw(13) << "Up(now)"
|
|
<< std::endl;
|
|
|
|
for (auto & info : res.connections)
|
|
{
|
|
std::string address = info.incoming ? "INC " : "OUT ";
|
|
address += info.ip + ":" + info.port;
|
|
//std::string in_out = info.incoming ? "INC " : "OUT ";
|
|
tools::msg_writer()
|
|
//<< std::setw(30) << std::left << in_out
|
|
<< std::setw(30) << std::left << address
|
|
<< std::setw(8) << (get_address_type_name((epee::net_utils::address_type)info.address_type))
|
|
<< std::setw(6) << (info.ssl ? "yes" : "no")
|
|
<< std::setw(20) << info.peer_id
|
|
<< std::setw(20) << info.support_flags
|
|
<< std::setw(30) << std::to_string(info.recv_count) + "(" + std::to_string(info.recv_idle_time) + ")/" + std::to_string(info.send_count) + "(" + std::to_string(info.send_idle_time) + ")"
|
|
<< std::setw(25) << info.state
|
|
<< std::setw(20) << info.live_time
|
|
<< std::setw(12) << info.avg_download
|
|
<< std::setw(14) << info.current_download
|
|
<< std::setw(10) << info.avg_upload
|
|
<< std::setw(13) << info.current_upload
|
|
|
|
<< std::left << (info.localhost ? "[LOCALHOST]" : "")
|
|
<< std::left << (info.local_ip ? "[LAN]" : "");
|
|
//tools::msg_writer() << boost::format("%-25s peer_id: %-25s %s") % address % info.peer_id % in_out;
|
|
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_net_stats()
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_NET_STATS::request net_stats_req;
|
|
cryptonote::COMMAND_RPC_GET_NET_STATS::response net_stats_res;
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::request limit_req;
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::response limit_res;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(net_stats_req, net_stats_res, "/get_net_stats", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
if (!m_rpc_client->rpc_request(limit_req, limit_res, "/get_limit", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_net_stats(net_stats_req, net_stats_res) || net_stats_res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, net_stats_res.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_get_limit(limit_req, limit_res) || limit_res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, limit_res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
uint64_t seconds = (uint64_t)time(NULL) - net_stats_res.start_time;
|
|
uint64_t average = seconds > 0 ? net_stats_res.total_bytes_in / seconds : 0;
|
|
uint64_t limit = limit_res.limit_down * 1024; // convert to bytes, as limits are always kB/s
|
|
double percent = (double)average / (double)limit * 100.0;
|
|
tools::success_msg_writer() << boost::format("Received %u bytes (%s) in %u packets in %s, average %s/s = %.2f%% of the limit of %s/s")
|
|
% net_stats_res.total_bytes_in
|
|
% tools::get_human_readable_bytes(net_stats_res.total_bytes_in)
|
|
% net_stats_res.total_packets_in
|
|
% tools::get_human_readable_timespan(seconds)
|
|
% tools::get_human_readable_bytes(average)
|
|
% percent
|
|
% tools::get_human_readable_bytes(limit);
|
|
|
|
average = seconds > 0 ? net_stats_res.total_bytes_out / seconds : 0;
|
|
limit = limit_res.limit_up * 1024;
|
|
percent = (double)average / (double)limit * 100.0;
|
|
tools::success_msg_writer() << boost::format("Sent %u bytes (%s) in %u packets in %s, average %s/s = %.2f%% of the limit of %s/s")
|
|
% net_stats_res.total_bytes_out
|
|
% tools::get_human_readable_bytes(net_stats_res.total_bytes_out)
|
|
% net_stats_res.total_packets_out
|
|
% tools::get_human_readable_timespan(seconds)
|
|
% tools::get_human_readable_bytes(average)
|
|
% percent
|
|
% tools::get_human_readable_bytes(limit);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_blockchain_info(int64_t start_block_index, uint64_t end_block_index) {
|
|
cryptonote::COMMAND_RPC_GET_BLOCK_HEADERS_RANGE::request req;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK_HEADERS_RANGE::response res;
|
|
epee::json_rpc::error error_resp;
|
|
std::string fail_message = "Problem fetching info";
|
|
|
|
// negative: relative to the end
|
|
if (start_block_index < 0)
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_INFO::request ireq;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response ires;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(ireq, ires, "/getinfo", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_info(ireq, ires) || ires.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, ires.status);
|
|
return true;
|
|
}
|
|
}
|
|
if (start_block_index < 0 && (uint64_t)-start_block_index >= ires.height)
|
|
{
|
|
tools::fail_msg_writer() << "start offset is larger than blockchain height";
|
|
return true;
|
|
}
|
|
start_block_index = ires.height + start_block_index;
|
|
end_block_index = start_block_index + end_block_index - 1;
|
|
}
|
|
|
|
req.start_height = start_block_index;
|
|
req.end_height = end_block_index;
|
|
req.fill_pow_hash = false;
|
|
|
|
fail_message = "Failed calling getblockheadersrange";
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "getblockheadersrange", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_block_headers_range(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
bool first = true;
|
|
for (auto & header : res.headers)
|
|
{
|
|
if (!first)
|
|
tools::msg_writer() << "" << std::endl;
|
|
tools::msg_writer()
|
|
<< "height: " << header.height << ", timestamp: " << header.timestamp << " (" << tools::get_human_readable_timestamp(header.timestamp) << ")"
|
|
<< ", size: " << header.block_size << ", weight: " << header.block_weight << " (long term " << header.long_term_weight << "), transactions: " << header.num_txes << std::endl
|
|
<< "major version: " << (unsigned)header.major_version << ", minor version: " << (unsigned)header.minor_version << std::endl
|
|
<< "block id: " << header.hash << ", previous block id: " << header.prev_hash << std::endl
|
|
<< "difficulty: " << cryptonote::difficulty_type(header.wide_difficulty) << ", nonce " << header.nonce << ", reward " << cryptonote::print_money(header.reward) << std::endl;
|
|
first = false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::set_log_level(int8_t level) {
|
|
cryptonote::COMMAND_RPC_SET_LOG_LEVEL::request req;
|
|
cryptonote::COMMAND_RPC_SET_LOG_LEVEL::response res;
|
|
req.level = level;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/set_log_level", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_log_level(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Log level is now " << std::to_string(level);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::set_log_categories(const std::string &categories) {
|
|
cryptonote::COMMAND_RPC_SET_LOG_CATEGORIES::request req;
|
|
cryptonote::COMMAND_RPC_SET_LOG_CATEGORIES::response res;
|
|
req.categories = categories;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/set_log_categories", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_log_categories(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Log categories are now " << res.categories;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_height() {
|
|
cryptonote::COMMAND_RPC_GET_HEIGHT::request req;
|
|
cryptonote::COMMAND_RPC_GET_HEIGHT::response res;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/getheight", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_height(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << boost::lexical_cast<std::string>(res.height);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_block_by_hash(crypto::hash block_hash, bool include_hex) {
|
|
cryptonote::COMMAND_RPC_GET_BLOCK::request req;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK::response res;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.hash = epee::string_tools::pod_to_hex(block_hash);
|
|
req.fill_pow_hash = true;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "getblock", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_block(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (include_hex)
|
|
tools::success_msg_writer() << res.blob << std::endl;
|
|
print_block_header(res.block_header);
|
|
tools::success_msg_writer() << res.json << ENDL;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_block_by_height(uint64_t height, bool include_hex) {
|
|
cryptonote::COMMAND_RPC_GET_BLOCK::request req;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK::response res;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.height = height;
|
|
req.fill_pow_hash = true;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "getblock", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_block(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (include_hex)
|
|
tools::success_msg_writer() << res.blob << std::endl;
|
|
print_block_header(res.block_header);
|
|
tools::success_msg_writer() << res.json << ENDL;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_transaction(crypto::hash transaction_hash,
|
|
bool include_metadata,
|
|
bool include_hex,
|
|
bool include_json) {
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTIONS::request req;
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTIONS::response res;
|
|
|
|
std::string fail_message = "Problem fetching transaction";
|
|
|
|
req.txs_hashes.push_back(epee::string_tools::pod_to_hex(transaction_hash));
|
|
req.decode_as_json = false;
|
|
req.split = true;
|
|
req.prune = false;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/gettransactions", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_transactions(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (1 == res.txs.size() || 1 == res.txs_as_hex.size())
|
|
{
|
|
if (1 == res.txs.size())
|
|
{
|
|
// only available for new style answers
|
|
static const std::string empty_hash = epee::string_tools::pod_to_hex(crypto::cn_fast_hash("", 0));
|
|
// prunable_hash will equal empty_hash when nothing is prunable (mostly when the transaction is coinbase)
|
|
bool pruned = res.txs.front().prunable_as_hex.empty() && res.txs.front().prunable_hash != epee::string_tools::pod_to_hex(crypto::null_hash) && res.txs.front().prunable_hash != empty_hash;
|
|
if (res.txs.front().in_pool)
|
|
tools::success_msg_writer() << "Found in pool";
|
|
else
|
|
tools::success_msg_writer() << "Found in blockchain at height " << res.txs.front().block_height << (pruned ? " (pruned)" : "");
|
|
}
|
|
|
|
const std::string &as_hex = (1 == res.txs.size()) ? res.txs.front().as_hex : res.txs_as_hex.front();
|
|
const std::string &pruned_as_hex = (1 == res.txs.size()) ? res.txs.front().pruned_as_hex : "";
|
|
const std::string &prunable_as_hex = (1 == res.txs.size()) ? res.txs.front().prunable_as_hex : "";
|
|
// Print metadata if requested
|
|
if (include_metadata)
|
|
{
|
|
if (!res.txs.front().in_pool)
|
|
{
|
|
tools::msg_writer() << "Block timestamp: " << res.txs.front().block_timestamp << " (" << tools::get_human_readable_timestamp(res.txs.front().block_timestamp) << ")";
|
|
}
|
|
cryptonote::blobdata blob;
|
|
if (epee::string_tools::parse_hexstr_to_binbuff(pruned_as_hex + prunable_as_hex, blob))
|
|
{
|
|
cryptonote::transaction tx;
|
|
if (cryptonote::parse_and_validate_tx_from_blob(blob, tx))
|
|
{
|
|
tools::msg_writer() << "Size: " << blob.size();
|
|
tools::msg_writer() << "Weight: " << cryptonote::get_transaction_weight(tx);
|
|
}
|
|
else
|
|
tools::fail_msg_writer() << "Error parsing transaction blob";
|
|
}
|
|
else
|
|
tools::fail_msg_writer() << "Error parsing transaction from hex";
|
|
}
|
|
|
|
// Print raw hex if requested
|
|
if (include_hex)
|
|
{
|
|
if (!as_hex.empty())
|
|
{
|
|
tools::success_msg_writer() << as_hex << std::endl;
|
|
}
|
|
else
|
|
{
|
|
std::string output = pruned_as_hex + prunable_as_hex;
|
|
tools::success_msg_writer() << output << std::endl;
|
|
}
|
|
}
|
|
|
|
// Print json if requested
|
|
if (include_json)
|
|
{
|
|
cryptonote::transaction tx;
|
|
cryptonote::blobdata blob;
|
|
std::string source = as_hex.empty() ? pruned_as_hex + prunable_as_hex : as_hex;
|
|
bool pruned = !pruned_as_hex.empty() && prunable_as_hex.empty();
|
|
if (!string_tools::parse_hexstr_to_binbuff(source, blob))
|
|
{
|
|
tools::fail_msg_writer() << "Failed to parse tx to get json format";
|
|
}
|
|
else
|
|
{
|
|
bool ret;
|
|
if (pruned)
|
|
ret = cryptonote::parse_and_validate_tx_base_from_blob(blob, tx);
|
|
else
|
|
ret = cryptonote::parse_and_validate_tx_from_blob(blob, tx);
|
|
if (!ret)
|
|
{
|
|
tools::fail_msg_writer() << "Failed to parse tx blob to get json format";
|
|
}
|
|
else
|
|
{
|
|
tools::success_msg_writer() << cryptonote::obj_to_json_str(tx) << std::endl;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
else
|
|
{
|
|
tools::fail_msg_writer() << "Transaction wasn't found: " << transaction_hash << std::endl;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::is_key_image_spent(const crypto::key_image &ki) {
|
|
cryptonote::COMMAND_RPC_IS_KEY_IMAGE_SPENT::request req;
|
|
cryptonote::COMMAND_RPC_IS_KEY_IMAGE_SPENT::response res;
|
|
|
|
std::string fail_message = "Problem checking key image";
|
|
|
|
req.key_images.push_back(epee::string_tools::pod_to_hex(ki));
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/is_key_image_spent", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_is_key_image_spent(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (1 == res.spent_status.size())
|
|
{
|
|
// first as hex
|
|
tools::success_msg_writer() << ki << ": " << (res.spent_status.front() ? "spent" : "unspent") << (res.spent_status.front() == cryptonote::COMMAND_RPC_IS_KEY_IMAGE_SPENT::SPENT_IN_POOL ? " (in pool)" : "");
|
|
}
|
|
else
|
|
{
|
|
tools::fail_msg_writer() << "key image status could not be determined" << std::endl;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_transaction_pool_long() {
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL::request req;
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL::response res;
|
|
|
|
std::string fail_message = "Problem fetching transaction pool";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_transaction_pool", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_transaction_pool(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (res.transactions.empty() && res.spent_key_images.empty())
|
|
{
|
|
tools::msg_writer() << "Pool is empty" << std::endl;
|
|
}
|
|
if (! res.transactions.empty())
|
|
{
|
|
const time_t now = time(NULL);
|
|
tools::msg_writer() << "Transactions: ";
|
|
for (auto & tx_info : res.transactions)
|
|
{
|
|
tools::msg_writer() << "id: " << tx_info.id_hash << std::endl
|
|
<< tx_info.tx_json << std::endl
|
|
<< "blob_size: " << tx_info.blob_size << std::endl
|
|
<< "weight: " << tx_info.weight << std::endl
|
|
<< "fee: " << cryptonote::print_money(tx_info.fee) << std::endl
|
|
<< "fee/byte: " << cryptonote::print_money(tx_info.fee / (double)tx_info.weight) << std::endl
|
|
<< "receive_time: " << tx_info.receive_time << " (" << get_human_time_ago(tx_info.receive_time, now) << ")" << std::endl
|
|
<< "relayed: " << [&](const cryptonote::tx_info &tx_info)->std::string { if (!tx_info.relayed) return "no"; return boost::lexical_cast<std::string>(tx_info.last_relayed_time) + " (" + get_human_time_ago(tx_info.last_relayed_time, now) + ")"; } (tx_info) << std::endl
|
|
<< "do_not_relay: " << (tx_info.do_not_relay ? 'T' : 'F') << std::endl
|
|
<< "kept_by_block: " << (tx_info.kept_by_block ? 'T' : 'F') << std::endl
|
|
<< "double_spend_seen: " << (tx_info.double_spend_seen ? 'T' : 'F') << std::endl
|
|
<< "max_used_block_height: " << tx_info.max_used_block_height << std::endl
|
|
<< "max_used_block_id: " << tx_info.max_used_block_id_hash << std::endl
|
|
<< "last_failed_height: " << tx_info.last_failed_height << std::endl
|
|
<< "last_failed_id: " << tx_info.last_failed_id_hash << std::endl;
|
|
}
|
|
if (res.spent_key_images.empty())
|
|
{
|
|
tools::msg_writer() << "WARNING: Inconsistent pool state - no spent key images";
|
|
}
|
|
}
|
|
if (! res.spent_key_images.empty())
|
|
{
|
|
tools::msg_writer() << ""; // one newline
|
|
tools::msg_writer() << "Spent key images: ";
|
|
for (const cryptonote::spent_key_image_info& kinfo : res.spent_key_images)
|
|
{
|
|
tools::msg_writer() << "key image: " << kinfo.id_hash;
|
|
if (kinfo.txs_hashes.size() == 1)
|
|
{
|
|
tools::msg_writer() << " tx: " << kinfo.txs_hashes[0];
|
|
}
|
|
else if (kinfo.txs_hashes.size() == 0)
|
|
{
|
|
tools::msg_writer() << " WARNING: spent key image has no txs associated";
|
|
}
|
|
else
|
|
{
|
|
tools::msg_writer() << " NOTE: key image for multiple txs: " << kinfo.txs_hashes.size();
|
|
for (const std::string& tx_id : kinfo.txs_hashes)
|
|
{
|
|
tools::msg_writer() << " tx: " << tx_id;
|
|
}
|
|
}
|
|
}
|
|
if (res.transactions.empty())
|
|
{
|
|
tools::msg_writer() << "WARNING: Inconsistent pool state - no transactions";
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_transaction_pool_short() {
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL::request req;
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL::response res;
|
|
|
|
std::string fail_message = "Problem fetching transaction pool";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_transaction_pool", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_transaction_pool(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (res.transactions.empty())
|
|
{
|
|
tools::msg_writer() << "Pool is empty" << std::endl;
|
|
}
|
|
else
|
|
{
|
|
const time_t now = time(NULL);
|
|
for (auto & tx_info : res.transactions)
|
|
{
|
|
tools::msg_writer() << "id: " << tx_info.id_hash << std::endl
|
|
<< "blob_size: " << tx_info.blob_size << std::endl
|
|
<< "weight: " << tx_info.weight << std::endl
|
|
<< "fee: " << cryptonote::print_money(tx_info.fee) << std::endl
|
|
<< "fee/byte: " << cryptonote::print_money(tx_info.fee / (double)tx_info.weight) << std::endl
|
|
<< "receive_time: " << tx_info.receive_time << " (" << get_human_time_ago(tx_info.receive_time, now) << ")" << std::endl
|
|
<< "relayed: " << [&](const cryptonote::tx_info &tx_info)->std::string { if (!tx_info.relayed) return "no"; return boost::lexical_cast<std::string>(tx_info.last_relayed_time) + " (" + get_human_time_ago(tx_info.last_relayed_time, now) + ")"; } (tx_info) << std::endl
|
|
<< "do_not_relay: " << (tx_info.do_not_relay ? 'T' : 'F') << std::endl
|
|
<< "kept_by_block: " << (tx_info.kept_by_block ? 'T' : 'F') << std::endl
|
|
<< "double_spend_seen: " << (tx_info.double_spend_seen ? 'T' : 'F') << std::endl
|
|
<< "max_used_block_height: " << tx_info.max_used_block_height << std::endl
|
|
<< "max_used_block_id: " << tx_info.max_used_block_id_hash << std::endl
|
|
<< "last_failed_height: " << tx_info.last_failed_height << std::endl
|
|
<< "last_failed_id: " << tx_info.last_failed_id_hash << std::endl;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_transaction_pool_stats() {
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL_STATS::request req;
|
|
cryptonote::COMMAND_RPC_GET_TRANSACTION_POOL_STATS::response res;
|
|
cryptonote::COMMAND_RPC_GET_INFO::request ireq;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response ires;
|
|
|
|
std::string fail_message = "Problem fetching transaction pool stats";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_transaction_pool_stats", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
if (!m_rpc_client->rpc_request(ireq, ires, "/getinfo", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
res.pool_stats = {};
|
|
if (!m_rpc_server->on_get_transaction_pool_stats(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_get_info(ireq, ires) || ires.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, ires.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
size_t n_transactions = res.pool_stats.txs_total;
|
|
const uint64_t now = time(NULL);
|
|
size_t avg_bytes = n_transactions ? res.pool_stats.bytes_total / n_transactions : 0;
|
|
|
|
std::string backlog_message;
|
|
const uint64_t full_reward_zone = ires.block_weight_limit / 2;
|
|
if (res.pool_stats.bytes_total <= full_reward_zone)
|
|
{
|
|
backlog_message = "no backlog";
|
|
}
|
|
else
|
|
{
|
|
uint64_t backlog = (res.pool_stats.bytes_total + full_reward_zone - 1) / full_reward_zone;
|
|
backlog_message = (boost::format("estimated %u block (%u minutes) backlog") % backlog % (backlog * DIFFICULTY_TARGET_V2 / 60)).str();
|
|
}
|
|
|
|
tools::msg_writer() << n_transactions << " tx(es), " << res.pool_stats.bytes_total << " bytes total (min " << res.pool_stats.bytes_min << ", max " << res.pool_stats.bytes_max << ", avg " << avg_bytes << ", median " << res.pool_stats.bytes_med << ")" << std::endl
|
|
<< "fees " << cryptonote::print_money(res.pool_stats.fee_total) << " (avg " << cryptonote::print_money(n_transactions ? res.pool_stats.fee_total / n_transactions : 0) << " per tx" << ", " << cryptonote::print_money(res.pool_stats.bytes_total ? res.pool_stats.fee_total / res.pool_stats.bytes_total : 0) << " per byte)" << std::endl
|
|
<< res.pool_stats.num_double_spends << " double spends, " << res.pool_stats.num_not_relayed << " not relayed, " << res.pool_stats.num_failing << " failing, " << res.pool_stats.num_10m << " older than 10 minutes (oldest " << (res.pool_stats.oldest == 0 ? "-" : get_human_time_ago(res.pool_stats.oldest, now)) << "), " << backlog_message;
|
|
|
|
if (n_transactions > 1 && res.pool_stats.histo.size())
|
|
{
|
|
std::vector<uint64_t> times;
|
|
uint64_t numer;
|
|
size_t i, n = res.pool_stats.histo.size(), denom;
|
|
times.resize(n);
|
|
if (res.pool_stats.histo_98pc)
|
|
{
|
|
numer = res.pool_stats.histo_98pc;
|
|
denom = n-1;
|
|
for (i=0; i<denom; i++)
|
|
times[i] = i * numer / denom;
|
|
times[i] = now - res.pool_stats.oldest;
|
|
} else
|
|
{
|
|
numer = now - res.pool_stats.oldest;
|
|
denom = n;
|
|
for (i=0; i<denom; i++)
|
|
times[i] = i * numer / denom;
|
|
}
|
|
tools::msg_writer() << " Age Txes Bytes";
|
|
for (i=0; i<n; i++)
|
|
{
|
|
tools::msg_writer() << get_time_hms(times[i]) << std::setw(8) << res.pool_stats.histo[i].txs << std::setw(12) << res.pool_stats.histo[i].bytes;
|
|
}
|
|
}
|
|
tools::msg_writer();
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::start_mining(cryptonote::account_public_address address, uint64_t num_threads, cryptonote::network_type nettype, bool do_background_mining, bool ignore_battery) {
|
|
cryptonote::COMMAND_RPC_START_MINING::request req;
|
|
cryptonote::COMMAND_RPC_START_MINING::response res;
|
|
req.miner_address = cryptonote::get_account_address_as_str(nettype, false, address);
|
|
req.threads_count = num_threads;
|
|
req.do_background_mining = do_background_mining;
|
|
req.ignore_battery = ignore_battery;
|
|
|
|
std::string fail_message = "Mining did not start";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (m_rpc_client->rpc_request(req, res, "/start_mining", fail_message.c_str()))
|
|
{
|
|
tools::success_msg_writer() << "Mining started";
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_start_mining(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::stop_mining() {
|
|
cryptonote::COMMAND_RPC_STOP_MINING::request req;
|
|
cryptonote::COMMAND_RPC_STOP_MINING::response res;
|
|
|
|
std::string fail_message = "Mining did not stop";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/stop_mining", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_stop_mining(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Mining stopped";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::stop_daemon()
|
|
{
|
|
cryptonote::COMMAND_RPC_STOP_DAEMON::request req;
|
|
cryptonote::COMMAND_RPC_STOP_DAEMON::response res;
|
|
|
|
//# ifdef WIN32
|
|
// // Stop via service API
|
|
// // TODO - this is only temporary! Get rid of hard-coded constants!
|
|
// bool ok = windows::stop_service("BitMonero Daemon");
|
|
// ok = windows::uninstall_service("BitMonero Daemon");
|
|
// //bool ok = windows::stop_service(SERVICE_NAME);
|
|
// //ok = windows::uninstall_service(SERVICE_NAME);
|
|
// if (ok)
|
|
// {
|
|
// return true;
|
|
// }
|
|
//# endif
|
|
|
|
// Stop via RPC
|
|
std::string fail_message = "Daemon did not stop";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if(!m_rpc_client->rpc_request(req, res, "/stop_daemon", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_stop_daemon(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Stop signal sent";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_status()
|
|
{
|
|
if (!m_is_rpc)
|
|
{
|
|
tools::success_msg_writer() << "print_status makes no sense in interactive mode";
|
|
return true;
|
|
}
|
|
|
|
bool daemon_is_alive = m_rpc_client->check_connection();
|
|
|
|
if(daemon_is_alive) {
|
|
tools::success_msg_writer() << "monerod is running";
|
|
}
|
|
else {
|
|
tools::fail_msg_writer() << "monerod is NOT running";
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::get_limit()
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::request req;
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::response res;
|
|
|
|
std::string failure_message = "Couldn't get limit";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_limit", failure_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_limit(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(failure_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << "limit-down is " << res.limit_down << " kB/s";
|
|
tools::msg_writer() << "limit-up is " << res.limit_up << " kB/s";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::set_limit(int64_t limit_down, int64_t limit_up)
|
|
{
|
|
cryptonote::COMMAND_RPC_SET_LIMIT::request req;
|
|
cryptonote::COMMAND_RPC_SET_LIMIT::response res;
|
|
|
|
req.limit_down = limit_down;
|
|
req.limit_up = limit_up;
|
|
|
|
std::string failure_message = "Couldn't set limit";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/set_limit", failure_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_limit(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(failure_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << "Set limit-down to " << res.limit_down << " kB/s";
|
|
tools::msg_writer() << "Set limit-up to " << res.limit_up << " kB/s";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::get_limit_up()
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::request req;
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::response res;
|
|
|
|
std::string failure_message = "Couldn't get limit";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_limit", failure_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_limit(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(failure_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << "limit-up is " << res.limit_up << " kB/s";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::get_limit_down()
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::request req;
|
|
cryptonote::COMMAND_RPC_GET_LIMIT::response res;
|
|
|
|
std::string failure_message = "Couldn't get limit";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/get_limit", failure_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_limit(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(failure_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << "limit-down is " << res.limit_down << " kB/s";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::out_peers(bool set, uint32_t limit)
|
|
{
|
|
cryptonote::COMMAND_RPC_OUT_PEERS::request req;
|
|
cryptonote::COMMAND_RPC_OUT_PEERS::response res;
|
|
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.set = set;
|
|
req.out_peers = limit;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/out_peers", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_out_peers(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
const std::string s = res.out_peers == (uint32_t)-1 ? "unlimited" : std::to_string(res.out_peers);
|
|
tools::msg_writer() << "Max number of out peers set to " << s << std::endl;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::in_peers(bool set, uint32_t limit)
|
|
{
|
|
cryptonote::COMMAND_RPC_IN_PEERS::request req;
|
|
cryptonote::COMMAND_RPC_IN_PEERS::response res;
|
|
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.set = set;
|
|
req.in_peers = limit;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/in_peers", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_in_peers(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
const std::string s = res.in_peers == (uint32_t)-1 ? "unlimited" : std::to_string(res.in_peers);
|
|
tools::msg_writer() << "Max number of in peers set to " << s << std::endl;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::hard_fork_info(uint8_t version)
|
|
{
|
|
cryptonote::COMMAND_RPC_HARD_FORK_INFO::request req;
|
|
cryptonote::COMMAND_RPC_HARD_FORK_INFO::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.version = version;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "hard_fork_info", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_hard_fork_info(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
version = version > 0 ? version : res.voting;
|
|
tools::msg_writer() << "version " << (uint32_t)version << " " << (res.enabled ? "enabled" : "not enabled") <<
|
|
", " << res.votes << "/" << res.window << " votes, threshold " << res.threshold;
|
|
tools::msg_writer() << "current version " << (uint32_t)res.version << ", voting for version " << (uint32_t)res.voting;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_bans()
|
|
{
|
|
cryptonote::COMMAND_RPC_GETBANS::request req;
|
|
cryptonote::COMMAND_RPC_GETBANS::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "get_bans", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_bans(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (!res.bans.empty())
|
|
{
|
|
for (auto i = res.bans.begin(); i != res.bans.end(); ++i)
|
|
{
|
|
tools::msg_writer() << i->host << " banned for " << i->seconds << " seconds";
|
|
}
|
|
}
|
|
else
|
|
tools::msg_writer() << "No IPs are banned";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::ban(const std::string &address, time_t seconds)
|
|
{
|
|
cryptonote::COMMAND_RPC_SETBANS::request req;
|
|
cryptonote::COMMAND_RPC_SETBANS::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
cryptonote::COMMAND_RPC_SETBANS::ban ban;
|
|
ban.host = address;
|
|
ban.ip = 0;
|
|
ban.ban = true;
|
|
ban.seconds = seconds;
|
|
req.bans.push_back(ban);
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "set_bans", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_bans(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::unban(const std::string &address)
|
|
{
|
|
cryptonote::COMMAND_RPC_SETBANS::request req;
|
|
cryptonote::COMMAND_RPC_SETBANS::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
cryptonote::COMMAND_RPC_SETBANS::ban ban;
|
|
ban.host = address;
|
|
ban.ip = 0;
|
|
ban.ban = false;
|
|
ban.seconds = 0;
|
|
req.bans.push_back(ban);
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "set_bans", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_bans(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::banned(const std::string &address)
|
|
{
|
|
cryptonote::COMMAND_RPC_BANNED::request req;
|
|
cryptonote::COMMAND_RPC_BANNED::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.address = address;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "banned", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_banned(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (res.banned)
|
|
tools::msg_writer() << address << " is banned for " << res.seconds << " seconds";
|
|
else
|
|
tools::msg_writer() << address << " is not banned";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::flush_txpool(const std::string &txid)
|
|
{
|
|
cryptonote::COMMAND_RPC_FLUSH_TRANSACTION_POOL::request req;
|
|
cryptonote::COMMAND_RPC_FLUSH_TRANSACTION_POOL::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
if (!txid.empty())
|
|
req.txids.push_back(txid);
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "flush_txpool", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_flush_txpool(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Pool successfully flushed";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::output_histogram(const std::vector<uint64_t> &amounts, uint64_t min_count, uint64_t max_count)
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_OUTPUT_HISTOGRAM::request req;
|
|
cryptonote::COMMAND_RPC_GET_OUTPUT_HISTOGRAM::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.amounts = amounts;
|
|
req.min_count = min_count;
|
|
req.max_count = max_count;
|
|
req.unlocked = false;
|
|
req.recent_cutoff = 0;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "get_output_histogram", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_output_histogram(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
std::sort(res.histogram.begin(), res.histogram.end(),
|
|
[](const cryptonote::COMMAND_RPC_GET_OUTPUT_HISTOGRAM::entry &e1, const cryptonote::COMMAND_RPC_GET_OUTPUT_HISTOGRAM::entry &e2)->bool { return e1.total_instances < e2.total_instances; });
|
|
for (const auto &e: res.histogram)
|
|
{
|
|
tools::msg_writer() << e.total_instances << " " << cryptonote::print_money(e.amount);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_coinbase_tx_sum(uint64_t height, uint64_t count)
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_COINBASE_TX_SUM::request req;
|
|
cryptonote::COMMAND_RPC_GET_COINBASE_TX_SUM::response res;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.height = height;
|
|
req.count = count;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "get_coinbase_tx_sum", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_coinbase_tx_sum(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << "Sum of coinbase transactions between block heights ["
|
|
<< height << ", " << (height + count) << ") is "
|
|
<< cryptonote::print_money(boost::multiprecision::uint128_t(res.wide_emission_amount) + boost::multiprecision::uint128_t(res.wide_fee_amount)) << " "
|
|
<< "consisting of " << cryptonote::print_money(boost::multiprecision::uint128_t(res.wide_emission_amount))
|
|
<< " in emissions, and " << cryptonote::print_money(boost::multiprecision::uint128_t(res.wide_fee_amount)) << " in fees";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::alt_chain_info(const std::string &tip, size_t above, uint64_t last_blocks)
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_INFO::request ireq;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response ires;
|
|
cryptonote::COMMAND_RPC_GET_ALTERNATE_CHAINS::request req;
|
|
cryptonote::COMMAND_RPC_GET_ALTERNATE_CHAINS::response res;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
std::string fail_message = "Unsuccessful";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(ireq, ires, "/getinfo", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
if (!m_rpc_client->json_rpc_request(req, res, "get_alternate_chains", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_info(ireq, ires) || ires.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, ires.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_get_alternate_chains(req, res, error_resp))
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (tip.empty())
|
|
{
|
|
auto chains = res.chains;
|
|
std::sort(chains.begin(), chains.end(), [](const cryptonote::COMMAND_RPC_GET_ALTERNATE_CHAINS::chain_info &info0, cryptonote::COMMAND_RPC_GET_ALTERNATE_CHAINS::chain_info &info1){ return info0.height < info1.height; });
|
|
std::vector<size_t> display;
|
|
for (size_t i = 0; i < chains.size(); ++i)
|
|
{
|
|
const auto &chain = chains[i];
|
|
if (chain.length <= above)
|
|
continue;
|
|
const uint64_t start_height = (chain.height - chain.length + 1);
|
|
if (last_blocks > 0 && ires.height - 1 - start_height >= last_blocks)
|
|
continue;
|
|
display.push_back(i);
|
|
}
|
|
tools::msg_writer() << boost::lexical_cast<std::string>(display.size()) << " alternate chains found:";
|
|
for (const size_t idx: display)
|
|
{
|
|
const auto &chain = chains[idx];
|
|
const uint64_t start_height = (chain.height - chain.length + 1);
|
|
tools::msg_writer() << chain.length << " blocks long, from height " << start_height << " (" << (ires.height - start_height - 1)
|
|
<< " deep), diff " << cryptonote::difficulty_type(chain.wide_difficulty) << ": " << chain.block_hash;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
const uint64_t now = time(NULL);
|
|
const auto i = std::find_if(res.chains.begin(), res.chains.end(), [&tip](cryptonote::COMMAND_RPC_GET_ALTERNATE_CHAINS::chain_info &info){ return info.block_hash == tip; });
|
|
if (i != res.chains.end())
|
|
{
|
|
const auto &chain = *i;
|
|
tools::success_msg_writer() << "Found alternate chain with tip " << tip;
|
|
uint64_t start_height = (chain.height - chain.length + 1);
|
|
tools::msg_writer() << chain.length << " blocks long, from height " << start_height << " (" << (ires.height - start_height - 1)
|
|
<< " deep), diff " << cryptonote::difficulty_type(chain.wide_difficulty) << ":";
|
|
for (const std::string &block_id: chain.block_hashes)
|
|
tools::msg_writer() << " " << block_id;
|
|
tools::msg_writer() << "Chain parent on main chain: " << chain.main_chain_parent_block;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK_HEADER_BY_HASH::request bhreq;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK_HEADER_BY_HASH::response bhres;
|
|
bhreq.hashes = chain.block_hashes;
|
|
bhreq.hashes.push_back(chain.main_chain_parent_block);
|
|
bhreq.fill_pow_hash = false;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(bhreq, bhres, "getblockheaderbyhash", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_block_header_by_hash(bhreq, bhres, error_resp))
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
if (bhres.block_headers.size() != chain.length + 1)
|
|
{
|
|
tools::fail_msg_writer() << "Failed to get block header info for alt chain";
|
|
return true;
|
|
}
|
|
uint64_t t0 = bhres.block_headers.front().timestamp, t1 = t0;
|
|
for (const cryptonote::block_header_response &block_header: bhres.block_headers)
|
|
{
|
|
t0 = std::min<uint64_t>(t0, block_header.timestamp);
|
|
t1 = std::max<uint64_t>(t1, block_header.timestamp);
|
|
}
|
|
const uint64_t dt = t1 - t0;
|
|
const uint64_t age = std::max(dt, t0 < now ? now - t0 : 0);
|
|
tools::msg_writer() << "Age: " << tools::get_human_readable_timespan(age);
|
|
if (chain.length > 1)
|
|
{
|
|
tools::msg_writer() << "Time span: " << tools::get_human_readable_timespan(dt);
|
|
cryptonote::difficulty_type start_difficulty = bhres.block_headers.back().difficulty;
|
|
if (start_difficulty > 0)
|
|
tools::msg_writer() << "Approximated " << 100.f * DIFFICULTY_TARGET_V2 * chain.length / dt << "% of network hash rate";
|
|
else
|
|
tools::fail_msg_writer() << "Bad cmumulative difficulty reported by dameon";
|
|
}
|
|
}
|
|
else
|
|
tools::fail_msg_writer() << "Block hash " << tip << " is not the tip of any known alternate chain";
|
|
}
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::print_blockchain_dynamic_stats(uint64_t nblocks)
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_INFO::request ireq;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response ires;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK_HEADERS_RANGE::request bhreq;
|
|
cryptonote::COMMAND_RPC_GET_BLOCK_HEADERS_RANGE::response bhres;
|
|
cryptonote::COMMAND_RPC_GET_BASE_FEE_ESTIMATE::request fereq;
|
|
cryptonote::COMMAND_RPC_GET_BASE_FEE_ESTIMATE::response feres;
|
|
cryptonote::COMMAND_RPC_HARD_FORK_INFO::request hfreq;
|
|
cryptonote::COMMAND_RPC_HARD_FORK_INFO::response hfres;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
std::string fail_message = "Problem fetching info";
|
|
|
|
fereq.grace_blocks = 0;
|
|
hfreq.version = HF_VERSION_PER_BYTE_FEE;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(ireq, ires, "/getinfo", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
if (!m_rpc_client->json_rpc_request(fereq, feres, "get_fee_estimate", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
if (!m_rpc_client->json_rpc_request(hfreq, hfres, "hard_fork_info", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_info(ireq, ires) || ires.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, ires.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_get_base_fee_estimate(fereq, feres, error_resp) || feres.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, feres.status);
|
|
return true;
|
|
}
|
|
if (!m_rpc_server->on_hard_fork_info(hfreq, hfres, error_resp) || hfres.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, hfres.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::msg_writer() << "Height: " << ires.height << ", diff " << cryptonote::difficulty_type(ires.wide_difficulty) << ", cum. diff " << cryptonote::difficulty_type(ires.wide_cumulative_difficulty)
|
|
<< ", target " << ires.target << " sec" << ", dyn fee " << cryptonote::print_money(feres.fee) << "/" << (hfres.enabled ? "byte" : "kB");
|
|
|
|
if (nblocks > 0)
|
|
{
|
|
if (nblocks > ires.height)
|
|
nblocks = ires.height;
|
|
|
|
bhreq.start_height = ires.height - nblocks;
|
|
bhreq.end_height = ires.height - 1;
|
|
bhreq.fill_pow_hash = false;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(bhreq, bhres, "getblockheadersrange", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_block_headers_range(bhreq, bhres, error_resp) || bhres.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, bhres.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
cryptonote::difficulty_type avgdiff = 0;
|
|
double avgnumtxes = 0;
|
|
double avgreward = 0;
|
|
std::vector<uint64_t> weights;
|
|
weights.reserve(nblocks);
|
|
uint64_t earliest = std::numeric_limits<uint64_t>::max(), latest = 0;
|
|
std::vector<unsigned> major_versions(256, 0), minor_versions(256, 0);
|
|
for (const auto &bhr: bhres.headers)
|
|
{
|
|
avgdiff += cryptonote::difficulty_type(bhr.wide_difficulty);
|
|
avgnumtxes += bhr.num_txes;
|
|
avgreward += bhr.reward;
|
|
weights.push_back(bhr.block_weight);
|
|
static_assert(sizeof(bhr.major_version) == 1, "major_version expected to be uint8_t");
|
|
static_assert(sizeof(bhr.minor_version) == 1, "major_version expected to be uint8_t");
|
|
major_versions[(unsigned)bhr.major_version]++;
|
|
minor_versions[(unsigned)bhr.minor_version]++;
|
|
earliest = std::min(earliest, bhr.timestamp);
|
|
latest = std::max(latest, bhr.timestamp);
|
|
}
|
|
avgdiff /= nblocks;
|
|
avgnumtxes /= nblocks;
|
|
avgreward /= nblocks;
|
|
uint64_t median_block_weight = epee::misc_utils::median(weights);
|
|
tools::msg_writer() << "Last " << nblocks << ": avg. diff " << avgdiff << ", " << (latest - earliest) / nblocks << " avg sec/block, avg num txes " << avgnumtxes
|
|
<< ", avg. reward " << cryptonote::print_money(avgreward) << ", median block weight " << median_block_weight;
|
|
|
|
unsigned int max_major = 256, max_minor = 256;
|
|
while (max_major > 0 && !major_versions[--max_major]);
|
|
while (max_minor > 0 && !minor_versions[--max_minor]);
|
|
std::string s = "";
|
|
for (unsigned n = 0; n <= max_major; ++n)
|
|
if (major_versions[n])
|
|
s += (s.empty() ? "" : ", ") + boost::lexical_cast<std::string>(major_versions[n]) + std::string(" v") + boost::lexical_cast<std::string>(n);
|
|
tools::msg_writer() << "Block versions: " << s;
|
|
s = "";
|
|
for (unsigned n = 0; n <= max_minor; ++n)
|
|
if (minor_versions[n])
|
|
s += (s.empty() ? "" : ", ") + boost::lexical_cast<std::string>(minor_versions[n]) + std::string(" v") + boost::lexical_cast<std::string>(n);
|
|
tools::msg_writer() << "Voting for: " << s;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::update(const std::string &command)
|
|
{
|
|
cryptonote::COMMAND_RPC_UPDATE::request req;
|
|
cryptonote::COMMAND_RPC_UPDATE::response res;
|
|
epee::json_rpc::error error_resp;
|
|
|
|
std::string fail_message = "Problem fetching info";
|
|
|
|
req.command = command;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/update", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_update(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (!res.update)
|
|
{
|
|
tools::msg_writer() << "No update available";
|
|
return true;
|
|
}
|
|
|
|
tools::msg_writer() << "Update available: v" << res.version << ": " << res.user_uri << ", hash " << res.hash;
|
|
if (command == "check")
|
|
return true;
|
|
|
|
if (!res.path.empty())
|
|
tools::msg_writer() << "Update downloaded to: " << res.path;
|
|
else
|
|
tools::msg_writer() << "Update download failed: " << res.status;
|
|
if (command == "download")
|
|
return true;
|
|
|
|
tools::msg_writer() << "'update' not implemented yet";
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::relay_tx(const std::string &txid)
|
|
{
|
|
cryptonote::COMMAND_RPC_RELAY_TX::request req;
|
|
cryptonote::COMMAND_RPC_RELAY_TX::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.txids.push_back(txid);
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "relay_tx", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_relay_tx(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Transaction successfully relayed";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::sync_info()
|
|
{
|
|
cryptonote::COMMAND_RPC_SYNC_INFO::request req;
|
|
cryptonote::COMMAND_RPC_SYNC_INFO::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "sync_info", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_sync_info(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
uint64_t target = res.target_height < res.height ? res.height : res.target_height;
|
|
tools::success_msg_writer() << "Height: " << res.height << ", target: " << target << " (" << (100.0 * res.height / target) << "%)";
|
|
uint64_t current_download = 0;
|
|
for (const auto &p: res.peers)
|
|
current_download += p.info.current_download;
|
|
tools::success_msg_writer() << "Downloading at " << current_download << " kB/s";
|
|
if (res.next_needed_pruning_seed)
|
|
tools::success_msg_writer() << "Next needed pruning seed: " << res.next_needed_pruning_seed;
|
|
|
|
tools::success_msg_writer() << std::to_string(res.peers.size()) << " peers";
|
|
tools::success_msg_writer() << "Remote Host Peer_ID State Prune_Seed Height DL kB/s, Queued Blocks / MB";
|
|
for (const auto &p: res.peers)
|
|
{
|
|
std::string address = epee::string_tools::pad_string(p.info.address, 24);
|
|
uint64_t nblocks = 0, size = 0;
|
|
for (const auto &s: res.spans)
|
|
if (s.connection_id == p.info.connection_id)
|
|
nblocks += s.nblocks, size += s.size;
|
|
tools::success_msg_writer() << address << " " << p.info.peer_id << " " <<
|
|
epee::string_tools::pad_string(p.info.state, 16) << " " <<
|
|
epee::string_tools::pad_string(epee::string_tools::to_string_hex(p.info.pruning_seed), 8) << " " << p.info.height << " " <<
|
|
p.info.current_download << " kB/s, " << nblocks << " blocks / " << size/1e6 << " MB queued";
|
|
}
|
|
|
|
uint64_t total_size = 0;
|
|
for (const auto &s: res.spans)
|
|
total_size += s.size;
|
|
tools::success_msg_writer() << std::to_string(res.spans.size()) << " spans, " << total_size/1e6 << " MB";
|
|
tools::success_msg_writer() << res.overview;
|
|
for (const auto &s: res.spans)
|
|
{
|
|
std::string address = epee::string_tools::pad_string(s.remote_address, 24);
|
|
std::string pruning_seed = epee::string_tools::to_string_hex(tools::get_pruning_seed(s.start_block_height, std::numeric_limits<uint64_t>::max(), CRYPTONOTE_PRUNING_LOG_STRIPES));
|
|
if (s.size == 0)
|
|
{
|
|
tools::success_msg_writer() << address << " " << s.nblocks << "/" << pruning_seed << " (" << s.start_block_height << " - " << (s.start_block_height + s.nblocks - 1) << ") -";
|
|
}
|
|
else
|
|
{
|
|
tools::success_msg_writer() << address << " " << s.nblocks << "/" << pruning_seed << " (" << s.start_block_height << " - " << (s.start_block_height + s.nblocks - 1) << ", " << (uint64_t)(s.size/1e3) << " kB) " << (unsigned)(s.rate/1e3) << " kB/s (" << s.speed/100.0f << ")";
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::pop_blocks(uint64_t num_blocks)
|
|
{
|
|
cryptonote::COMMAND_RPC_POP_BLOCKS::request req;
|
|
cryptonote::COMMAND_RPC_POP_BLOCKS::response res;
|
|
std::string fail_message = "pop_blocks failed";
|
|
|
|
req.nblocks = num_blocks;
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/pop_blocks", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_pop_blocks(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
tools::success_msg_writer() << "new height: " << res.height;
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::prune_blockchain()
|
|
{
|
|
cryptonote::COMMAND_RPC_PRUNE_BLOCKCHAIN::request req;
|
|
cryptonote::COMMAND_RPC_PRUNE_BLOCKCHAIN::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.check = false;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "prune_blockchain", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_prune_blockchain(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer() << "Blockchain pruned";
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::check_blockchain_pruning()
|
|
{
|
|
cryptonote::COMMAND_RPC_PRUNE_BLOCKCHAIN::request req;
|
|
cryptonote::COMMAND_RPC_PRUNE_BLOCKCHAIN::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.check = true;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "prune_blockchain", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_prune_blockchain(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (res.pruning_seed)
|
|
{
|
|
tools::success_msg_writer() << "Blockchain is pruned";
|
|
}
|
|
else
|
|
{
|
|
tools::success_msg_writer() << "Blockchain is not pruned";
|
|
}
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::set_bootstrap_daemon(
|
|
const std::string &address,
|
|
const std::string &username,
|
|
const std::string &password)
|
|
{
|
|
cryptonote::COMMAND_RPC_SET_BOOTSTRAP_DAEMON::request req;
|
|
cryptonote::COMMAND_RPC_SET_BOOTSTRAP_DAEMON::response res;
|
|
const std::string fail_message = "Unsuccessful";
|
|
|
|
req.address = address;
|
|
req.username = username;
|
|
req.password = password;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/set_bootstrap_daemon", fail_message))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_set_bootstrap_daemon(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
tools::success_msg_writer()
|
|
<< "Successfully set bootstrap daemon address to "
|
|
<< (!req.address.empty() ? req.address : "none");
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::flush_cache(bool bad_txs, bool bad_blocks)
|
|
{
|
|
cryptonote::COMMAND_RPC_FLUSH_CACHE::request req;
|
|
cryptonote::COMMAND_RPC_FLUSH_CACHE::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
req.bad_txs = bad_txs;
|
|
req.bad_blocks = bad_blocks;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "flush_cache", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_flush_cache(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::rpc_payments()
|
|
{
|
|
cryptonote::COMMAND_RPC_ACCESS_DATA::request req;
|
|
cryptonote::COMMAND_RPC_ACCESS_DATA::response res;
|
|
std::string fail_message = "Unsuccessful";
|
|
epee::json_rpc::error error_resp;
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->json_rpc_request(req, res, "rpc_access_data", fail_message.c_str()))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_rpc_access_data(req, res, error_resp) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
const uint64_t now = std::chrono::duration_cast<std::chrono::seconds>(std::chrono::system_clock::now().time_since_epoch()).count();
|
|
uint64_t balance = 0;
|
|
tools::msg_writer() << boost::format("%64s %16u %16u %8u %8u %8u %8u %s")
|
|
% "Client ID" % "Balance" % "Total mined" % "Good" % "Stale" % "Bad" % "Dupes" % "Last update";
|
|
for (const auto &entry: res.entries)
|
|
{
|
|
tools::msg_writer() << boost::format("%64s %16u %16u %8u %8u %8u %8u %s")
|
|
% entry.client % entry.balance % entry.credits_total
|
|
% entry.nonces_good % entry.nonces_stale % entry.nonces_bad % entry.nonces_dupe
|
|
% (entry.last_update_time == 0 ? "never" : get_human_time_ago(entry.last_update_time, now).c_str());
|
|
balance += entry.balance;
|
|
}
|
|
tools::msg_writer() << res.entries.size() << " clients with a total of " << balance << " credits";
|
|
tools::msg_writer() << "Aggregated client hash rate: " << get_mining_speed(res.hashrate);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool t_rpc_command_executor::version()
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_INFO::request req;
|
|
cryptonote::COMMAND_RPC_GET_INFO::response res;
|
|
|
|
const char *fail_message = "Problem fetching info";
|
|
|
|
if (m_is_rpc)
|
|
{
|
|
if (!m_rpc_client->rpc_request(req, res, "/getinfo", fail_message))
|
|
{
|
|
return true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
if (!m_rpc_server->on_get_info(req, res) || res.status != CORE_RPC_STATUS_OK)
|
|
{
|
|
tools::fail_msg_writer() << make_error(fail_message, res.status);
|
|
return true;
|
|
}
|
|
}
|
|
|
|
if (res.version.empty() || !cryptonote::rpc::is_version_string_valid(res.version))
|
|
{
|
|
tools::fail_msg_writer() << "The daemon software version is not available.";
|
|
}
|
|
else
|
|
{
|
|
tools::success_msg_writer() << res.version;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
}// namespace daemonize
|