You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
307 lines
11 KiB
307 lines
11 KiB
// Copyright (c) 2014-2022, 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 <boost/uuid/uuid.hpp>
|
|
#include <boost/uuid/uuid_io.hpp>
|
|
#include <boost/uuid/random_generator.hpp>
|
|
#include <unordered_map>
|
|
|
|
#include "include_base_utils.h"
|
|
using namespace epee;
|
|
#include "wallet/wallet2.h"
|
|
using namespace cryptonote;
|
|
|
|
namespace
|
|
{
|
|
uint64_t const TEST_FEE = 5000000000; // 5 * 10^9
|
|
}
|
|
|
|
std::string generate_random_wallet_name()
|
|
{
|
|
std::stringstream ss;
|
|
ss << boost::uuids::random_generator()();
|
|
return ss.str();
|
|
}
|
|
|
|
inline uint64_t random(const uint64_t max_value) {
|
|
return (uint64_t(rand()) ^
|
|
(uint64_t(rand())<<16) ^
|
|
(uint64_t(rand())<<32) ^
|
|
(uint64_t(rand())<<48)) % max_value;
|
|
}
|
|
|
|
bool do_send_money(tools::wallet2& w1, tools::wallet2& w2, size_t mix_in_factor, uint64_t amount_to_transfer, transaction& tx, size_t parts=1)
|
|
{
|
|
CHECK_AND_ASSERT_MES(parts > 0, false, "parts must be > 0");
|
|
|
|
std::vector<cryptonote::tx_destination_entry> dsts;
|
|
dsts.reserve(parts);
|
|
uint64_t amount_used = 0;
|
|
uint64_t max_part = amount_to_transfer / parts;
|
|
|
|
for (size_t i = 0; i < parts; ++i)
|
|
{
|
|
cryptonote::tx_destination_entry de;
|
|
de.addr = w2.get_account().get_keys().m_account_address;
|
|
|
|
if (i < parts - 1)
|
|
de.amount = random(max_part);
|
|
else
|
|
de.amount = amount_to_transfer - amount_used;
|
|
amount_used += de.amount;
|
|
|
|
//std::cout << "PARTS (" << amount_to_transfer << ") " << amount_used << " " << de.amount << std::endl;
|
|
|
|
dsts.push_back(de);
|
|
}
|
|
|
|
try
|
|
{
|
|
std::vector<tools::wallet2::pending_tx> ptx;
|
|
ptx = w1.create_transactions_2(dsts, mix_in_factor, 0, 0, std::vector<uint8_t>(), 0, {});
|
|
for (auto &p: ptx)
|
|
w1.commit_tx(p);
|
|
return true;
|
|
}
|
|
catch (const std::exception&)
|
|
{
|
|
return false;
|
|
}
|
|
}
|
|
|
|
uint64_t get_money_in_first_transfers(const tools::wallet2::transfer_container& incoming_transfers, size_t n_transfers)
|
|
{
|
|
uint64_t summ = 0;
|
|
size_t count = 0;
|
|
BOOST_FOREACH(const tools::wallet2::transfer_details& td, incoming_transfers)
|
|
{
|
|
summ += td.m_tx.vout[td.m_internal_output_index].amount;
|
|
if(++count >= n_transfers)
|
|
return summ;
|
|
}
|
|
return summ;
|
|
}
|
|
|
|
#define FIRST_N_TRANSFERS 10*10
|
|
|
|
bool transactions_flow_test(std::string& working_folder,
|
|
std::string path_source_wallet,
|
|
std::string path_target_wallet,
|
|
std::string& daemon_addr_a,
|
|
std::string& daemon_addr_b,
|
|
uint64_t amount_to_transfer, size_t mix_in_factor, size_t transactions_count, size_t transactions_per_second)
|
|
{
|
|
LOG_PRINT_L0("-----------------------STARTING TRANSACTIONS FLOW TEST-----------------------");
|
|
tools::wallet2 w1, w2;
|
|
if(path_source_wallet.empty())
|
|
path_source_wallet = generate_random_wallet_name();
|
|
|
|
if(path_target_wallet.empty())
|
|
path_target_wallet = generate_random_wallet_name();
|
|
|
|
|
|
try
|
|
{
|
|
w1.generate(working_folder + "/" + path_source_wallet, "");
|
|
w2.generate(working_folder + "/" + path_target_wallet, "");
|
|
}
|
|
catch (const std::exception& e)
|
|
{
|
|
LOG_ERROR("failed to generate wallet: " << e.what());
|
|
return false;
|
|
}
|
|
|
|
w1.init(daemon_addr_a);
|
|
|
|
uint64_t blocks_fetched = 0;
|
|
bool received_money;
|
|
bool ok;
|
|
if(!w1.refresh(true, blocks_fetched, received_money, ok))
|
|
{
|
|
LOG_ERROR( "failed to refresh source wallet from " << daemon_addr_a );
|
|
return false;
|
|
}
|
|
|
|
w2.init(daemon_addr_b);
|
|
|
|
MGINFO_GREEN("Using wallets: " << ENDL
|
|
<< "Source: " << w1.get_account().get_public_address_str(MAINNET) << ENDL << "Path: " << working_folder + "/" + path_source_wallet << ENDL
|
|
<< "Target: " << w2.get_account().get_public_address_str(MAINNET) << ENDL << "Path: " << working_folder + "/" + path_target_wallet);
|
|
|
|
//lets do some money
|
|
epee::net_utils::http::http_simple_client http_client;
|
|
COMMAND_RPC_STOP_MINING::request daemon1_req = AUTO_VAL_INIT(daemon1_req);
|
|
COMMAND_RPC_STOP_MINING::response daemon1_rsp = AUTO_VAL_INIT(daemon1_rsp);
|
|
bool r = http_client.set_server(daemon_addr_a, boost::none) && net_utils::invoke_http_json("/stop_mine", daemon1_req, daemon1_rsp, http_client, std::chrono::seconds(10));
|
|
CHECK_AND_ASSERT_MES(r, false, "failed to stop mining");
|
|
|
|
COMMAND_RPC_START_MINING::request daemon_req = AUTO_VAL_INIT(daemon_req);
|
|
COMMAND_RPC_START_MINING::response daemon_rsp = AUTO_VAL_INIT(daemon_rsp);
|
|
daemon_req.miner_address = w1.get_account().get_public_address_str(MAINNET);
|
|
daemon_req.threads_count = 9;
|
|
r = net_utils::invoke_http_json("/start_mining", daemon_req, daemon_rsp, http_client, std::chrono::seconds(10));
|
|
CHECK_AND_ASSERT_MES(r, false, "failed to start mining getrandom_outs");
|
|
CHECK_AND_ASSERT_MES(daemon_rsp.status == CORE_RPC_STATUS_OK, false, "failed to start mining");
|
|
|
|
//wait for money, until balance will have enough money
|
|
w1.refresh(true, blocks_fetched, received_money, ok);
|
|
while(w1.unlocked_balance(0, true) < amount_to_transfer)
|
|
{
|
|
misc_utils::sleep_no_w(1000);
|
|
w1.refresh(true, blocks_fetched, received_money, ok);
|
|
}
|
|
|
|
//lets make a lot of small outs to ourselves
|
|
//since it is not possible to start from transaction that bigger than 20Kb, we gonna make transactions
|
|
//with 500 outs (about 18kb), and we have to wait appropriate count blocks, mined for test wallet
|
|
while(true)
|
|
{
|
|
tools::wallet2::transfer_container incoming_transfers;
|
|
w1.get_transfers(incoming_transfers);
|
|
if(incoming_transfers.size() > FIRST_N_TRANSFERS && get_money_in_first_transfers(incoming_transfers, FIRST_N_TRANSFERS) < w1.unlocked_balance(0, true) )
|
|
{
|
|
//lets go!
|
|
size_t count = 0;
|
|
BOOST_FOREACH(tools::wallet2::transfer_details& td, incoming_transfers)
|
|
{
|
|
cryptonote::transaction tx_s;
|
|
bool r = do_send_money(w1, w1, 0, td.m_tx.vout[td.m_internal_output_index].amount - TEST_FEE, tx_s, 50);
|
|
CHECK_AND_ASSERT_MES(r, false, "Failed to send starter tx " << get_transaction_hash(tx_s));
|
|
MGINFO_GREEN("Starter transaction sent " << get_transaction_hash(tx_s));
|
|
if(++count >= FIRST_N_TRANSFERS)
|
|
break;
|
|
}
|
|
break;
|
|
}else
|
|
{
|
|
misc_utils::sleep_no_w(1000);
|
|
w1.refresh(true, blocks_fetched, received_money, ok);
|
|
}
|
|
}
|
|
//do actual transfer
|
|
uint64_t transfered_money = 0;
|
|
uint64_t transfer_size = amount_to_transfer/transactions_count;
|
|
size_t i = 0;
|
|
struct tx_test_entry
|
|
{
|
|
transaction tx;
|
|
size_t m_received_count;
|
|
uint64_t amount_transfered;
|
|
};
|
|
crypto::key_image lst_sent_ki = AUTO_VAL_INIT(lst_sent_ki);
|
|
std::unordered_map<crypto::hash, tx_test_entry> txs;
|
|
for(i = 0; i != transactions_count; i++)
|
|
{
|
|
uint64_t amount_to_tx = (amount_to_transfer - transfered_money) > transfer_size ? transfer_size: (amount_to_transfer - transfered_money);
|
|
while(w1.unlocked_balance(0, true) < amount_to_tx + TEST_FEE)
|
|
{
|
|
misc_utils::sleep_no_w(1000);
|
|
LOG_PRINT_L0("not enough money, waiting for cashback or mining");
|
|
w1.refresh(true, blocks_fetched, received_money, ok);
|
|
}
|
|
|
|
transaction tx;
|
|
/*size_t n_attempts = 0;
|
|
while (!do_send_money(w1, w2, mix_in_factor, amount_to_tx, tx)) {
|
|
n_attempts++;
|
|
std::cout << "failed to transfer money, refresh and try again (attempts=" << n_attempts << ")" << std::endl;
|
|
w1.refresh();
|
|
}*/
|
|
|
|
|
|
if(!do_send_money(w1, w2, mix_in_factor, amount_to_tx, tx))
|
|
{
|
|
LOG_PRINT_L0("failed to transfer money, tx: " << get_transaction_hash(tx) << ", refresh and try again" );
|
|
w1.refresh(true, blocks_fetched, received_money, ok);
|
|
if(!do_send_money(w1, w2, mix_in_factor, amount_to_tx, tx))
|
|
{
|
|
LOG_PRINT_L0( "failed to transfer money, second chance. tx: " << get_transaction_hash(tx) << ", exit" );
|
|
LOCAL_ASSERT(false);
|
|
return false;
|
|
}
|
|
}
|
|
lst_sent_ki = boost::get<txin_to_key>(tx.vin[0]).k_image;
|
|
|
|
transfered_money += amount_to_tx;
|
|
|
|
LOG_PRINT_L0("transferred " << amount_to_tx << ", i=" << i );
|
|
tx_test_entry& ent = txs[get_transaction_hash(tx)] = tx_test_entry{};
|
|
ent.amount_transfered = amount_to_tx;
|
|
ent.tx = tx;
|
|
//if(i % transactions_per_second)
|
|
// misc_utils::sleep_no_w(1000);
|
|
}
|
|
|
|
|
|
LOG_PRINT_L0( "waiting some new blocks...");
|
|
misc_utils::sleep_no_w(DIFFICULTY_BLOCKS_ESTIMATE_TIMESPAN*20*1000);//wait two blocks before sync on another wallet on another daemon
|
|
LOG_PRINT_L0( "refreshing...");
|
|
bool recvd_money = false;
|
|
while(w2.refresh(true, blocks_fetched, recvd_money, ok) && ( (blocks_fetched && recvd_money) || !blocks_fetched ) )
|
|
{
|
|
misc_utils::sleep_no_w(DIFFICULTY_BLOCKS_ESTIMATE_TIMESPAN*1000);//wait two blocks before sync on another wallet on another daemon
|
|
}
|
|
|
|
uint64_t money_2 = w2.balance(0, true);
|
|
if(money_2 == transfered_money)
|
|
{
|
|
MGINFO_GREEN("-----------------------FINISHING TRANSACTIONS FLOW TEST OK-----------------------");
|
|
MGINFO_GREEN("transferred " << print_money(transfered_money) << " via " << i << " transactions" );
|
|
return true;
|
|
}else
|
|
{
|
|
tools::wallet2::transfer_container tc;
|
|
w2.get_transfers(tc);
|
|
BOOST_FOREACH(tools::wallet2::transfer_details& td, tc)
|
|
{
|
|
auto it = txs.find(td.m_txid);
|
|
CHECK_AND_ASSERT_MES(it != txs.end(), false, "transaction not found in local cache");
|
|
it->second.m_received_count += 1;
|
|
}
|
|
|
|
BOOST_FOREACH(auto& tx_pair, txs)
|
|
{
|
|
if(tx_pair.second.m_received_count != 1)
|
|
{
|
|
MERROR("Transaction lost: " << get_transaction_hash(tx_pair.second.tx));
|
|
}
|
|
|
|
}
|
|
|
|
MERROR("-----------------------FINISHING TRANSACTIONS FLOW TEST FAILED-----------------------" );
|
|
MERROR("income " << print_money(money_2) << " via " << i << " transactions, expected money = " << print_money(transfered_money) );
|
|
LOCAL_ASSERT(false);
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|