embark-area-51/lib/modules/blockchain_process/index.js

121 lines
3.4 KiB
JavaScript
Raw Normal View History

2018-07-20 12:21:23 +00:00
const async = require('async');
const utils = require('../../utils/utils.js');
const constants = require('../../constants');
const BlockchainProcessLauncher = require('./blockchainProcessLauncher');
class BlockchainModule {
constructor(embark, options) {
this.logger = embark.logger;
this.events = embark.events;
this.blockchainConfig = embark.config.blockchainConfig;
this.contractsConfig = embark.config.contractsConfig;
this.embark = embark;
this.locale = options.locale;
this.isDev = options.isDev;
2018-08-23 16:54:43 +00:00
this.ipc = options.ipc;
2018-07-20 12:21:23 +00:00
this.registerBlockchainProcess();
}
registerBlockchainProcess() {
const self = this;
this.events.request('processes:register', 'blockchain', (cb) => {
self.assertNodeConnection(true, (connected) => {
if (connected) return cb();
self.startBlockchainNode(cb);
this.listenToCommands();
this.registerConsoleCommands();
2018-07-20 12:21:23 +00:00
});
});
2018-08-23 16:54:43 +00:00
if (!this.ipc.isServer()) return;
self.ipc.on('blockchain:node', (_message, cb) => {
cb(null, utils.buildUrlFromConfig(self.contractsConfig.deployment));
});
2018-07-20 12:21:23 +00:00
}
listenToCommands() {
this.events.setCommandHandler('logs:ethereum:turnOn', (cb) => {
this.events.emit('logs:ethereum:enable');
return cb(null, 'Enabling Geth logs');
});
this.events.setCommandHandler('logs:ethereum:turnOff', (cb) => {
this.events.emit('logs:ethereum:disable');
return cb(null, 'Disabling Geth logs');
});
}
registerConsoleCommands() {
const self = this;
self.embark.registerConsoleCommand((cmd, _options) => {
return {
match: () => cmd === 'log geth on',
process: (cb) => self.events.request('logs:ethereum:turnOn', cb)
};
});
self.embark.registerConsoleCommand((cmd, _options) => {
return {
match: () => cmd === 'log geth off',
process: (cb) => self.events.request('logs:ethereum:turnOff', cb)
};
});
}
2018-07-20 12:21:23 +00:00
assertNodeConnection(noLogs, cb) {
if (typeof noLogs === 'function') {
cb = noLogs;
noLogs = false;
}
const self = this;
async.waterfall([
function checkWeb3State(next) {
self.events.request("blockchain:web3:isReady", (connected) => {
if (connected) {
return next(connected);
}
next();
2018-07-26 16:37:33 +00:00
});
2018-07-20 12:21:23 +00:00
},
function pingEndpoint(next) {
if (!self.contractsConfig || !self.contractsConfig.deployment || !self.contractsConfig.deployment.host) {
return next();
}
2018-08-23 16:54:43 +00:00
const {host, port, type, protocol} = self.contractsConfig.deployment;
2018-07-20 12:21:23 +00:00
utils.pingEndpoint(host, port, type, protocol, self.blockchainConfig.wsOrigins.split(',')[0], next);
}
2018-07-31 13:59:58 +00:00
], function (err) {
2018-07-20 14:12:57 +00:00
if (err === true || err === undefined) {
2018-07-20 12:21:23 +00:00
return cb(true);
}
return cb(false);
});
}
startBlockchainNode(callback) {
const self = this;
let blockchainProcess = new BlockchainProcessLauncher({
events: self.events,
logger: self.logger,
normalizeInput: utils.normalizeInput,
blockchainConfig: self.blockchainConfig,
locale: self.locale,
isDev: self.isDev
});
blockchainProcess.startBlockchainNode();
self.events.once(constants.blockchain.blockchainReady, () => {
callback();
});
self.events.once(constants.blockchain.blockchainExit, () => {
callback();
});
}
}
module.exports = BlockchainModule;