You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
103 lines
4.4 KiB
103 lines
4.4 KiB
var redis = require('redis');
|
|
// var Stratum = require('stratum-pool');
|
|
|
|
/*
|
|
This module deals with handling shares when in internal payment processing mode. It connects to a redis
|
|
database and inserts shares with the database structure of:
|
|
|
|
key: coin_name + ':' + block_height
|
|
value: a hash with..
|
|
key:
|
|
|
|
*/
|
|
|
|
module.exports = function(logger, poolConfig){
|
|
|
|
var redisConfig = poolConfig.redis;
|
|
var coin = poolConfig.coin.name;
|
|
var trackShares = (typeof poolConfig.trackShares !== 'undefined' && typeof poolConfig.trackShares.disable !== 'undefined') ? !poolConfig.trackShares.disable : true;
|
|
|
|
var forkId = process.env.forkId;
|
|
var logSystem = 'Pool';
|
|
var logComponent = coin;
|
|
var logSubCat = 'Thread ' + (parseInt(forkId) + 1);
|
|
|
|
var connection = redis.createClient(redisConfig.port, redisConfig.host);
|
|
if (redisConfig.password) {
|
|
connection.auth(redisConfig.password);
|
|
}
|
|
connection.on('ready', function(){
|
|
logger.info(logSystem, logComponent, logSubCat, 'Share processing setup with redis (' + redisConfig.host +
|
|
':' + redisConfig.port + ')');
|
|
});
|
|
connection.on('error', function(err){
|
|
logger.error(logSystem, logComponent, logSubCat, 'Redis client had an error: ' + JSON.stringify(err))
|
|
});
|
|
connection.on('end', function(){
|
|
logger.error(logSystem, logComponent, logSubCat, 'Connection to redis database has been ended');
|
|
});
|
|
connection.info(function(error, response){
|
|
if (error){
|
|
logger.error(logSystem, logComponent, logSubCat, 'Redis version check failed');
|
|
return;
|
|
}
|
|
var parts = response.split('\r\n');
|
|
var version;
|
|
var versionString;
|
|
for (var i = 0; i < parts.length; i++){
|
|
if (parts[i].indexOf(':') !== -1){
|
|
var valParts = parts[i].split(':');
|
|
if (valParts[0] === 'redis_version'){
|
|
versionString = valParts[1];
|
|
version = parseFloat(versionString);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if (!version){
|
|
logger.error(logSystem, logComponent, logSubCat, 'Could not detect redis version - but be super old or broken');
|
|
}
|
|
else if (version < 2.6){
|
|
logger.error(logSystem, logComponent, logSubCat, "You're using redis version " + versionString + " the minimum required version is 2.6. Follow the damn usage instructions...");
|
|
}
|
|
});
|
|
|
|
this.handleShare = function(isValidShare, isValidBlock, shareData) {
|
|
|
|
var redisCommands = [];
|
|
|
|
if (isValidShare) {
|
|
if (trackShares) {
|
|
redisCommands.push(['hincrbyfloat', coin + ':shares:roundCurrent', shareData.worker, shareData.difficulty]);
|
|
}
|
|
redisCommands.push(['hincrby', coin + ':stats', 'validShares', 1]);
|
|
} else {
|
|
redisCommands.push(['hincrby', coin + ':stats', 'invalidShares', 1]);
|
|
}
|
|
|
|
/* Stores share diff, worker, and unique value with a score that is the timestamp. Unique value ensures it
|
|
doesn't overwrite an existing entry, and timestamp as score lets us query shares from last X minutes to
|
|
generate hashrate for each worker and pool. */
|
|
var dateNow = Date.now();
|
|
var hashrateData = [ isValidShare ? shareData.difficulty : -shareData.difficulty, shareData.worker, dateNow];
|
|
redisCommands.push(['zadd', coin + ':hashrate', dateNow / 1000 | 0, hashrateData.join(':')]);
|
|
|
|
if (isValidBlock){
|
|
if (trackShares) {
|
|
redisCommands.push(['rename', coin + ':shares:roundCurrent', coin + ':shares:round' + shareData.height]);
|
|
redisCommands.push(['rename', coin + ':shares:timesCurrent', coin + ':shares:times' + shareData.height]);
|
|
redisCommands.push(['sadd', coin + ':blocksPending', [shareData.blockHash, shareData.txHash, shareData.height, shareData.worker, dateNow].join(':')]);
|
|
}
|
|
redisCommands.push(['hincrby', coin + ':stats', 'validBlocks', 1]);
|
|
}
|
|
else if (shareData.blockHash){
|
|
redisCommands.push(['hincrby', coin + ':stats', 'invalidBlocks', 1]);
|
|
}
|
|
|
|
connection.multi(redisCommands).exec(function(err, replies){
|
|
if (err)
|
|
logger.error(logSystem, logComponent, logSubCat, 'Error with share processor multi ' + JSON.stringify(err));
|
|
});
|
|
};
|
|
|
|
};
|
|
|