mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-03-09 15:37:00 -04:00
7e2e62cf7c
This commit does not change behavior. It just adds new skeleton classes that don't do anything and aren't instantiated yet.
487 lines
18 KiB
C++
487 lines
18 KiB
C++
// Copyright (c) 2018 The Bitcoin Core developers
|
|
// Distributed under the MIT software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#include <interfaces/wallet.h>
|
|
|
|
#include <amount.h>
|
|
#include <chain.h>
|
|
#include <consensus/validation.h>
|
|
#include <interfaces/chain.h>
|
|
#include <interfaces/handler.h>
|
|
#include <net.h>
|
|
#include <policy/feerate.h>
|
|
#include <policy/fees.h>
|
|
#include <policy/policy.h>
|
|
#include <primitives/transaction.h>
|
|
#include <script/ismine.h>
|
|
#include <script/standard.h>
|
|
#include <support/allocators/secure.h>
|
|
#include <sync.h>
|
|
#include <timedata.h>
|
|
#include <ui_interface.h>
|
|
#include <uint256.h>
|
|
#include <util/system.h>
|
|
#include <validation.h>
|
|
#include <wallet/feebumper.h>
|
|
#include <wallet/fees.h>
|
|
#include <wallet/wallet.h>
|
|
|
|
#include <memory>
|
|
#include <string>
|
|
#include <utility>
|
|
#include <vector>
|
|
|
|
namespace interfaces {
|
|
namespace {
|
|
|
|
class PendingWalletTxImpl : public PendingWalletTx
|
|
{
|
|
public:
|
|
explicit PendingWalletTxImpl(CWallet& wallet) : m_wallet(wallet), m_key(&wallet) {}
|
|
|
|
const CTransaction& get() override { return *m_tx; }
|
|
|
|
int64_t getVirtualSize() override { return GetVirtualTransactionSize(*m_tx); }
|
|
|
|
bool commit(WalletValueMap value_map,
|
|
WalletOrderForm order_form,
|
|
std::string& reject_reason) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
CValidationState state;
|
|
if (!m_wallet.CommitTransaction(m_tx, std::move(value_map), std::move(order_form), m_key, g_connman.get(), state)) {
|
|
reject_reason = state.GetRejectReason();
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
CTransactionRef m_tx;
|
|
CWallet& m_wallet;
|
|
CReserveKey m_key;
|
|
};
|
|
|
|
//! Construct wallet tx struct.
|
|
static WalletTx MakeWalletTx(CWallet& wallet, const CWalletTx& wtx) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
|
|
{
|
|
WalletTx result;
|
|
result.tx = wtx.tx;
|
|
result.txin_is_mine.reserve(wtx.tx->vin.size());
|
|
for (const auto& txin : wtx.tx->vin) {
|
|
result.txin_is_mine.emplace_back(wallet.IsMine(txin));
|
|
}
|
|
result.txout_is_mine.reserve(wtx.tx->vout.size());
|
|
result.txout_address.reserve(wtx.tx->vout.size());
|
|
result.txout_address_is_mine.reserve(wtx.tx->vout.size());
|
|
for (const auto& txout : wtx.tx->vout) {
|
|
result.txout_is_mine.emplace_back(wallet.IsMine(txout));
|
|
result.txout_address.emplace_back();
|
|
result.txout_address_is_mine.emplace_back(ExtractDestination(txout.scriptPubKey, result.txout_address.back()) ?
|
|
IsMine(wallet, result.txout_address.back()) :
|
|
ISMINE_NO);
|
|
}
|
|
result.credit = wtx.GetCredit(ISMINE_ALL);
|
|
result.debit = wtx.GetDebit(ISMINE_ALL);
|
|
result.change = wtx.GetChange();
|
|
result.time = wtx.GetTxTime();
|
|
result.value_map = wtx.mapValue;
|
|
result.is_coinbase = wtx.IsCoinBase();
|
|
return result;
|
|
}
|
|
|
|
//! Construct wallet tx status struct.
|
|
static WalletTxStatus MakeWalletTxStatus(const CWalletTx& wtx) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
|
|
{
|
|
WalletTxStatus result;
|
|
auto mi = ::mapBlockIndex.find(wtx.hashBlock);
|
|
CBlockIndex* block = mi != ::mapBlockIndex.end() ? mi->second : nullptr;
|
|
result.block_height = (block ? block->nHeight : std::numeric_limits<int>::max());
|
|
result.blocks_to_maturity = wtx.GetBlocksToMaturity();
|
|
result.depth_in_main_chain = wtx.GetDepthInMainChain();
|
|
result.time_received = wtx.nTimeReceived;
|
|
result.lock_time = wtx.tx->nLockTime;
|
|
result.is_final = CheckFinalTx(*wtx.tx);
|
|
result.is_trusted = wtx.IsTrusted();
|
|
result.is_abandoned = wtx.isAbandoned();
|
|
result.is_coinbase = wtx.IsCoinBase();
|
|
result.is_in_main_chain = wtx.IsInMainChain();
|
|
return result;
|
|
}
|
|
|
|
//! Construct wallet TxOut struct.
|
|
static WalletTxOut MakeWalletTxOut(CWallet& wallet, const CWalletTx& wtx, int n, int depth) EXCLUSIVE_LOCKS_REQUIRED(cs_main, wallet.cs_wallet)
|
|
{
|
|
WalletTxOut result;
|
|
result.txout = wtx.tx->vout[n];
|
|
result.time = wtx.GetTxTime();
|
|
result.depth_in_main_chain = depth;
|
|
result.is_spent = wallet.IsSpent(wtx.GetHash(), n);
|
|
return result;
|
|
}
|
|
|
|
class WalletImpl : public Wallet
|
|
{
|
|
public:
|
|
explicit WalletImpl(const std::shared_ptr<CWallet>& wallet) : m_shared_wallet(wallet), m_wallet(*wallet.get()) {}
|
|
|
|
bool encryptWallet(const SecureString& wallet_passphrase) override
|
|
{
|
|
return m_wallet.EncryptWallet(wallet_passphrase);
|
|
}
|
|
bool isCrypted() override { return m_wallet.IsCrypted(); }
|
|
bool lock() override { return m_wallet.Lock(); }
|
|
bool unlock(const SecureString& wallet_passphrase) override { return m_wallet.Unlock(wallet_passphrase); }
|
|
bool isLocked() override { return m_wallet.IsLocked(); }
|
|
bool changeWalletPassphrase(const SecureString& old_wallet_passphrase,
|
|
const SecureString& new_wallet_passphrase) override
|
|
{
|
|
return m_wallet.ChangeWalletPassphrase(old_wallet_passphrase, new_wallet_passphrase);
|
|
}
|
|
void abortRescan() override { m_wallet.AbortRescan(); }
|
|
bool backupWallet(const std::string& filename) override { return m_wallet.BackupWallet(filename); }
|
|
std::string getWalletName() override { return m_wallet.GetName(); }
|
|
bool getKeyFromPool(bool internal, CPubKey& pub_key) override
|
|
{
|
|
return m_wallet.GetKeyFromPool(pub_key, internal);
|
|
}
|
|
bool getPubKey(const CKeyID& address, CPubKey& pub_key) override { return m_wallet.GetPubKey(address, pub_key); }
|
|
bool getPrivKey(const CKeyID& address, CKey& key) override { return m_wallet.GetKey(address, key); }
|
|
bool isSpendable(const CTxDestination& dest) override { return IsMine(m_wallet, dest) & ISMINE_SPENDABLE; }
|
|
bool haveWatchOnly() override { return m_wallet.HaveWatchOnly(); };
|
|
bool setAddressBook(const CTxDestination& dest, const std::string& name, const std::string& purpose) override
|
|
{
|
|
return m_wallet.SetAddressBook(dest, name, purpose);
|
|
}
|
|
bool delAddressBook(const CTxDestination& dest) override
|
|
{
|
|
return m_wallet.DelAddressBook(dest);
|
|
}
|
|
bool getAddress(const CTxDestination& dest,
|
|
std::string* name,
|
|
isminetype* is_mine,
|
|
std::string* purpose) override
|
|
{
|
|
LOCK(m_wallet.cs_wallet);
|
|
auto it = m_wallet.mapAddressBook.find(dest);
|
|
if (it == m_wallet.mapAddressBook.end()) {
|
|
return false;
|
|
}
|
|
if (name) {
|
|
*name = it->second.name;
|
|
}
|
|
if (is_mine) {
|
|
*is_mine = IsMine(m_wallet, dest);
|
|
}
|
|
if (purpose) {
|
|
*purpose = it->second.purpose;
|
|
}
|
|
return true;
|
|
}
|
|
std::vector<WalletAddress> getAddresses() override
|
|
{
|
|
LOCK(m_wallet.cs_wallet);
|
|
std::vector<WalletAddress> result;
|
|
for (const auto& item : m_wallet.mapAddressBook) {
|
|
result.emplace_back(item.first, IsMine(m_wallet, item.first), item.second.name, item.second.purpose);
|
|
}
|
|
return result;
|
|
}
|
|
void learnRelatedScripts(const CPubKey& key, OutputType type) override { m_wallet.LearnRelatedScripts(key, type); }
|
|
bool addDestData(const CTxDestination& dest, const std::string& key, const std::string& value) override
|
|
{
|
|
LOCK(m_wallet.cs_wallet);
|
|
return m_wallet.AddDestData(dest, key, value);
|
|
}
|
|
bool eraseDestData(const CTxDestination& dest, const std::string& key) override
|
|
{
|
|
LOCK(m_wallet.cs_wallet);
|
|
return m_wallet.EraseDestData(dest, key);
|
|
}
|
|
std::vector<std::string> getDestValues(const std::string& prefix) override
|
|
{
|
|
return m_wallet.GetDestValues(prefix);
|
|
}
|
|
void lockCoin(const COutPoint& output) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.LockCoin(output);
|
|
}
|
|
void unlockCoin(const COutPoint& output) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.UnlockCoin(output);
|
|
}
|
|
bool isLockedCoin(const COutPoint& output) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.IsLockedCoin(output.hash, output.n);
|
|
}
|
|
void listLockedCoins(std::vector<COutPoint>& outputs) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.ListLockedCoins(outputs);
|
|
}
|
|
std::unique_ptr<PendingWalletTx> createTransaction(const std::vector<CRecipient>& recipients,
|
|
const CCoinControl& coin_control,
|
|
bool sign,
|
|
int& change_pos,
|
|
CAmount& fee,
|
|
std::string& fail_reason) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
auto pending = MakeUnique<PendingWalletTxImpl>(m_wallet);
|
|
if (!m_wallet.CreateTransaction(recipients, pending->m_tx, pending->m_key, fee, change_pos,
|
|
fail_reason, coin_control, sign)) {
|
|
return {};
|
|
}
|
|
return std::move(pending);
|
|
}
|
|
bool transactionCanBeAbandoned(const uint256& txid) override { return m_wallet.TransactionCanBeAbandoned(txid); }
|
|
bool abandonTransaction(const uint256& txid) override
|
|
{
|
|
LOCK2(cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.AbandonTransaction(txid);
|
|
}
|
|
bool transactionCanBeBumped(const uint256& txid) override
|
|
{
|
|
return feebumper::TransactionCanBeBumped(&m_wallet, txid);
|
|
}
|
|
bool createBumpTransaction(const uint256& txid,
|
|
const CCoinControl& coin_control,
|
|
CAmount total_fee,
|
|
std::vector<std::string>& errors,
|
|
CAmount& old_fee,
|
|
CAmount& new_fee,
|
|
CMutableTransaction& mtx) override
|
|
{
|
|
return feebumper::CreateTransaction(&m_wallet, txid, coin_control, total_fee, errors, old_fee, new_fee, mtx) ==
|
|
feebumper::Result::OK;
|
|
}
|
|
bool signBumpTransaction(CMutableTransaction& mtx) override { return feebumper::SignTransaction(&m_wallet, mtx); }
|
|
bool commitBumpTransaction(const uint256& txid,
|
|
CMutableTransaction&& mtx,
|
|
std::vector<std::string>& errors,
|
|
uint256& bumped_txid) override
|
|
{
|
|
return feebumper::CommitTransaction(&m_wallet, txid, std::move(mtx), errors, bumped_txid) ==
|
|
feebumper::Result::OK;
|
|
}
|
|
CTransactionRef getTx(const uint256& txid) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
auto mi = m_wallet.mapWallet.find(txid);
|
|
if (mi != m_wallet.mapWallet.end()) {
|
|
return mi->second.tx;
|
|
}
|
|
return {};
|
|
}
|
|
WalletTx getWalletTx(const uint256& txid) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
auto mi = m_wallet.mapWallet.find(txid);
|
|
if (mi != m_wallet.mapWallet.end()) {
|
|
return MakeWalletTx(m_wallet, mi->second);
|
|
}
|
|
return {};
|
|
}
|
|
std::vector<WalletTx> getWalletTxs() override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
std::vector<WalletTx> result;
|
|
result.reserve(m_wallet.mapWallet.size());
|
|
for (const auto& entry : m_wallet.mapWallet) {
|
|
result.emplace_back(MakeWalletTx(m_wallet, entry.second));
|
|
}
|
|
return result;
|
|
}
|
|
bool tryGetTxStatus(const uint256& txid,
|
|
interfaces::WalletTxStatus& tx_status,
|
|
int& num_blocks) override
|
|
{
|
|
TRY_LOCK(::cs_main, locked_chain);
|
|
if (!locked_chain) {
|
|
return false;
|
|
}
|
|
TRY_LOCK(m_wallet.cs_wallet, locked_wallet);
|
|
if (!locked_wallet) {
|
|
return false;
|
|
}
|
|
auto mi = m_wallet.mapWallet.find(txid);
|
|
if (mi == m_wallet.mapWallet.end()) {
|
|
return false;
|
|
}
|
|
num_blocks = ::chainActive.Height();
|
|
tx_status = MakeWalletTxStatus(mi->second);
|
|
return true;
|
|
}
|
|
WalletTx getWalletTxDetails(const uint256& txid,
|
|
WalletTxStatus& tx_status,
|
|
WalletOrderForm& order_form,
|
|
bool& in_mempool,
|
|
int& num_blocks) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
auto mi = m_wallet.mapWallet.find(txid);
|
|
if (mi != m_wallet.mapWallet.end()) {
|
|
num_blocks = ::chainActive.Height();
|
|
in_mempool = mi->second.InMempool();
|
|
order_form = mi->second.vOrderForm;
|
|
tx_status = MakeWalletTxStatus(mi->second);
|
|
return MakeWalletTx(m_wallet, mi->second);
|
|
}
|
|
return {};
|
|
}
|
|
WalletBalances getBalances() override
|
|
{
|
|
WalletBalances result;
|
|
result.balance = m_wallet.GetBalance();
|
|
result.unconfirmed_balance = m_wallet.GetUnconfirmedBalance();
|
|
result.immature_balance = m_wallet.GetImmatureBalance();
|
|
result.have_watch_only = m_wallet.HaveWatchOnly();
|
|
if (result.have_watch_only) {
|
|
result.watch_only_balance = m_wallet.GetBalance(ISMINE_WATCH_ONLY);
|
|
result.unconfirmed_watch_only_balance = m_wallet.GetUnconfirmedWatchOnlyBalance();
|
|
result.immature_watch_only_balance = m_wallet.GetImmatureWatchOnlyBalance();
|
|
}
|
|
return result;
|
|
}
|
|
bool tryGetBalances(WalletBalances& balances, int& num_blocks) override
|
|
{
|
|
TRY_LOCK(cs_main, locked_chain);
|
|
if (!locked_chain) return false;
|
|
TRY_LOCK(m_wallet.cs_wallet, locked_wallet);
|
|
if (!locked_wallet) {
|
|
return false;
|
|
}
|
|
balances = getBalances();
|
|
num_blocks = ::chainActive.Height();
|
|
return true;
|
|
}
|
|
CAmount getBalance() override { return m_wallet.GetBalance(); }
|
|
CAmount getAvailableBalance(const CCoinControl& coin_control) override
|
|
{
|
|
return m_wallet.GetAvailableBalance(&coin_control);
|
|
}
|
|
isminetype txinIsMine(const CTxIn& txin) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.IsMine(txin);
|
|
}
|
|
isminetype txoutIsMine(const CTxOut& txout) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.IsMine(txout);
|
|
}
|
|
CAmount getDebit(const CTxIn& txin, isminefilter filter) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.GetDebit(txin, filter);
|
|
}
|
|
CAmount getCredit(const CTxOut& txout, isminefilter filter) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
return m_wallet.GetCredit(txout, filter);
|
|
}
|
|
CoinsList listCoins() override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
CoinsList result;
|
|
for (const auto& entry : m_wallet.ListCoins()) {
|
|
auto& group = result[entry.first];
|
|
for (const auto& coin : entry.second) {
|
|
group.emplace_back(
|
|
COutPoint(coin.tx->GetHash(), coin.i), MakeWalletTxOut(m_wallet, *coin.tx, coin.i, coin.nDepth));
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
std::vector<WalletTxOut> getCoins(const std::vector<COutPoint>& outputs) override
|
|
{
|
|
LOCK2(::cs_main, m_wallet.cs_wallet);
|
|
std::vector<WalletTxOut> result;
|
|
result.reserve(outputs.size());
|
|
for (const auto& output : outputs) {
|
|
result.emplace_back();
|
|
auto it = m_wallet.mapWallet.find(output.hash);
|
|
if (it != m_wallet.mapWallet.end()) {
|
|
int depth = it->second.GetDepthInMainChain();
|
|
if (depth >= 0) {
|
|
result.back() = MakeWalletTxOut(m_wallet, it->second, output.n, depth);
|
|
}
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
CAmount getRequiredFee(unsigned int tx_bytes) override { return GetRequiredFee(m_wallet, tx_bytes); }
|
|
CAmount getMinimumFee(unsigned int tx_bytes,
|
|
const CCoinControl& coin_control,
|
|
int* returned_target,
|
|
FeeReason* reason) override
|
|
{
|
|
FeeCalculation fee_calc;
|
|
CAmount result;
|
|
result = GetMinimumFee(m_wallet, tx_bytes, coin_control, ::mempool, ::feeEstimator, &fee_calc);
|
|
if (returned_target) *returned_target = fee_calc.returnedTarget;
|
|
if (reason) *reason = fee_calc.reason;
|
|
return result;
|
|
}
|
|
unsigned int getConfirmTarget() override { return m_wallet.m_confirm_target; }
|
|
bool hdEnabled() override { return m_wallet.IsHDEnabled(); }
|
|
bool IsWalletFlagSet(uint64_t flag) override { return m_wallet.IsWalletFlagSet(flag); }
|
|
OutputType getDefaultAddressType() override { return m_wallet.m_default_address_type; }
|
|
OutputType getDefaultChangeType() override { return m_wallet.m_default_change_type; }
|
|
std::unique_ptr<Handler> handleUnload(UnloadFn fn) override
|
|
{
|
|
return MakeHandler(m_wallet.NotifyUnload.connect(fn));
|
|
}
|
|
std::unique_ptr<Handler> handleShowProgress(ShowProgressFn fn) override
|
|
{
|
|
return MakeHandler(m_wallet.ShowProgress.connect(fn));
|
|
}
|
|
std::unique_ptr<Handler> handleStatusChanged(StatusChangedFn fn) override
|
|
{
|
|
return MakeHandler(m_wallet.NotifyStatusChanged.connect([fn](CCryptoKeyStore*) { fn(); }));
|
|
}
|
|
std::unique_ptr<Handler> handleAddressBookChanged(AddressBookChangedFn fn) override
|
|
{
|
|
return MakeHandler(m_wallet.NotifyAddressBookChanged.connect(
|
|
[fn](CWallet*, const CTxDestination& address, const std::string& label, bool is_mine,
|
|
const std::string& purpose, ChangeType status) { fn(address, label, is_mine, purpose, status); }));
|
|
}
|
|
std::unique_ptr<Handler> handleTransactionChanged(TransactionChangedFn fn) override
|
|
{
|
|
return MakeHandler(m_wallet.NotifyTransactionChanged.connect(
|
|
[fn](CWallet*, const uint256& txid, ChangeType status) { fn(txid, status); }));
|
|
}
|
|
std::unique_ptr<Handler> handleWatchOnlyChanged(WatchOnlyChangedFn fn) override
|
|
{
|
|
return MakeHandler(m_wallet.NotifyWatchonlyChanged.connect(fn));
|
|
}
|
|
|
|
std::shared_ptr<CWallet> m_shared_wallet;
|
|
CWallet& m_wallet;
|
|
};
|
|
|
|
class WalletClientImpl : public ChainClient
|
|
{
|
|
public:
|
|
WalletClientImpl(Chain& chain, std::vector<std::string> wallet_filenames)
|
|
: m_chain(chain), m_wallet_filenames(std::move(wallet_filenames))
|
|
{
|
|
}
|
|
|
|
Chain& m_chain;
|
|
std::vector<std::string> m_wallet_filenames;
|
|
};
|
|
|
|
} // namespace
|
|
|
|
std::unique_ptr<Wallet> MakeWallet(const std::shared_ptr<CWallet>& wallet) { return MakeUnique<WalletImpl>(wallet); }
|
|
|
|
std::unique_ptr<ChainClient> MakeWalletClient(Chain& chain, std::vector<std::string> wallet_filenames)
|
|
{
|
|
return MakeUnique<WalletClientImpl>(chain, std::move(wallet_filenames));
|
|
}
|
|
|
|
} // namespace interfaces
|