mirror of
https://github.com/LBRYFoundation/pool.git
synced 2025-08-23 17:37:25 +00:00
564 lines
15 KiB
PHP
564 lines
15 KiB
PHP
<?php
|
|
/**
|
|
* CoindbCommand is a console command :
|
|
* - labels: complete Unknown Coins Labels from CryptoCoinCharts.info
|
|
* - icons: grab coin icons from web sites
|
|
*
|
|
* To use this command, enter the following on the command line:
|
|
* <pre>
|
|
* yiimp coindb labels
|
|
* yiimp coindb icons
|
|
* </pre>
|
|
*
|
|
* @property string $help The command description.
|
|
*
|
|
*/
|
|
class CoindbCommand 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);
|
|
|
|
if (!isset($args[0])) {
|
|
|
|
echo "Yiimp coindb command\n";
|
|
echo "Usage: yiimp coindb labels\n";
|
|
echo " yiimp coindb icons\n";
|
|
return 1;
|
|
|
|
} elseif ($args[0] == 'labels') {
|
|
|
|
$nbUpdated = $this->updateCryptopiaLabels();
|
|
$nbUpdated += $this->updateCoinCapLabels();
|
|
$nbUpdated += $this->updateLiveCoinLabels();
|
|
$nbUpdated += $this->updateYiimpLabels("api.yiimp.eu");
|
|
$nbUpdated += $this->updateFromJson();
|
|
|
|
echo "total updated: $nbUpdated\n";
|
|
return 0;
|
|
|
|
} elseif ($args[0] == 'icons') {
|
|
|
|
$nbUpdated = $this->grabBterIcons();
|
|
$nbUpdated += $this->grabCcexIcons();
|
|
$nbUpdated += $this->grabCryptopiaIcons();
|
|
$nbUpdated += $this->grabBittrexIcons(); // can be huge ones
|
|
$nbUpdated += $this->grabCoinExchangeIcons();
|
|
$nbUpdated += $this->grabAlcurexIcons();
|
|
$nbUpdated += $this->grabNovaIcons();
|
|
|
|
echo "total updated: $nbUpdated\n";
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Provides the command description.
|
|
* @return string the command description.
|
|
*/
|
|
public function getHelp()
|
|
{
|
|
return parent::getHelp().'coindb labels';
|
|
}
|
|
|
|
/**
|
|
* coincap.io api
|
|
*/
|
|
public static function getCoinCapData()
|
|
{
|
|
$json = file_get_contents('http://coincap.io/front');
|
|
$data = json_decode($json,true);
|
|
$array = array();
|
|
foreach ($data as $coin) {
|
|
$key = strtoupper($coin['short']);
|
|
if (empty($key)) continue;
|
|
$array[$key] = $coin;
|
|
}
|
|
return $array;
|
|
}
|
|
|
|
public function updateCoinCapLabels()
|
|
{
|
|
$coins = new db_coins;
|
|
$nbUpdated = 0;
|
|
|
|
$dataset = $coins->findAll(array(
|
|
'condition'=>"name='unknown' OR name=symbol"
|
|
));
|
|
|
|
if (!empty($dataset))
|
|
{
|
|
$json = self::getCoinCapData();
|
|
if (empty($json)) return 0;
|
|
|
|
foreach ($dataset as $coin) {
|
|
if ($coin->name == 'unknown' && isset($json[$coin->symbol])) {
|
|
$data = $json[$coin->symbol];
|
|
if ($data['long'] != $coin->name) {
|
|
echo "{$coin->symbol}: {$data['long']}\n";
|
|
$coin->name = trim($data['long']);
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated coin labels updated from coincap.io\n";
|
|
}
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Special for cryptopia coins
|
|
*/
|
|
protected function getCryptopiaCurrencies()
|
|
{
|
|
$array = array();
|
|
require_once($this->basePath.'/yaamp/core/exchange/cryptopia.php');
|
|
$data = cryptopia_api_query('GetCurrencies');
|
|
|
|
if (is_object($data) && !empty($data->Data))
|
|
foreach ($data->Data as $coin) {
|
|
$key = strtoupper($coin->Symbol);
|
|
if (empty($key)) continue;
|
|
$array[$key] = $coin;
|
|
}
|
|
|
|
return $array;
|
|
}
|
|
|
|
public function updateCryptopiaLabels()
|
|
{
|
|
$coins = new db_coins;
|
|
$nbUpdated = 0;
|
|
|
|
$dataset = $coins->findAll(array(
|
|
'condition'=>"name=:u OR algo='' OR algo='scrypt'",
|
|
'params'=>array(':u'=>'unknown')
|
|
));
|
|
|
|
if (!empty($dataset))
|
|
{
|
|
$json = self::getCryptopiaCurrencies();
|
|
|
|
foreach ($dataset as $coin) {
|
|
if ($coin->name == 'unknown' && isset($json[$coin->symbol])) {
|
|
$cc = $json[$coin->symbol];
|
|
if ($cc->Name != $coin->name) {
|
|
echo "{$coin->symbol}: {$cc->Name}\n";
|
|
$coin->name = $cc->Name;
|
|
if ($cc->Algorithm != 'scrypt')
|
|
$coin->algo = strtolower($cc->Algorithm);
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated coin labels updated from cryptopia\n";
|
|
}
|
|
return $nbUpdated;
|
|
}
|
|
|
|
public function updateLiveCoinLabels()
|
|
{
|
|
if (exchange_get('livecoin', 'disabled') == true) return 0;
|
|
|
|
$coins = new db_coins;
|
|
$nbUpdated = 0;
|
|
|
|
$dataset = $coins->findAll(array(
|
|
'condition'=>"name='unknown' AND id IN (SELECT M.coinid FROM markets M WHERE M.name='livecoin')",
|
|
));
|
|
|
|
if (!empty($dataset))
|
|
{
|
|
//echo count($dataset)." livecoin currencies without labels\n";
|
|
$labels = array();
|
|
$data = livecoin_api_query('info/coinInfo');
|
|
if(objSafeVal($data,'success') !== true || !is_array($data->info)) return;
|
|
|
|
foreach ($data->info as $c) {
|
|
$symbol = objSafeVal($c,'symbol','');
|
|
$labels[$symbol] = objSafeVal($c,'name','unknown');
|
|
}
|
|
|
|
foreach ($dataset as $coin) {
|
|
if ($coin->name == 'unknown' && isset($labels[$coin->symbol])) {
|
|
$label = $labels[$coin->symbol];
|
|
if ($label != $coin->name) {
|
|
echo "{$coin->symbol}: {$label}\n";
|
|
$coin->name = $label;
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated coin labels updated from livecoin coininfo\n";
|
|
}
|
|
return $nbUpdated;
|
|
}
|
|
|
|
public function updateYiimpLabels($pool)
|
|
{
|
|
$coins = new db_coins;
|
|
$nbUpdated = 0; $nbAlgos = 0;
|
|
|
|
$dataset = $coins->findAll(array(
|
|
'condition'=>"name=:u OR algo='' OR algo='scrypt'",
|
|
'params'=>array(':u'=>'unknown')
|
|
));
|
|
|
|
if (!empty($dataset))
|
|
{
|
|
$url = "http://{$pool}/api/currencies";
|
|
$data = @ file_get_contents($url);
|
|
if (empty($data)) return 0;
|
|
$json = json_decode($data, true);
|
|
|
|
if (!empty($json))
|
|
foreach ($dataset as $coin) {
|
|
if (!isset($json[$coin->symbol])) continue;
|
|
$cc = $json[$coin->symbol];
|
|
if ($coin->name == 'unknown') {
|
|
echo "{$coin->symbol}: {$cc['name']}\n";
|
|
$coin->name = $cc['name'];
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
if (empty($cc['algo'])) continue;
|
|
if (empty($coin->algo) || $coin->algo != $cc['algo']) {
|
|
$coin->algo = strtolower($cc['algo']);
|
|
echo "{$coin->symbol}: algo set to {$cc['algo']}\n";
|
|
$nbAlgos += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated labels and $nbAlgos algos updated from $pool\n";
|
|
}
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* To import from a json file placed in the sql/ folder
|
|
*/
|
|
public function updateFromJson()
|
|
{
|
|
$sqlFolder = $this->basePath.'/../sql/';
|
|
$jsonFile = $sqlFolder.'labels.json';
|
|
//$jsonFile = $sqlFolder.'yobit.txt';
|
|
if (!file_exists($jsonFile))
|
|
return 0;
|
|
|
|
$nbUpdated = 0;
|
|
|
|
$json = json_decode(file_get_contents($jsonFile), true);
|
|
/*
|
|
$json = array();
|
|
$txt = explode("\n", file_get_contents($jsonFile));
|
|
foreach ($txt as $line)
|
|
{
|
|
$cells = explode("\t", $line);
|
|
if (count($cells) < 2) continue;
|
|
$json[$cells[0]] = $cells[1];
|
|
}
|
|
*/
|
|
if (!empty($json))
|
|
{
|
|
$coins = new db_coins;
|
|
$dataset = $coins->findAll(array(
|
|
'condition'=>"name=:u",
|
|
'params'=>array(':u'=>'unknown')
|
|
));
|
|
|
|
if (!empty($dataset))
|
|
foreach ($dataset as $coin) {
|
|
if (isset($json[$coin->symbol])) {
|
|
$name = $json[$coin->symbol];
|
|
echo "{$coin->symbol}: {$name}\n";
|
|
$coin->name = $name;
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated coin labels updated from labels.json file\n";
|
|
}
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - Bter
|
|
*/
|
|
public function grabBterIcons()
|
|
{
|
|
$url = 'http://bter.com/images/coin_icon/64/';
|
|
$nbUpdated = 0;
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id WHERE M.name='bter' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return 0;
|
|
echo "bter: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
try {
|
|
$data = @ file_get_contents($url.strtolower($symbol).'.png');
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
echo $coin->symbol." icon found\n";
|
|
file_put_contents($local, $data);
|
|
if (filesize($local) > 0) {
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from bter\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - Bittrex
|
|
*/
|
|
public function grabBittrexIcons()
|
|
{
|
|
$nbUpdated = 0;
|
|
$markets = bittrex_api_query('public/getmarkets');
|
|
if (!is_object($markets) || !is_object($markets->result)) {
|
|
echo "bittrex api error\n";
|
|
return $nbUpdated;
|
|
}
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id WHERE M.name='bittrex' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return $nbUpdated;
|
|
echo "bittrex: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
$url = '';
|
|
foreach ($markets->result as $m) {
|
|
if ($m->MarketCurrency == $symbol) {
|
|
$url = $m->LogoUrl;
|
|
break;
|
|
}
|
|
}
|
|
if (empty($url)) continue;
|
|
try {
|
|
$data = @ file_get_contents($url);
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
file_put_contents($local, $data);
|
|
$size = filesize($local);
|
|
if ($size > 0) {
|
|
if ($size > 100*1024) {
|
|
echo "warning: $symbol icon is huge, ".round($size/1024,1)." KB ($url)\n";
|
|
unlink($local);
|
|
} else {
|
|
echo $symbol." icon found\n";
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from bittrex\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - Ccex
|
|
*/
|
|
public function grabCcexIcons()
|
|
{
|
|
$url = 'http://c-cex.com/i/l/';
|
|
$nbUpdated = 0;
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id WHERE M.name='c-cex' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return 0;
|
|
echo "c-cex: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
try {
|
|
$data = @ file_get_contents($url.strtolower($symbol).'.png');
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
echo $symbol." icon found\n";
|
|
file_put_contents($local, $data);
|
|
if (filesize($local) > 0) {
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from c-cex\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - Cryptopia (slow https)
|
|
*/
|
|
public function grabCryptopiaIcons()
|
|
{
|
|
$url = 'https://www.cryptopia.co.nz/Content/Images/Coins/';
|
|
$nbUpdated = 0;
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id ".
|
|
"WHERE M.name='cryptopia' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return 0;
|
|
echo "cryptopia: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
try {
|
|
$data = @ file_get_contents($url.strtolower($symbol).'-medium.png');
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
echo $symbol." icon found\n";
|
|
file_put_contents($local, $data);
|
|
if (filesize($local) > 0) {
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from cryptopia\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - CoinExchange
|
|
*/
|
|
public function grabCoinExchangeIcons()
|
|
{
|
|
$url = 'https://www.coinexchange.io/assets/currencies/';
|
|
$nbUpdated = 0;
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id ".
|
|
"WHERE M.name='coinexchange' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return 0;
|
|
echo "coinexchange: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
try {
|
|
$data = @ file_get_contents($url.strtolower($coin->name).'.png');
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
echo $symbol." icon found\n";
|
|
file_put_contents($local, $data);
|
|
if (filesize($local) > 0) {
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from coinexchange\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - Alcurex
|
|
*/
|
|
public function grabAlcurexIcons()
|
|
{
|
|
$url = 'https://alcurex.com/CSS/img/coins/';
|
|
$nbUpdated = 0;
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id ".
|
|
"WHERE M.name='alcurex' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return 0;
|
|
echo "alcurex: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
try {
|
|
$data = @ file_get_contents($url.strtoupper($symbol).'.png');
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
echo $symbol." icon found\n";
|
|
file_put_contents($local, $data);
|
|
if (filesize($local) > 0) {
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from alcurex\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
/**
|
|
* Icon grabber - NovaExchange
|
|
*/
|
|
public function grabNovaIcons()
|
|
{
|
|
$url = 'http://novaexchange.com/static/symbols/';
|
|
$nbUpdated = 0;
|
|
$sql = "SELECT DISTINCT coins.id FROM coins INNER JOIN markets M ON M.coinid = coins.id ".
|
|
"WHERE M.name='nova' AND IFNULL(coins.image,'') = ''";
|
|
$coins = dbolist($sql);
|
|
if (empty($coins))
|
|
return 0;
|
|
echo "nova: try to download new icons...\n";
|
|
foreach ($coins as $coin) {
|
|
$coin = getdbo('db_coins', $coin["id"]);
|
|
$symbol = $coin->symbol;
|
|
if (!empty($coin->symbol2)) $symbol = $coin->symbol2;
|
|
$local = $this->basePath."/images/coin-{$symbol}.png";
|
|
try {
|
|
$data = @ file_get_contents($url.strtolower($symbol).'.png');
|
|
} catch (Exception $e) {
|
|
continue;
|
|
}
|
|
if (strlen($data) < 2048) continue;
|
|
echo $symbol." icon found\n";
|
|
file_put_contents($local, $data);
|
|
if (filesize($local) > 0) {
|
|
$coin->image = "/images/coin-{$symbol}.png";
|
|
$nbUpdated += $coin->save();
|
|
}
|
|
}
|
|
if ($nbUpdated)
|
|
echo "$nbUpdated icons downloaded from novaexchange\n";
|
|
return $nbUpdated;
|
|
}
|
|
|
|
}
|