Files
peya-nodejs-pool/config_examples/bytecoin/paymentProcessor.js
2020-02-10 15:49:40 -05:00

442 lines
14 KiB
JavaScript

/**
* Cryptonote Node.JS Pool
* https://github.com/dvandal/cryptonote-nodejs-pool
*
* Payments processor
**/
// Load required modules
var fs = require('fs');
var async = require('async');
var apiInterfaces = require('./apiInterfaces.js')(config.daemon, config.wallet, config.api);
var notifications = require('./notifications.js');
var utils = require('./utils.js');
// Initialize log system
var logSystem = 'payments';
require('./exceptionWriter.js')(logSystem);
/**
* Run payments processor
**/
log('info', logSystem, 'Started');
if (!config.poolServer.paymentId) config.poolServer.paymentId = {};
if (!config.poolServer.paymentId.addressSeparator) config.poolServer.paymentId.addressSeparator = "+";
if (!config.payments.priority) config.payments.priority = 0;
var daemonType = config.daemonType ? config.daemonType.toLowerCase() : "default";
/***************************
BYTECOIN FUNCTIONS
***************************/
function bytecoin_create_transaction (transferCmd, callback) {
rpcCommand = "create_transaction";
rpcRequest = {
transaction: {
anonymity: transferCmd.rpc.mixin,
// payment_id: "",
transfers: transferCmd.rpc.destinations
},
spend_addresses: [
config.poolServer.poolAddress
],
change_address: config.poolServer.poolAddress,
optimization: "minimal"
};
if (transferCmd.rpc.payment_id) {
rpcRequest.transaction.payment_id = transferCmd.rpc.payment_id;
}
console.log(rpcCommand);
apiInterfaces.rpcWallet(rpcCommand, rpcRequest, function (error, result) {
callback(error, result, transferCmd);
});
}
function bytecoin_send_transaction (createTransactionResult, transferCmd, callback) {
var tx_hash = "";
var timeOffset = 0;
var notify_miners = [];
if (!(createTransactionResult && createTransactionResult.binary_transaction)) {
callback(createTransactionResult);
} else {
rpcCommand = "send_transaction";
rpcRequest = {
binary_transaction: createTransactionResult.binary_transaction
};
tx_hash = createTransactionResult.transaction.hash;
console.log(rpcCommand);
apiInterfaces.rpcWallet(rpcCommand, rpcRequest, function (error, result) {
if (error) {
log('error', logSystem, 'Error with %s RPC request to wallet daemon %j', [rpcCommand, error]);
log('error', logSystem, 'Payments failed to send to %j', transferCmd.rpc.destinations);
callback(error);
}
var now = (timeOffset++) + Date.now() / 1000 | 0;
var txHash = daemonType === "bytecoin" ? (tx_hash ? tx_hash : result.transactionHash) : result.tx_hash;
txHash = txHash.replace('<', '')
.replace('>', '');
transferCmd.redis.push(['zadd', config.coin + ':payments:all', now, [
txHash,
transferCmd.amount,
transferCmd.rpc.fee,
transferCmd.rpc.mixin,
Object.keys(transferCmd.rpc.destinations)
.length
].join(':')]);
var notify_miners_on_success = [];
for (var i = 0; i < transferCmd.rpc.destinations.length; i++) {
var destination = transferCmd.rpc.destinations[i];
if (transferCmd.rpc.payment_id) {
destination.address += config.poolServer.paymentId.addressSeparator + transferCmd.rpc.payment_id;
}
transferCmd.redis.push(['zadd', config.coin + ':payments:' + destination.address, now, [
txHash,
destination.amount,
transferCmd.rpc.fee,
transferCmd.rpc.mixin
].join(':')]);
notify_miners_on_success.push(destination);
}
log('info', logSystem, 'Payments sent via wallet daemon %j', [result]);
redisClient.multi(transferCmd.redis)
.exec(function (error, replies) {
if (error) {
log('error', logSystem, 'Super critical error! Payments sent yet failing to update balance in redis, double payouts likely to happen %j', [error]);
log('error', logSystem, 'Double payments likely to be sent to %j', transferCmd.rpc.destinations);
callback(error);
return;
}
for (var m in notify_miners_on_success) {
notify_miners.push(notify_miners_on_success[m]);
}
callback(null, true);
});
});
} // endif result && result.binary_transaction
}
/***************************
/BYTECOIN FUNCTIONS
***************************/
function runInterval () {
async.waterfall([
// Get worker keys
function (callback) {
redisClient.keys(config.coin + ':workers:*', function (error, result) {
if (error) {
log('error', logSystem, 'Error trying to get worker balances from redis %j', [error]);
callback(true);
return;
}
callback(null, result);
});
},
// Get worker balances
function (keys, callback) {
var redisCommands = keys.map(function (k) {
return ['hget', k, 'balance'];
});
redisClient.multi(redisCommands)
.exec(function (error, replies) {
if (error) {
log('error', logSystem, 'Error with getting balances from redis %j', [error]);
callback(true);
return;
}
var balances = {};
for (var i = 0; i < replies.length; i++) {
var parts = keys[i].split(':');
var workerId = parts[parts.length - 1];
balances[workerId] = parseInt(replies[i]) || 0;
}
callback(null, keys, balances);
});
},
// Get worker minimum payout
function (keys, balances, callback) {
var redisCommands = keys.map(function (k) {
return ['hget', k, 'minPayoutLevel'];
});
redisClient.multi(redisCommands)
.exec(function (error, replies) {
if (error) {
log('error', logSystem, 'Error with getting minimum payout from redis %j', [error]);
callback(true);
return;
}
var minPayoutLevel = {};
for (var i = 0; i < replies.length; i++) {
var parts = keys[i].split(':');
var workerId = parts[parts.length - 1];
var minLevel = config.payments.minPayment;
var maxLevel = config.payments.maxPayment;
var defaultLevel = minLevel;
var payoutLevel = parseInt(replies[i]) || minLevel;
if (payoutLevel < minLevel) payoutLevel = minLevel;
if (maxLevel && payoutLevel > maxLevel) payoutLevel = maxLevel;
minPayoutLevel[workerId] = payoutLevel;
if (payoutLevel !== defaultLevel) {
log('info', logSystem, 'Using payout level of %s for %s (default: %s)', [utils.getReadableCoins(minPayoutLevel[workerId]), workerId, utils.getReadableCoins(defaultLevel)]);
}
}
callback(null, balances, minPayoutLevel);
});
},
// Filter workers under balance threshold for payment
function (balances, minPayoutLevel, callback) {
var payments = {};
for (var worker in balances) {
var balance = balances[worker];
if (balance >= minPayoutLevel[worker]) {
var remainder = balance % config.payments.denomination;
var payout = balance - remainder;
if (config.payments.dynamicTransferFee && config.payments.minerPayFee) {
payout -= config.payments.transferFee;
}
if (payout < 0) continue;
payments[worker] = payout;
}
}
if (Object.keys(payments)
.length === 0) {
log('info', logSystem, 'No workers\' balances reached the minimum payment threshold');
callback(true);
return;
}
var transferCommands = [];
var addresses = 0;
var commandAmount = 0;
var commandIndex = 0;
for (var worker in payments) {
var amount = parseInt(payments[worker]);
if (config.payments.maxTransactionAmount && amount + commandAmount > config.payments.maxTransactionAmount) {
amount = config.payments.maxTransactionAmount - commandAmount;
}
var address = worker;
var payment_id = null;
var with_payment_id = false;
var addr = address.split(config.poolServer.paymentId.addressSeparator);
if ((addr.length === 1 && utils.isIntegratedAddress(address)) || addr.length >= 2) {
with_payment_id = true;
if (addr.length >= 2) {
address = addr[0];
payment_id = addr[1];
payment_id = payment_id.replace(/[^A-Za-z0-9]/g, '');
if (payment_id.length !== 16 && payment_id.length !== 64) {
with_payment_id = false;
payment_id = null;
}
}
if (addresses > 0) {
commandIndex++;
addresses = 0;
commandAmount = 0;
}
}
if (config.poolServer.fixedDiff && config.poolServer.fixedDiff.enabled) {
var addr = address.split(config.poolServer.fixedDiff.addressSeparator);
if (addr.length >= 2) address = addr[0];
}
if (!transferCommands[commandIndex]) {
transferCommands[commandIndex] = {
redis: [],
amount: 0,
rpc: {
destinations: [],
fee: config.payments.transferFee,
mixin: config.payments.mixin,
priority: config.payments.priority,
unlock_time: 0
}
};
}
transferCommands[commandIndex].rpc.destinations.push({
amount: amount,
address: address
});
if (payment_id) transferCommands[commandIndex].rpc.payment_id = payment_id;
transferCommands[commandIndex].redis.push(['hincrby', config.coin + ':workers:' + worker, 'balance', -amount]);
if (config.payments.dynamicTransferFee && config.payments.minerPayFee) {
transferCommands[commandIndex].redis.push(['hincrby', config.coin + ':workers:' + worker, 'balance', -config.payments.transferFee]);
}
transferCommands[commandIndex].redis.push(['hincrby', config.coin + ':workers:' + worker, 'paid', amount]);
transferCommands[commandIndex].amount += amount;
addresses++;
commandAmount += amount;
if (config.payments.dynamicTransferFee) {
transferCommands[commandIndex].rpc.fee = config.payments.transferFee * addresses;
}
if (addresses >= config.payments.maxAddresses || (config.payments.maxTransactionAmount && commandAmount >= config.payments.maxTransactionAmount) || with_payment_id) {
commandIndex++;
addresses = 0;
commandAmount = 0;
}
}
var timeOffset = 0;
var notify_miners = [];
var daemonType = config.daemonType ? config.daemonType.toLowerCase() : "default";
if (daemonType === "bytecoin" && transferCommands.length > 1) { // TODO: Limit to sent just 1 transaction. I don't know why it fails if I sent more than one
transferCommands = [transferCommands[0]];
}
async.filter(transferCommands, function (transferCmd, cback) {
var rpcCommand = "transfer";
var rpcRequest = transferCmd.rpc;
var tx_hash = '';
if (daemonType === "bytecoin") {
rpcCommand = "sendTransaction";
rpcRequest = {
transfers: transferCmd.rpc.destinations,
fee: transferCmd.rpc.fee,
anonymity: transferCmd.rpc.mixin,
unlockTime: transferCmd.rpc.unlock_time
};
if (transferCmd.rpc.payment_id) {
rpcRequest.paymentId = transferCmd.rpc.payment_id;
}
// Nueva versión from Bytecoin/walletd 3.2.0-beta
async.waterfall([
async.apply(bytecoin_create_transaction, transferCmd),
bytecoin_send_transaction
], function (err, res) {
if (err) {
log('error', logSystem, 'Error waterfall %j , %j', [err, res]);
}
});
// Para que no se ejecute la siguiente llamada
rpcCommand = "";
} // endif bytecoin
if (rpcCommand) {
apiInterfaces.rpcWallet(rpcCommand, rpcRequest, function (error, result) {
if (error) {
log('error', logSystem, 'Error with %s RPC request to wallet daemon %j', [rpcCommand, error]);
log('error', logSystem, 'Payments failed to send to %j', transferCmd.rpc.destinations);
cback(false);
return;
}
var now = (timeOffset++) + Date.now() / 1000 | 0;
var txHash = daemonType === "bytecoin" ? (tx_hash ? tx_hash : result.transactionHash) : result.tx_hash;
txHash = txHash.replace('<', '')
.replace('>', '');
transferCmd.redis.push(['zadd', config.coin + ':payments:all', now, [
txHash,
transferCmd.amount,
transferCmd.rpc.fee,
transferCmd.rpc.mixin,
Object.keys(transferCmd.rpc.destinations)
.length
].join(':')]);
var notify_miners_on_success = [];
for (var i = 0; i < transferCmd.rpc.destinations.length; i++) {
var destination = transferCmd.rpc.destinations[i];
if (transferCmd.rpc.payment_id) {
destination.address += config.poolServer.paymentId.addressSeparator + transferCmd.rpc.payment_id;
}
transferCmd.redis.push(['zadd', config.coin + ':payments:' + destination.address, now, [
txHash,
destination.amount,
transferCmd.rpc.fee,
transferCmd.rpc.mixin
].join(':')]);
notify_miners_on_success.push(destination);
}
log('info', logSystem, 'Payments sent via wallet daemon %j', [result]);
redisClient.multi(transferCmd.redis)
.exec(function (error, replies) {
if (error) {
log('error', logSystem, 'Super critical error! Payments sent yet failing to update balance in redis, double payouts likely to happen %j', [error]);
log('error', logSystem, 'Double payments likely to be sent to %j', transferCmd.rpc.destinations);
cback(false);
return;
}
for (var m in notify_miners_on_success) {
notify_miners.push(notify_miners_on_success[m]);
}
cback(true);
});
});
} // end if rpcCommand
}, function (succeeded) {
var failedAmount = transferCommands.length - succeeded.length;
for (var m in notify_miners) {
var notify = notify_miners[m];
log('info', logSystem, 'Payment of %s to %s', [utils.getReadableCoins(notify.amount), notify.address]);
notifications.sendToMiner(notify.address, 'payment', {
'ADDRESS': notify.address.substring(0, 7) + '...' + notify.address.substring(notify.address.length - 7),
'AMOUNT': utils.getReadableCoins(notify.amount),
});
}
log('info', logSystem, 'Payments splintered and %d successfully sent, %d failed', [succeeded.length, failedAmount]);
callback(null);
});
}
], function (error, result) {
setTimeout(runInterval, config.payments.interval * 1000);
});
}
runInterval();