mirror of
https://github.com/LBRYFoundation/pool.git
synced 2025-09-20 18:09:54 +00:00
b21098c037
can be useful if blocknotify is not working or if the backend had issues.. basically search for missed generated blocks.. and create them if the second param is set Note: to use with care, old blocks are purged from the db after some time...
392 lines
12 KiB
PHP
392 lines
12 KiB
PHP
<?php
|
|
/**
|
|
* CoinCommand is a console command, to get/set coin user settings
|
|
*
|
|
* To use this command, enter the following on the command line:
|
|
* <pre>
|
|
* php web/yaamp/yiic.php coin help
|
|
* </pre>
|
|
*
|
|
* @property string $help The command description.
|
|
*
|
|
*/
|
|
class CoinCommand extends CConsoleCommand
|
|
{
|
|
protected $basePath;
|
|
|
|
/**
|
|
* Execute the action.
|
|
* @param array $args command line parameters specific for this command
|
|
* @return integer non zero application exit code after printing help
|
|
*/
|
|
public function run($args)
|
|
{
|
|
$runner=$this->getCommandRunner();
|
|
$commands=$runner->commands;
|
|
|
|
$root = realpath(Yii::app()->getBasePath().DIRECTORY_SEPARATOR.'..');
|
|
$this->basePath = str_replace(DIRECTORY_SEPARATOR, '/', $root);
|
|
|
|
$symbol = arraySafeVal($args, 0);
|
|
|
|
if (!isset($args[1]) || $args[1] == 'help') {
|
|
|
|
echo "Yiimp coin command\n";
|
|
echo "Usage: yiimp coin <SYM> delete - to delete with all related records\n";
|
|
echo " yiimp coin <SYM> purge - to clean users and history \n";
|
|
echo " yiimp coin <SYM> diff - to check if wallet diff is standard\n";
|
|
echo " yiimp coin <SYM> blocktime - estimate the chain blocktime\n";
|
|
echo " yiimp coin <SYM> checkblocks - recheck confirmed blocks\n";
|
|
echo " yiimp coin <SYM> generated [height] - search blocks not notified, set height to fix\n";
|
|
echo " yiimp coin <SYM> get <key>\n";
|
|
echo " yiimp coin <SYM> set <key> <value>\n";
|
|
echo " yiimp coin <SYM> unset <key>\n";
|
|
echo " yiimp coin <SYM> settings\n";
|
|
return 1;
|
|
|
|
} else if ($args[1] == 'delete') {
|
|
return $this->deleteCoin($symbol);
|
|
|
|
} else if ($args[1] == 'purge') {
|
|
return $this->purgeCoin($symbol);
|
|
|
|
} else if ($args[1] == 'diff') {
|
|
return $this->checkMiningDiff($symbol);
|
|
|
|
} else if ($args[1] == 'blocktime') {
|
|
return $this->estimateBlockTime($symbol);
|
|
|
|
} else if ($args[1] == 'checkblocks') {
|
|
return $this->checkConfirmedBlocks($symbol);
|
|
|
|
} else if ($args[1] == 'generated') {
|
|
$start_height = arraySafeVal($args, 2, 0);
|
|
// if start_height is set, it will create missed block(s)
|
|
return $this->listGeneratedTxs($symbol, $start_height);
|
|
|
|
} else if ($args[1] == 'get') {
|
|
return $this->getCoinSetting($args);
|
|
|
|
} else if ($args[1] == 'set') {
|
|
return $this->setCoinSetting($args);
|
|
|
|
} else if ($args[1] == 'unset') {
|
|
return $this->unsetCoinSetting($args);
|
|
|
|
} else if ($args[1] == 'settings') {
|
|
return $this->listCoinSettings($args);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Provides the command description.
|
|
* @return string the command description.
|
|
*/
|
|
public function getHelp()
|
|
{
|
|
return $this->run(array('help'));
|
|
}
|
|
|
|
private function checkSymbol($symbol)
|
|
{
|
|
return dboscalar("SELECT COUNT(*) FROM coins WHERE symbol=:symbol",
|
|
array(':symbol'=>$symbol));
|
|
}
|
|
|
|
/**
|
|
* Purge coin by symbol
|
|
*/
|
|
public function purgeCoin($symbol)
|
|
{
|
|
$coins = new db_coins;
|
|
|
|
if (!$coins instanceof CActiveRecord)
|
|
return;
|
|
|
|
$coin = $coins->find(array('condition'=>'symbol=:sym', 'params'=>array(':sym'=>$symbol)));
|
|
if ($coin)
|
|
{
|
|
$nbAccounts = getdbocount('db_accounts', "coinid=".$coin->id);
|
|
$coin->deleteDeps();
|
|
|
|
echo "coin ".$coin->symbol." purged\n";
|
|
if ($nbAccounts) {
|
|
$nbAccounts -= getdbocount('db_accounts', "coinid=".$coin->id);
|
|
echo " $nbAccounts accounts deleted\n";
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Delete (and purge) coin by symbol
|
|
*/
|
|
public function deleteCoin($symbol)
|
|
{
|
|
$coins = new db_coins;
|
|
|
|
if (!$coins instanceof CActiveRecord)
|
|
return;
|
|
|
|
$coin = $coins->find(array('condition'=>'symbol=:sym', 'params'=>array(':sym'=>$symbol)));
|
|
if ($coin)
|
|
{
|
|
$this->purgeCoin($symbol);
|
|
|
|
$coin->installed=0;
|
|
$coin->enable=0;
|
|
$coin->save();
|
|
|
|
$coin->delete();
|
|
echo "coin ".$coin->symbol." deleted\n";
|
|
}
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
/**
|
|
* Compare getminininginfo difficulty and computed one (from the target hash)
|
|
*/
|
|
public function checkMiningDiff($symbol)
|
|
{
|
|
$coins = new db_coins;
|
|
|
|
if (!$coins instanceof CActiveRecord)
|
|
return;
|
|
|
|
$coin = $coins->find(array('condition'=>'symbol=:sym', 'params'=>array(':sym'=>$symbol)));
|
|
if ($coin)
|
|
{
|
|
$remote = new WalletRPC($coin);
|
|
$tpl = $remote->getblocktemplate();
|
|
$mnf = $remote->getmininginfo();
|
|
if (empty($tpl)) die("error {$remote->error} ".json_encode($tpl)."\n");
|
|
|
|
$target = arraySafeVal($tpl,"target","");
|
|
$computed_diff = hash_to_difficulty($coin,$target);
|
|
$wallet_diff = arraySafeVal($mnf,"difficulty",0);
|
|
$factor = $computed_diff ? round($wallet_diff/$computed_diff,3) : 'NaN';
|
|
|
|
echo $coin->symbol.": network=".Itoa2(arraySafeVal($mnf,"networkhashps",0)*1000, 3)."H/s\n".
|
|
"bits=".arraySafeVal($tpl,"bits","")." target=$target\n".
|
|
"difficulty=$wallet_diff hash_to_difficulty(target)=$computed_diff factor=$factor\n";
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Extract/Compute the average block time of a block chain
|
|
*/
|
|
public function estimateBlockTime($symbol)
|
|
{
|
|
$coins = new db_coins;
|
|
|
|
if (!$coins instanceof CActiveRecord)
|
|
return;
|
|
|
|
$coin = $coins->find(array('condition'=>'symbol=:sym', 'params'=>array(':sym'=>$symbol)));
|
|
if ($coin)
|
|
{
|
|
$remote = new WalletRPC($coin);
|
|
$nfo = $remote->getinfo();
|
|
if (empty($nfo)) die("error {$remote->error} ".json_encode($nfo)."\n");
|
|
$height = arraySafeVal($nfo,"blocks",0);
|
|
|
|
$hash = $remote->getblockhash($height-1024);
|
|
if (empty($hash)) die("error {$remote->error} ".json_encode($hash)."\n");
|
|
$block = $remote->getblock($hash);
|
|
$time1 = arraySafeVal($block, 'time', 0);
|
|
|
|
$hash = $remote->getblockhash($height-512);
|
|
if (empty($hash)) die("error {$remote->error} ".json_encode($hash)."\n");
|
|
$block = $remote->getblock($hash);
|
|
$time2 = arraySafeVal($block, 'time', 0);
|
|
|
|
$hash = $remote->getblockhash($height-128);
|
|
if (empty($hash)) die("error {$remote->error} ".json_encode($hash)."\n");
|
|
$block = $remote->getblock($hash);
|
|
$time3 = arraySafeVal($block, 'time', 0);
|
|
|
|
$hash = $remote->getblockhash($height);
|
|
if (empty($hash)) die("error {$remote->error} ".json_encode($hash)."\n");
|
|
$block = $remote->getblock($hash);
|
|
$time = arraySafeVal($block, 'time', 0);
|
|
|
|
$t = intval($coin->block_time);
|
|
$human_time = sprintf('%dmn%02d', ($t/60), ($t%60));
|
|
echo $coin->symbol.": current block_time set in the db $human_time ($t sec) \n";
|
|
|
|
$t = round(($time - $time1) / 1024);
|
|
$human_time = sprintf('%dmn%02d', ($t/60), ($t%60));
|
|
echo $coin->symbol.": avg time for the last 1024 blocks = $human_time ($t sec) \n";
|
|
if (empty($coin->block_time) && $t > 10) {
|
|
$coin->block_time = $t;
|
|
$coin->save();
|
|
echo $coin->symbol.": db block_time set to $t\n";
|
|
}
|
|
$t = round(($time - $time2) / 512);
|
|
$human_time = sprintf('%dmn%02d', ($t/60), ($t%60));
|
|
echo $coin->symbol.": avg time for the last 512 blocks = $human_time ($t sec) \n";
|
|
$t = round(($time - $time3) / 128);
|
|
$human_time = sprintf('%dmn%02d', ($t/60), ($t%60));
|
|
echo $coin->symbol.": avg time for the last 128 blocks = $human_time ($t sec) \n";
|
|
}
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
public function checkConfirmedBlocks($symbol)
|
|
{
|
|
$coin = getdbosql('db_coins', 'symbol=:sym', array(':sym'=>$symbol));
|
|
if (!$coin) return -1;
|
|
$blocks = new db_blocks;
|
|
|
|
$data = $blocks->findAll(array('condition'=>"coin_id=:id AND category='generate'", 'order'=>'height DESC', 'params'=>array(':id'=>$coin->id)));
|
|
//echo count($data)." confirmed blocks to check...\n";
|
|
if (!$data || !count($data)) return 0;
|
|
|
|
$remote = new WalletRPC($coin);
|
|
$nbReset = 0; $totAmount = 0.0;
|
|
|
|
foreach ($data as $block) {
|
|
$b = $remote->getblock($block->blockhash);
|
|
$confs = arraySafeVal($b,'confirmations', 0);
|
|
if ($confs <= 0 || !$b) {
|
|
$date = strftime("%Y-%m-%d %H:%M", arraySafeVal($b,'time', $block->time));
|
|
$height = arraySafeVal($b,'height', $block->height);
|
|
$conf2 = $coin->block_height - $height;
|
|
echo arraySafeVal($b,'height')." $confs/$conf2 $date\n";
|
|
$totAmount += $block->amount;
|
|
$block->amount = 0;
|
|
$block->category = 'orphan';
|
|
$nbReset += dborun('UPDATE earnings SET amount=0 WHERE blockid='.$block->id);
|
|
$block->save();
|
|
}
|
|
}
|
|
if ($totAmount) {
|
|
echo "found $totAmount $symbol orphaned after confirmed status ($nbReset earnings reset)!\n";
|
|
} else {
|
|
echo count($data)." confirmed blocks verified\n";
|
|
}
|
|
return $nbReset;
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
public function listGeneratedTxs($symbol,$start_height=0)
|
|
{
|
|
$coin = getdbosql('db_coins', 'symbol=:sym', array(':sym'=>$symbol));
|
|
if (!$coin) return -1;
|
|
|
|
$remote = new WalletRPC($coin);
|
|
$cur_height = $remote->getblockcount();
|
|
if (!$cur_height) {
|
|
echo "unable to query current block height!\n";
|
|
return 0;
|
|
}
|
|
|
|
// note: rpc not compatible with decred
|
|
$txs = $remote->listtransactions($coin->account, 900);
|
|
if(!$txs || !is_array($txs)) {
|
|
echo "no txs found!\n";
|
|
return 0;
|
|
}
|
|
|
|
$nbOk = $nbMissed = 0;
|
|
foreach($txs as $tx) {
|
|
if ($tx['category'] == 'generate' || $tx['category'] == 'immature') {
|
|
$height = $cur_height - $tx['confirmations'] + 1;
|
|
if ($tx['confirmations'] < 3) continue; // let the backend detect them...
|
|
$block = getdbosql('db_blocks', "coin_id={$coin->id} AND height=$height");
|
|
if ($block)
|
|
$nbOk++;
|
|
else {
|
|
$time = round($tx['time'] / 900) * 900;
|
|
if ($time < time() - 2 * 24 * 3600) continue;
|
|
echo strftime("%Y-%m-%d %H:%M", $tx['time'])." $time missed block $height : ".json_encode($tx)."\n";
|
|
$data = getdbolist('db_hashuser','algo=:algo AND time='.$time, array(':algo'=>$coin->algo));
|
|
$b = new db_blocks;
|
|
$b->coin_id = $coin->id;
|
|
$b->height = $height;
|
|
$b->time = $tx['time'];
|
|
$b->category = 'new';
|
|
$b->algo = $coin->algo;
|
|
$b->blockhash = $tx['blockhash'];
|
|
$b->txhash = $tx['txid'];
|
|
$b->isNewRecord = true;
|
|
if ($start_height > 0 && $height >= $start_height) {
|
|
if ($b->save()) echo "Added new block id {$b->id}\n";
|
|
}
|
|
$nbMissed++;
|
|
}
|
|
}
|
|
}
|
|
echo "$nbOk blocks checked, $nbMissed missed by the backend\n";
|
|
return 0;
|
|
}
|
|
|
|
////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
public function getCoinSetting($args)
|
|
{
|
|
if (count($args) < 3)
|
|
die("usage: yiimp coin <SYM> get <key>\n");
|
|
$symbol = $args[0];
|
|
$key = $args[2];
|
|
if (!$this->checkSymbol($symbol)) {
|
|
echo "error: symbol '$symbol' does not exist!\n";
|
|
return 1;
|
|
}
|
|
$value = coin_get($symbol, $key);
|
|
echo "$value\n";
|
|
return 0;
|
|
}
|
|
|
|
public function setCoinSetting($args)
|
|
{
|
|
if (count($args) < 4)
|
|
die("usage: yiimp coin <SYM> set <key> <value>\n");
|
|
$symbol = $args[0];
|
|
$key = $args[2];
|
|
$value = $args[3];
|
|
if (!$this->checkSymbol($symbol)) {
|
|
echo "error: symbol '$symbol' does not exist!\n";
|
|
return 1;
|
|
}
|
|
$res = coin_set($symbol, $key, $value);
|
|
$val = coin_get($symbol, $key);
|
|
echo ($res ? "$symbol $exchange $key ".json_encode($val) : "error") . "\n";
|
|
return 0;
|
|
}
|
|
|
|
public function unsetCoinSetting($args)
|
|
{
|
|
if (count($args) < 3)
|
|
die("usage: yiimp coin <SYM> unset <key>\n");
|
|
$symbol = $args[0];
|
|
$key = $args[2];
|
|
if (!$this->checkSymbol($symbol)) {
|
|
echo "error: symbol '$symbol' does not exist!\n";
|
|
return 1;
|
|
}
|
|
coin_unset($symbol, $key);
|
|
echo "ok\n";
|
|
return 0;
|
|
}
|
|
|
|
public function listCoinSettings($args)
|
|
{
|
|
if (count($args) < 2)
|
|
die("usage: yiimp coin <SYM> settings\n");
|
|
$symbol = $args[0];
|
|
if (!$this->checkSymbol($symbol)) {
|
|
echo "error: symbol '$symbol' does not exist!\n";
|
|
return 1;
|
|
}
|
|
$keys = coin_settings_prefetch($symbol);
|
|
foreach ($keys as $key => $value) {
|
|
if ($key == $symbol) continue;
|
|
echo "$key ".json_encode($value)."\n";
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
}
|