Merge pull request #32

f0d2e58 make splash less resource intensive (Jacob Brydolf)
ad2943f libwallet_api: switched to main repo (Ilya Kitaev)
f402fd9 Wallet::daemonBlockChainHeight(); BC sync progress in GUI (Ilya Kitaev)
7e769b3 Wallet: moneySpent, moneyReceived, newBlock signals (Ilya Kitaev)
This commit is contained in:
Riccardo Spagni 2016-10-04 12:27:33 +02:00
commit a9a279c979
No known key found for this signature in database
GPG key ID: 55432DF31CCD4FCD
6 changed files with 106 additions and 22 deletions

View file

@ -32,13 +32,15 @@ import QtQuick.Controls 1.4
import QtQuick.Layouts 1.1 import QtQuick.Layouts 1.1
Window { Window {
id: splash id: root
modality: Qt.ApplicationModal modality: Qt.ApplicationModal
flags: Qt.Window | Qt.FramelessWindowHint flags: Qt.Window | Qt.FramelessWindowHint
property alias message: message.text property alias messageText: messageTitle.text
property alias heightProgressText : heightProgress.text
width: 200 width: 200
height: 100 height: 100
opacity: 0.5 opacity: 0.7
ColumnLayout { ColumnLayout {
anchors.horizontalCenter: parent.horizontalCenter anchors.horizontalCenter: parent.horizontalCenter
@ -50,14 +52,23 @@ Window {
} }
Text { Text {
id: message id: messageTitle
text: "Please wait..." text: "Please wait..."
font { font {
pointSize: 22 pointSize: 22
} }
horizontalAlignment: Text.AlignHCenter horizontalAlignment: Text.AlignHCenter
Layout.alignment: Qt.AlignVCenter | Qt.AlignHCenter
}
Text {
id: heightProgress
font {
pointSize: 18
}
horizontalAlignment: Text.AlignHCenter
Layout.alignment: Qt.AlignVCenter | Qt.AlignHCenter
} }
} }
} }

View file

@ -3,6 +3,8 @@
MONERO_URL=https://github.com/monero-project/monero.git MONERO_URL=https://github.com/monero-project/monero.git
MONERO_BRANCH=master MONERO_BRANCH=master
# MONERO_URL=https://github.com/mbg033/monero.git
# MONERO_BRANCH=develop
# thanks to SO: http://stackoverflow.com/a/20283965/4118915 # thanks to SO: http://stackoverflow.com/a/20283965/4118915
CPU_CORE_COUNT=$(grep -c ^processor /proc/cpuinfo 2>/dev/null || sysctl -n hw.ncpu) CPU_CORE_COUNT=$(grep -c ^processor /proc/cpuinfo 2>/dev/null || sysctl -n hw.ncpu)
pushd $(pwd) pushd $(pwd)

View file

@ -114,7 +114,7 @@ int main(int argc, char *argv[])
QObject::connect(eventFilter, SIGNAL(mousePressed(QVariant,QVariant,QVariant)), rootObject, SLOT(mousePressed(QVariant,QVariant,QVariant))); QObject::connect(eventFilter, SIGNAL(mousePressed(QVariant,QVariant,QVariant)), rootObject, SLOT(mousePressed(QVariant,QVariant,QVariant)));
QObject::connect(eventFilter, SIGNAL(mouseReleased(QVariant,QVariant,QVariant)), rootObject, SLOT(mouseReleased(QVariant,QVariant,QVariant))); QObject::connect(eventFilter, SIGNAL(mouseReleased(QVariant,QVariant,QVariant)), rootObject, SLOT(mouseReleased(QVariant,QVariant,QVariant)));
WalletManager::instance()->setLogLevel(WalletManager::LogLevel_Max); // WalletManager::instance()->setLogLevel(WalletManager::LogLevel_Max);
return app.exec(); return app.exec();
} }

View file

@ -52,7 +52,7 @@ ApplicationWindow {
property var currentWallet; property var currentWallet;
property var transaction; property var transaction;
property alias password : passwordDialog.password property alias password : passwordDialog.password
property int splashCounter: 0
function altKeyReleased() { ctrlPressed = false; } function altKeyReleased() { ctrlPressed = false; }
@ -156,8 +156,12 @@ ApplicationWindow {
currentWallet = wallet currentWallet = wallet
currentWallet.refreshed.connect(onWalletRefresh) currentWallet.refreshed.connect(onWalletRefresh)
currentWallet.updated.connect(onWalletUpdate) currentWallet.updated.connect(onWalletUpdate)
currentWallet.newBlock.connect(onWalletNewBlock)
console.log("initializing with daemon address: ", persistentSettings.daemon_address) console.log("initializing with daemon address: ", persistentSettings.daemon_address)
currentWallet.initAsync(persistentSettings.daemon_address, 0); currentWallet.initAsync(persistentSettings.daemon_address, 0);
} }
function walletPath() { function walletPath() {
@ -219,6 +223,18 @@ ApplicationWindow {
onWalletUpdate(); onWalletUpdate();
} }
function onWalletNewBlock(blockHeight) {
if (splash.visible) {
var currHeight = blockHeight.toFixed(0)
if(currHeight > splashCounter + 1000){
splashCounter = currHeight
var progressText = qsTr("Synchronizing blocks %1/%2").arg(currHeight).arg(currentWallet.daemonBlockChainHeight().toFixed(0));
console.log("Progress text: " + progressText);
splash.heightProgressText = progressText
}
}
}
function walletsFound() { function walletsFound() {
var wallets = walletManager.findWallets(moneroAccountsDir); var wallets = walletManager.findWallets(moneroAccountsDir);
@ -418,7 +434,7 @@ ApplicationWindow {
height: appWindow.height / 2 height: appWindow.height / 2
x: (appWindow.width - width) / 2 + appWindow.x x: (appWindow.width - width) / 2 + appWindow.x
y: (appWindow.height - height) / 2 + appWindow.y y: (appWindow.height - height) / 2 + appWindow.y
message: qsTr("Please wait...") messageText: qsTr("Please wait...")
} }

View file

@ -10,8 +10,7 @@
#include <QTimer> #include <QTimer>
namespace { namespace {
static const int DAEMON_BLOCKCHAIN_HEIGHT_CACHE_TTL_SECONDS = 60;
} }
class WalletListenerImpl : public Bitmonero::WalletListener class WalletListenerImpl : public Bitmonero::WalletListener
@ -25,18 +24,22 @@ public:
virtual void moneySpent(const std::string &txId, uint64_t amount) virtual void moneySpent(const std::string &txId, uint64_t amount)
{ {
// TODO
Q_UNUSED(txId)
Q_UNUSED(amount)
qDebug() << __FUNCTION__; qDebug() << __FUNCTION__;
emit m_wallet->moneySpent(QString::fromStdString(txId), amount);
} }
virtual void moneyReceived(const std::string &txId, uint64_t amount) virtual void moneyReceived(const std::string &txId, uint64_t amount)
{ {
// TODO
Q_UNUSED(txId)
Q_UNUSED(amount)
qDebug() << __FUNCTION__; qDebug() << __FUNCTION__;
emit m_wallet->moneyReceived(QString::fromStdString(txId), amount);
}
virtual void newBlock(uint64_t height)
{
// qDebug() << __FUNCTION__;
emit m_wallet->newBlock(height);
} }
virtual void updated() virtual void updated()
@ -133,6 +136,23 @@ quint64 Wallet::unlockedBalance() const
return m_walletImpl->unlockedBalance(); return m_walletImpl->unlockedBalance();
} }
quint64 Wallet::blockChainHeight() const
{
return m_walletImpl->blockChainHeight();
}
quint64 Wallet::daemonBlockChainHeight() const
{
// cache daemon blockchain height for some time (60 seconds by default)
if (m_daemonBlockChainHeight == 0
|| m_daemonBlockChainHeightTime.elapsed() / 1000 > m_daemonBlockChainHeightTtl) {
m_daemonBlockChainHeight = m_walletImpl->daemonBlockChainHeight();
m_daemonBlockChainHeightTime.restart();
}
return m_daemonBlockChainHeight;
}
bool Wallet::refresh() bool Wallet::refresh()
{ {
bool result = m_walletImpl->refresh(); bool result = m_walletImpl->refresh();
@ -146,6 +166,16 @@ void Wallet::refreshAsync()
m_walletImpl->refreshAsync(); m_walletImpl->refreshAsync();
} }
void Wallet::setAutoRefreshInterval(int seconds)
{
m_walletImpl->setAutoRefreshInterval(seconds);
}
int Wallet::autoRefreshInterval() const
{
return m_walletImpl->autoRefreshInterval();
}
PendingTransaction *Wallet::createTransaction(const QString &dst_addr, const QString &payment_id, PendingTransaction *Wallet::createTransaction(const QString &dst_addr, const QString &payment_id,
quint64 amount, quint32 mixin_count, quint64 amount, quint32 mixin_count,
PendingTransaction::Priority priority) PendingTransaction::Priority priority)
@ -195,7 +225,11 @@ void Wallet::setPaymentId(const QString &paymentId)
Wallet::Wallet(Bitmonero::Wallet *w, QObject *parent) Wallet::Wallet(Bitmonero::Wallet *w, QObject *parent)
: QObject(parent), m_walletImpl(w), m_history(nullptr) : QObject(parent)
, m_walletImpl(w)
, m_history(nullptr)
, m_daemonBlockChainHeight(0)
, m_daemonBlockChainHeightTtl(DAEMON_BLOCKCHAIN_HEIGHT_CACHE_TTL_SECONDS)
{ {
m_walletImpl->setListener(new WalletListenerImpl(this)); m_walletImpl->setListener(new WalletListenerImpl(this));
} }

View file

@ -2,11 +2,11 @@
#define WALLET_H #define WALLET_H
#include <QObject> #include <QObject>
#include <QTime>
#include "wallet/wallet2_api.h" // we need to have an access to the Bitmonero::Wallet::Status enum here; #include "wallet/wallet2_api.h" // we need to have an access to the Bitmonero::Wallet::Status enum here;
#include "PendingTransaction.h" // we need to have an access to the PendingTransaction::Priority enum here; #include "PendingTransaction.h" // we need to have an access to the PendingTransaction::Priority enum here;
namespace Bitmonero { namespace Bitmonero {
class Wallet; // forward declaration class Wallet; // forward declaration
} }
@ -28,7 +28,6 @@ class Wallet : public QObject
Q_PROPERTY(TransactionHistory * history READ history) Q_PROPERTY(TransactionHistory * history READ history)
Q_PROPERTY(QString paymentId READ paymentId WRITE setPaymentId) Q_PROPERTY(QString paymentId READ paymentId WRITE setPaymentId)
public: public:
enum Status { enum Status {
Status_Ok = Bitmonero::Wallet::Status_Ok, Status_Ok = Bitmonero::Wallet::Status_Ok,
@ -77,10 +76,17 @@ public:
Q_INVOKABLE void setTrustedDaemon(bool arg); Q_INVOKABLE void setTrustedDaemon(bool arg);
//! returns balance //! returns balance
quint64 balance() const; Q_INVOKABLE quint64 balance() const;
//! returns unlocked balance //! returns unlocked balance
quint64 unlockedBalance() const; Q_INVOKABLE quint64 unlockedBalance() const;
//! returns current wallet's block height
//! (can be less than daemon's blockchain height when wallet sync in progress)
Q_INVOKABLE quint64 blockChainHeight() const;
//! returns daemon's blockchain height
Q_INVOKABLE quint64 daemonBlockChainHeight() const;
//! refreshes the wallet //! refreshes the wallet
Q_INVOKABLE bool refresh(); Q_INVOKABLE bool refresh();
@ -89,6 +95,12 @@ public:
//! refreshes the wallet asynchronously //! refreshes the wallet asynchronously
Q_INVOKABLE void refreshAsync(); Q_INVOKABLE void refreshAsync();
//! setup auto-refresh interval in seconds
Q_INVOKABLE void setAutoRefreshInterval(int seconds);
//! return auto-refresh interval in seconds
Q_INVOKABLE int autoRefreshInterval() const;
//! creates transaction //! creates transaction
Q_INVOKABLE PendingTransaction * createTransaction(const QString &dst_addr, const QString &payment_id, Q_INVOKABLE PendingTransaction * createTransaction(const QString &dst_addr, const QString &payment_id,
quint64 amount, quint32 mixin_count, quint64 amount, quint32 mixin_count,
@ -113,12 +125,18 @@ public:
// TODO: setListenter() when it implemented in API // TODO: setListenter() when it implemented in API
signals: signals:
// emitted on every event happened with wallet
// (money sent/received, new block)
void updated(); void updated();
// emitted when refresh process finished (could take a long time) // emitted when refresh process finished (could take a long time)
// signalling only after we // signalling only after we
void refreshed(); void refreshed();
void moneySpent(const QString &txId, quint64 amount);
void moneyReceived(const QString &txId, quint64 amount);
void newBlock(quint64 height);
private: private:
Wallet(Bitmonero::Wallet *w, QObject * parent = 0); Wallet(Bitmonero::Wallet *w, QObject * parent = 0);
@ -132,6 +150,9 @@ private:
// history lifetime managed by wallet; // history lifetime managed by wallet;
TransactionHistory * m_history; TransactionHistory * m_history;
QString m_paymentId; QString m_paymentId;
mutable QTime m_daemonBlockChainHeightTime;
mutable quint64 m_daemonBlockChainHeight;
int m_daemonBlockChainHeightTtl;
}; };