129 lines
4.2 KiB
C++
129 lines
4.2 KiB
C++
// Copyright (c) 2012-2013 The Cryptonote developers
|
|
// Distributed under the MIT/X11 software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#include "INodeStubs.h"
|
|
#include "cryptonote_core/cryptonote_format_utils.h"
|
|
#include "wallet/WalletErrors.h"
|
|
|
|
#include <functional>
|
|
#include <thread>
|
|
#include <iterator>
|
|
#include <cassert>
|
|
|
|
#include "crypto/crypto.h"
|
|
|
|
void INodeTrivialRefreshStub::getNewBlocks(std::list<crypto::hash>&& knownBlockIds, std::list<cryptonote::block_complete_entry>& newBlocks, uint64_t& startHeight, const Callback& callback)
|
|
{
|
|
std::thread task(&INodeTrivialRefreshStub::doGetNewBlocks, this, knownBlockIds, std::ref(newBlocks), std::ref(startHeight), callback);
|
|
task.detach();
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::doGetNewBlocks(std::list<crypto::hash> knownBlockIds, std::list<cryptonote::block_complete_entry>& newBlocks, uint64_t& startHeight, const Callback& callback)
|
|
{
|
|
auto& blockchain = m_blockchainGenerator.getBlockchain();
|
|
|
|
startHeight = m_lastHeight;
|
|
|
|
for (; m_lastHeight < blockchain.size(); ++m_lastHeight)
|
|
{
|
|
cryptonote::block_complete_entry e;
|
|
e.block = cryptonote::t_serializable_object_to_blob(blockchain[m_lastHeight]);
|
|
|
|
for (auto hash: blockchain[m_lastHeight].tx_hashes)
|
|
{
|
|
cryptonote::transaction tx;
|
|
if (!m_blockchainGenerator.getTransactionByHash(hash, tx))
|
|
continue;
|
|
|
|
e.txs.push_back(t_serializable_object_to_blob(tx));
|
|
}
|
|
|
|
newBlocks.push_back(e);
|
|
}
|
|
|
|
m_lastHeight = blockchain.size() - 1;
|
|
|
|
callback(std::error_code());
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::getTransactionOutsGlobalIndices(const crypto::hash& transactionHash, std::vector<uint64_t>& outsGlobalIndices, const Callback& callback)
|
|
{
|
|
std::thread task(&INodeTrivialRefreshStub::doGetTransactionOutsGlobalIndices, this, transactionHash, std::ref(outsGlobalIndices), callback);
|
|
task.detach();
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::doGetTransactionOutsGlobalIndices(const crypto::hash& transactionHash, std::vector<uint64_t>& outsGlobalIndices, const Callback& callback)
|
|
{
|
|
outsGlobalIndices.resize(20); //random
|
|
callback(std::error_code());
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::relayTransaction(const cryptonote::transaction& transaction, const Callback& callback)
|
|
{
|
|
std::thread task(&INodeTrivialRefreshStub::doRelayTransaction, this, transaction, callback);
|
|
task.detach();
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::doRelayTransaction(const cryptonote::transaction& transaction, const Callback& callback)
|
|
{
|
|
if (m_nextTxError)
|
|
{
|
|
callback(make_error_code(cryptonote::error::INTERNAL_WALLET_ERROR));
|
|
m_nextTxError = false;
|
|
return;
|
|
}
|
|
m_blockchainGenerator.addTxToBlockchain(transaction);
|
|
callback(std::error_code());
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::getRandomOutsByAmounts(std::vector<uint64_t>&& amounts, uint64_t outsCount, std::vector<cryptonote::COMMAND_RPC_GET_RANDOM_OUTPUTS_FOR_AMOUNTS::outs_for_amount>& result, const Callback& callback)
|
|
{
|
|
std::thread task(&INodeTrivialRefreshStub::doGetRandomOutsByAmounts, this, amounts, outsCount, std::ref(result), callback);
|
|
task.detach();
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::doGetRandomOutsByAmounts(std::vector<uint64_t> amounts, uint64_t outsCount, std::vector<cryptonote::COMMAND_RPC_GET_RANDOM_OUTPUTS_FOR_AMOUNTS::outs_for_amount>& result, const Callback& callback)
|
|
{
|
|
for (uint64_t amount: amounts)
|
|
{
|
|
cryptonote::COMMAND_RPC_GET_RANDOM_OUTPUTS_FOR_AMOUNTS::outs_for_amount out;
|
|
out.amount = amount;
|
|
|
|
for (uint64_t i = 0; i < outsCount; ++i)
|
|
{
|
|
crypto::public_key key;
|
|
crypto::secret_key sk;
|
|
generate_keys(key, sk);
|
|
|
|
cryptonote::COMMAND_RPC_GET_RANDOM_OUTPUTS_FOR_AMOUNTS::out_entry e;
|
|
e.global_amount_index = i;
|
|
e.out_key = key;
|
|
|
|
out.outs.push_back(e);
|
|
}
|
|
}
|
|
|
|
callback(std::error_code());
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::startAlternativeChain(uint64_t height)
|
|
{
|
|
std::vector<cryptonote::block>& blockchain = m_blockchainGenerator.getBlockchain();
|
|
|
|
assert(height < blockchain.size());
|
|
assert(height > m_lastHeight);
|
|
|
|
auto it = blockchain.begin();
|
|
std::advance(it, height);
|
|
|
|
blockchain.erase(it, blockchain.end());
|
|
|
|
m_lastHeight = height;
|
|
}
|
|
|
|
void INodeTrivialRefreshStub::setNextTransactionError()
|
|
{
|
|
m_nextTxError = true;
|
|
}
|