Restructured usage of pool module - removed stratum object so only pool object is instantiated

This commit is contained in:
Matt 2014-03-01 12:18:58 -07:00
parent dcdeba0267
commit f5ef2a4df9

11
init.js
View File

@ -118,15 +118,15 @@ else{
var poolConfigs = JSON.parse(process.env.pools); var poolConfigs = JSON.parse(process.env.pools);
var fork = process.env.fork; var fork = process.env.fork;
var stratum = new Stratum(); var pools = [];
//Handle blocknotify message from master process sent via IPC //Handle blocknotify message from master process sent via IPC
process.on('message', function(msg) { process.on('message', function(msg) {
var message = JSON.parse(msg); var message = JSON.parse(msg);
if (message.blocknotify){ if (message.blocknotify){
for (var i = 0; i < stratum.pools.length; i++){ for (var i = 0; i < pools.length; i++){
if (stratum.pools[i].options.coin.name.toLowerCase() === message.coin.toLowerCase()){ if (pools[i].options.coin.name.toLowerCase() === message.coin.toLowerCase()){
stratum.pools[i].processBlockNotify(message.blockHash) pools[i].processBlockNotify(message.blockHash)
return; return;
} }
} }
@ -151,7 +151,7 @@ else{
}; };
var pool = stratum.createPool(poolOptions, authorizeFN); var pool = Stratum.createPool(poolOptions, authorizeFN);
pool.on('share', function(isValidShare, isValidBlock, data){ pool.on('share', function(isValidShare, isValidBlock, data){
var shareData = JSON.stringify(data); var shareData = JSON.stringify(data);
@ -176,5 +176,6 @@ else{
} }
}); });
pool.start(); pool.start();
pools.push(pool);
}); });
} }