diff --git a/lib/pool_connector.js b/lib/pool_connector.js index 0cde289..3db825d 100644 --- a/lib/pool_connector.js +++ b/lib/pool_connector.js @@ -99,7 +99,7 @@ var PoolConnector = function(restartCallback){ // - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - this.onEnd = function() { logger.log('Pool closed the connection...'); - this.reconnect(); + this.reset(); }; // - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - this.send = function(obj){ @@ -160,11 +160,13 @@ var PoolConnector = function(restartCallback){ this.poolSocket.on('end',()=>{this.onEnd();}); }else{ logger.err('All connections failed...'); - this.reconnect(); + this.reset(); } } - this.reconnect = function () { + this.reset = function () { + logger.err('Closing all connections...'); + this.destroy(); logger.err("Waiting 10 seconds before attempting to restart the Stratum Proxy"); setTimeout( () => { restartCallback(); },10000); } diff --git a/package.json b/package.json index 34142ee..5379741 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "zecproxy", - "version": "1.0.5", + "version": "1.0.6", "description": "Zcash Stratum Proxy", "main": "proxy.js", "scripts": {}, diff --git a/proxy.js b/proxy.js index 68da700..27b7c12 100644 --- a/proxy.js +++ b/proxy.js @@ -1,17 +1,19 @@ var remotePool = require('./lib/pool_connector.js'); var logger = require('./lib/stratum_logger.js'); +var info = require('./package.json'); + var poolProxy = null; var startStratum = function() { - logger.log("ZEC STRATUM PROXY STARTING..."); + logger.log("ZEC STRATUM PROXY "+ info.version +" STARTING..."); poolProxy = new remotePool.PoolConnector(restartStratum); } var restartStratum = function() { - logger.warn("ZEC STRATUM PROXY RESTARTING..."); + logger.warn("ZEC STRATUM PROXY RESETING..."); poolProxy.destroy(); delete poolProxy; startStratum();