onion-wownero-explorer/src/MempoolStatus.cpp

//
// Created by mwo on 28/05/17.
//

#include "MempoolStatus.h"

#include "rpccalls.h"

namespace xmreg
{

using namespace std;


void
MempoolStatus::set_blockchain_variables(MicroCore *_mcore,
                                        Blockchain *_core_storage)
{
    mcore = _mcore;
    core_storage = _core_storage;
}

void
MempoolStatus::start_mempool_status_thread()
{

    if (mempool_refresh_time < 1)
    {
        // to protect from diviation by zero below.
        mempool_refresh_time = 1;
    }

    if (!is_running)
    {
        m_thread = boost::thread{[]()
        {
         try
         {
             uint64_t loop_index {0};

             // so that network status is checked every minute
             uint64_t loop_index_divider = 60 / mempool_refresh_time;
             loop_index_divider = loop_index_divider == 0 ? 1 : loop_index_divider;

             while (true)
             {

                 // we just query network status every minute. No sense
                 // to do it as frequently as getting mempool data.
                 if (loop_index % loop_index_divider == 0)
                 {
                     if (!MempoolStatus::read_network_info())
                     {
                         network_info local_copy = current_network_info;

                         cerr << " Cant read network info "<< endl;

                         local_copy.current = false;

                         current_network_info = local_copy;
                     }
                     else
                     {
                         cout << "Current network info read, ";
                         loop_index == 0;
                     }
                 }

                 if (MempoolStatus::read_mempool())
                 {
                     vector<mempool_tx> current_mempool_txs = get_mempool_txs();

                     cout << "mempool status txs: "
                          << current_mempool_txs.size()
                          << endl;
                 }

                 // when we reach top of the blockchain, update
                 // the emission amount every minute.
                 boost::this_thread::sleep_for(
                         boost::chrono::seconds(mempool_refresh_time));

                 ++loop_index;

             } // while (true)
         }
         catch (boost::thread_interrupted&)
         {
             cout << "Mempool status thread interrupted." << endl;
             return;
         }

        }}; //  m_thread = boost::thread{[]()

        is_running = true;

    } //  if (!is_running)
}


bool
MempoolStatus::read_mempool()
{
    rpccalls rpc {deamon_url};

    string error_msg;

    // we populate this variable instead of global mempool_txs
    // mempool_txs will be changed only when this function completes.
    // this ensures that we don't sent out partial mempool txs to
    // other places.
    vector<mempool_tx> local_copy_of_mempool_txs;

    // get txs in the mempool
    std::vector<tx_info> mempool_tx_info;

    if (!rpc.get_mempool(mempool_tx_info))
    {
        cerr << "Getting mempool failed " << endl;
        return false;
    }

    // if dont have tx_blob member, construct tx
    // from json obtained from the rpc call

    uint64_t mempool_size_kB {0};

    for (size_t i = 0; i < mempool_tx_info.size(); ++i)
    {
        // get transaction info of the tx in the mempool
        const tx_info& _tx_info = mempool_tx_info.at(i);

        crypto::hash mem_tx_hash = null_hash;

        if (epee::string_tools::hex_to_pod(_tx_info.id_hash, mem_tx_hash))
        {
            transaction tx;

            if (!xmreg::make_tx_from_json(_tx_info.tx_json, tx))
            {
                cerr << "Cant make tx from _tx_info.tx_json" << endl;
                return false;
            }

            crypto::hash tx_hash_reconstructed = get_transaction_hash(tx);

            if (mem_tx_hash != tx_hash_reconstructed)
            {
                cerr << "Hash of reconstructed tx from json does not match "
                        "what we should get!"
                     << endl;

                return false;
            }

            mempool_size_kB += _tx_info.blob_size;

            local_copy_of_mempool_txs.push_back(mempool_tx {tx_hash_reconstructed, tx});

            mempool_tx& last_tx = local_copy_of_mempool_txs.back();

            // key images of inputs
            vector<txin_to_key> input_key_imgs;

            // public keys and xmr amount of outputs
            vector<pair<txout_to_key, uint64_t>> output_pub_keys;

            // sum xmr in inputs and ouputs in the given tx
            const array<uint64_t, 4>& sum_data = summary_of_in_out_rct(
                   tx, output_pub_keys, input_key_imgs);

            last_tx.receive_time = _tx_info.receive_time;

            last_tx.sum_outputs       = sum_data[0];
            last_tx.sum_inputs        = sum_data[1];
            last_tx.no_outputs        = output_pub_keys.size();
            last_tx.no_inputs         = input_key_imgs.size();
            last_tx.mixin_no          = sum_data[2];
            last_tx.num_nonrct_inputs = sum_data[3];

            last_tx.fee_str         = xmreg::xmr_amount_to_str(_tx_info.fee, "{:0.3f}");
            last_tx.xmr_inputs_str  = xmreg::xmr_amount_to_str(last_tx.sum_inputs , "{:0.3f}");
            last_tx.xmr_outputs_str = xmreg::xmr_amount_to_str(last_tx.sum_outputs, "{:0.3f}");
            last_tx.timestamp_str   = xmreg::timestamp_to_str_gm(_tx_info.receive_time);

            last_tx.txsize          = fmt::format("{:0.2f}",
                                          static_cast<double>(_tx_info.blob_size)/1024.0);

        } // if (hex_to_pod(_tx_info.id_hash, mem_tx_hash))

    } // for (size_t i = 0; i < mempool_tx_info.size(); ++i)



    std::lock_guard<std::mutex> lck (mempool_mutx);

    // clear current mempool txs vector
    // repopulate it with each execution of read_mempool()
    // not very efficient but good enough for now.
    mempool_txs = std::move(local_copy_of_mempool_txs);

    mempool_no = local_copy_of_mempool_txs.size();
    mempool_size = mempool_size_kB;

    return true;
}


bool
MempoolStatus::read_network_info()
{
    rpccalls rpc {deamon_url};

    COMMAND_RPC_GET_INFO::response rpc_network_info;

    if (!rpc.get_network_info(rpc_network_info))
    {
        return false;
    }

    uint64_t fee_estimated;

    string error_msg;

    if (!rpc.get_dynamic_per_kb_fee_estimate(
            FEE_ESTIMATE_GRACE_BLOCKS,
            fee_estimated, error_msg))
    {
        cerr << "rpc.get_dynamic_per_kb_fee_estimate failed" << endl;
        return false;
    }

    (void) error_msg;


    network_info local_copy;

    local_copy.height                     = rpc_network_info.height;
    local_copy.target_height              = rpc_network_info.target_height;
    local_copy.difficulty                 = rpc_network_info.difficulty;
    local_copy.target                     = rpc_network_info.target;
    local_copy.hash_rate                  = (rpc_network_info.difficulty/rpc_network_info.target);
    local_copy.tx_count                   = rpc_network_info.tx_count;
    local_copy.tx_pool_size               = rpc_network_info.tx_pool_size;
    local_copy.alt_blocks_count           = rpc_network_info.alt_blocks_count;
    local_copy.outgoing_connections_count = rpc_network_info.outgoing_connections_count;
    local_copy.incoming_connections_count = rpc_network_info.incoming_connections_count;
    local_copy.white_peerlist_size        = rpc_network_info.white_peerlist_size;
    local_copy.testnet                    = rpc_network_info.testnet;
    local_copy.cumulative_difficulty      = rpc_network_info.cumulative_difficulty;
    local_copy.block_size_limit           = rpc_network_info.block_size_limit;
    local_copy.start_time                 = rpc_network_info.start_time;

    epee::string_tools::hex_to_pod(rpc_network_info.top_block_hash, local_copy.top_block_hash);
    local_copy.fee_per_kb                 = fee_estimated;
    local_copy.info_timestamp             = static_cast<uint64_t>(std::time(nullptr));

    local_copy.current                    = true;

    current_network_info = local_copy;

    return true;
}

vector<MempoolStatus::mempool_tx>
MempoolStatus::get_mempool_txs()
{
    std::lock_guard<std::mutex> lck (mempool_mutx);
    return mempool_txs;
}


bool
MempoolStatus::is_thread_running()
{
    return is_running;
}

bf::path MempoolStatus::blockchain_path {"/home/mwo/.bitmonero/lmdb"};
string MempoolStatus::deamon_url {"http:://127.0.0.1:18081"};
bool   MempoolStatus::testnet {false};
atomic<bool>       MempoolStatus::is_running {false};
boost::thread      MempoolStatus::m_thread;
Blockchain*        MempoolStatus::core_storage {nullptr};
xmreg::MicroCore*  MempoolStatus::mcore {nullptr};
vector<MempoolStatus::mempool_tx> MempoolStatus::mempool_txs;
atomic<MempoolStatus::network_info> MempoolStatus::current_network_info;
atomic<uint64_t> MempoolStatus::mempool_no {0};   // no of txs
atomic<uint64_t> MempoolStatus::mempool_size {0}; // size in bytes.
uint64_t MempoolStatus::mempool_refresh_time {10};
mutex MempoolStatus::mempool_mutx;
}