tabs

Author: mining-visualizer

index.js

@@ -24,8 +24,8 @@ if (process.argv[2] == '-v' || process.argv[2] == '--version') {
 var iniFile = path.join(process.cwd(), 'config.ini');
 
 if (!fs.existsSync(iniFile)) {
-console.log('Error : unable to locate ', iniFile);
-process.exit();
+ console.log('Error : unable to locate ', iniFile);
+ process.exit();
 }
 
 var config = ini.parse(fs.readFileSync(iniFile, 'utf-8'));
@@ -41,25 +41,25 @@ async function init() {
  var stratumClient = new StratumClient(config);
 
  if (!rpcServer) {
-rpcServer = new RPCServer(config);
+ rpcServer = new RPCServer(config);
  }
 
  // wait for shares from the miner and send them up to the pool. use the 
  // callback to notify the miner if share was accepted.
-rpcServer.on('submitShare', async function(args, callback) {
-var res = await stratumClient.submitShare(args);
-callback(res);
-});
+ rpcServer.on('submitShare', async function(args, callback) {
+ var res = await stratumClient.submitShare(args);
+ callback(res);
+ });
 
-// if we get disconnected from the pool, try to reconnect
+ // if we get disconnected from the pool, try to reconnect
  stratumClient.on('disconnect', function() {
- rpcServer.removeAllListeners('submitShare');
+  rpcServer.removeAllListeners('submitShare');
  LogB('Connection closed. Reconnecting in 5 seconds ...');
  setTimeout(init, 5000);
 
  }).on('workPackage', function(params) {
-// listen for work packages from the stratum pool and make them available to the rpc server
-rpcServer.setWork(params);
+ // listen for work packages from the stratum pool and make them available to the rpc server
+ rpcServer.setWork(params);
  });
 
 }

lib/rpc.js

@@ -9,75 +9,75 @@ var LogB = global.logger.LogB;
 
 module.exports = class RPCServer extends EventEmitter {
 
-constructor (config) {
+ constructor (config) {
  super();
-var _this = this;
-
-this.minerEthAddress = config.Miner.EthAddress.toLowerCase();
-this.mintingAccount = "";
-this.minerVarDiff = 0;
-this.minimumShareTarget = "";
-this.challengeNumber = "";
-
-LogB('JSON-RPC server listening on localhost:' + config.RPC.Port);
-
-// create an rpc server
-var server = jayson.server({
-
-getPoolEthAddress: function(args, callback) {
-// LogB('getPoolEthAddress: ', args);
-callback(null, _this.mintingAccount);
-},
-
-getMinimumShareDifficulty: async function(args, callback) {
-// LogB('getMinimumShareDifficulty: ', args);
-if (args[0].toLowerCase() != _this.minerEthAddress) {
-callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + _this.minerEthAddress}); 
-}
-callback(null, _this.minerVarDiff);
-},
-
-getMinimumShareTarget: async function(args, callback) {
-// LogB('getMinimumShareTarget: ', args);
-if (args[0].toLowerCase() != _this.minerEthAddress) {
-callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + _this.minerEthAddress}); 
-}
-callback(null, _this.minimumShareTarget);
-},
-
-getChallengeNumber: async function(args, callback) {
-// LogB('getChallengeNumber: ', args);
-callback(null, _this.challengeNumber);
-},
-
-submitShare: async function(args, callback) {
-// LogB('submitShare: ', args);
-
-// notify interested listeners of a share submit. provide a callback so we can be 
-// notified if share was accepted (true/false).
- _this.emit('submitShare', args, (res) => {
- callback(null, res);
- })
-},
-
-});
-
-server.http().listen(config.RPC.Port);
-}
-
-
-setWork(params) {
-try {
-this.challengeNumber = params[0];
-this.minimumShareTarget = params[1];
-this.minerVarDiff = params[2];
-this.mintingAccount = params[3];
-}
-catch (err) {
-LogB('Error in setWork: unable to process mining pool work parameters');
-LogB('params=', params);
-}
-}
-
+ var _this = this;
+
+ this.minerEthAddress = config.Miner.EthAddress.toLowerCase();
+ this.mintingAccount = "";
+ this.minerVarDiff = 0;
+ this.minimumShareTarget = "";
+ this.challengeNumber = "";
+
+ LogB('JSON-RPC server listening on localhost:' + config.RPC.Port);
+
+ // create an rpc server
+ var server = jayson.server({
+
+ getPoolEthAddress: function(args, callback) {
+ // LogB('getPoolEthAddress: ', args);
+ callback(null, _this.mintingAccount);
+ },
+
+ getMinimumShareDifficulty: async function(args, callback) {
+ // LogB('getMinimumShareDifficulty: ', args);
+ if (args[0].toLowerCase() != _this.minerEthAddress) {
+ callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + _this.minerEthAddress}); 
+ }
+ callback(null, _this.minerVarDiff);
+ },
+
+ getMinimumShareTarget: async function(args, callback) {
+ // LogB('getMinimumShareTarget: ', args);
+ if (args[0].toLowerCase() != _this.minerEthAddress) {
+ callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + _this.minerEthAddress}); 
+ }
+ callback(null, _this.minimumShareTarget);
+ },
+
+ getChallengeNumber: async function(args, callback) {
+ // LogB('getChallengeNumber: ', args);
+ callback(null, _this.challengeNumber);
+ },
+
+ submitShare: async function(args, callback) {
+ // LogB('submitShare: ', args);
+
+ // notify interested listeners of a share submit. provide a callback so we can be 
+ // notified if share was accepted (true/false).
+  _this.emit('submitShare', args, (res) => {
+  callback(null, res);
+  })
+ },
+
+ });
+
+ server.http().listen(config.RPC.Port);
+ }
+
+
+ setWork(params) {
+ try {
+ this.challengeNumber = params[0];
+ this.minimumShareTarget = params[1];
+ this.minerVarDiff = params[2];
+ this.mintingAccount = params[3];
+ }
+ catch (err) {
+ LogB('Error in setWork: unable to process mining pool work parameters');
+ LogB('params=', params);
+ }
+ }
+ 
 }