sido/node
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'master' of https://github.com/arionum/node

Browse Source 
Conflicts:
	util.php
This commit is contained in:
Arionum
2018-08-30 01:28:07 +03:00
parent 616dde11ea b974dc4c9a
commit 3549da461d
4 changed files with 28 additions and 558 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
include/config-sample.inc.php
View File

@@ -84,7 +84,7 @@ $_config['allow_hostname_change'] = false;
$_config['sanity_rebroadcast_locals'] = true;
// Get more peers?
$_config['get_more_peers']=true;
$_config['get_more_peers'] = true;
/*
|--------------------------------------------------------------------------

47
include/transaction.inc.php
View File

@@ -10,20 +10,20 @@ class Transaction
$acc = new Account();
$r = $db->run("SELECT * FROM transactions WHERE block=:block ORDER by `version` ASC", [":block" => $block]);
foreach ($r as $x) {
_log("Reversing transaction $x[id]",4);
_log("Reversing transaction $x[id]", 4);
if (empty($x['src'])) {
$x['src'] = $acc->get_address($x['public_key']);
}
if ($x['version'] == 2) {
// payment sent to alias
$rez=$db->run(
$rez=$db->run(
"UPDATE accounts SET balance=balance-:val WHERE alias=:alias",
[":alias" => $x['dst'], ":val" => $x['val']]
);
if($rez!=1) {
_log("Update alias balance minus failed",3);
return false;
}
if ($rez!=1) {
_log("Update alias balance minus failed", 3);
return false;
}
} else {
// other type of transactions
@@ -32,8 +32,8 @@ class Transaction
"UPDATE accounts SET balance=balance-:val WHERE id=:id",
[":id" => $x['dst'], ":val" => $x['val']]
);
if($rez!=1) {
_log("Update accounts balance minus failed",3);
if ($rez!=1) {
_log("Update accounts balance minus failed", 3);
return false;
}
}
@@ -44,8 +44,8 @@ class Transaction
"UPDATE accounts SET balance=balance+:val WHERE id=:id",
[":id" => $x['src'], ":val" => $x['val'] + $x['fee']]
);
if($rez!=1) {
_log("Update account balance plus failed",3);
if ($rez!=1) {
_log("Update account balance plus failed", 3);
return false;
}
}
@@ -55,8 +55,8 @@ class Transaction
"UPDATE accounts SET alias=NULL WHERE id=:id",
[":id" => $x['src']]
);
if($rez!=1) {
_log("Clear alias failed",3);
if ($rez!=1) {
_log("Clear alias failed", 3);
return false;
}
}
@@ -65,8 +65,8 @@ class Transaction
if ($x['version']>=100&&$x['version']<110&&$x['height']>=80000) {
if ($x['version']==100) {
$rez=$db->run("DELETE FROM masternode WHERE public_key=:public_key", [':public_key'=>$x['public_key']]);
if($rez!=1) {
_log("Delete from masternode failed",3);
if ($rez!=1) {
_log("Delete from masternode failed", 3);
return false;
}
} elseif ($x['version']==101) {
@@ -74,10 +74,8 @@ class Transaction
"UPDATE masternode SET status=1 WHERE public_key=:public_key",
[':public_key'=>$x['public_key']]
);
} elseif ($x['version']==102) {
$rez=$db->run("UPDATE masternode SET status=0 WHERE public_key=:public_key", [':public_key'=>$x['public_key']]);
} elseif ($x['version']==103) {
$mnt=$db->row("SELECT height, `message` FROM transactions WHERE version=100 AND public_key=:public_key ORDER by height DESC LIMIT 1", [":public_key"=>$x['public_key']]);
$vers=$db->single(
@@ -95,31 +93,30 @@ class Transaction
"INSERT into masternode SET `public_key`=:public_key, `height`=:height, `ip`=:ip, `status`=:status",
[":public_key"=>$x['public_key'], ":height"=>$mnt['height'], ":ip"=>$mnt['message'], ":status"=>$status]
);
if($rez!=1) {
_log("Insert into masternode failed",3);
if ($rez!=1) {
_log("Insert into masternode failed", 3);
return false;
}
$rez=$db->run("UPDATE accounts SET balance=balance-100000 WHERE public_key=:public_key", [':public_key'=>$x['public_key']]);
if($rez!=1) {
_log("Update masternode balance failed",3);
if ($rez!=1) {
_log("Update masternode balance failed", 3);
return false;
}
}
}
// internal masternode history
if ($x['version']==111) {
_log("Masternode reverse: $x[message]",4);
_log("Masternode reverse: $x[message]", 4);
$m=explode(",", $x['message']);
$rez=$db->run(
"UPDATE masternode SET fails=:fails, blacklist=:blacklist, last_won=:last_won WHERE public_key=:public_key",
[":public_key"=>$x['public_key'], ":blacklist"=> $m[0], ":fails"=>$m[2], ":last_won"=>$m[1]]
);
if($rez!=1) {
_log("Update masternode log failed",3);
if ($rez!=1) {
_log("Update masternode log failed", 3);
return false;
}
}
// add the transactions to mempool
@@ -128,7 +125,7 @@ class Transaction
}
$res = $db->run("DELETE FROM transactions WHERE id=:id", [":id" => $x['id']]);
if ($res != 1) {
_log("Delete transaction failed",3);
_log("Delete transaction failed", 3);
return false;
}
}

11
sanity.php
View File

@@ -603,9 +603,9 @@ if ($current['height'] < $largest_height && $largest_height > 1) {
_log("Rechecking reward transactions");
$current = $block->current();
$rwpb=$db->single("SELECT COUNT(1) FROM transactions WHERE version=0 AND message=''");
if($rwpb!=$current['height']){
$failed=$db->single("SELECT blocks.height FROM blocks LEFT JOIN transactions ON transactions.block=blocks.id and transactions.version=0 and transactions.message='' WHERE transactions.height is NULL ORDER by blocks.height ASC LIMIT 1");
if($failed>1){
if ($rwpb!=$current['height']) {
$failed=$db->single("SELECT blocks.height FROM blocks LEFT JOIN transactions ON transactions.block=blocks.id and transactions.version=0 and transactions.message='' WHERE transactions.height is NULL ORDER by blocks.height ASC LIMIT 1");
if ($failed>1) {
_log("Found failed block - $faield");
$block->delete($failed);
$block_parse_failed==false;
@@ -613,12 +613,11 @@ if ($current['height'] < $largest_height && $largest_height > 1) {
}
}
if ($block_parse_failed==true||$argv[1]=="resync") {
$last_resync=$db->single("SELECT val FROM config WHERE cfg='last_resync'");
if ($last_resync<time()-(3600*24)||$argv[1]=="resync") {
if ($current['date']<time()-(3600*72)||$argv[1]=="resync") {
$to_remove=3000;
if(intval($argv[2])>0){
if (intval($argv[2])>0) {
$to_remove=intval($argv[2]);
}
_log("Removing $to_remove blocks, the blockchain is stale.");
@@ -655,7 +654,7 @@ if ($current['height'] < $largest_height && $largest_height > 1) {
}
}
$current = $block->current();
$db->run("DELETE FROM masternode WHERE height>:h",[":h"=>$current['height']]);
$db->run("DELETE FROM masternode WHERE height>:h", [":h"=>$current['height']]);
$db->exec("UNLOCK TABLES");
}
}

526
util.php
View File

@@ -1,526 +0,0 @@
<?php
/*
The MIT License (MIT)
Copyright (c) 2018 AroDev
www.arionum.com
Permission is hereby granted, free of charge, to any person obtaining a copy
of this software and associated documentation files (the "Software"), to deal
in the Software without restriction, including without limitation the rights
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
copies of the Software, and to permit persons to whom the Software is
furnished to do so, subject to the following conditions:
The above copyright notice and this permission notice shall be included in all
copies or substantial portions of the Software.
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.
IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE
OR OTHER DEALINGS IN THE SOFTWARE.
*/
// make sure it's not accessible in the browser
if (php_sapi_name() !== 'cli') {
die("This should only be run as cli");
}
require_once("include/init.inc.php");
$cmd = trim($argv[1]);
/**
* @api {php util.php} clean Clean
* @apiName clean
* @apiGroup UTIL
* @apiDescription Cleans the entire database
*
* @apiExample {cli} Example usage:
* php util.php clean
*/
if ($cmd == 'clean') {
if(file_exists("tmp/sanity-lock")) die("Sanity running. Wait for it to finish");
touch("tmp/sanity-lock");
$db->run("SET foreign_key_checks=0;");
$tables = ["accounts", "transactions", "mempool", "masternode","blocks"];
foreach ($tables as $table) {
$db->run("TRUNCATE TABLE {$table}");
}
$db->run("SET foreign_key_checks=1;");
echo "\n The database has been cleared\n";
unlink("tmp/sanity-lock");
} /**
* @api {php util.php} pop Pop
* @apiName pop
* @apiGroup UTIL
* @apiDescription Cleans the entire database
*
* @apiParam {Number} arg2 Number of blocks to delete
*
* @apiExample {cli} Example usage:
* php util.php pop 1
*/
elseif ($cmd == 'pop') {
if(file_exists("tmp/sanity-lock")) die("Sanity running. Wait for it to finish");
touch("tmp/sanity-lock");
$no = intval($argv[2]);
$block = new Block();
$block->pop($no);
unlink("tmp/sanity-lock");
} /**
* @api {php util.php} block-time Block-time
* @apiName block-time
* @apiGroup UTIL
* @apiDescription Shows the block time of the last 100 blocks
*
* @apiExample {cli} Example usage:
* php util.php block-time
*
* @apiSuccessExample {text} Success-Response:
* 16830 -> 323
* ...
* 16731 -> 302
* Average block time: 217 seconds
*/
elseif ($cmd == 'block-time') {
$t = time();
$r = $db->run("SELECT * FROM blocks ORDER by height DESC LIMIT 100");
$start = 0;
foreach ($r as $x) {
if ($start == 0) {
$start = $x['date'];
}
$time = $t - $x['date'];
$t = $x['date'];
echo "$x[height]\t\t$time\t\t$x[difficulty]\n";
$end = $x['date'];
}
echo "Average block time: ".ceil(($start - $end) / 100)." seconds\n";
} /**
* @api {php util.php} peer Peer
* @apiName peer
* @apiGroup UTIL
* @apiDescription Creates a peering session with another node
*
* @apiParam {text} arg2 The Hostname of the other node
*
* @apiExample {cli} Example usage:
* php util.php peer http://peer1.arionum.com
*
* @apiSuccessExample {text} Success-Response:
* Peering OK
*/
elseif ($cmd == "peer") {
$res = peer_post($argv[2]."/peer.php?q=peer", ["hostname" => $_config['hostname']]);
if ($res !== false) {
echo "Peering OK\n";
} else {
echo "Peering FAIL\n";
}
} /**
* @api {php util.php} current Current
* @apiName current
* @apiGroup UTIL
* @apiDescription Prints the current block in var_dump
*
* @apiExample {cli} Example usage:
* php util.php current
*
* @apiSuccessExample {text} Success-Response:
* array(9) {
* ["id"]=>
* string(88) "4khstc1AknzDXg8h2v12rX42vDrzBaai6Rz53mbaBsghYN4DnfPhfG7oLZS24Q92MuusdYmwvDuiZiuHHWgdELLR"
* ["generator"]=>
* string(88) "5ADfrJUnLefPsaYjMTR4KmvQ79eHo2rYWnKBRCXConYKYJVAw2adtzb38oUG5EnsXEbTct3p7GagT2VVZ9hfVTVn"
* ["height"]=>
* int(16833)
* ["date"]=>
* int(1519312385)
* ["nonce"]=>
* string(41) "EwtJ1EigKrLurlXROuuiozrR6ICervJDF2KFl4qEY"
* ["signature"]=>
* string(97) "AN1rKpqit8UYv6uvf79GnbjyihCPE1UZu4CGRx7saZ68g396yjHFmzkzuBV69Hcr7TF2egTsEwVsRA3CETiqXVqet58MCM6tu"
* ["difficulty"]=>
* string(8) "61982809"
* ["argon"]=>
* string(68) "$SfghIBNSHoOJDlMthVcUtg$WTJMrQWHHqDA6FowzaZJ+O9JC8DPZTjTxNE4Pj/ggwg"
* ["transactions"]=>
* int(0)
* }
*
*/
elseif ($cmd == "current") {
$block = new Block();
var_dump($block->current());
} /**
* @api {php util.php} blocks Blocks
* @apiName blocks
* @apiGroup UTIL
* @apiDescription Prints the id and the height of the blocks >=arg2, max 100 or arg3
*
* @apiParam {number} arg2 Starting height
*
* @apiParam {number} [arg3] Block Limit
*
* @apiExample {cli} Example usage:
* php util.php blocks 10800 5
*
* @apiSuccessExample {text} Success-Response:
* 10801 2yAHaZ3ghNnThaNK6BJcup2zq7EXuFsruMb5qqXaHP9M6JfBfstAag1n1PX7SMKGcuYGZddMzU7hW87S5ZSayeKX
* 10802 wNa4mRvRPCMHzsgLdseMdJCvmeBaCNibRJCDhsuTeznJh8C1aSpGuXRDPYMbqKiVtmGAaYYb9Ze2NJdmK1HY9zM
* 10803 3eW3B8jCFBauw8EoKN4SXgrn33UBPw7n8kvDDpyQBw1uQcmJQEzecAvwBk5sVfQxUqgzv31JdNHK45JxUFcupVot
* 10804 4mWK1f8ch2Ji3D6aw1BsCJavLNBhQgpUHBCHihnrLDuh8Bjwsou5bQDj7D7nV4RsEPmP2ZbjUUMZwqywpRc8r6dR
* 10805 5RBeWXo2c9NZ7UF2ubztk53PZpiA4tsk3bhXNXbcBk89cNqorNj771Qu4kthQN5hXLtu1hzUnv7nkH33hDxBM34m
*
*/
elseif ($cmd == "blocks") {
$height = intval($argv[2]);
$limit = intval($argv[3]);
if ($limit < 1) {
$limit = 100;
}
$r = $db->run("SELECT * FROM blocks WHERE height>:height ORDER by height ASC LIMIT $limit", [":height" => $height]);
foreach ($r as $x) {
echo "$x[height]\t$x[id]\n";
}
} /**
* @api {php util.php} recheck-blocks Recheck-Blocks
* @apiName recheck-blocks
* @apiGroup UTIL
* @apiDescription Recheck all the blocks to make sure the blockchain is correct
*
* @apiExample {cli} Example usage:
* php util.php recheck-blocks
*
*/
elseif ($cmd == "recheck-blocks") {
$blocks = [];
$block = new Block();
$r = $db->run("SELECT * FROM blocks ORDER by height ASC");
foreach ($r as $x) {
$blocks[$x['height']] = $x;
$max_height = $x['height'];
}
for ($i = 2; $i <= $max_height; $i++) {
$data = $blocks[$i];
$key = $db->single("SELECT public_key FROM accounts WHERE id=:id", [":id" => $data['generator']]);
if (!$block->mine(
$key,
$data['nonce'],
$data['argon'],
$data['difficulty'],
$blocks[$i - 1]['id'],
$blocks[$i - 1]['height'],
$data['date']
)) {
_log("Invalid block detected. We should delete everything after $data[height] - $data[id]");
break;
}
}
} /**
* @api {php util.php} peers Peers
* @apiName peers
* @apiGroup UTIL
* @apiDescription Prints all the peers and their status
*
* @apiExample {cli} Example usage:
* php util.php peers
*
* @apiSuccessExample {text} Success-Response:
* http://35.190.160.142 active
* ...
* http://aro.master.hashpi.com active
*/
elseif ($cmd == "peers") {
$r = $db->run("SELECT * FROM peers ORDER by reserve ASC");
$status = "active";
if ($x['reserve'] == 1) {
$status = "reserve";
}
foreach ($r as $x) {
echo "$x[hostname]\t$status\n";
}
} /**
* @api {php util.php} mempool Mempool
* @apiName mempool
* @apiGroup UTIL
* @apiDescription Prints the number of transactions in mempool
*
* @apiExample {cli} Example usage:
* php util.php mempool
*
* @apiSuccessExample {text} Success-Response:
* Mempool size: 12
*/
elseif ($cmd == "mempool") {
$res = $db->single("SELECT COUNT(1) from mempool");
echo "Mempool size: $res\n";
} /**
* @api {php util.php} delete-peer Delete-peer
* @apiName delete-peer
* @apiGroup UTIL
* @apiDescription Removes a peer from the peerlist
*
* @apiParam {text} arg2 Peer's hostname
*
* @apiExample {cli} Example usage:
* php util.php delete-peer http://peer1.arionum.com
*
* @apiSuccessExample {text} Success-Response:
* Peer removed
*/
elseif ($cmd == "delete-peer") {
$peer = trim($argv[2]);
if (empty($peer)) {
die("Invalid peer");
}
$db->run("DELETE FROM peers WHERE ip=:ip", [":ip" => $peer]);
echo "Peer removed\n";
} elseif ($cmd == "recheck-peers") {
$r = $db->run("SELECT * FROM peers");
foreach ($r as $x) {
$a = peer_post($x['hostname']."/peer.php?q=ping");
if ($a != "pong") {
echo "$x[hostname] -> failed\n";
$db->run("DELETE FROM peers WHERE id=:id", [":id" => $x['id']]);
} else {
echo "$x[hostname] ->ok \n";
}
}
} /**
* @api {php util.php} peers-block Peers-Block
* @apiName peers-block
* @apiGroup UTIL
* @apiDescription Prints the current height of all the peers
*
* @apiExample {cli} Example usage:
* php util.php peers-block
*
* @apiSuccessExample {text} Success-Response:
* http://peer5.arionum.com 16849
* ...
* http://peer10.arionum.com 16849
*/
elseif ($cmd == "peers-block") {
$only_diff = false;
if ($argv[2] == "diff") {
$current = $db->single("SELECT height FROM blocks ORDER by height DESC LIMIT 1");
$only_diff = true;
}
$r = $db->run("SELECT * FROM peers WHERE blacklisted<UNIX_TIMESTAMP()");
foreach ($r as $x) {
$a = peer_post($x['hostname']."/peer.php?q=currentBlock", [], 5);
$enc = base58_encode($x['hostname']);
if ($argv[2] == "debug") {
echo "$enc\t";
}
if ($only_diff == false || $current != $a['height']) {
echo "$x[hostname]\t$a[height]\n";
}
}
} /**
* @api {php util.php} balance Balance
* @apiName balance
* @apiGroup UTIL
* @apiDescription Prints the balance of an address or a public key
*
* @apiParam {text} arg2 address or public_key
*
* @apiExample {cli} Example usage:
* php util.php balance 5WuRMXGM7Pf8NqEArVz1NxgSBptkimSpvuSaYC79g1yo3RDQc8TjVtGH5chQWQV7CHbJEuq9DmW5fbmCEW4AghQr
*
* @apiSuccessExample {text} Success-Response:
* Balance: 2,487
*/
elseif ($cmd == "balance") {
$id = san($argv[2]);
$res = $db->single(
"SELECT balance FROM accounts WHERE id=:id OR public_key=:id2 LIMIT 1",
[":id" => $id, ":id2" => $id]
);
echo "Balance: ".number_format($res)."\n";
} /**
* @api {php util.php} block Block
* @apiName block
* @apiGroup UTIL
* @apiDescription Returns a specific block
*
* @apiParam {text} arg2 block id
*
* @apiExample {cli} Example usage:
* php util.php block 4khstc1AknzDXg8h2v12rX42vDrzBaai6Rz53mbaBsghYN4DnfPhfG7oLZS24Q92MuusdYmwvDuiZiuHHWgdELLR
*
* @apiSuccessExample {text} Success-Response:
* array(9) {
* ["id"]=>
* string(88) "4khstc1AknzDXg8h2v12rX42vDrzBaai6Rz53mbaBsghYN4DnfPhfG7oLZS24Q92MuusdYmwvDuiZiuHHWgdELLR"
* ["generator"]=>
* string(88) "5ADfrJUnLefPsaYjMTR4KmvQ79eHo2rYWnKBRCXConYKYJVAw2adtzb38oUG5EnsXEbTct3p7GagT2VVZ9hfVTVn"
* ["height"]=>
* int(16833)
* ["date"]=>
* int(1519312385)
* ["nonce"]=>
* string(41) "EwtJ1EigKrLurlXROuuiozrR6ICervJDF2KFl4qEY"
* ["signature"]=>
* string(97) "AN1rKpqit8UYv6uvf79GnbjyihCPE1UZu4CGRx7saZ68g396yjHFmzkzuBV69Hcr7TF2egTsEwVsRA3CETiqXVqet58MCM6tu"
* ["difficulty"]=>
* string(8) "61982809"
* ["argon"]=>
* string(68) "$SfghIBNSHoOJDlMthVcUtg$WTJMrQWHHqDA6FowzaZJ+O9JC8DPZTjTxNE4Pj/ggwg"
* ["transactions"]=>
* int(0)
* }
*/
elseif ($cmd == "block") {
$id = san($argv[2]);
$res = $db->row("SELECT * FROM blocks WHERE id=:id OR height=:id2 LIMIT 1", [":id" => $id, ":id2" => $id]);
var_dump($res);
} /**
* @api {php util.php} check-address Check-Address
* @apiName check-address
* @apiGroup UTIL
* @apiDescription Checks a specific address for validity
*
* @apiParam {text} arg2 block id
*
* @apiExample {cli} Example usage:
* php util.php check-address 4khstc1AknzDXg8h2v12rX42vDrzBaai6Rz53mbaBsghYN4DnfPhfG7oLZS24Q92MuusdYmwvDuiZiuHHWgdELLR
*
* @apiSuccessExample {text} Success-Response:
* The address is valid
*/
elseif ($cmd == "check-address") {
$dst = trim($argv[2]);
$acc = new Account();
if (!$acc->valid($dst)) {
die("Invalid address");
}
$dst_b = base58_decode($dst);
if (strlen($dst_b) != 64) {
die("Invalid address - ".strlen($dst_b)." bytes");
}
echo "The address is valid\n";
}
/**
* @api {php util.php} get-address Get-Address
* @apiName get-address
* @apiGroup UTIL
* @apiDescription Converts a public key into an address
*
* @apiParam {text} arg2 public key
*
* @apiExample {cli} Example usage:
* php util.php get-address PZ8Tyr4Nx8MHsRAGMpZmZ6TWY63dXWSCwQr8cE5s6APWAE1SWAmH6NM1nJTryBURULEsifA2hLVuW5GXFD1XU6s6REG1iPK7qGaRDkGpQwJjDhQKVoSVkSNp
*
* @apiSuccessExample {text} Success-Response:
* 5WuRMXGM7Pf8NqEArVz1NxgSBptkimSpvuSaYC79g1yo3RDQc8TjVtGH5chQWQV7CHbJEuq9DmW5fbmCEW4AghQr
*/
elseif ($cmd == 'get-address') {
$public_key = trim($argv2);
if (strlen($public_key) < 32) {
die("Invalid public key");
}
print($acc->get_address($public_key));
/**
* @api {php util.php} clean-blacklist Clean-Blacklist
* @apiName clean-blacklist
* @apiGroup UTIL
* @apiDescription Removes all the peers from blacklist
*
* @apiExample {cli} Example usage:
* php util.php clean-blacklist
*
*/
} elseif ($cmd == 'clean-blacklist') {
$db->run("UPDATE peers SET blacklisted=0, fails=0, stuckfail=0");
echo "All the peers have been removed from the blacklist\n";
} elseif ($cmd == 'resync-accounts') {
// resyncs the balance on all accounts
// lock table to avoid race conditions on blocks
$db->exec("LOCK TABLES blocks WRITE, accounts WRITE, transactions WRITE, mempool WRITE");
$r=$db->run("SELECT * FROM accounts");
foreach ($r as $x) {
$alias=$x['alias'];
if (empty($alias)) {
$alias="A";
}
$rec=$db->single("SELECT SUM(val) FROM transactions WHERE (dst=:id or dst=:alias) AND (height<80000 OR (version!=100 AND version!=103)) and version<111", [":id"=>$x['id'], ":alias"=>$alias]);
$spent=$db->single("SELECT SUM(val+fee) FROM transactions WHERE public_key=:pub AND version>0", [":pub"=>$x['public_key']]);
if ($spent==false) {
$spent=0;
}
$balance=round(($rec-$spent), 8);
if ($x['balance']!=$balance) {
echo "rec: $rec, spent: $spent, bal: $x[balance], should be: $balance - $x[id] $x[public_key]\n";
if (trim($argv[2])!="check") {
$db->run("UPDATE accounts SET balance=:bal WHERE id=:id", [":id"=>$x['id'], ":bal"=>$balance]);
}
}
}
$db->exec("UNLOCK TABLES");
echo "All done";
} elseif ($cmd=="compare-blocks") {
$block=new Block();
$current=$block->current();
$peer=trim($argv[2]);
$limit=intval($argv[3]);
if($limit==0) $limit=5000;
for($i=$current['height']-$limit;$i<=$current['height'];$i++){
$data=peer_post($peer."/peer.php?q=getBlock",["height" => $i]);
if($data==false) {
continue;
}
$our=$block->export(false,$i);
if($data!=$our) {
echo "Failed block -> $i\n";
if($argv[4]=="dump"){
echo "\n\n ---- Internal ----\n\n";
var_dump($our);
echo "\n\n ---- External ----\n\n";
var_dump($data);
}
}
}
} elseif ($cmd=='compare-accounts'){
$peer=trim($argv[2]);
$r=$db->run("SELECT id,balance FROM accounts");
foreach($r as $x){
$data=peer_post($peer."/api.php?q=getBalance",["account" => $x['id']]);
if($data==false) {
continue;
}
if($data!=$x['balance']) {
echo "$x[id]\t\t$x[balance]\t$data\n";
}
}
} elseif ($cmd=='masternode-hash'){
$res=$db->run("SELECT * FROM masternode ORDER by public_key ASC");
$block=new Block();
$current=$block->current();
echo "Height:\t\t$current[height]\n";
echo "Hash:\t\t".md5(json_encode($res))."\n\n";
} else {
echo "Invalid command\n";
}