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

Update propagate file to PSR-2

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

93
propagate.php
View File

@@ -32,8 +32,12 @@ $id=san($argv[2]);
$debug = false; $debug = false;
$linear = false; $linear = false;
// if debug mode, all data is printed to console, no background processes // if debug mode, all data is printed to console, no background processes
if(trim($argv[5])=='debug') $debug=true; if (trim($argv[5]) == 'debug') {
if(trim($argv[5])=='linear') $linear=true; $debug = true;
}
if (trim($argv[5]) == 'linear') {
$linear = true;
}
$peer = san(trim($argv[3])); $peer = san(trim($argv[3]));
@@ -46,95 +50,128 @@ if((empty($peer)||$peer=='all')&&$type=="block"){
} }
$data = $block->export($id); $data = $block->export($id);
$id = san($id); $id = san($id);
if($data===false||empty($data)) die("Could not export block"); if ($data === false || empty($data)) {
die("Could not export block");
}
$data = json_encode($data); $data = json_encode($data);
// cache it to reduce the load // cache it to reduce the load
$res = file_put_contents("tmp/$id", $data); $res = file_put_contents("tmp/$id", $data);
if($res===false) die("Could not write the cache file"); if ($res === false) {
die("Could not write the cache file");
}
// broadcasting to all peers // broadcasting to all peers
$ewhr = ""; $ewhr = "";
// boradcasting to only certain peers // boradcasting to only certain peers
if($linear==true) $ewhr=" ORDER by RAND() LIMIT 5"; if ($linear == true) {
$ewhr = " ORDER by RAND() LIMIT 5";
}
$r = $db->run("SELECT * FROM peers WHERE blacklisted < UNIX_TIMESTAMP() AND reserve=0 $ewhr"); $r = $db->run("SELECT * FROM peers WHERE blacklisted < UNIX_TIMESTAMP() AND reserve=0 $ewhr");
foreach ($r as $x) { foreach ($r as $x) {
// encode the hostname in base58 and sanitize the IP to avoid any second order shell injections // encode the hostname in base58 and sanitize the IP to avoid any second order shell injections
$host = base58_encode($x['hostname']); $host = base58_encode($x['hostname']);
$ip = filter_var($x['ip'], FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE); $ip = filter_var($x['ip'], FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE);
// fork a new process to send the blocks async // fork a new process to send the blocks async
if($debug) system("php propagate.php '$type' '$id' '$host' '$ip' debug"); if ($debug) {
elseif($linear) system("php propagate.php '$type' '$id' '$host' '$ip' linear"); system("php propagate.php '$type' '$id' '$host' '$ip' debug");
else system("php propagate.php '$type' '$id' '$host' 'ip' > /dev/null 2>&1 &"); } elseif ($linear) {
system("php propagate.php '$type' '$id' '$host' '$ip' linear");
} else {
system("php propagate.php '$type' '$id' '$host' 'ip' > /dev/null 2>&1 &");
}
} }
exit; exit;
} }
// broadcast a block to a single peer (usually a forked process from above) // broadcast a block to a single peer (usually a forked process from above)
if ($type == "block") { if ($type == "block") {
// current block or read cache // current block or read cache
if ($id == "current") { if ($id == "current") {
$current = $block->current(); $current = $block->current();
$data = $block->export($current['id']); $data = $block->export($current['id']);
if(!$data) { echo "Invalid Block data"; exit; } if (!$data) {
echo "Invalid Block data";
exit;
}
} else { } else {
$data = file_get_contents("tmp/$id"); $data = file_get_contents("tmp/$id");
if(empty($data)) { echo "Invalid Block data"; exit; } if (empty($data)) {
echo "Invalid Block data";
exit;
}
$data = json_decode($data, true); $data = json_decode($data, true);
} }
$hostname = base58_decode($peer); $hostname = base58_decode($peer);
// send the block as POST to the peer // send the block as POST to the peer
echo "Block sent to $hostname:\n"; echo "Block sent to $hostname:\n";
$response = peer_post($hostname."/peer.php?q=submitBlock", $data, 60, $debug); $response = peer_post($hostname."/peer.php?q=submitBlock", $data, 60, $debug);
if($response=="block-ok") { echo "Block $i accepted. Exiting.\n"; exit;} if ($response == "block-ok") {
elseif($response['request']=="microsync"){ echo "Block $i accepted. Exiting.\n";
exit;
} elseif ($response['request'] == "microsync") {
// the peer requested us to send more blocks, as it's behind // the peer requested us to send more blocks, as it's behind
echo "Microsync request\n"; echo "Microsync request\n";
$height = intval($response['height']); $height = intval($response['height']);
$bl = san($response['block']); $bl = san($response['block']);
$current = $block->current(); $current = $block->current();
// maximum microsync is 10 blocks, for more, the peer should sync by sanity // maximum microsync is 10 blocks, for more, the peer should sync by sanity
if($current['height']-$height>10) { echo "Height Differece too high\n"; exit; } if ($current['height'] - $height > 10) {
echo "Height Differece too high\n";
exit;
}
$last_block = $block->get($height); $last_block = $block->get($height);
// if their last block does not match our blockchain/fork, ignore the request // if their last block does not match our blockchain/fork, ignore the request
if ($last_block['id'] != $bl ) { echo "Last block does not match\n"; exit; } if ($last_block['id'] != $bl) {
echo "Last block does not match\n";
exit;
}
echo "Sending the requested blocks\n"; echo "Sending the requested blocks\n";
//start sending the requested block //start sending the requested block
for ($i = $height + 1; $i <= $current['height']; $i++) { for ($i = $height + 1; $i <= $current['height']; $i++) {
$data = $block->export("", $i); $data = $block->export("", $i);
$response = peer_post($hostname."/peer.php?q=submitBlock", $data, 60, $debug); $response = peer_post($hostname."/peer.php?q=submitBlock", $data, 60, $debug);
if($response!="block-ok") { echo "Block $i not accepted. Exiting.\n"; exit;} if ($response != "block-ok") {
echo "Block $i not accepted. Exiting.\n";
exit;
}
echo "Block\t$i\t accepted\n"; echo "Block\t$i\t accepted\n";
} }
} elseif ($response == "reverse-microsanity") { } elseif ($response == "reverse-microsanity") {
// the peer informe us that we should run a microsanity // the peer informe us that we should run a microsanity
echo "Running microsanity\n"; echo "Running microsanity\n";
$ip = trim($argv[4]); $ip = trim($argv[4]);
$ip = filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE); $ip = filter_var($ip, FILTER_VALIDATE_IP, FILTER_FLAG_NO_PRIV_RANGE | FILTER_FLAG_NO_RES_RANGE);
if(empty($ip)) die("Invalid IP"); if (empty($ip)) {
die("Invalid IP");
}
// fork a microsanity in a new process // fork a microsanity in a new process
system("php sanity.php microsanity '$ip' > /dev/null 2>&1 &"); system("php sanity.php microsanity '$ip' > /dev/null 2>&1 &");
} else {
echo "Block not accepted!\n";
} }
else echo "Block not accepted!\n";
} }
// broadcast a transaction to some peers // broadcast a transaction to some peers
if ($type == "transaction") { if ($type == "transaction") {
$trx = new Transaction; $trx = new Transaction;
// get the transaction data // get the transaction data
$data = $trx->export($id); $data = $trx->export($id);
if(!$data){ echo "Invalid transaction id\n"; exit; } if (!$data) {
echo "Invalid transaction id\n";
exit;
}
// if the transaction was first sent locally, we will send it to all our peers, otherwise to just a few // if the transaction was first sent locally, we will send it to all our peers, otherwise to just a few
if($data['peer']=="local") $r=$db->run("SELECT hostname FROM peers WHERE blacklisted < UNIX_TIMESTAMP()"); if ($data['peer'] == "local") {
else $r=$db->run("SELECT hostname FROM peers WHERE blacklisted < UNIX_TIMESTAMP() AND reserve=0 ORDER by RAND() LIMIT ".intval($_config['transaction_propagation_peers'])); $r = $db->run("SELECT hostname FROM peers WHERE blacklisted < UNIX_TIMESTAMP()");
} else {
$r = $db->run("SELECT hostname FROM peers WHERE blacklisted < UNIX_TIMESTAMP() AND reserve=0 ORDER by RAND() LIMIT ".intval($_config['transaction_propagation_peers']));
}
foreach ($r as $x) { foreach ($r as $x) {
$res = peer_post($x['hostname']."/peer.php?q=submitTransaction", $data); $res = peer_post($x['hostname']."/peer.php?q=submitTransaction", $data);
if(!$res) echo "Transaction not accepted\n"; if (!$res) {
else echo "Transaction accepted\n"; echo "Transaction not accepted\n";
} else {
echo "Transaction accepted\n";
}
} }
} }
?>