f3a0cf0417
Round shares are taken to only match PPLNS target. Round target was not re-adjusted to reflect the new, lower amount of round shares. * Fix: Properly adjust round target shares when exceeding PPLNS target Fixes #588 once merged
190 lines
9.4 KiB
PHP
Executable File
190 lines
9.4 KiB
PHP
Executable File
#!/usr/bin/php
|
|
<?php
|
|
|
|
/*
|
|
|
|
Copyright:: 2013, Sebastian Grewe
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
|
|
*/
|
|
|
|
// Include all settings and classes
|
|
require_once('shared.inc.php');
|
|
|
|
// Check if we are set as the payout system
|
|
if ($config['payout_system'] != 'pplns') {
|
|
$log->logInfo("Please activate this cron in configuration via payout_system = pplns");
|
|
exit(0);
|
|
}
|
|
|
|
// Fetch all unaccounted blocks
|
|
$aAllBlocks = $block->getAllUnaccounted('ASC');
|
|
if (empty($aAllBlocks)) {
|
|
$log->logDebug("No new unaccounted blocks found");
|
|
$monitoring->setStatus($cron_name . "_active", "yesno", 0);
|
|
$monitoring->setStatus($cron_name . "_message", "message", "No new unaccounted blocks");
|
|
$monitoring->setStatus($cron_name . "_status", "okerror", 0);
|
|
exit(0);
|
|
}
|
|
|
|
$count = 0;
|
|
foreach ($aAllBlocks as $iIndex => $aBlock) {
|
|
// We support some dynamic share targets but fall back to our fixed value
|
|
// Re-calculate after each run due to re-targets in this loop
|
|
if ($config['pplns']['shares']['type'] == 'blockavg' && $block->getBlockCount() > 0) {
|
|
$pplns_target = round($block->getAvgBlockShares($config['pplns']['blockavg']['blockcount']));
|
|
} else {
|
|
$pplns_target = $config['pplns']['shares']['default'] ;
|
|
}
|
|
|
|
if (!$aBlock['accounted']) {
|
|
$iPreviousShareId = @$aAllBlocks[$iIndex - 1]['share_id'] ? $aAllBlocks[$iIndex - 1]['share_id'] : 0;
|
|
$iCurrentUpstreamId = $aBlock['share_id'];
|
|
if (!is_numeric($iCurrentUpstreamId)) {
|
|
$log->logFatal("Block " . $aBlock['height'] . " has no share_id associated with it, not going to continue");
|
|
$monitoring->setStatus($cron_name . "_active", "yesno", 0);
|
|
$monitoring->setStatus($cron_name . "_message", "message", "Block " . $aBlock['height'] . " has no share_id associated with it");
|
|
$monitoring->setStatus($cron_name . "_status", "okerror", 1);
|
|
exit(1);
|
|
}
|
|
$iRoundShares = $share->getRoundShares($iPreviousShareId, $aBlock['share_id']);
|
|
$iNewRoundShares = 0;
|
|
$config['reward_type'] == 'block' ? $dReward = $aBlock['amount'] : $dReward = $config['reward'];
|
|
$aRoundAccountShares = $share->getSharesForAccounts($iPreviousShareId, $aBlock['share_id']);
|
|
|
|
if ($iRoundShares >= $pplns_target) {
|
|
$log->logDebug("Matching or exceeding PPLNS target of $pplns_target with $iRoundShares");
|
|
$aAccountShares = $share->getSharesForAccounts($aBlock['share_id'] - $pplns_target, $aBlock['share_id']);
|
|
if (empty($aAccountShares)) {
|
|
$log->logFatal("No shares found for this block, aborted! Block Height : " . $aBlock['height']);
|
|
$monitoring->setStatus($cron_name . "_active", "yesno", 0);
|
|
$monitoring->setStatus($cron_name . "_message", "message", "No shares found for this block: " . $aBlock['height']);
|
|
$monitoring->setStatus($cron_name . "_status", "okerror", 1);
|
|
exit(1);
|
|
}
|
|
$log->logInfo('Adjusting round target to PPLNS target ' . $pplns_target);
|
|
$iRoundShares = $pplns_target;
|
|
} else {
|
|
$log->logDebug("Not able to match PPLNS target of $pplns_target with $iRoundShares");
|
|
// We need to fill up with archived shares
|
|
// Grab the full current round shares since we didn't match target
|
|
$aAccountShares = $aRoundAccountShares;
|
|
if (empty($aAccountShares)) {
|
|
$log->logFatal("No shares found for this block, aborted! Block height: " . $aBlock['height']);
|
|
$monitoring->setStatus($cron_name . "_active", "yesno", 0);
|
|
$monitoring->setStatus($cron_name . "_message", "message", "No shares found for this block: " . $aBlock['height']);
|
|
$monitoring->setStatus($cron_name . "_status", "okerror", 1);
|
|
exit(1);
|
|
}
|
|
|
|
// Grab only the most recent shares from Archive that fill the missing shares
|
|
$log->logInfo('Fetching ' . ($pplns_target - $iRoundShares) . ' additional shares from archive');
|
|
if (!$aArchiveShares = $share->getArchiveShares($pplns_target - $iRoundShares)) {
|
|
$log->logError('Failed to fetch shares from archive, setting target to round total');
|
|
$pplns_target = $iRoundShares;
|
|
} else {
|
|
// Add archived shares to users current shares, if we have any in archive
|
|
if (is_array($aArchiveShares)) {
|
|
$log->logDebug('Found shares in archive to match PPLNS target, calculating per-user shares');
|
|
foreach($aAccountShares as $key => $aData) {
|
|
if (array_key_exists($aData['username'], $aArchiveShares)) {
|
|
$log->logDebug('Found user ' . $aData['username'] . ' in archived shares');
|
|
$log->logDebug(' valid : ' . $aAccountShares[$key]['valid'] . ' + ' . $aArchiveShares[$aData['username']]['valid'] . ' = ' . ($aAccountShares[$key]['valid'] + $aArchiveShares[$aData['username']]['valid']) );
|
|
$log->logDebug(' invalid : ' . $aAccountShares[$key]['invalid'] . ' + ' . $aArchiveShares[$aData['username']]['invalid'] . ' = ' . ($aAccountShares[$key]['invalid'] + $aArchiveShares[$aData['username']]['invalid']) );
|
|
$aAccountShares[$key]['valid'] += $aArchiveShares[$aData['username']]['valid'];
|
|
$aAccountShares[$key]['invalid'] += $aArchiveShares[$aData['username']]['invalid'];
|
|
}
|
|
}
|
|
}
|
|
// We tried to fill up to PPLNS target, now we need to check the actual shares to properly payout users
|
|
foreach($aAccountShares as $key => $aData) {
|
|
$iNewRoundShares += $aData['valid'];
|
|
}
|
|
}
|
|
}
|
|
|
|
// We filled from archive but still are not able to match PPLNS target, re-adjust
|
|
if ($iRoundShares < $iNewRoundShares) {
|
|
$log->logInfo('Adjusting round target to ' . $iNewRoundShares);
|
|
$iRoundShares = $iNewRoundShares;
|
|
}
|
|
|
|
// Table header for account shares
|
|
$log->logInfo("ID\tUsername\tValid\tInvalid\tPercentage\tPayout\t\tDonation\tFee");
|
|
|
|
// Loop through all accounts that have found shares for this round
|
|
foreach ($aAccountShares as $key => $aData) {
|
|
// Payout based on PPLNS target shares, proportional payout for all users
|
|
$aData['percentage'] = round(( 100 / $iRoundShares) * $aData['valid'], 8);
|
|
$aData['payout'] = round(( $aData['percentage'] / 100 ) * $dReward, 8);
|
|
// Defaults
|
|
$aData['fee' ] = 0;
|
|
$aData['donation'] = 0;
|
|
|
|
if ($config['fees'] > 0 && $aData['no_fees'] == 0)
|
|
$aData['fee'] = round($config['fees'] / 100 * $aData['payout'], 8);
|
|
// Calculate donation amount, fees not included
|
|
$aData['donation'] = round($user->getDonatePercent($user->getUserId($aData['username'])) / 100 * ( $aData['payout'] - $aData['fee']), 8);
|
|
|
|
// Verbose output of this users calculations
|
|
$log->logInfo($aData['id'] . "\t" .
|
|
$aData['username'] . "\t" .
|
|
$aData['valid'] . "\t" .
|
|
$aData['invalid'] . "\t" .
|
|
number_format($aData['percentage'], 8) . "\t" .
|
|
number_format($aData['payout'], 8) . "\t" .
|
|
number_format($aData['donation'], 8) . "\t" .
|
|
number_format($aData['fee'], 8));
|
|
|
|
// Add full round share statistics, not just PPLNS
|
|
foreach ($aRoundAccountShares as $key => $aRoundData) {
|
|
if ($aRoundData['username'] == $aData['username'])
|
|
if (!$statistics->updateShareStatistics($aRoundData, $aBlock['id']))
|
|
$log->logError('Failed to update share statistics for ' . $aData['username']);
|
|
}
|
|
// Add new credit transaction
|
|
if (!$transaction->addTransaction($aData['id'], $aData['payout'], 'Credit', $aBlock['id']))
|
|
$log->logFatal('Failed to insert new Credit transaction to database for ' . $aData['username']);
|
|
// Add new fee debit for this block
|
|
if ($aData['fee'] > 0 && $config['fees'] > 0)
|
|
if (!$transaction->addTransaction($aData['id'], $aData['fee'], 'Fee', $aBlock['id']))
|
|
$log->logFatal('Failed to insert new Fee transaction to database for ' . $aData['username']);
|
|
// Add new donation debit
|
|
if ($aData['donation'] > 0)
|
|
if (!$transaction->addTransaction($aData['id'], $aData['donation'], 'Donation', $aBlock['id']))
|
|
$log->logFatal('Failed to insert new Donation transaction to database for ' . $aData['username']);
|
|
}
|
|
|
|
// Move counted shares to archive before this blockhash upstream share
|
|
if (!$share->moveArchive($iCurrentUpstreamId, $aBlock['id'], $iPreviousShareId))
|
|
$log->logError('Failed to copy shares to archive table');
|
|
// Delete all accounted shares
|
|
if (!$share->deleteAccountedShares($iCurrentUpstreamId, $iPreviousShareId)) {
|
|
$log->logFatal("Failed to delete accounted shares from $iPreviousShareId to $iCurrentUpstreamId, aborting!");
|
|
exit(1);
|
|
}
|
|
// Mark this block as accounted for
|
|
if (!$block->setAccounted($aBlock['id'])) {
|
|
$log->logFatal("Failed to mark block as accounted! Aborting!");
|
|
$monitoring->setStatus($cron_name . "_active", "yesno", 0);
|
|
$monitoring->setStatus($cron_name . "_message", "message", "Failed to mark block " . $aBlock['height'] . " as accounted");
|
|
$monitoring->setStatus($cron_name . "_status", "okerror", 1);
|
|
exit(1);
|
|
}
|
|
}
|
|
}
|
|
|
|
require_once('cron_end.inc.php');
|
|
?>
|