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

Update sanity file to PSR-2

Browse Source
This commit is contained in:
pxgamer
2018-05-29 15:47:59 +01:00
parent b68f316029
commit aae845548f
1 changed files with 469 additions and 391 deletions
Download Patch File Download Diff File Expand all files Collapse all files

832
sanity.php
View File

@@ -27,282 +27,326 @@ set_time_limit(0);
error_reporting(0); error_reporting(0);
// make sure it's not accessible in the browser // make sure it's not accessible in the browser
if(php_sapi_name() !== 'cli') die("This should only be run as cli"); if (php_sapi_name() !== 'cli') {
die("This should only be run as cli");
}
// make sure there's only a single sanity process running at the same time // make sure there's only a single sanity process running at the same time
if(file_exists("tmp/sanity-lock")){ if (file_exists("tmp/sanity-lock")) {
$ignore_lock=false; $ignore_lock = false;
if($argv[1]=="force"){ if ($argv[1] == "force") {
$res=intval(shell_exec("ps aux|grep sanity.php|grep -v grep|wc -l")); $res = intval(shell_exec("ps aux|grep sanity.php|grep -v grep|wc -l"));
if($res==1){ if ($res == 1) {
$ignore_lock=true; $ignore_lock = true;
} }
} }
$pid_time=filemtime("tmp/sanity-lock"); $pid_time = filemtime("tmp/sanity-lock");
// if the process died, restart after 1day // if the process died, restart after 1day
if(time()-$pid_time>86400){ if (time() - $pid_time > 86400) {
@unlink("tmp/sanity-lock"); @unlink("tmp/sanity-lock");
} }
if(!$ignore_lock) die("Sanity lock in place"); if (!$ignore_lock) {
die("Sanity lock in place");
}
} }
// set the new sanity lock // set the new sanity lock
$lock = fopen("tmp/sanity-lock", "w"); $lock = fopen("tmp/sanity-lock", "w");
fclose($lock); fclose($lock);
$arg=trim($argv[1]); $arg = trim($argv[1]);
$arg2=trim($argv[2]); $arg2 = trim($argv[2]);
echo "Sleeping for 3 seconds\n"; echo "Sleeping for 3 seconds\n";
// sleep for 3 seconds to make sure there's a delay between starting the sanity and other processes // sleep for 3 seconds to make sure there's a delay between starting the sanity and other processes
if($arg!="microsanity") sleep(3); if ($arg != "microsanity") {
sleep(3);
}
require_once("include/init.inc.php"); require_once("include/init.inc.php");
// the sanity can't run without the schema being installed // the sanity can't run without the schema being installed
if($_config['dbversion']<2){ if ($_config['dbversion'] < 2) {
die("DB schema not created"); die("DB schema not created");
@unlink("tmp/sanity-lock"); @unlink("tmp/sanity-lock");
exit; exit;
} }
$block=new Block(); $block = new Block();
$acc=new Account(); $acc = new Account();
$current=$block->current(); $current = $block->current();
// the microsanity process is an anti-fork measure that will determine the best blockchain to choose for the last block // the microsanity process is an anti-fork measure that will determine the best blockchain to choose for the last block
$microsanity=false; $microsanity = false;
if($arg=="microsanity"&&!empty($arg2)){ if ($arg == "microsanity" && !empty($arg2)) {
do {
// the microsanity runs only against 1 specific peer
$x = $db->row("SELECT id,hostname FROM peers WHERE reserve=0 AND blacklisted<UNIX_TIMESTAMP() AND ip=:ip",
[":ip" => $arg2]);
do { if (!$x) {
// the microsanity runs only against 1 specific peer echo "Invalid node - $arg2\n";
$x=$db->row("SELECT id,hostname FROM peers WHERE reserve=0 AND blacklisted<UNIX_TIMESTAMP() AND ip=:ip",array(":ip"=>$arg2)); break;
}
$url = $x['hostname']."/peer.php?q=";
$data = peer_post($url."getBlock", ["height" => $current['height']]);
if(!$x){ echo "Invalid node - $arg2\n"; break; } if (!$data) {
$url=$x['hostname']."/peer.php?q="; echo "Invalid getBlock result\n";
$data=peer_post($url."getBlock",array("height"=>$current['height'])); break;
}
$data['id'] = san($data['id']);
$data['height'] = san($data['height']);
// nothing to be done, same blockchain
if ($data['id'] == $current['id']) {
echo "Same block\n";
break;
}
if(!$data) {echo "Invalid getBlock result\n"; break; } // the blockchain with the most transactions wins the fork (to encourage the miners to include as many transactions as possible) / might backfire on garbage
$data['id']=san($data['id']); if ($current['transactions'] > $data['transactions']) {
$data['height']=san($data['height']); echo "Block has less transactions\n";
// nothing to be done, same blockchain break;
if($data['id']==$current['id']) {echo "Same block\n"; break;} } elseif ($current['transactions'] == $data['transactions']) {
// transform the first 12 chars into an integer and choose the blockchain with the biggest value
$no1 = hexdec(substr(coin2hex($current['id']), 0, 12));
$no2 = hexdec(substr(coin2hex($data['id']), 0, 12));
// the blockchain with the most transactions wins the fork (to encourage the miners to include as many transactions as possible) / might backfire on garbage if (gmp_cmp($no1, $no2) != -1) {
if($current['transactions']>$data['transactions']){ echo "Block hex larger than current\n";
echo "Block has less transactions\n"; break;
break; }
} elseif($current['transactions']==$data['transactions']) { }
// transform the first 12 chars into an integer and choose the blockchain with the biggest value // make sure the block is valid
$no1=hexdec(substr(coin2hex($current['id']),0,12)); $prev = $block->get($current['height'] - 1);
$no2=hexdec(substr(coin2hex($data['id']),0,12)); $public = $acc->public_key($data['generator']);
if (!$block->mine($public, $data['nonce'], $data['argon'], $block->difficulty($current['height'] - 1),
$prev['id'], $prev['height'])) {
echo "Invalid prev-block\n";
break;
}
if (!$block->check($data)) {
break;
}
if(gmp_cmp($no1,$no2)!=-1){ // delete the last block
echo "Block hex larger than current\n"; $block->pop(1);
break;
}
}
// make sure the block is valid
$prev = $block->get($current['height']-1);
$public=$acc->public_key($data['generator']);
if(!$block->mine($public, $data['nonce'],$data['argon'],$block->difficulty($current['height']-1),$prev['id'], $prev['height'])) { echo "Invalid prev-block\n"; break;}
if(!$block->check($data)) break;
// delete the last block
$block->pop(1);
// add the new block // add the new block
echo "Starting to sync last block from $x[hostname]\n"; echo "Starting to sync last block from $x[hostname]\n";
$b=$data; $b = $data;
$res=$block->add($b['height'], $b['public_key'], $b['nonce'], $b['data'], $b['date'], $b['signature'], $b['difficulty'], $b['reward_signature'], $b['argon']); $res = $block->add($b['height'], $b['public_key'], $b['nonce'], $b['data'], $b['date'], $b['signature'],
if(!$res) { $b['difficulty'], $b['reward_signature'], $b['argon']);
if (!$res) {
_log("Block add: could not add block - $b[id] - $b[height]");
_log("Block add: could not add block - $b[id] - $b[height]"); break;
}
break; _log("Synced block from $host - $b[height] $b[difficulty]");
} } while (0);
_log("Synced block from $host - $b[height] $b[difficulty]"); @unlink("tmp/sanity-lock");
exit;
} while(0);
@unlink("tmp/sanity-lock");
exit;
} }
$t=time(); $t = time();
//if($t-$_config['sanity_last']<300) {@unlink("tmp/sanity-lock"); die("The sanity cron was already run recently"); } //if($t-$_config['sanity_last']<300) {@unlink("tmp/sanity-lock"); die("The sanity cron was already run recently"); }
_log("Starting sanity"); _log("Starting sanity");
// update the last time sanity ran, to set the execution of the next run // update the last time sanity ran, to set the execution of the next run
$db->run("UPDATE config SET val=:time WHERE cfg='sanity_last'",array(":time"=>$t)); $db->run("UPDATE config SET val=:time WHERE cfg='sanity_last'", [":time" => $t]);
$block_peers=array(); $block_peers = [];
$longest_size=0; $longest_size = 0;
$longest=0; $longest = 0;
$blocks=array(); $blocks = [];
$blocks_count=array(); $blocks_count = [];
$most_common=""; $most_common = "";
$most_common_size=0; $most_common_size = 0;
$total_active_peers=0; $total_active_peers = 0;
// checking peers // checking peers
// delete the dead peers // delete the dead peers
$db->run("DELETE from peers WHERE fails>100 OR stuckfail>200"); $db->run("DELETE from peers WHERE fails>100 OR stuckfail>200");
$r=$db->run("SELECT id,hostname,stuckfail,fails FROM peers WHERE reserve=0 AND blacklisted<UNIX_TIMESTAMP()"); $r = $db->run("SELECT id,hostname,stuckfail,fails FROM peers WHERE reserve=0 AND blacklisted<UNIX_TIMESTAMP()");
$total_peers=count($r); $total_peers = count($r);
$peered=array(); $peered = [];
// if we have no peers, get the seed list from the official site // if we have no peers, get the seed list from the official site
if($total_peers==0&&$_config['testnet']==false){ if ($total_peers == 0 && $_config['testnet'] == false) {
$i=0; $i = 0;
echo "No peers found. Attempting to get peers from arionum.com\n"; echo "No peers found. Attempting to get peers from arionum.com\n";
$f=file("https://www.arionum.com/peers.txt"); $f = file("https://www.arionum.com/peers.txt");
shuffle($f); shuffle($f);
// we can't connect to arionum.com // we can't connect to arionum.com
if(count($f)<2){ @unlink("tmp/sanity-lock"); die("Could nto connect to arionum.com! Will try later!\n"); } if (count($f) < 2) {
foreach($f as $peer){ @unlink("tmp/sanity-lock");
//peer with all until max_peers, this will ask them to send a peering request to our peer.php where we add their peer to the db. die("Could nto connect to arionum.com! Will try later!\n");
$peer=trim(san_host($peer)); }
$bad_peers=array("127.0.0.1","localhost","10.0.0","192.168.0"); foreach ($f as $peer) {
if(str_replace($bad_peers,"",$peer)!=$peer) continue; //peer with all until max_peers, this will ask them to send a peering request to our peer.php where we add their peer to the db.
$peer = filter_var($peer, FILTER_SANITIZE_URL); $peer = trim(san_host($peer));
if (!filter_var($peer, FILTER_VALIDATE_URL)) continue; $bad_peers = ["127.0.0.1", "localhost", "10.0.0", "192.168.0"];
// store the hostname as md5 hash, for easier checking if (str_replace($bad_peers, "", $peer) != $peer) {
$pid=md5($peer); continue;
// do not peer if we are already peered }
if($peered[$pid]==1) continue; $peer = filter_var($peer, FILTER_SANITIZE_URL);
$peered[$pid]=1; if (!filter_var($peer, FILTER_VALIDATE_URL)) {
$res=peer_post($peer."/peer.php?q=peer",array("hostname"=>$_config['hostname'], "repeer"=>1)); continue;
if($res!==false) {$i++; echo "Peering OK - $peer\n"; } }
else echo "Peering FAIL - $peer\n"; // store the hostname as md5 hash, for easier checking
if($i>$_config['max_peers']) break; $pid = md5($peer);
} // do not peer if we are already peered
// count the total peers we have if ($peered[$pid] == 1) {
$r=$db->run("SELECT id,hostname FROM peers WHERE reserve=0 AND blacklisted<UNIX_TIMESTAMP()"); continue;
$total_peers=count($r); }
if($total_peers==0){ $peered[$pid] = 1;
// something went wrong, could nto add any peers -> exit $res = peer_post($peer."/peer.php?q=peer", ["hostname" => $_config['hostname'], "repeer" => 1]);
@unlink("tmp/sanity-lock"); if ($res !== false) {
die("Could not peer to any peers! Please check internet connectivity!\n"); $i++;
} echo "Peering OK - $peer\n";
} else {
echo "Peering FAIL - $peer\n";
}
if ($i > $_config['max_peers']) {
break;
}
}
// count the total peers we have
$r = $db->run("SELECT id,hostname FROM peers WHERE reserve=0 AND blacklisted<UNIX_TIMESTAMP()");
$total_peers = count($r);
if ($total_peers == 0) {
// something went wrong, could nto add any peers -> exit
@unlink("tmp/sanity-lock");
die("Could not peer to any peers! Please check internet connectivity!\n");
}
} }
// contact all the active peers // contact all the active peers
foreach($r as $x){ foreach ($r as $x) {
_log("Contacting peer $x[hostname]"); _log("Contacting peer $x[hostname]");
$url=$x['hostname']."/peer.php?q="; $url = $x['hostname']."/peer.php?q=";
// get their peers list // get their peers list
$data=peer_post($url."getPeers",array(),5); $data = peer_post($url."getPeers", [], 5);
if($data===false) { if ($data === false) {
_log("Peer $x[hostname] unresponsive"); _log("Peer $x[hostname] unresponsive");
// if the peer is unresponsive, mark it as failed and blacklist it for a while // if the peer is unresponsive, mark it as failed and blacklist it for a while
$db->run("UPDATE peers SET fails=fails+1, blacklisted=UNIX_TIMESTAMP()+((fails+1)*3600) WHERE id=:id",array(":id"=>$x['id'])); $db->run("UPDATE peers SET fails=fails+1, blacklisted=UNIX_TIMESTAMP()+((fails+1)*3600) WHERE id=:id",
continue; [":id" => $x['id']]);
} continue;
}
$i=0; $i = 0;
foreach($data as $peer){ foreach ($data as $peer) {
// store the hostname as md5 hash, for easier checking // store the hostname as md5 hash, for easier checking
$peer['hostname']=san_host($peer['hostname']); $peer['hostname'] = san_host($peer['hostname']);
$peer['ip']=san_ip($peer['ip']); $peer['ip'] = san_ip($peer['ip']);
$pid=md5($peer['hostname']); $pid = md5($peer['hostname']);
// do not peer if we are already peered // do not peer if we are already peered
if($peered[$pid]==1) continue; if ($peered[$pid] == 1) {
$peered[$pid]=1; continue;
$bad_peers=array("127.0.0.1","localhost","10.0.0.","192.168.0."); }
if(str_replace($bad_peers,"",$peer['hostname'])!=$peer['hostname']) continue; $peered[$pid] = 1;
// if it's our hostname, ignore $bad_peers = ["127.0.0.1", "localhost", "10.0.0.", "192.168.0."];
if($peer['hostname']==$_config['hostname']) continue; if (str_replace($bad_peers, "", $peer['hostname']) != $peer['hostname']) {
// if invalid hostname, ignore continue;
if (!filter_var($peer['hostname'], FILTER_VALIDATE_URL)) continue; }
// make sure there's no peer in db with this ip or hostname // if it's our hostname, ignore
if(!$db->single("SELECT COUNT(1) FROM peers WHERE ip=:ip or hostname=:hostname",array(":ip"=>$peer['ip'],":hostname"=>$peer['hostname']))){ if ($peer['hostname'] == $_config['hostname']) {
$i++; continue;
// check a max_test_peers number of peers from each peer }
if($i>$_config['max_test_peers']) break; // if invalid hostname, ignore
$peer['hostname'] = filter_var($peer['hostname'], FILTER_SANITIZE_URL); if (!filter_var($peer['hostname'], FILTER_VALIDATE_URL)) {
// peer with each one continue;
_log("Trying to peer with recommended peer: $peer[hostname]"); }
$test=peer_post($peer['hostname']."/peer.php?q=peer",array("hostname"=>$_config['hostname']),5); // make sure there's no peer in db with this ip or hostname
if($test!==false){ if (!$db->single("SELECT COUNT(1) FROM peers WHERE ip=:ip or hostname=:hostname",
$total_peers++; [":ip" => $peer['ip'], ":hostname" => $peer['hostname']])) {
echo "Peered with: $peer[hostname]\n"; $i++;
} // check a max_test_peers number of peers from each peer
} if ($i > $_config['max_test_peers']) {
} break;
}
$peer['hostname'] = filter_var($peer['hostname'], FILTER_SANITIZE_URL);
// peer with each one
_log("Trying to peer with recommended peer: $peer[hostname]");
$test = peer_post($peer['hostname']."/peer.php?q=peer", ["hostname" => $_config['hostname']], 5);
// get the current block and check it's blockchain if ($test !== false) {
$data=peer_post($url."currentBlock",array(),5); $total_peers++;
if($data===false) continue; echo "Peered with: $peer[hostname]\n";
// peer was responsive, mark it as good }
if($x['fails']>0) $db->run("UPDATE peers SET fails=0 WHERE id=:id",array(":id"=>$x['id'])); }
$data['id']=san($data['id']); }
$data['height']=san($data['height']);
if($data['height']<$current['height']-500) {
$db->run("UPDATE peers SET stuckfail=stuckfail+1, blacklisted=UNIX_TIMESTAMP()+7200 WHERE id=:id",array(":id"=>$x['id']));
continue;
} else {
if($x['stuckfail']>0) $db->run("UPDATE peers SET stuckfail=0 WHERE id=:id",array(":id"=>$x['id']));
}
$total_active_peers++;
// add the hostname and block relationship to an array
$block_peers[$data['id']][]=$x['hostname'];
// count the number of peers with this block id
$blocks_count[$data['id']]++;
// keep block data for this block id
$blocks[$data['id']]=$data;
// set the most common block on all peers
if($blocks_count[$data['id']]>$most_common_size){
$most_common=$data['id'];
$most_common_size=$blocks_count[$data['id']];
}
// set the largest height block
if($data['height']>$largest_height){
$largest_height=$data['height'];
$largest_height_block=$data['id'];
} elseif($data['height']==$largest_height&&$data['id']!=$largest_height_block){
// if there are multiple blocks on the largest height, choose one with the smallest (hardest) difficulty
if($data['difficulty']==$blocks[$largest_height_block]['difficulty']){
// if they have the same difficulty, choose if it's most common
if($most_common==$data['id']){
$largest_height=$data['height'];
$largest_height_block=$data['id'];
} else {
// if this block has more transactions, declare it as winner
if($blocks[$largest_height_block]['transactions']<$data['transactions']){
$largest_height=$data['height'];
$largest_height_block=$data['id'];
} elseif($blocks[$largest_height_block]['transactions']==$data['transactions']) {
// if the blocks have the same number of transactions, choose the one with the highest derived integer from the first 12 hex characters
$no1=hexdec(substr(coin2hex($largest_height_block),0,12));
$no2=hexdec(substr(coin2hex($data['id']),0,12));
if(gmp_cmp($no1,$no2)==1){
$largest_height=$data['height'];
$largest_height_block=$data['id'];
}
}
}
} elseif($data['difficulty']<$blocks[$largest_height_block]['difficulty']){
// choose smallest (hardest) difficulty
$largest_height=$data['height'];
$largest_height_block=$data['id'];
}
}
// get the current block and check it's blockchain
$data = peer_post($url."currentBlock", [], 5);
if ($data === false) {
continue;
}
// peer was responsive, mark it as good
if ($x['fails'] > 0) {
$db->run("UPDATE peers SET fails=0 WHERE id=:id", [":id" => $x['id']]);
}
$data['id'] = san($data['id']);
$data['height'] = san($data['height']);
if ($data['height'] < $current['height'] - 500) {
$db->run("UPDATE peers SET stuckfail=stuckfail+1, blacklisted=UNIX_TIMESTAMP()+7200 WHERE id=:id",
[":id" => $x['id']]);
continue;
} else {
if ($x['stuckfail'] > 0) {
$db->run("UPDATE peers SET stuckfail=0 WHERE id=:id", [":id" => $x['id']]);
}
}
$total_active_peers++;
// add the hostname and block relationship to an array
$block_peers[$data['id']][] = $x['hostname'];
// count the number of peers with this block id
$blocks_count[$data['id']]++;
// keep block data for this block id
$blocks[$data['id']] = $data;
// set the most common block on all peers
if ($blocks_count[$data['id']] > $most_common_size) {
$most_common = $data['id'];
$most_common_size = $blocks_count[$data['id']];
}
// set the largest height block
if ($data['height'] > $largest_height) {
$largest_height = $data['height'];
$largest_height_block = $data['id'];
} elseif ($data['height'] == $largest_height && $data['id'] != $largest_height_block) {
// if there are multiple blocks on the largest height, choose one with the smallest (hardest) difficulty
if ($data['difficulty'] == $blocks[$largest_height_block]['difficulty']) {
// if they have the same difficulty, choose if it's most common
if ($most_common == $data['id']) {
$largest_height = $data['height'];
$largest_height_block = $data['id'];
} else {
// if this block has more transactions, declare it as winner
if ($blocks[$largest_height_block]['transactions'] < $data['transactions']) {
$largest_height = $data['height'];
$largest_height_block = $data['id'];
} elseif ($blocks[$largest_height_block]['transactions'] == $data['transactions']) {
// if the blocks have the same number of transactions, choose the one with the highest derived integer from the first 12 hex characters
$no1 = hexdec(substr(coin2hex($largest_height_block), 0, 12));
$no2 = hexdec(substr(coin2hex($data['id']), 0, 12));
if (gmp_cmp($no1, $no2) == 1) {
$largest_height = $data['height'];
$largest_height_block = $data['id'];
}
}
}
} elseif ($data['difficulty'] < $blocks[$largest_height_block]['difficulty']) {
// choose smallest (hardest) difficulty
$largest_height = $data['height'];
$largest_height_block = $data['id'];
}
}
} }
echo "Most common: $most_common\n"; echo "Most common: $most_common\n";
echo "Most common block: $most_common_size\n"; echo "Most common block: $most_common_size\n";
@@ -310,102 +354,126 @@ echo "Max height: $largest_height\n";
echo "Current block: $current[height]\n"; echo "Current block: $current[height]\n";
// if we're not on the largest height // if we're not on the largest height
if($current['height']<$largest_height&&$largest_height>1){ if ($current['height'] < $largest_height && $largest_height > 1) {
// start sanity sync / block all other transactions/blocks // start sanity sync / block all other transactions/blocks
$db->run("UPDATE config SET val=1 WHERE cfg='sanity_sync'"); $db->run("UPDATE config SET val=1 WHERE cfg='sanity_sync'");
sleep(10); sleep(10);
_log("Longest chain rule triggered - $largest_height - $largest_height_block"); _log("Longest chain rule triggered - $largest_height - $largest_height_block");
// choose the peers which have the larget height block // choose the peers which have the larget height block
$peers=$block_peers[$largest_height_block]; $peers = $block_peers[$largest_height_block];
shuffle($peers); shuffle($peers);
// sync from them // sync from them
foreach($peers as $host){ foreach ($peers as $host) {
_log("Starting to sync from $host"); _log("Starting to sync from $host");
$url=$host."/peer.php?q="; $url = $host."/peer.php?q=";
$data=peer_post($url."getBlock",array("height"=>$current['height']),60); $data = peer_post($url."getBlock", ["height" => $current['height']], 60);
// invalid data // invalid data
if($data===false){ _log("Could not get block from $host - $current[height]"); continue; } if ($data === false) {
$data['id']=san($data['id']); _log("Could not get block from $host - $current[height]");
$data['height']=san($data['height']); continue;
}
$data['id'] = san($data['id']);
$data['height'] = san($data['height']);
// if we're not on the same blockchain but the blockchain is most common with over 90% of the peers, delete the last 3 blocks and retry // if we're not on the same blockchain but the blockchain is most common with over 90% of the peers, delete the last 3 blocks and retry
if($data['id']!=$current['id']&&$data['id']==$most_common&&($most_common_size/$total_active_peers)>0.90){ if ($data['id'] != $current['id'] && $data['id'] == $most_common && ($most_common_size / $total_active_peers) > 0.90) {
$block->delete($current['height']-3); $block->delete($current['height'] - 3);
$current=$block->current(); $current = $block->current();
$data=peer_post($url."getBlock",array("height"=>$current['height'])); $data = peer_post($url."getBlock", ["height" => $current['height']]);
if($data===false){_log("Could not get block from $host - $current[height]"); break; } if ($data === false) {
_log("Could not get block from $host - $current[height]");
break;
}
} elseif ($data['id'] != $current['id'] && $data['id'] != $most_common) {
//if we're not on the same blockchain and also it's not the most common, verify all the blocks on on this blockchain starting at current-10 until current
$invalid = false;
$last_good = $current['height'];
for ($i = $current['height'] - 10; $i < $current['height']; $i++) {
$data = peer_post($url."getBlock", ["height" => $i]);
if ($data === false) {
$invalid = true;
break;
}
$ext = $block->get($i);
if ($i == $current['height'] - 10 && $ext['id'] != $data['id']) {
$invalid = true;
break;
}
}elseif($data['id']!=$current['id']&&$data['id']!=$most_common){ if ($ext['id'] == $data['id']) {
//if we're not on the same blockchain and also it's not the most common, verify all the blocks on on this blockchain starting at current-10 until current $last_good = $i;
$invalid=false; }
$last_good=$current['height']; }
for($i=$current['height']-10;$i<$current['height'];$i++){ // if last 10 blocks are good, verify all the blocks
$data=peer_post($url."getBlock",array("height"=>$i)); if ($invalid == false) {
if($data===false){ $invalid=true; break; } $cblock = [];
$ext=$block->get($i); for ($i = $last_good; $i <= $largest_height; $i++) {
if($i==$current['height']-10&&$ext['id']!=$data['id']){ $invalid=true; break; } $data = peer_post($url."getBlock", ["height" => $i]);
if ($data === false) {
$invalid = true;
break;
}
$cblock[$i] = $data;
}
// check if the block mining data is correct
for ($i = $last_good + 1; $i <= $largest_height; $i++) {
if (!$block->mine($cblock[$i]['public_key'], $cblock[$i]['nonce'], $cblock[$i]['argon'],
$cblock[$i]['difficulty'], $cblock[$i - 1]['id'], $cblock[$i - 1]['height'])) {
$invalid = true;
break;
}
}
}
// if the blockchain proves ok, delete until the last block
if ($invalid == false) {
$block->delete($last_good);
$current = $block->current();
$data = $current;
}
}
// if current still doesn't match the data, something went wrong
if ($data['id'] != $current['id']) {
continue;
}
// start syncing all blocks
while ($current['height'] < $largest_height) {
$data = peer_post($url."getBlocks", ["height" => $current['height'] + 1]);
if($ext['id']==$data['id']) $last_good=$i; if ($data === false) {
_log("Could not get blocks from $host - height: $current[height]");
break;
}
$good_peer = true;
foreach ($data as $b) {
$b['id'] = san($b['id']);
$b['height'] = san($b['height']);
} if (!$block->check($b)) {
// if last 10 blocks are good, verify all the blocks _log("Block check: could not add block - $b[id] - $b[height]");
if($invalid==false) { $good_peer = false;
$cblock=array(); break;
for($i=$last_good;$i<=$largest_height;$i++){ }
$data=peer_post($url."getBlock",array("height"=>$i)); $res = $block->add($b['height'], $b['public_key'], $b['nonce'], $b['data'], $b['date'], $b['signature'],
if($data===false){ $invalid=true; break; } $b['difficulty'], $b['reward_signature'], $b['argon']);
$cblock[$i]=$data; if (!$res) {
} _log("Block add: could not add block - $b[id] - $b[height]");
// check if the block mining data is correct $good_peer = false;
for($i=$last_good+1;$i<=$largest_height;$i++){ break;
if(!$block->mine($cblock[$i]['public_key'], $cblock[$i]['nonce'], $cblock[$i]['argon'], $cblock[$i]['difficulty'], $cblock[$i-1]['id'],$cblock[$i-1]['height'])) {$invalid=true; break; } }
}
}
// if the blockchain proves ok, delete until the last block
if($invalid==false){
$block->delete($last_good);
$current=$block->current();
$data=$current;
}
} _log("Synced block from $host - $b[height] $b[difficulty]");
// if current still doesn't match the data, something went wrong }
if($data['id']!=$current['id']) continue; if (!$good_peer) {
// start syncing all blocks break;
while($current['height']<$largest_height){ }
$data=peer_post($url."getBlocks",array("height"=>$current['height']+1)); $current = $block->current();
}
if($data===false){_log("Could not get blocks from $host - height: $current[height]"); break; } if ($good_peer) {
$good_peer=true; break;
foreach($data as $b){ }
$b['id']=san($b['id']); }
$b['height']=san($b['height']); $db->run("UPDATE config SET val=0 WHERE cfg='sanity_sync'", [":time" => $t]);
if(!$block->check($b)){
_log("Block check: could not add block - $b[id] - $b[height]");
$good_peer=false;
break;
}
$res=$block->add($b['height'], $b['public_key'], $b['nonce'], $b['data'], $b['date'], $b['signature'], $b['difficulty'], $b['reward_signature'], $b['argon']);
if(!$res) {
_log("Block add: could not add block - $b[id] - $b[height]");
$good_peer=false;
break;
}
_log("Synced block from $host - $b[height] $b[difficulty]");
}
if(!$good_peer) break;
$current=$block->current();
}
if($good_peer) break;
}
$db->run("UPDATE config SET val=0 WHERE cfg='sanity_sync'",array(":time"=>$t));
} }
@@ -413,96 +481,106 @@ if($current['height']<$largest_height&&$largest_height>1){
$db->run("DELETE FROM `mempool` WHERE `date` < UNIX_TIMESTAMP()-(3600*24*14)"); $db->run("DELETE FROM `mempool` WHERE `date` < UNIX_TIMESTAMP()-(3600*24*14)");
//rebroadcasting local transactions //rebroadcasting local transactions
if($_config['sanity_rebroadcast_locals']==true){ if ($_config['sanity_rebroadcast_locals'] == true) {
$r=$db->run("SELECT id FROM mempool WHERE height>=:current and peer='local' order by `height` asc LIMIT 20",array(":current"=>$current['height'])); $r = $db->run("SELECT id FROM mempool WHERE height>=:current and peer='local' order by `height` asc LIMIT 20",
_log("Rebroadcasting local transactions - ".count($r)); [":current" => $current['height']]);
foreach($r as $x){ _log("Rebroadcasting local transactions - ".count($r));
$x['id']=san($x['id']); foreach ($r as $x) {
$x['id'] = san($x['id']);
system("php propagate.php transaction $x[id] > /dev/null 2>&1 &"); system("php propagate.php transaction $x[id] > /dev/null 2>&1 &");
$db->run("UPDATE mempool SET height=:current WHERE id=:id",array(":id"=>$x['id'], ":current"=>$current['height'])); $db->run("UPDATE mempool SET height=:current WHERE id=:id",
} [":id" => $x['id'], ":current" => $current['height']]);
}
} }
//rebroadcasting transactions //rebroadcasting transactions
$forgotten=$current['height']-$_config['sanity_rebroadcast_height']; $forgotten = $current['height'] - $_config['sanity_rebroadcast_height'];
$r=$db->run("SELECT id FROM mempool WHERE height<:forgotten ORDER by val DESC LIMIT 10",array(":forgotten"=>$forgotten)); $r = $db->run("SELECT id FROM mempool WHERE height<:forgotten ORDER by val DESC LIMIT 10",
[":forgotten" => $forgotten]);
_log("Rebroadcasting external transactions - ".count($r)); _log("Rebroadcasting external transactions - ".count($r));
foreach($r as $x){ foreach ($r as $x) {
$x['id']=san($x['id']); $x['id'] = san($x['id']);
system("php propagate.php transaction $x[id] > /dev/null 2>&1 &"); system("php propagate.php transaction $x[id] > /dev/null 2>&1 &");
$db->run("UPDATE mempool SET height=:current WHERE id=:id",array(":id"=>$x['id'], ":current"=>$current['height'])); $db->run("UPDATE mempool SET height=:current WHERE id=:id", [":id" => $x['id'], ":current" => $current['height']]);
} }
//add new peers if there aren't enough active //add new peers if there aren't enough active
if($total_peers<$_config['max_peers']*0.7){ if ($total_peers < $_config['max_peers'] * 0.7) {
$res=$_config['max_peers']-$total_peers; $res = $_config['max_peers'] - $total_peers;
$db->run("UPDATE peers SET reserve=0 WHERE reserve=1 AND blacklisted<UNIX_TIMESTAMP() LIMIT $res"); $db->run("UPDATE peers SET reserve=0 WHERE reserve=1 AND blacklisted<UNIX_TIMESTAMP() LIMIT $res");
} }
//random peer check //random peer check
$r=$db->run("SELECT * FROM peers WHERE blacklisted<UNIX_TIMESTAMP() and reserve=1 LIMIT ".$_config['max_test_peers']); $r = $db->run("SELECT * FROM peers WHERE blacklisted<UNIX_TIMESTAMP() and reserve=1 LIMIT ".$_config['max_test_peers']);
foreach($r as $x){ foreach ($r as $x) {
$url = $x['hostname']."/peer.php?q=";
$url=$x['hostname']."/peer.php?q="; $data = peer_post($url."ping", [], 5);
$data=peer_post($url."ping",array(),5); if ($data === false) {
if($data===false){ $db->run("UPDATE peers SET fails=fails+1, blacklisted=UNIX_TIMESTAMP()+((fails+1)*60) WHERE id=:id",
$db->run("UPDATE peers SET fails=fails+1, blacklisted=UNIX_TIMESTAMP()+((fails+1)*60) WHERE id=:id",array(":id"=>$x['id'])); [":id" => $x['id']]);
_log("Random reserve peer test $x[hostname] -> FAILED"); _log("Random reserve peer test $x[hostname] -> FAILED");
}else{ } else {
_log("Random reserve peer test $x[hostname] -> OK"); _log("Random reserve peer test $x[hostname] -> OK");
$db->run("UPDATE peers SET fails=0 WHERE id=:id",array(":id"=>$x['id'])); $db->run("UPDATE peers SET fails=0 WHERE id=:id", [":id" => $x['id']]);
} }
} }
//clean tmp files //clean tmp files
_log("Cleaning tmp files"); _log("Cleaning tmp files");
$f=scandir("tmp/"); $f = scandir("tmp/");
$time=time(); $time = time();
foreach($f as $x){ foreach ($f as $x) {
if(strlen($x)<5&&substr($x,0,1)==".") continue; if (strlen($x) < 5 && substr($x, 0, 1) == ".") {
$pid_time=filemtime("tmp/$x"); continue;
if($time-$pid_time>7200) @unlink("tmp/$x"); }
$pid_time = filemtime("tmp/$x");
if ($time - $pid_time > 7200) {
@unlink("tmp/$x");
}
} }
//recheck the last blocks //recheck the last blocks
if($_config['sanity_recheck_blocks']>0){ if ($_config['sanity_recheck_blocks'] > 0) {
_log("Rechecking blocks"); _log("Rechecking blocks");
$blocks=array(); $blocks = [];
$all_blocks_ok=true; $all_blocks_ok = true;
$start=$current['height']-$_config['sanity_recheck_blocks']; $start = $current['height'] - $_config['sanity_recheck_blocks'];
if($start<2) $start=2; if ($start < 2) {
$r=$db->run("SELECT * FROM blocks WHERE height>=:height ORDER by height ASC",array(":height"=>$start)); $start = 2;
foreach($r as $x){ }
$blocks[$x['height']]=$x; $r = $db->run("SELECT * FROM blocks WHERE height>=:height ORDER by height ASC", [":height" => $start]);
$max_height=$x['height']; foreach ($r as $x) {
} $blocks[$x['height']] = $x;
$max_height = $x['height'];
}
for($i=$start+1;$i<=$max_height;$i++){ for ($i = $start + 1; $i <= $max_height; $i++) {
$data=$blocks[$i]; $data = $blocks[$i];
$key=$db->single("SELECT public_key FROM accounts WHERE id=:id",array(":id"=>$data['generator'])); $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'])) { if (!$block->mine($key, $data['nonce'], $data['argon'], $data['difficulty'], $blocks[$i - 1]['id'],
$db->run("UPDATE config SET val=1 WHERE cfg='sanity_sync'"); $blocks[$i - 1]['height'])) {
_log("Invalid block detected. Deleting everything after $data[height] - $data[id]"); $db->run("UPDATE config SET val=1 WHERE cfg='sanity_sync'");
sleep(10); _log("Invalid block detected. Deleting everything after $data[height] - $data[id]");
$all_blocks_ok=false; sleep(10);
$block->delete($i); $all_blocks_ok = false;
$block->delete($i);
$db->run("UPDATE config SET val=0 WHERE cfg='sanity_sync'"); $db->run("UPDATE config SET val=0 WHERE cfg='sanity_sync'");
break; break;
} }
} }
if($all_blocks_ok) echo "All checked blocks are ok\n"; if ($all_blocks_ok) {
echo "All checked blocks are ok\n";
}
} }
_log("Finishing sanity"); _log("Finishing sanity");
@unlink("tmp/sanity-lock"); @unlink("tmp/sanity-lock");
?>