Skip to content

Commit

Permalink
MN
Browse files Browse the repository at this point in the history 
preparing Masternodes
  • Loading branch information
@surgecoin1
surgecoin1 committed Dec 23, 2017
1 parent 3bb47fe commit 9e44d6d
Show file tree
Hide file tree
Showing 2 changed files with 428 additions and 0 deletions.
366 changes: 366 additions & 0 deletions src/qt/masternodemanager.cpp
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,366 @@
#include "masternodemanager.h"
#include "ui_masternodemanager.h"
#include "addeditadrenalinenode.h"
#include "adrenalinenodeconfigdialog.h"

#include "sync.h"
#include "clientmodel.h"
#include "walletmodel.h"
#include "activemasternode.h"
#include "masternodeconfig.h"
#include "masternodeman.h"
#include "masternode.h"
#include "walletdb.h"
#include "wallet.h"
#include "init.h"
#include "rpcserver.h"
#include <boost/lexical_cast.hpp>
#include <fstream>
using namespace json_spirit;
using namespace std;

#include <QAbstractItemDelegate>
#include <QPainter>
#include <QTimer>
#include <QDebug>
#include <QScrollArea>
#include <QScroller>
#include <QDateTime>
#include <QApplication>
#include <QClipboard>
#include <QMessageBox>
#include <QThread>
#include <QtConcurrent/QtConcurrent>
#include <QScrollBar>


MasternodeManager::MasternodeManager(QWidget *parent) :
QWidget(parent),
ui(new Ui::MasternodeManager),
clientModel(0),
walletModel(0)
{
ui->setupUi(this);

ui->editButton->setEnabled(false);
ui->startButton->setEnabled(false);

ui->tableWidget->horizontalHeader()->setSectionResizeMode(QHeaderView::ResizeToContents);
ui->tableWidget_2->horizontalHeader()->setSectionResizeMode(QHeaderView::ResizeToContents);
ui->tableWidget_3->horizontalHeader()->setSectionResizeMode(QHeaderView::ResizeToContents);

timer = new QTimer(this);
connect(timer, SIGNAL(timeout()), this, SLOT(updateNodeList()));
if(!GetBoolArg("-reindexaddr", false))
timer->start(1000);
fFilterUpdated = true;
nTimeFilterUpdated = GetTime();
updateNodeList();
}

MasternodeManager::~MasternodeManager()
{
delete ui;
}

void MasternodeManager::on_tableWidget_2_itemSelectionChanged()
{
if(ui->tableWidget_2->selectedItems().count() > 0)
{
ui->editButton->setEnabled(true);
ui->startButton->setEnabled(true);
}
}

void MasternodeManager::updateAdrenalineNode(QString alias, QString addr, QString privkey, QString txHash, QString txIndex, QString donationAddress, QString donationPercentage, QString status)
{
LOCK(cs_adrenaline);
bool bFound = false;
int nodeRow = 0;
for(int i=0; i < ui->tableWidget_2->rowCount(); i++)
{
if(ui->tableWidget_2->item(i, 0)->text() == alias)
{
bFound = true;
nodeRow = i;
break;
}
}

if(nodeRow == 0 && !bFound)
ui->tableWidget_2->insertRow(0);

QTableWidgetItem *aliasItem = new QTableWidgetItem(alias);
QTableWidgetItem *addrItem = new QTableWidgetItem(addr);
QTableWidgetItem *donationAddressItem = new QTableWidgetItem(donationAddress);
QTableWidgetItem *donationPercentageItem = new QTableWidgetItem(donationPercentage);
QTableWidgetItem *statusItem = new QTableWidgetItem(status);

ui->tableWidget_2->setItem(nodeRow, 0, aliasItem);
ui->tableWidget_2->setItem(nodeRow, 1, addrItem);
ui->tableWidget_2->setItem(nodeRow, 2, donationPercentageItem);
ui->tableWidget_2->setItem(nodeRow, 3, donationAddressItem);
ui->tableWidget_2->setItem(nodeRow, 4, statusItem);
}

static QString seconds_to_DHMS(quint32 duration)
{
QString res;
int seconds = (int) (duration % 60);
duration /= 60;
int minutes = (int) (duration % 60);
duration /= 60;
int hours = (int) (duration % 24);
int days = (int) (duration / 24);
if((hours == 0)&&(days == 0))
return res.sprintf("%02dm:%02ds", minutes, seconds);
if (days == 0)
return res.sprintf("%02dh:%02dm:%02ds", hours, minutes, seconds);
return res.sprintf("%dd %02dh:%02dm:%02ds", days, hours, minutes, seconds);
}

void MasternodeManager::updateListConc() {
if (ui->tableWidget->isVisible())
{
ui->tableWidget_3->clearContents();
ui->tableWidget_3->setRowCount(0);
std::vector<CMasternode> vMasternodes = mnodeman.GetFullMasternodeVector();
ui->tableWidget_3->horizontalHeader()->setSortIndicator(ui->tableWidget->horizontalHeader()->sortIndicatorSection() ,ui->tableWidget->horizontalHeader()->sortIndicatorOrder());

BOOST_FOREACH(CMasternode& mn, vMasternodes)
{
int mnRow = 0;
ui->tableWidget_3->insertRow(0);

// populate list
// Address, Rank, Active, Active Seconds, Last Seen, Pub Key
QTableWidgetItem *activeItem = new QTableWidgetItem(QString::number(mn.IsEnabled()));
QTableWidgetItem *addressItem = new QTableWidgetItem(QString::fromStdString(mn.addr.ToString()));
QString Rank = QString::number(mnodeman.GetMasternodeRank(mn.vin, pindexBest->nHeight));
QTableWidgetItem *rankItem = new QTableWidgetItem(Rank.rightJustified(2, '0', false));
QTableWidgetItem *activeSecondsItem = new QTableWidgetItem(seconds_to_DHMS((qint64)(mn.lastTimeSeen - mn.sigTime)));
QTableWidgetItem *lastSeenItem = new QTableWidgetItem(QString::fromStdString(DateTimeStrFormat(mn.lastTimeSeen)));

CScript pubkey;
pubkey =GetScriptForDestination(mn.pubkey.GetID());
CTxDestination address1;
ExtractDestination(pubkey, address1);
CSurgecoinAddress address2(address1);
QTableWidgetItem *pubkeyItem = new QTableWidgetItem(QString::fromStdString(address2.ToString()));

ui->tableWidget_3->setItem(mnRow, 0, addressItem);
ui->tableWidget_3->setItem(mnRow, 1, rankItem);
ui->tableWidget_3->setItem(mnRow, 2, activeItem);
ui->tableWidget_3->setItem(mnRow, 3, activeSecondsItem);
ui->tableWidget_3->setItem(mnRow, 4, lastSeenItem);
ui->tableWidget_3->setItem(mnRow, 5, pubkeyItem);
}
ui->countLabel->setText(QString::number(ui->tableWidget_3->rowCount()));
on_UpdateButton_clicked();
ui->tableWidget->setVisible(0);
ui->tableWidget_3->setVisible(1);
ui->tableWidget_3->verticalScrollBar()->setSliderPosition(ui->tableWidget->verticalScrollBar()->sliderPosition());
}
else
{
ui->tableWidget->clearContents();
ui->tableWidget->setRowCount(0);
std::vector<CMasternode> vMasternodes = mnodeman.GetFullMasternodeVector();
ui->tableWidget->horizontalHeader()->setSortIndicator(ui->tableWidget_3->horizontalHeader()->sortIndicatorSection() ,ui->tableWidget_3->horizontalHeader()->sortIndicatorOrder());

BOOST_FOREACH(CMasternode& mn, vMasternodes)
{
int mnRow = 0;
ui->tableWidget->insertRow(0);

// populate list
// Address, Rank, Active, Active Seconds, Last Seen, Pub Key
QTableWidgetItem *activeItem = new QTableWidgetItem(QString::number(mn.IsEnabled()));
QTableWidgetItem *addressItem = new QTableWidgetItem(QString::fromStdString(mn.addr.ToString()));
QString Rank = QString::number(mnodeman.GetMasternodeRank(mn.vin, pindexBest->nHeight));
QTableWidgetItem *rankItem = new QTableWidgetItem(Rank.rightJustified(2, '0', false));
QTableWidgetItem *activeSecondsItem = new QTableWidgetItem(seconds_to_DHMS((qint64)(mn.lastTimeSeen - mn.sigTime)));
QTableWidgetItem *lastSeenItem = new QTableWidgetItem(QString::fromStdString(DateTimeStrFormat(mn.lastTimeSeen)));

CScript pubkey;
pubkey =GetScriptForDestination(mn.pubkey.GetID());
CTxDestination address1;
ExtractDestination(pubkey, address1);
CSurgeAddress address2(address1);
QTableWidgetItem *pubkeyItem = new QTableWidgetItem(QString::fromStdString(address2.ToString()));

ui->tableWidget->setItem(mnRow, 0, addressItem);
ui->tableWidget->setItem(mnRow, 1, rankItem);
ui->tableWidget->setItem(mnRow, 2, activeItem);
ui->tableWidget->setItem(mnRow, 3, activeSecondsItem);
ui->tableWidget->setItem(mnRow, 4, lastSeenItem);
ui->tableWidget->setItem(mnRow, 5, pubkeyItem);
}
ui->countLabel->setText(QString::number(ui->tableWidget->rowCount()));
on_UpdateButton_clicked();
ui->tableWidget_3->setVisible(0);
ui->tableWidget->setVisible(1);
ui->tableWidget->verticalScrollBar()->setSliderPosition(ui->tableWidget_3->verticalScrollBar()->sliderPosition());
}
}


void MasternodeManager::updateNodeList()
{

TRY_LOCK(cs_masternodes, lockMasternodes);
if(!lockMasternodes)
return;
static int64_t nTimeListUpdated = GetTime();

// to prevent high cpu usage update only once in MASTERNODELIST_UPDATE_SECONDS seconds
// or MASTERNODELIST_FILTER_COOLDOWN_SECONDS seconds after filter was last changed
int64_t nSecondsToWait = fFilterUpdated ? nTimeFilterUpdated - GetTime() + MASTERNODELIST_FILTER_COOLDOWN_SECONDS : nTimeListUpdated - GetTime() + MASTERNODELIST_UPDATE_SECONDS;

if (fFilterUpdated) ui->countLabel->setText(QString::fromStdString(strprintf("Please wait... %d", nSecondsToWait)));
if (nSecondsToWait > 0) return;

nTimeListUpdated = GetTime();

nTimeListUpdated = GetTime();
fFilterUpdated = false;
if (f1.isFinished())
f1 = QtConcurrent::run(this,&MasternodeManager::updateListConc);

}


void MasternodeManager::setClientModel(ClientModel *model)
{
this->clientModel = model;
if(model)
{
}
}

void MasternodeManager::setWalletModel(WalletModel *model)
{
this->walletModel = model;
if(model && model->getOptionsModel())
{
}

}

void MasternodeManager::on_createButton_clicked()
{
AddEditAdrenalineNode* aenode = new AddEditAdrenalineNode();
aenode->exec();
}

void MasternodeManager::on_startButton_clicked()
{
// start the node
QItemSelectionModel* selectionModel = ui->tableWidget_2->selectionModel();
QModelIndexList selected = selectionModel->selectedRows();
if(selected.count() == 0)
return;

QModelIndex index = selected.at(0);
int r = index.row();
std::string sAlias = ui->tableWidget_2->item(r, 0)->text().toStdString();



if(pwalletMain->IsLocked()) {
}

std::string statusObj;
statusObj += "<center>Alias: " + sAlias;

BOOST_FOREACH(CMasternodeConfig::CMasternodeEntry mne, masternodeConfig.getEntries()) {
if(mne.getAlias() == sAlias) {
std::string errorMessage;
std::string strDonateAddress = mne.getDonationAddress();
std::string strDonationPercentage = mne.getDonationPercentage();

bool result = activeMasternode.Register(mne.getIp(), mne.getPrivKey(), mne.getTxHash(), mne.getOutputIndex(), strDonateAddress, strDonationPercentage, errorMessage);

if(result) {
statusObj += "<br>Successfully started masternode." ;
} else {
statusObj += "<br>Failed to start masternode.<br>Error: " + errorMessage;
}
break;
}
}
statusObj += "</center>";
pwalletMain->Lock();

QMessageBox msg;
msg.setText(QString::fromStdString(statusObj));

msg.exec();
}

void MasternodeManager::on_startAllButton_clicked()
{
if(pwalletMain->IsLocked()) {
}

std::vector<CMasternodeConfig::CMasternodeEntry> mnEntries;

int total = 0;
int successful = 0;
int fail = 0;
std::string statusObj;

BOOST_FOREACH(CMasternodeConfig::CMasternodeEntry mne, masternodeConfig.getEntries()) {
total++;

std::string errorMessage;
std::string strDonateAddress = mne.getDonationAddress();
std::string strDonationPercentage = mne.getDonationPercentage();

bool result = activeMasternode.Register(mne.getIp(), mne.getPrivKey(), mne.getTxHash(), mne.getOutputIndex(), strDonateAddress, strDonationPercentage, errorMessage);

if(result) {
successful++;
} else {
fail++;
statusObj += "\nFailed to start " + mne.getAlias() + ". Error: " + errorMessage;
}
}
pwalletMain->Lock();

std::string returnObj;
returnObj = "Successfully started " + boost::lexical_cast<std::string>(successful) + " masternodes, failed to start " +
boost::lexical_cast<std::string>(fail) + ", total " + boost::lexical_cast<std::string>(total);
if (fail > 0)
returnObj += statusObj;

QMessageBox msg;
msg.setText(QString::fromStdString(returnObj));
msg.exec();
}

void MasternodeManager::on_UpdateButton_clicked()
{
BOOST_FOREACH(CMasternodeConfig::CMasternodeEntry mne, masternodeConfig.getEntries()) {
std::string errorMessage;
std::string strDonateAddress = mne.getDonationAddress();
std::string strDonationPercentage = mne.getDonationPercentage();

std::vector<CMasternode> vMasternodes = mnodeman.GetFullMasternodeVector();
if (errorMessage == ""){
updateAdrenalineNode(QString::fromStdString(mne.getAlias()), QString::fromStdString(mne.getIp()), QString::fromStdString(mne.getPrivKey()), QString::fromStdString(mne.getTxHash()),
QString::fromStdString(mne.getOutputIndex()), QString::fromStdString(strDonateAddress), QString::fromStdString(strDonationPercentage), QString::fromStdString("Not in the masternode list."));
}
else {
updateAdrenalineNode(QString::fromStdString(mne.getAlias()), QString::fromStdString(mne.getIp()), QString::fromStdString(mne.getPrivKey()), QString::fromStdString(mne.getTxHash()),
QString::fromStdString(mne.getOutputIndex()), QString::fromStdString(strDonateAddress), QString::fromStdString(strDonationPercentage), QString::fromStdString(errorMessage));
}

BOOST_FOREACH(CMasternode& mn, vMasternodes) {
if (mn.addr.ToString().c_str() == mne.getIp()){
updateAdrenalineNode(QString::fromStdString(mne.getAlias()), QString::fromStdString(mne.getIp()), QString::fromStdString(mne.getPrivKey()), QString::fromStdString(mne.getTxHash()),
QString::fromStdString(mne.getOutputIndex()), QString::fromStdString(strDonateAddress), QString::fromStdString(strDonationPercentage), QString::fromStdString("Masternode is Running."));
}
}
}
}
Loading

0 comments on commit 9e44d6d

Please sign in to comment.