let async = require('async'); // require("./utils/debug_util.js")(__filename, async); require('colors'); let Engine = require('./core/engine.js'); let version = require('../package.json').version; class Embark { constructor (options) { this.version = version; this.options = options || {}; } initConfig(env, options) { let Events = require('./core/events.js'); let Logger = require('./core/logger.js'); let Config = require('./core/config.js'); this.events = new Events(); this.logger = new Logger({logLevel: 'debug'}); this.config = new Config({env: env, logger: this.logger, events: this.events}); this.config.loadConfigFiles(options); this.plugins = this.config.plugins; } blockchain(env, client) { return require('./cmds/blockchain/blockchain.js')(this.config.blockchainConfig, client, env).run(); } simulator(options) { let Simulator = require('./cmds/simulator.js'); let simulator = new Simulator({blockchainConfig: this.config.blockchainConfig}); simulator.run(options); } generateTemplate(templateName, destinationFolder, name) { let TemplateGenerator = require('./cmds/template_generator.js'); let templateGenerator = new TemplateGenerator(templateName); templateGenerator.generate(destinationFolder, name); } run(options) { let self = this; let Dashboard = require('./dashboard/dashboard.js'); let windowSize = require('window-size'); let engine = new Engine({ env: options.env, version: this.version, embarkConfig: options.embarkConfig || 'embark.json', logfile: options.logfile }); engine.init(); if (!options.useDashboard) { console.log('========================'.bold.green); console.log(('Welcome to Embark ' + this.version).yellow.bold); console.log('========================'.bold.green); } async.parallel([ function startDashboard(callback) { if (!options.useDashboard) { return callback(); } let dashboard = new Dashboard({ events: engine.events, logger: engine.logger, plugins: engine.plugins, version: self.version, env: engine.env, contractsConfig: engine.config.contractsConfig }); dashboard.start(function () { engine.events.on('code-generator-ready', function () { engine.events.request('code-vanila-deployment', function (abi) { dashboard.console.runCode(abi); }); }); engine.logger.info('dashboard start'); callback(); }); }, 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("web3"); engine.startService("pipeline"); engine.startService("codeGenerator"); 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'); }); }); engine.deployManager.deployContracts(function (err) { engine.startService("fileWatcher"); if (options.runWebserver) { engine.startService("webServer", { host: options.serverHost, port: options.serverPort }); } callback(err); }); } ], function (err, _result) { if (err) { engine.logger.error(err.message); engine.logger.info(err.stack); } else { engine.events.emit('firstDeploymentDone'); engine.events.emit("status", "Ready".green); engine.logger.info("Looking for documentation? you can find it at ".cyan + "http://embark.readthedocs.io/".green.underline); engine.logger.info("Ready".underline); 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); } } }); } build(options) { let engine = new Engine({ env: options.env, version: this.version, embarkConfig: 'embark.json', interceptLogs: false }); engine.init(); async.waterfall([ function startServices(callback) { let pluginList = engine.plugins.listPlugins(); if (pluginList.length > 0) { engine.logger.info("loaded plugins: " + pluginList.join(", ")); } engine.startService("libraryManager"); engine.startService("web3"); engine.startService("pipeline"); engine.startService("codeGenerator"); engine.startService("deployment"); engine.startService("ipfs"); callback(); }, function deploy(callback) { engine.deployManager.deployContracts(function (err) { callback(err); }); } ], function (err, _result) { 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(); }); } initTests(options) { let Test = require('./tests/test.js'); return new Test(options); } reset() { let resetCmd = require('./cmds/reset.js'); resetCmd(); } // TODO: should deploy if it hasn't already upload(platform) { let options = { buildDir: 'dist/', storageConfig: this.config.storageConfig }; this.plugins.loadInternalPlugin('ipfs', options); this.plugins.loadInternalPlugin('swarm', options); let cmdPlugins = this.plugins.getPluginsFor('uploadCmds'); let cmdPlugin; if (cmdPlugins.length > 0) { cmdPlugin = cmdPlugins.find((pluginCmd) => { return pluginCmd.name == platform; }); } if (cmdPlugin) { cmdPlugin.uploadCmds[0].cb(); } else { console.log(("unknown platform: " + platform).red); console.log('try "embark upload ipfs" or "embark upload swarm"'.green); } } runTests(file) { let RunTests = require('./tests/run_tests.js'); RunTests.run(file); } } // temporary until next refactor Embark.initTests = function(options) { let Test = require('./tests/test.js'); return new Test(options); }; module.exports = Embark;