Better mpos/mysql logging. Added maxcoin config.
This commit is contained in:
parent
3ec38e5523
commit
c699e66a5d
|
@ -0,0 +1,6 @@
|
||||||
|
{
|
||||||
|
"name" : "Maxcoin",
|
||||||
|
"symbol" : "MAX",
|
||||||
|
"algorithm" : "keccak",
|
||||||
|
"txMessages" : false
|
||||||
|
}
|
|
@ -7,7 +7,8 @@ module.exports = function(logger, poolConfig){
|
||||||
|
|
||||||
var connection;
|
var connection;
|
||||||
|
|
||||||
var logIdentify = 'MPOS';
|
var logIdentify = 'MySQL';
|
||||||
|
var logComponent = coin;
|
||||||
|
|
||||||
function connect(){
|
function connect(){
|
||||||
connection = mysql.createConnection({
|
connection = mysql.createConnection({
|
||||||
|
@ -19,18 +20,18 @@ module.exports = function(logger, poolConfig){
|
||||||
});
|
});
|
||||||
connection.connect(function(err){
|
connection.connect(function(err){
|
||||||
if (err)
|
if (err)
|
||||||
logger.error(logIdentify, 'mysql', 'Could not connect to mysql database: ' + JSON.stringify(err))
|
logger.error(logIdentify, logComponent, 'Could not connect to mysql database: ' + JSON.stringify(err))
|
||||||
else{
|
else{
|
||||||
logger.debug(logIdentify, 'mysql', 'Successful connection to MySQL database');
|
logger.debug(logIdentify, logComponent, 'Successful connection to MySQL database');
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
connection.on('error', function(err){
|
connection.on('error', function(err){
|
||||||
if(err.code === 'PROTOCOL_CONNECTION_LOST') {
|
if(err.code === 'PROTOCOL_CONNECTION_LOST') {
|
||||||
logger.warning(logIdentify, 'mysql', 'Lost connection to MySQL database, attempting reconnection...');
|
logger.warning(logIdentify, logComponent, 'Lost connection to MySQL database, attempting reconnection...');
|
||||||
connect();
|
connect();
|
||||||
}
|
}
|
||||||
else{
|
else{
|
||||||
logger.error(logIdentify, 'mysql', 'Database error: ' + JSON.stringify(err))
|
logger.error(logIdentify, logComponent, 'Database error: ' + JSON.stringify(err))
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
@ -43,7 +44,7 @@ module.exports = function(logger, poolConfig){
|
||||||
[workerName],
|
[workerName],
|
||||||
function(err, result){
|
function(err, result){
|
||||||
if (err){
|
if (err){
|
||||||
logger.error(logIdentify, 'mysql', 'Database error when authenticating worker: ' +
|
logger.error(logIdentify, logComponent, 'Database error when authenticating worker: ' +
|
||||||
JSON.stringify(err));
|
JSON.stringify(err));
|
||||||
authCallback(false);
|
authCallback(false);
|
||||||
}
|
}
|
||||||
|
@ -76,9 +77,9 @@ module.exports = function(logger, poolConfig){
|
||||||
dbData,
|
dbData,
|
||||||
function(err, result) {
|
function(err, result) {
|
||||||
if (err)
|
if (err)
|
||||||
logger.error(logIdentify, 'mysql', 'Insert error when adding share: ' + JSON.stringify(err));
|
logger.error(logIdentify, logComponent, 'Insert error when adding share: ' + JSON.stringify(err));
|
||||||
else
|
else
|
||||||
logger.debug(logIdentify, 'mysql', 'Share inserted');
|
logger.debug(logIdentify, logComponent, 'Share inserted');
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
};
|
};
|
||||||
|
@ -89,7 +90,7 @@ module.exports = function(logger, poolConfig){
|
||||||
'UPDATE `pool_worker` SET `difficulty` = ' + diff + ' WHERE `username` = ' + connection.escape(workerName),
|
'UPDATE `pool_worker` SET `difficulty` = ' + diff + ' WHERE `username` = ' + connection.escape(workerName),
|
||||||
function(err, result){
|
function(err, result){
|
||||||
if (err)
|
if (err)
|
||||||
logger.error(logIdentify, 'mysql', 'Error when updating worker diff: ' +
|
logger.error(logIdentify, logComponent, 'Error when updating worker diff: ' +
|
||||||
JSON.stringify(err));
|
JSON.stringify(err));
|
||||||
else if (result.affectedRows === 0){
|
else if (result.affectedRows === 0){
|
||||||
connection.query('INSERT INTO `pool_worker` SET ?', {username: workerName, difficulty: diff});
|
connection.query('INSERT INTO `pool_worker` SET ?', {username: workerName, difficulty: diff});
|
||||||
|
|
|
@ -48,7 +48,7 @@ function SetupForPool(logger, poolOptions){
|
||||||
logger.error(logSystem, logComponent, 'Failed to connect to daemon for payment processing: ' +
|
logger.error(logSystem, logComponent, 'Failed to connect to daemon for payment processing: ' +
|
||||||
JSON.stringify(error));
|
JSON.stringify(error));
|
||||||
}).on('error', function(error){
|
}).on('error', function(error){
|
||||||
logger.error(logSystem, logComponent);
|
logger.error(logSystem, logComponent, 'Daemon error ' + JSON.stringify(error));
|
||||||
}).init();
|
}).init();
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,47 @@
|
||||||
|
{
|
||||||
|
"enabled": false,
|
||||||
|
"coin": "maxcoin.json",
|
||||||
|
|
||||||
|
"address": "tKWkadAkT2vqK6v2PHLJmV1RTVvF7XZEgN",
|
||||||
|
"blockRefreshInterval": 1000,
|
||||||
|
"txRefreshInterval": 20000,
|
||||||
|
"connectionTimeout": 600,
|
||||||
|
|
||||||
|
"shareProcessing": {
|
||||||
|
"internal": {
|
||||||
|
"enabled": true,
|
||||||
|
"validateWorkerAddress": true,
|
||||||
|
"paymentInterval": 10,
|
||||||
|
"minimumPayment": 100.001,
|
||||||
|
"minimumReserve": 10,
|
||||||
|
"feePercent": 0.02,
|
||||||
|
"feeReceiveAddress": "tQ2TKXXk2jh7EX2RJQ4ZxpZYEdRx7fdiaw",
|
||||||
|
"feeWithdrawalThreshold": 5,
|
||||||
|
"daemon": {
|
||||||
|
"host": "localhost",
|
||||||
|
"port": 27932,
|
||||||
|
"user": "testuser",
|
||||||
|
"password": "testpass"
|
||||||
|
},
|
||||||
|
"redis": {
|
||||||
|
"host": "localhost",
|
||||||
|
"port": 6379
|
||||||
|
}
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
"ports": {
|
||||||
|
"5547": {
|
||||||
|
"diff": 2
|
||||||
|
}
|
||||||
|
},
|
||||||
|
|
||||||
|
"daemons": [
|
||||||
|
{
|
||||||
|
"host": "localhost",
|
||||||
|
"port": 27932,
|
||||||
|
"user": "testuser",
|
||||||
|
"password": "testpass"
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
Loading…
Reference in New Issue