diff --git a/example/coins/dogecoin.json b/example/coins/dogecoin.json index eb87631..2af1290 100644 --- a/example/coins/dogecoin.json +++ b/example/coins/dogecoin.json @@ -10,6 +10,6 @@ "host": "localhost", "port": 19334, "user": "testnet", - "password": "AHhQYqfSZqzQvkSXAtHtDAbKaZaoPih3wfmJfgCtjRx9" + "password": "testnet1" } } diff --git a/index.js b/index.js index 1253474..111009c 100644 --- a/index.js +++ b/index.js @@ -76,15 +76,14 @@ var pool = module.exports = function pool(coin, authFn){ [coin.options.address], function(error, result){ if (error){ - console.log('validateaddress rpc error for ' + coin.options.name); + console.error('validateaddress rpc error for ' + coin.options.name); callback(error); - } - else if (!result.isvalid){ - console.log('address is not valid for ' + coin.options.name); + } else if (!result.isvalid) { + console.error('address is not valid for ' + coin.options.name); callback(error); - } - else + } else { callback(error, result); + } } ); }, diff --git a/libs/stratum.js b/libs/stratum.js index 5eeeab6..a8e3f7b 100644 --- a/libs/stratum.js +++ b/libs/stratum.js @@ -248,6 +248,10 @@ var StratumServer = exports.Server = function StratumServer(options){ ); stratumClients[subscriptionId] = client; _this.emit('client', client); + c.on('disconnect', function() { + delete stratumClients[subscriptionId]; + _this.emit('client.disconnected', client); + }); }); _socketServer.listen(options.port, function(){ _this.emit('started'); @@ -258,7 +262,7 @@ var StratumServer = exports.Server = function StratumServer(options){ //public members this.broadcastMiningJobs = function(jobParams){ - for (var clientId in stratumClients){ + for (var clientId in stratumClients) { stratumClients[clientId].sendMiningJob(jobParams) } };