zecfoundation
/
s-nomp
mirror of https://github.com/ZcashFoundation/s-nomp.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #76 from whyyk7/master 

auto create mpos worker with tested
This commit is contained in:
Matthew Little 2014-04-21 12:23:55 -06:00
parent 9722c054f9 019865bc95
commit 0fd39f0569
1 changed files with 34 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
libs/mposCompatibility.js
View File

@ -38,7 +38,7 @@ module.exports = function(logger, poolConfig){
connect(); connect();
this.handleAuth = function(workerName, password, authCallback){ this.handleAuth = function(workerName, password, authCallback){
connection.query( connection.query(
'SELECT password FROM pool_worker WHERE username = LOWER(?)', 'SELECT password FROM pool_worker WHERE username = LOWER(?)',
[workerName.toLowerCase()], [workerName.toLowerCase()],
@ -48,8 +48,39 @@ module.exports = function(logger, poolConfig){
JSON.stringify(err)); JSON.stringify(err));
authCallback(false); authCallback(false);
} }
else if (!result[0]) else if (!result[0]){
authCallback(false); if(mposConfig.autoCreateWorker){
var account = workerName.split('.')[0];
connection.query(
'SELECT id,username FROM accounts WHERE username = LOWER(?)',
[account.toLowerCase()],
function(err, result){
if (err){
logger.error(logIdentify, logComponent, 'Database error when authenticating account: ' +
JSON.stringify(err));
authCallback(false);
}else if(!result[0]){
authCallback(false);
}else{
connection.query(
"INSERT INTO `pool_worker` (`account_id`, `username`, `password`) VALUES (?, ?, ?);",
[result[0].id,workerName.toLowerCase(),password],
function(err, result){
if (err){
logger.error(logIdentify, logComponent, 'Database error when insert worker: ' +
JSON.stringify(err));
authCallback(false);
}else {
authCallback(true);
}
})
}
}
);
}else{
authCallback(false);
}
}
else if (mposConfig.stratumAuth === 'worker') else if (mposConfig.stratumAuth === 'worker')
authCallback(true); authCallback(true);
else if (result[0].password === password) else if (result[0].password === password)