remove inconsistent file between master and develop
This commit is contained in:
parent
e175cd6b56
commit
48c72ab257
|
@ -1,75 +0,0 @@
|
||||||
var Web3 = require('web3');
|
|
||||||
var async = require('async');
|
|
||||||
var request = require('request');
|
|
||||||
|
|
||||||
var ServicesMonitor = function(options) {
|
|
||||||
this.logger = options.logger;
|
|
||||||
this.interval = options.interval || 5000;
|
|
||||||
this.config = options.config;
|
|
||||||
this.serverPort = options.serverPort || 8000;
|
|
||||||
};
|
|
||||||
|
|
||||||
ServicesMonitor.prototype.startMonitor = function() {
|
|
||||||
this.monitor = setInterval(this.check.bind(this), this.interval);
|
|
||||||
};
|
|
||||||
|
|
||||||
ServicesMonitor.prototype.stopMonitor = function() {
|
|
||||||
};
|
|
||||||
|
|
||||||
ServicesMonitor.prototype.check = function() {
|
|
||||||
var self = this;
|
|
||||||
async.waterfall([
|
|
||||||
function connectWeb3(callback) {
|
|
||||||
self.logger.trace('connectWeb3');
|
|
||||||
var web3 = new Web3();
|
|
||||||
var web3Endpoint = 'http://' + self.config.blockchainConfig.rpcHost + ':' + self.config.blockchainConfig.rpcPort;
|
|
||||||
web3.setProvider(new web3.providers.HttpProvider(web3Endpoint));
|
|
||||||
callback(null, web3, []);
|
|
||||||
},
|
|
||||||
function addEmbarkVersion(web3, result, callback) {
|
|
||||||
self.logger.trace('addEmbarkVersion');
|
|
||||||
result.push('Embark 2.1.4'.green);
|
|
||||||
callback(null, web3, result);
|
|
||||||
},
|
|
||||||
function checkEthereum(web3, result, callback) {
|
|
||||||
self.logger.trace('checkEthereum');
|
|
||||||
var service;
|
|
||||||
if (web3.isConnected()) {
|
|
||||||
service = (web3.version.node.split("/")[0] + " (Ethereum)").green;
|
|
||||||
} else {
|
|
||||||
service = "No Blockchain node found".red;
|
|
||||||
}
|
|
||||||
result.push(service);
|
|
||||||
callback(null, web3, result);
|
|
||||||
},
|
|
||||||
function checkWhisper(web3, result, callback) {
|
|
||||||
self.logger.trace('checkWhisper');
|
|
||||||
web3.version.getWhisper(function(err, res) {
|
|
||||||
var service = 'whisper';
|
|
||||||
result.push(err ? service.red : service.green);
|
|
||||||
callback(null, result);
|
|
||||||
});
|
|
||||||
},
|
|
||||||
function checkIPFS(result, callback) {
|
|
||||||
self.logger.trace('checkIPFS');
|
|
||||||
|
|
||||||
request('http://localhost:5001', function(error, response, body) {
|
|
||||||
if (error) {
|
|
||||||
result.push('IPFS'.red);
|
|
||||||
} else {
|
|
||||||
result.push('IPFS'.green);
|
|
||||||
}
|
|
||||||
callback(null, result);
|
|
||||||
});
|
|
||||||
},
|
|
||||||
function checkDevServer(result, callback) {
|
|
||||||
self.logger.trace('checkDevServer');
|
|
||||||
result.push(('dev server (http://localhost:' + self.serverPort + ')').green);
|
|
||||||
callback(null, result);
|
|
||||||
}
|
|
||||||
], function(err, result) {
|
|
||||||
self.logger.availableServices(result);
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
module.exports = ServicesMonitor;
|
|
Loading…
Reference in New Issue