embark/lib/index.js

383 lines
12 KiB
JavaScript
Raw Normal View History

let async = require('async');
const constants = require('./constants');
2017-03-12 15:21:19 +00:00
// require("./utils/debug_util.js")(__filename, async);
2017-12-05 23:14:46 +00:00
require('colors');
2016-08-14 12:04:34 +00:00
2018-04-09 20:14:07 +00:00
// Override process.chdir so that we have a partial-implementation PWD for Windows
const realChdir = process.chdir;
process.chdir = (...args) => {
if (!process.env.PWD) {
process.env.PWD = process.cwd();
}
realChdir(...args);
};
2017-03-30 13:16:46 +00:00
let Engine = require('./core/engine.js');
let version = require('../package.json').version;
2017-03-31 11:34:43 +00:00
class Embark {
2017-03-30 13:16:46 +00:00
constructor (options) {
this.version = version;
this.options = options || {};
}
2017-03-30 11:12:39 +00:00
2017-03-30 13:16:46 +00:00
initConfig(env, options) {
let Events = require('./core/events.js');
let Logger = require('./core/logger.js');
let Config = require('./core/config.js');
2017-03-30 11:12:39 +00:00
2017-03-30 13:16:46 +00:00
this.events = new Events();
2018-03-15 21:18:20 +00:00
this.logger = new Logger({logLevel: 'debug', events: this.events});
2017-03-30 13:16:46 +00:00
this.config = new Config({env: env, logger: this.logger, events: this.events, context: this.context});
2017-03-30 11:12:39 +00:00
this.config.loadConfigFiles(options);
this.plugins = this.config.plugins;
2017-03-30 13:16:46 +00:00
}
2017-03-30 11:12:39 +00:00
2017-03-30 13:16:46 +00:00
blockchain(env, client) {
this.context = [constants.contexts.blockchain];
let blockchainConfig = this.config.blockchainConfig;
let storageConfig = this.config.storageConfig;
let webServerConfig = this.config.webServerConfig;
if(blockchainConfig.rpcCorsDomain === 'auto') {
if(webServerConfig) blockchainConfig.rpcCorsDomain = `http://${webServerConfig.host}:${webServerConfig.port}`;
if(storageConfig) blockchainConfig.rpcCorsDomain += `${blockchainConfig.rpcCorsDomain.length ? ',' : ''}http://${storageConfig.host}:${storageConfig.port}`;
}
if(blockchainConfig.wsOrigins === 'auto') {
if(webServerConfig) blockchainConfig.wsOrigins = `http://${webServerConfig.host}:${webServerConfig.port}`;
if(storageConfig) blockchainConfig.wsOrigins += `${blockchainConfig.wsOrigins.length ? ',' : ''}http://${storageConfig.host}:${storageConfig.port}`;
}
return require('./cmds/blockchain/blockchain.js')(blockchainConfig, client, env).run();
2017-03-30 13:16:46 +00:00
}
2017-02-25 03:49:34 +00:00
2017-03-30 13:16:46 +00:00
simulator(options) {
this.context = options.context || [constants.contexts.simulator, constants.contexts.blockchain];
2017-03-30 13:16:46 +00:00
let Simulator = require('./cmds/simulator.js');
let simulator = new Simulator({blockchainConfig: this.config.blockchainConfig});
simulator.run(options);
}
generateTemplate(templateName, destinationFolder, name) {
this.context = [constants.contexts.templateGeneration];
2017-03-30 13:16:46 +00:00
let TemplateGenerator = require('./cmds/template_generator.js');
let templateGenerator = new TemplateGenerator(templateName);
templateGenerator.generate(destinationFolder, name);
}
2017-02-25 03:49:34 +00:00
2017-03-30 13:16:46 +00:00
run(options) {
2017-03-31 11:34:43 +00:00
let self = this;
self.context = options.context || [constants.contexts.run, constants.contexts.build];
2017-03-30 13:16:46 +00:00
let Dashboard = require('./dashboard/dashboard.js');
2017-12-19 20:14:09 +00:00
let windowSize = require('window-size');
2017-03-30 13:16:46 +00:00
let engine = new Engine({
env: options.env,
2017-03-31 11:34:43 +00:00
version: this.version,
embarkConfig: options.embarkConfig || 'embark.json',
logFile: options.logFile,
logLevel: options.logLevel,
context: self.context
2017-03-30 13:16:46 +00:00
});
engine.init();
if (!options.useDashboard) {
engine.logger.info('========================'.bold.green);
engine.logger.info(('Welcome to Embark ' + this.version).yellow.bold);
engine.logger.info('========================'.bold.green);
2017-03-30 13:16:46 +00:00
}
async.parallel([
function startDashboard(callback) {
if (!options.useDashboard) {
return callback();
}
let dashboard = new Dashboard({
2017-12-17 23:34:41 +00:00
events: engine.events,
2017-03-30 13:16:46 +00:00
logger: engine.logger,
plugins: engine.plugins,
2017-03-31 11:34:43 +00:00
version: self.version,
2017-07-06 23:50:36 +00:00
env: engine.env,
contractsConfig: engine.config.contractsConfig
2017-03-30 13:16:46 +00:00
});
dashboard.start(function () {
engine.events.on('code-generator-ready', function () {
2017-10-17 11:03:13 +00:00
engine.events.request('code-vanila-deployment', function (abi) {
dashboard.console.runCode(abi);
});
2017-03-30 11:12:39 +00:00
});
2017-03-30 13:16:46 +00:00
engine.logger.info('dashboard start');
callback();
2017-03-30 13:16:46 +00:00
});
},
function (callback) {
let pluginList = engine.plugins.listPlugins();
if (pluginList.length > 0) {
engine.logger.info("loaded plugins: " + pluginList.join(", "));
2017-03-30 11:12:39 +00:00
}
2017-03-30 13:16:46 +00:00
engine.startMonitor();
engine.startService("libraryManager");
2017-03-30 13:16:46 +00:00
engine.startService("web3");
engine.startService("pipeline");
engine.startService("codeGenerator");
2017-03-30 13:16:46 +00:00
engine.startService("deployment");
engine.startService("ipfs");
engine.events.on('check:backOnline:Ethereum', function () {
engine.logger.info('Ethereum node detected..');
engine.config.reloadConfig();
engine.deployManager.deployContracts(function () {
engine.logger.info('Deployment Done');
});
2016-11-28 20:14:39 +00:00
});
2017-03-30 13:16:46 +00:00
engine.events.on('outputDone', function () {
engine.logger.info("Looking for documentation? You can find it at ".cyan + "http://embark.readthedocs.io/".green.underline + ".".cyan);
engine.logger.info("Ready".underline);
});
2017-03-30 13:16:46 +00:00
engine.deployManager.deployContracts(function (err) {
engine.startService("fileWatcher");
if (options.runWebserver) {
engine.startService("webServer", {
host: options.serverHost,
port: options.serverPort
});
}
callback(err);
2017-03-30 11:12:39 +00:00
});
2017-03-30 13:16:46 +00:00
}
2017-12-05 23:14:46 +00:00
], function (err, _result) {
2017-03-30 13:16:46 +00:00
if (err) {
engine.logger.error(err.message);
engine.logger.info(err.stack);
2016-10-31 02:04:25 +00:00
} else {
2017-12-19 20:14:09 +00:00
engine.events.emit('firstDeploymentDone');
engine.events.emit("status", "Ready".green);
2017-12-19 20:14:09 +00:00
let size = windowSize.get();
if (size.height < 40 || size.width < 118) {
engine.logger.warn("tip: you can resize the terminal or disable the dashboard with " + "embark run --nodashboard".bold.underline);
}
2016-10-31 02:04:25 +00:00
}
2017-03-30 13:16:46 +00:00
});
}
build(options) {
this.context = options.context || [constants.contexts.build];
let engine = new Engine({
env: options.env,
version: this.version,
embarkConfig: 'embark.json',
interceptLogs: false,
logFile: options.logFile,
logLevel: options.logLevel,
events: options.events,
logger: options.logger,
config: options.config,
plugins: options.plugins,
context: this.context
});
engine.init();
2016-10-02 21:26:57 +00:00
2017-03-30 13:16:46 +00:00
async.waterfall([
function startServices(callback) {
let pluginList = engine.plugins.listPlugins();
if (pluginList.length > 0) {
engine.logger.info("loaded plugins: " + pluginList.join(", "));
}
engine.startService("libraryManager");
2017-03-30 13:16:46 +00:00
engine.startService("web3");
engine.startService("pipeline");
engine.startService("codeGenerator");
2017-03-30 13:16:46 +00:00
engine.startService("deployment");
engine.startService("ipfs");
2017-03-30 13:16:46 +00:00
callback();
},
function deploy(callback) {
engine.deployManager.deployContracts(function (err) {
callback(err);
});
}
2017-12-05 23:14:46 +00:00
], function (err, _result) {
2017-03-30 13:16:46 +00:00
if (err) {
engine.logger.error(err.message);
engine.logger.debug(err.stack);
} else {
engine.logger.info("finished building".underline);
}
// needed due to child processes
process.exit();
2017-03-30 13:16:46 +00:00
});
}
initTests(options) {
this.context = options.context || [constants.contexts.test];
let Test = require('./tests/test.js');
options.context = this.context;
2017-03-30 13:16:46 +00:00
return new Test(options);
}
graph(options) {
this.context = options.context || [constants.contexts.graph];
options.onlyCompile = true;
let engine = new Engine({
env: options.env,
version: this.version,
embarkConfig: options.embarkConfig || 'embark.json',
logFile: options.logFile,
context: this.context
});
engine.init();
async.parallel([
function (callback) {
let pluginList = engine.plugins.listPlugins();
if (pluginList.length > 0) {
engine.logger.info("loaded plugins: " + pluginList.join(", "));
}
engine.startMonitor();
engine.startService("libraryManager");
engine.startService("pipeline");
engine.startService("codeGenerator");
engine.startService("deployment", {onlyCompile: true});
engine.deployManager.deployContracts(function (err) {
callback(err);
});
}
], function (err, _result) {
if (err) {
engine.logger.error(err.message);
engine.logger.info(err.stack);
} else {
const GraphGenerator = require('./cmds/graph.js');
let graphGen = new GraphGenerator(engine);
graphGen.generate();
engine.logger.info("Done".underline);
process.exit();
}
});
}
2018-01-11 14:22:58 +00:00
reset() {
this.context = [constants.contexts.reset];
2018-01-11 14:22:58 +00:00
let resetCmd = require('./cmds/reset.js');
resetCmd();
}
upload(platform, options) {
this.context = options.context || [constants.contexts.upload, constants.contexts.build];
let engine = new Engine({
env: options.env,
version: this.version,
embarkConfig: 'embark.json',
interceptLogs: false,
logFile: options.logFile,
logLevel: options.logLevel,
events: options.events,
logger: options.logger,
config: options.config,
plugins: options.plugins
});
engine.init();
2017-12-27 00:55:42 +00:00
let cmdPlugin;
async.waterfall([
function startServices(callback) {
engine.startService("libraryManager");
engine.startService("web3");
engine.startService("pipeline");
engine.startService("codeGenerator");
engine.startService("deployment");
engine.startService("ipfs");
engine.startService("swarm", {buildDir:'dist/',web3: engine.web3});
callback();
},
function setupStoragePlugin(callback){
let pluginList = engine.plugins.listPlugins();
if (pluginList.length > 0) {
engine.logger.info("loaded plugins: " + pluginList.join(", "));
}
// check use has input existing storage plugin
let cmdPlugins = engine.plugins.getPluginsFor('uploadCmds');
if (cmdPlugins.length > 0) {
cmdPlugin = cmdPlugins.find((pluginCmd) => {
return pluginCmd.name == platform;
});
}
if (!cmdPlugin) {
engine.logger.info('try "embark upload ipfs" or "embark upload swarm"'.green);
callback({message: 'unknown platform: ' + platform});
} else {
callback();
}
},
function deploy(callback) {
// 2. upload to storage (outputDone event triggered after webpack finished)
engine.events.on('outputDone', function () {
cmdPlugin.uploadCmds[0].cb()
.then((success) => {
callback(null, success);
})
.catch(callback);
});
// 1. build the contracts and dapp webpack
engine.deployManager.deployContracts(function (err) {
engine.logger.info("finished deploying".underline);
if(err){
callback(err);
}
});
}
], function (err, _result) {
if (err) {
engine.logger.error(err.message);
engine.logger.debug(err.stack);
} else {
engine.logger.info(`finished building DApp and deploying to ${platform}`.underline);
}
// needed due to child processes
process.exit();
});
}
runTests(file) {
this.context = [constants.contexts.test];
let RunTests = require('./tests/run_tests.js');
RunTests.run(file);
}
2017-03-30 13:16:46 +00:00
}
2017-06-26 13:01:54 +00:00
// temporary until next refactor
Embark.initTests = function(options) {
let Test = require('./tests/test.js');
options.context = [constants.contexts.test];
2017-06-26 13:01:54 +00:00
return new Test(options);
2017-06-26 13:02:58 +00:00
};
2017-06-26 13:01:54 +00:00
2016-08-18 00:29:41 +00:00
module.exports = Embark;