use arrow functions

Author: mining-visualizer

index.js

@@ -56,20 +56,20 @@ async function init() {
 
  // 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) {
+ rpcServer.on('submitShare', async (args, callback) => {
  var res = await stratumClient.submitShare(args);
  callback(res);
  rejected = res ? rejected : rejected + 1;
  process.stdout.write('Total shares: ' + shareCount++ + ', Rejected: ' + rejected + "\r");
  });
 
  // if we get disconnected from the pool, try to reconnect
- stratumClient.on('disconnect', function() {
+ stratumClient.on('disconnect', () => {
  rpcServer.removeAllListeners('submitShare');
  LogB('Connection closed. Reconnecting in 5 seconds ...');
  setTimeout(init, 5000);
 
- }).on('workPackage', function(params) {
+ }).on('workPackage', (params) => {
  // listen for work packages from the stratum pool and make them available to the rpc server
  rpcServer.setWork(params);
  });

lib/rpc.js

@@ -11,7 +11,6 @@ module.exports = class RPCServer extends EventEmitter {
 
  constructor (config) {
  super();
- var _this = this;
 
  this.minerEthAddress = config.Miner.EthAddress.toLowerCase();
  this.mintingAccount = "";
@@ -22,38 +21,38 @@ module.exports = class RPCServer extends EventEmitter {
  // create an rpc server
  var server = jayson.server({
 
- getPoolEthAddress: function(args, callback) {
+ getPoolEthAddress: (args, callback) => {
  // LogB('getPoolEthAddress: ', args);
- callback(null, _this.mintingAccount);
+ callback(null, this.mintingAccount);
  },
 
- getMinimumShareDifficulty: async function(args, callback) {
+ getMinimumShareDifficulty: async (args, callback) => {
  // LogB('getMinimumShareDifficulty: ', args);
- if (args[0].toLowerCase() != _this.minerEthAddress) {
- callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + _this.minerEthAddress}); 
+ if (args[0].toLowerCase() != this.minerEthAddress) {
+ callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + this.minerEthAddress}); 
  }
- callback(null, _this.minerVarDiff);
+ callback(null, this.minerVarDiff);
  },
 
- getMinimumShareTarget: async function(args, callback) {
+ getMinimumShareTarget: async (args, callback) => {
  // LogB('getMinimumShareTarget: ', args);
- if (args[0].toLowerCase() != _this.minerEthAddress) {
- callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + _this.minerEthAddress}); 
+ if (args[0].toLowerCase() != this.minerEthAddress) {
+ callback({code: -1, message: 'Invalid minerEthAddresss ' + args[0] + '. Expecting ' + this.minerEthAddress}); 
  }
- callback(null, _this.minimumShareTarget);
+ callback(null, this.minimumShareTarget);
  },
 
- getChallengeNumber: async function(args, callback) {
+ getChallengeNumber: async (args, callback) => {
  // LogB('getChallengeNumber: ', args);
- callback(null, _this.challengeNumber);
+ callback(null, this.challengeNumber);
  },
 
- submitShare: async function(args, callback) {
+ submitShare: async (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) => {
+ this.emit('submitShare', args, (res) => {
  callback(null, res);
  })
  },

lib/stratum.js

@@ -23,7 +23,6 @@ module.exports = class StratumClient extends EventEmitter {
  }
 
  connectToPool() {
- var _this = this;
 
  this.subscribed = false;
  this.submitShareResponse = null;
@@ -33,25 +32,25 @@ module.exports = class StratumClient extends EventEmitter {
  this.client.setEncoding('utf8');
  this.client.setKeepAlive(true);
 
- this.client.on('connect', function() {
- LogB('Stratum proxy connected to ' + _this.config.Stratum.Host + ':' + _this.config.Stratum.Port);
+ this.client.on('connect', () => {
+ LogB('Stratum proxy connected to ' + this.config.Stratum.Host + ':' + this.config.Stratum.Port);
  // subscribe to work notifications
  var msg = {
  id : 1,
  method : 'mining.subscribe',
- params : [_this.minerAccount, 'Stratum Proxy v' + global.VERSION]
+ params : [this.minerAccount, 'Stratum Proxy v' + global.VERSION]
  };
- LogD('subscribing to pool with account', _this.minerAccount);
- _this.client.write(JSON.stringify(msg) + '\n');
+ LogD('subscribing to pool with account', this.minerAccount);
+ this.client.write(JSON.stringify(msg) + '\n');
 
- }).on('data', function(data) {
- _this.handleData(data);
+ }).on('data', (data) => {
+ this.handleData(data);
 
- }).on('close', function() {
- _this.subscribed = false;
- _this.emit('disconnect');
+ }).on('close', () => {
+ this.subscribed = false;
+ this.emit('disconnect');
 
- }).on('error', function(e) {
+ }).on('error', (e) => {
  if (e.code == 'ECONNREFUSED') {
  LogB('Socket error: unable to connect to mining pool at ', e.address + ':' + e.port, ' [ECONNREFUSED]');
  } else {
@@ -64,21 +63,19 @@ module.exports = class StratumClient extends EventEmitter {
  }
 
  handleData(data) {
- var _this = this;
-
  this.dataBuffer += data;
  if (this.dataBuffer.indexOf('\n') !== -1) {
  var messages = this.dataBuffer.split('\n');
  var incomplete = this.dataBuffer.slice(-1) === '\n' ? '' : messages.pop();
- messages.forEach(function(message) {
+ messages.forEach((message) => {
  if (message === '') return;
- _this.handleMessage(message);
+ this.handleMessage(message);
  });
  this.dataBuffer = incomplete;
  }
  }
 
- handleMessage(message){
+ handleMessage(message) {
  try {
  var jsonData = JSON.parse(message);
  if (jsonData.id !== undefined) {