mirror of
https://github.com/cake-tech/cake_wallet.git
synced 2024-12-23 12:09:43 +00:00
698 lines
18 KiB
C++
698 lines
18 KiB
C++
#include <stdint.h>
|
|
#include "cstdlib"
|
|
#include <chrono>
|
|
#include <functional>
|
|
#include <iostream>
|
|
#include <unistd.h>
|
|
#include "thread"
|
|
#include "CwWalletListener.h"
|
|
#include "../External/android/monero/include/wallet2_api.h"
|
|
|
|
using namespace std::chrono_literals;
|
|
|
|
#ifdef __cplusplus
|
|
extern "C"
|
|
{
|
|
#endif
|
|
const uint64_t MONERO_BLOCK_SIZE = 1000;
|
|
|
|
struct Utf8Box
|
|
{
|
|
char *value;
|
|
|
|
Utf8Box(char *_value)
|
|
{
|
|
value = _value;
|
|
}
|
|
};
|
|
|
|
struct SubaddressRow
|
|
{
|
|
uint64_t id;
|
|
char *address;
|
|
char *label;
|
|
|
|
SubaddressRow(std::size_t _id, char *_address, char *_label)
|
|
{
|
|
id = static_cast<uint64_t>(_id);
|
|
address = _address;
|
|
label = _label;
|
|
}
|
|
};
|
|
|
|
struct AccountRow
|
|
{
|
|
uint64_t id;
|
|
char *label;
|
|
|
|
AccountRow(std::size_t _id, char *_label)
|
|
{
|
|
id = static_cast<uint64_t>(_id);
|
|
label = _label;
|
|
}
|
|
};
|
|
|
|
struct MoneroWalletListener : Monero::WalletListener
|
|
{
|
|
uint64_t m_height;
|
|
bool m_need_to_refresh;
|
|
bool m_new_transaction;
|
|
|
|
MoneroWalletListener()
|
|
{
|
|
m_height = 0;
|
|
m_need_to_refresh = false;
|
|
m_new_transaction = false;
|
|
}
|
|
|
|
void moneySpent(const std::string &txId, uint64_t amount)
|
|
{
|
|
m_new_transaction = true;
|
|
}
|
|
|
|
void moneyReceived(const std::string &txId, uint64_t amount)
|
|
{
|
|
m_new_transaction = true;
|
|
}
|
|
|
|
void unconfirmedMoneyReceived(const std::string &txId, uint64_t amount)
|
|
{
|
|
m_new_transaction = true;
|
|
}
|
|
|
|
void newBlock(uint64_t height)
|
|
{
|
|
m_height = height;
|
|
}
|
|
|
|
void updated()
|
|
{
|
|
m_need_to_refresh = true;
|
|
}
|
|
|
|
void refreshed()
|
|
{
|
|
m_need_to_refresh = true;
|
|
}
|
|
|
|
void resetNeedToRefresh()
|
|
{
|
|
m_need_to_refresh = false;
|
|
}
|
|
|
|
bool isNeedToRefresh()
|
|
{
|
|
return m_need_to_refresh;
|
|
}
|
|
|
|
bool isNewTransactionExist()
|
|
{
|
|
return m_new_transaction;
|
|
}
|
|
|
|
void resetIsNewTransactionExist()
|
|
{
|
|
m_new_transaction = false;
|
|
}
|
|
|
|
uint64_t height()
|
|
{
|
|
return m_height;
|
|
}
|
|
};
|
|
|
|
struct TransactionInfoRow
|
|
{
|
|
uint64_t amount;
|
|
uint64_t fee;
|
|
uint64_t blockHeight;
|
|
uint64_t confirmations;
|
|
uint32_t subaddrAccount;
|
|
int8_t direction;
|
|
int8_t isPending;
|
|
|
|
char *hash;
|
|
char *paymentId;
|
|
|
|
int64_t datetime;
|
|
|
|
TransactionInfoRow(Monero::TransactionInfo *transaction)
|
|
{
|
|
amount = transaction->amount();
|
|
fee = transaction->fee();
|
|
blockHeight = transaction->blockHeight();
|
|
subaddrAccount = transaction->subaddrAccount();
|
|
confirmations = transaction->confirmations();
|
|
datetime = static_cast<int64_t>(transaction->timestamp());
|
|
direction = transaction->direction();
|
|
isPending = static_cast<int8_t>(transaction->isPending());
|
|
std::string *hash_str = new std::string(transaction->hash());
|
|
hash = strdup(hash_str->c_str());
|
|
paymentId = strdup(transaction->paymentId().c_str());
|
|
}
|
|
};
|
|
|
|
struct PendingTransactionRaw
|
|
{
|
|
uint64_t amount;
|
|
uint64_t fee;
|
|
char *hash;
|
|
Monero::PendingTransaction *transaction;
|
|
|
|
PendingTransactionRaw(Monero::PendingTransaction *_transaction)
|
|
{
|
|
transaction = _transaction;
|
|
amount = _transaction->amount();
|
|
fee = _transaction->fee();
|
|
hash = strdup(_transaction->txid()[0].c_str());
|
|
}
|
|
};
|
|
|
|
Monero::Wallet *m_wallet;
|
|
Monero::TransactionHistory *m_transaction_history;
|
|
MoneroWalletListener *m_listener;
|
|
Monero::Subaddress *m_subaddress;
|
|
Monero::SubaddressAccount *m_account;
|
|
uint64_t m_last_known_wallet_height;
|
|
uint64_t m_cached_syncing_blockchain_height = 0;
|
|
std::mutex store_mutex;
|
|
|
|
|
|
void change_current_wallet(Monero::Wallet *wallet)
|
|
{
|
|
m_wallet = wallet;
|
|
m_listener = nullptr;
|
|
|
|
|
|
if (wallet != nullptr)
|
|
{
|
|
m_transaction_history = wallet->history();
|
|
}
|
|
else
|
|
{
|
|
m_transaction_history = nullptr;
|
|
}
|
|
|
|
if (wallet != nullptr)
|
|
{
|
|
m_account = wallet->subaddressAccount();
|
|
}
|
|
else
|
|
{
|
|
m_account = nullptr;
|
|
}
|
|
|
|
if (wallet != nullptr)
|
|
{
|
|
m_subaddress = wallet->subaddress();
|
|
}
|
|
else
|
|
{
|
|
m_subaddress = nullptr;
|
|
}
|
|
}
|
|
|
|
Monero::Wallet *get_current_wallet()
|
|
{
|
|
return m_wallet;
|
|
}
|
|
|
|
bool create_wallet(char *path, char *password, char *language, int32_t networkType, char *error)
|
|
{
|
|
Monero::NetworkType _networkType = static_cast<Monero::NetworkType>(networkType);
|
|
Monero::WalletManager *walletManager = Monero::WalletManagerFactory::getWalletManager();
|
|
Monero::Wallet *wallet = walletManager->createWallet(path, password, language, _networkType);
|
|
|
|
int status;
|
|
std::string errorString;
|
|
|
|
wallet->statusWithErrorString(status, errorString);
|
|
|
|
if (status != Monero::Wallet::Status_Ok)
|
|
{
|
|
error = strdup(errorString.c_str());
|
|
return false;
|
|
}
|
|
|
|
change_current_wallet(wallet);
|
|
|
|
return true;
|
|
}
|
|
|
|
bool restore_wallet_from_seed(char *path, char *password, char *seed, int32_t networkType, uint64_t restoreHeight, char *error)
|
|
{
|
|
Monero::NetworkType _networkType = static_cast<Monero::NetworkType>(networkType);
|
|
Monero::Wallet *wallet = Monero::WalletManagerFactory::getWalletManager()->recoveryWallet(
|
|
std::string(path),
|
|
std::string(password),
|
|
std::string(seed),
|
|
_networkType,
|
|
(uint64_t)restoreHeight);
|
|
|
|
int status;
|
|
std::string errorString;
|
|
|
|
wallet->statusWithErrorString(status, errorString);
|
|
|
|
if (status != Monero::Wallet::Status_Ok)
|
|
{
|
|
error = strdup(errorString.c_str());
|
|
return false;
|
|
}
|
|
|
|
change_current_wallet(wallet);
|
|
return true;
|
|
}
|
|
|
|
bool restore_wallet_from_keys(char *path, char *password, char *language, char *address, char *viewKey, char *spendKey, int32_t networkType, uint64_t restoreHeight, char *error)
|
|
{
|
|
Monero::NetworkType _networkType = static_cast<Monero::NetworkType>(networkType);
|
|
Monero::Wallet *wallet = Monero::WalletManagerFactory::getWalletManager()->createWalletFromKeys(
|
|
std::string(path),
|
|
std::string(password),
|
|
std::string(language),
|
|
_networkType,
|
|
(uint64_t)restoreHeight,
|
|
std::string(address),
|
|
std::string(viewKey),
|
|
std::string(spendKey));
|
|
|
|
int status;
|
|
std::string errorString;
|
|
|
|
wallet->statusWithErrorString(status, errorString);
|
|
|
|
if (status != Monero::Wallet::Status_Ok)
|
|
{
|
|
error = strdup(errorString.c_str());
|
|
return false;
|
|
}
|
|
|
|
change_current_wallet(wallet);
|
|
return true;
|
|
}
|
|
|
|
void load_wallet(char *path, char *password, int32_t nettype)
|
|
{
|
|
nice(19);
|
|
Monero::NetworkType networkType = static_cast<Monero::NetworkType>(nettype);
|
|
Monero::Wallet *wallet = Monero::WalletManagerFactory::getWalletManager()->openWallet(std::string(path), std::string(password), networkType);
|
|
change_current_wallet(wallet);
|
|
}
|
|
|
|
bool is_wallet_exist(char *path)
|
|
{
|
|
return Monero::WalletManagerFactory::getWalletManager()->walletExists(std::string(path));
|
|
}
|
|
|
|
void close_current_wallet()
|
|
{
|
|
Monero::WalletManagerFactory::getWalletManager()->closeWallet(get_current_wallet());
|
|
change_current_wallet(nullptr);
|
|
}
|
|
|
|
char *get_filename()
|
|
{
|
|
return strdup(get_current_wallet()->filename().c_str());
|
|
}
|
|
|
|
char *secret_view_key()
|
|
{
|
|
return strdup(get_current_wallet()->secretViewKey().c_str());
|
|
}
|
|
|
|
char *public_view_key()
|
|
{
|
|
return strdup(get_current_wallet()->publicViewKey().c_str());
|
|
}
|
|
|
|
char *secret_spend_key()
|
|
{
|
|
return strdup(get_current_wallet()->secretSpendKey().c_str());
|
|
}
|
|
|
|
char *public_spend_key()
|
|
{
|
|
return strdup(get_current_wallet()->publicSpendKey().c_str());
|
|
}
|
|
|
|
char *get_address(uint32_t account_index, uint32_t address_index)
|
|
{
|
|
return strdup(get_current_wallet()->address(account_index, address_index).c_str());
|
|
}
|
|
|
|
|
|
const char *seed()
|
|
{
|
|
return strdup(get_current_wallet()->seed().c_str());
|
|
}
|
|
|
|
uint64_t get_full_balance(uint32_t account_index)
|
|
{
|
|
return get_current_wallet()->balance(account_index);
|
|
}
|
|
|
|
uint64_t get_unlocked_balance(uint32_t account_index)
|
|
{
|
|
return get_current_wallet()->unlockedBalance(account_index);
|
|
}
|
|
|
|
uint64_t get_current_height()
|
|
{
|
|
return get_current_wallet()->blockChainHeight();
|
|
}
|
|
|
|
uint64_t get_node_height()
|
|
{
|
|
return get_current_wallet()->daemonBlockChainHeight();
|
|
}
|
|
|
|
bool connect_to_node(char *error)
|
|
{
|
|
bool is_connected = get_current_wallet()->connectToDaemon();
|
|
|
|
if (!is_connected)
|
|
{
|
|
error = strdup(get_current_wallet()->errorString().c_str());
|
|
}
|
|
|
|
return is_connected;
|
|
}
|
|
|
|
bool setup_node(char *address, char *login, char *password, bool use_ssl, bool is_light_wallet, char *error)
|
|
{
|
|
Monero::Wallet *wallet = get_current_wallet();
|
|
|
|
std::string _login = "";
|
|
std::string _password = "";
|
|
|
|
if (login != nullptr)
|
|
{
|
|
_login = std::string(login);
|
|
}
|
|
|
|
if (password != nullptr)
|
|
{
|
|
_password = std::string(password);
|
|
}
|
|
|
|
bool inited = wallet->init(std::string(address), 0, _login, _password, use_ssl, is_light_wallet);
|
|
|
|
if (!inited)
|
|
{
|
|
error = strdup(wallet->errorString().c_str());
|
|
} else if (!wallet->connectToDaemon()) {
|
|
error = strdup(wallet->errorString().c_str());
|
|
}
|
|
|
|
return inited;
|
|
}
|
|
|
|
bool is_connected()
|
|
{
|
|
return get_current_wallet()->connected();
|
|
}
|
|
|
|
void start_refresh()
|
|
{
|
|
get_current_wallet()->refreshAsync();
|
|
get_current_wallet()->startRefresh();
|
|
}
|
|
|
|
void set_refresh_from_block_height(uint64_t height)
|
|
{
|
|
get_current_wallet()->setRefreshFromBlockHeight(height);
|
|
}
|
|
|
|
void set_recovering_from_seed(bool is_recovery)
|
|
{
|
|
get_current_wallet()->setRecoveringFromSeed(is_recovery);
|
|
}
|
|
|
|
void store(char *path)
|
|
{
|
|
store_mutex.lock();
|
|
get_current_wallet()->store(std::string(path));
|
|
store_mutex.unlock();
|
|
}
|
|
|
|
bool transaction_create(char *address, char *payment_id, char *amount,
|
|
uint8_t priority_raw, uint32_t subaddr_account, Utf8Box &error, PendingTransactionRaw &pendingTransaction)
|
|
{
|
|
nice(19);
|
|
|
|
auto priority = static_cast<Monero::PendingTransaction::Priority>(priority_raw);
|
|
std::string _payment_id;
|
|
Monero::PendingTransaction *transaction;
|
|
|
|
if (payment_id != nullptr)
|
|
{
|
|
_payment_id = std::string(payment_id);
|
|
}
|
|
|
|
if (amount != nullptr)
|
|
{
|
|
uint64_t _amount = Monero::Wallet::amountFromString(std::string(amount));
|
|
transaction = m_wallet->createTransaction(std::string(address), _payment_id, _amount, m_wallet->defaultMixin(), priority, subaddr_account);
|
|
}
|
|
else
|
|
{
|
|
transaction = m_wallet->createTransaction(std::string(address), _payment_id, Monero::optional<uint64_t>(), m_wallet->defaultMixin(), priority, subaddr_account);
|
|
}
|
|
|
|
int status = transaction->status();
|
|
|
|
if (status == Monero::PendingTransaction::Status::Status_Error || status == Monero::PendingTransaction::Status::Status_Critical)
|
|
{
|
|
error = Utf8Box(strdup(transaction->errorString().c_str()));
|
|
return false;
|
|
}
|
|
|
|
m_listener->m_new_transaction = true;
|
|
|
|
pendingTransaction = PendingTransactionRaw(transaction);
|
|
return true;
|
|
}
|
|
|
|
bool transaction_commit(PendingTransactionRaw *transaction, Utf8Box &error)
|
|
{
|
|
bool committed = transaction->transaction->commit();
|
|
|
|
if (!committed)
|
|
{
|
|
error = Utf8Box(strdup(transaction->transaction->errorString().c_str()));
|
|
} else {
|
|
m_listener->m_new_transaction = true;
|
|
}
|
|
|
|
return committed;
|
|
}
|
|
|
|
uint64_t get_node_height_or_update(uint64_t base_eight)
|
|
{
|
|
if (m_cached_syncing_blockchain_height < base_eight) {
|
|
m_cached_syncing_blockchain_height = base_eight;
|
|
}
|
|
|
|
return m_cached_syncing_blockchain_height;
|
|
}
|
|
|
|
uint64_t get_syncing_height()
|
|
{
|
|
if (m_listener == nullptr) {
|
|
return 0;
|
|
}
|
|
|
|
uint64_t height = m_listener->height();
|
|
uint64_t node_height = get_node_height_or_update(height);
|
|
|
|
if (height <= 1 || node_height <= 0) {
|
|
return 0;
|
|
}
|
|
|
|
if (height != m_last_known_wallet_height)
|
|
{
|
|
m_last_known_wallet_height = height;
|
|
}
|
|
|
|
return height;
|
|
}
|
|
|
|
uint64_t is_needed_to_refresh()
|
|
{
|
|
if (m_listener == nullptr) {
|
|
return false;
|
|
}
|
|
|
|
bool should_refresh = m_listener->isNeedToRefresh();
|
|
uint64_t node_height = get_node_height_or_update(m_last_known_wallet_height);
|
|
|
|
if (should_refresh || (node_height - m_last_known_wallet_height < MONERO_BLOCK_SIZE))
|
|
{
|
|
m_listener->resetNeedToRefresh();
|
|
}
|
|
|
|
return should_refresh;
|
|
}
|
|
|
|
uint8_t is_new_transaction_exist()
|
|
{
|
|
if (m_listener == nullptr) {
|
|
return false;
|
|
}
|
|
|
|
bool is_new_transaction_exist = m_listener->isNewTransactionExist();
|
|
|
|
if (is_new_transaction_exist)
|
|
{
|
|
m_listener->resetIsNewTransactionExist();
|
|
}
|
|
|
|
return is_new_transaction_exist;
|
|
}
|
|
|
|
void set_listener()
|
|
{
|
|
m_last_known_wallet_height = 0;
|
|
|
|
if (m_listener != nullptr)
|
|
{
|
|
// free(m_listener);
|
|
}
|
|
|
|
m_listener = new MoneroWalletListener();
|
|
get_current_wallet()->setListener(m_listener);
|
|
}
|
|
|
|
int64_t *subaddrress_get_all()
|
|
{
|
|
std::vector<Monero::SubaddressRow *> _subaddresses = m_subaddress->getAll();
|
|
size_t size = _subaddresses.size();
|
|
int64_t *subaddresses = (int64_t *)malloc(size * sizeof(int64_t));
|
|
|
|
for (int i = 0; i < size; i++)
|
|
{
|
|
Monero::SubaddressRow *row = _subaddresses[i];
|
|
SubaddressRow *_row = new SubaddressRow(row->getRowId(), strdup(row->getAddress().c_str()), strdup(row->getLabel().c_str()));
|
|
subaddresses[i] = reinterpret_cast<int64_t>(_row);
|
|
}
|
|
|
|
return subaddresses;
|
|
}
|
|
|
|
int32_t subaddrress_size()
|
|
{
|
|
std::vector<Monero::SubaddressRow *> _subaddresses = m_subaddress->getAll();
|
|
return _subaddresses.size();
|
|
}
|
|
|
|
void subaddress_add_row(uint32_t accountIndex, char *label)
|
|
{
|
|
m_subaddress->addRow(accountIndex, std::string(label));
|
|
}
|
|
|
|
void subaddress_set_label(uint32_t accountIndex, uint32_t addressIndex, char *label)
|
|
{
|
|
m_subaddress->setLabel(accountIndex, addressIndex, std::string(label));
|
|
}
|
|
|
|
void subaddress_refresh(uint32_t accountIndex)
|
|
{
|
|
m_subaddress->refresh(accountIndex);
|
|
}
|
|
|
|
int32_t account_size()
|
|
{
|
|
std::vector<Monero::SubaddressAccountRow *> _accocunts = m_account->getAll();
|
|
return _accocunts.size();
|
|
}
|
|
|
|
int64_t *account_get_all()
|
|
{
|
|
std::vector<Monero::SubaddressAccountRow *> _accocunts = m_account->getAll();
|
|
size_t size = _accocunts.size();
|
|
int64_t *accocunts = (int64_t *)malloc(size * sizeof(int64_t));
|
|
|
|
for (int i = 0; i < size; i++)
|
|
{
|
|
Monero::SubaddressAccountRow *row = _accocunts[i];
|
|
AccountRow *_row = new AccountRow(row->getRowId(), strdup(row->getLabel().c_str()));
|
|
accocunts[i] = reinterpret_cast<int64_t>(_row);
|
|
}
|
|
|
|
return accocunts;
|
|
}
|
|
|
|
void account_add_row(char *label)
|
|
{
|
|
m_account->addRow(std::string(label));
|
|
}
|
|
|
|
void account_set_label_row(uint32_t account_index, char *label)
|
|
{
|
|
m_account->setLabel(account_index, label);
|
|
}
|
|
|
|
void account_refresh()
|
|
{
|
|
m_account->refresh();
|
|
}
|
|
|
|
int64_t *transactions_get_all()
|
|
{
|
|
std::vector<Monero::TransactionInfo *> transactions = m_transaction_history->getAll();
|
|
size_t size = transactions.size();
|
|
int64_t *transactionAddresses = (int64_t *)malloc(size * sizeof(int64_t));
|
|
|
|
for (int i = 0; i < size; i++)
|
|
{
|
|
Monero::TransactionInfo *row = transactions[i];
|
|
TransactionInfoRow *tx = new TransactionInfoRow(row);
|
|
transactionAddresses[i] = reinterpret_cast<int64_t>(tx);
|
|
}
|
|
|
|
return transactionAddresses;
|
|
}
|
|
|
|
void transactions_refresh()
|
|
{
|
|
m_transaction_history->refresh();
|
|
}
|
|
|
|
int64_t transactions_count()
|
|
{
|
|
return m_transaction_history->count();
|
|
}
|
|
|
|
int LedgerExchange(
|
|
unsigned char *command,
|
|
unsigned int cmd_len,
|
|
unsigned char *response,
|
|
unsigned int max_resp_len)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
int LedgerFind(char *buffer, size_t len)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
void on_startup()
|
|
{
|
|
Monero::Utils::onStartup();
|
|
}
|
|
|
|
void rescan_blockchain()
|
|
{
|
|
m_wallet->rescanBlockchainAsync();
|
|
}
|
|
|
|
char * get_tx_key(char * txId)
|
|
{
|
|
return strdup(m_wallet->getTxKey(std::string(txId)).c_str());
|
|
}
|
|
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|