186 lines
7.3 KiB
PHP
Executable File
186 lines
7.3 KiB
PHP
Executable File
<?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.
|
|
*/
|
|
require_once("include/init.inc.php");
|
|
$trx = new Transaction;
|
|
$block=new Block;
|
|
$q=$_GET['q'];
|
|
if(!empty($_POST['data'])){
|
|
$data=json_decode(trim($_POST['data']),true);
|
|
|
|
|
|
}
|
|
|
|
if($_POST['coin']!=$_config['coin']) api_err("Invalid coin");
|
|
$ip=$_SERVER['REMOTE_ADDR'];
|
|
if($q=="peer"){
|
|
|
|
$hostname = filter_var($data['hostname'], FILTER_SANITIZE_URL);
|
|
|
|
if (!filter_var($hostname, FILTER_VALIDATE_URL)) api_err("invalid-hostname");
|
|
|
|
$res=$db->single("SELECT COUNT(1) FROM peers WHERE hostname=:hostname AND ip=:ip",array(":hostname"=>$hostname,":ip"=>$ip));
|
|
|
|
if($res==1){
|
|
if($data['repeer']==1){
|
|
$res=peer_post($hostname."/peer.php?q=peer",array("hostname"=>$_config['hostname']));
|
|
if($res!==false) api_echo("re-peer-ok");
|
|
else api_err("re-peer failed - $result");
|
|
}
|
|
api_echo("peer-ok-already");
|
|
}
|
|
$res=$db->single("SELECT COUNT(1) FROM peers WHERE blacklisted<UNIX_TIMESTAMP() AND ping >UNIX_TIMESTAMP()-86400 AND reserve=0");
|
|
$reserve=1;
|
|
if($res<$_config['max_peers']) $reserve=0;
|
|
$db->run("INSERT ignore INTO peers SET hostname=:hostname, reserve=:reserve, ping=UNIX_TIMESTAMP(), ip=:ip ON DUPLICATE KEY UPDATE hostname=:hostname2",array(":ip"=>$ip, ":hostname2"=>$hostname,":hostname"=>$hostname, ":reserve"=>$reserve));
|
|
|
|
$res=peer_post($hostname."/peer.php?q=peer",array("hostname"=>$_config['hostname']));
|
|
if($res!==false) api_echo("re-peer-ok");
|
|
else{
|
|
$db->run("DELETE FROM peers WHERE ip=:ip",array(":ip"=>$ip));
|
|
api_err("re-peer failed - $result");
|
|
}
|
|
}
|
|
elseif($q=="ping"){
|
|
api_echo("pong");
|
|
}
|
|
|
|
|
|
elseif($q=="submitTransaction"){
|
|
|
|
$current=$block->current();
|
|
|
|
if($current['height']>10790&&$current['height']<10810) api_err("Hard fork in progress. Please retry the transaction later!");
|
|
|
|
|
|
if($_config['sanity_sync']==1) api_err("sanity-sync");
|
|
|
|
$data['id']=san($data['id']);
|
|
|
|
if(!$trx->check($data)) api_err("Invalid transaction");
|
|
$hash=$data['id'];
|
|
$res=$db->single("SELECT COUNT(1) FROM mempool WHERE id=:id",array(":id"=>$hash));
|
|
if($res!=0) api_err("The transaction is already in mempool");
|
|
|
|
$res=$db->single("SELECT COUNT(1) FROM mempool WHERE src=:src",array(":src"=>$data['src']));
|
|
if($res>25) api_err("Too many transactions from this address in mempool. Please rebroadcast later.");
|
|
$res=$db->single("SELECT COUNT(1) FROM mempool WHERE peer=:peer",array(":peer"=>$_SERVER['REMOTE_ADDR']));
|
|
if($res>$_config['peer_max_mempool']) api_error("Too many transactions broadcasted from this peer");
|
|
|
|
|
|
|
|
$res=$db->single("SELECT COUNT(1) FROM transactions WHERE id=:id",array(":id"=>$hash));
|
|
if($res!=0) api_err("The transaction is already in a block");
|
|
$acc=new Account;
|
|
$src=$acc->get_address($data['public_key']);
|
|
|
|
$balance=$db->single("SELECT balance FROM accounts WHERE id=:id",array(":id"=>$src));
|
|
if($balance<$val+$fee) api_err("Not enough funds");
|
|
|
|
|
|
$memspent=$db->single("SELECT SUM(val+fee) FROM mempool WHERE src=:src",array(":src"=>$src));
|
|
if($balance-$memspent<$val+$fee) api_err("Not enough funds (mempool)");
|
|
$trx->add_mempool($data, $_SERVER['REMOTE_ADDR']);
|
|
|
|
$res=$db->row("SELECT COUNT(1) as c, sum(val) as v FROM mempool ",array(":src"=>$data['src']));
|
|
if($res['c']<$_config['max_mempool_rebroadcast']&&$res['v']/$res['c']<$data['val']) system("php propagate.php transaction '$data[id]' &>/dev/null &");
|
|
api_echo("transaction-ok");
|
|
}
|
|
elseif($q=="submitBlock"){
|
|
if($_config['sanity_sync']==1) api_err("sanity-sync");
|
|
$data['id']=san($data['id']);
|
|
$current=$block->current();
|
|
if($current['id']==$data['id']) api_echo("block-ok");
|
|
if($current['height']==$data['height']&&$current['id']!=$data['id']){
|
|
$accept_new=false;
|
|
if($current['transactions']<$data['transactions']){
|
|
$accept_new=true;
|
|
} elseif($current['transactions']==$data['transactions']) {
|
|
$no1=hexdec(substr(coin2hex($current['id']),0,12));
|
|
$no2=hexdec(substr(coin2hex($data['id']),0,12));
|
|
if(gmp_cmp($no1,$no2)==1){
|
|
$accept_new=true;
|
|
}
|
|
}
|
|
if($accept_new){
|
|
system("php sanity.php microsanity '$ip' &>/dev/null &");
|
|
api_echo("microsanity");
|
|
} else api_echo("reverse-microsanity");
|
|
}
|
|
|
|
if($current['height']!=$data['height']-1) {
|
|
if($data['height']<$current['height']){
|
|
$pr=$db->row("SELECT * FROM peers WHERE ip=:ip",array(":ip"=>$ip));
|
|
if(!$pr) api_err("block-too-old");
|
|
$peer_host=base58_encode($pr['hostname']);
|
|
system("php propagate.php block current '$peer_host' '$pr[ip]' &>/dev/null &");
|
|
api_err("block-too-old");
|
|
}
|
|
if($data['height']-$current['height']>150) api_err("block-out-of-sync");
|
|
api_echo(array("request"=>"microsync","height"=>$current['height'], "block"=>$current['id']));
|
|
|
|
}
|
|
if(!$block->check($data)) api_err("invalid-block");
|
|
$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']);
|
|
|
|
if(!$res) api_err("invalid-block-data");
|
|
api_echo("block-ok");
|
|
|
|
system("php propagate.php block '$data[id]' &>/dev/null &");
|
|
|
|
}
|
|
|
|
elseif($q=="currentBlock"){
|
|
$current=$block->current();
|
|
api_echo($current);
|
|
}
|
|
elseif($q=="getBlock"){
|
|
$height=intval($data['height']);
|
|
|
|
$export=$block->export("",$height);
|
|
if(!$export) api_err("invalid-block");
|
|
api_echo($export);
|
|
}
|
|
elseif($q=="getBlocks"){
|
|
$height=intval($data['height']);
|
|
|
|
$r=$db->run("SELECT id,height FROM blocks WHERE height>=:height ORDER by height ASC LIMIT 100",array(":height"=>$height));
|
|
foreach($r as $x){
|
|
$blocks[$x['height']]=$block->export($x['id']);
|
|
}
|
|
api_echo($blocks);
|
|
|
|
}
|
|
|
|
elseif($q=="getPeers"){
|
|
$peers=$db->run("SELECT ip,hostname FROM peers WHERE blacklisted<UNIX_TIMESTAMP() ORDER by RAND()");
|
|
api_echo($peers);
|
|
} else {
|
|
api_err("Invalid request");
|
|
}
|
|
|
|
?>
|