let fs = require('./../../core/fs.js'); let utils = require('./../../utils/utils.js'); let async = require('async'); class PluginCommand { constructor(embark) { this.embark = embark; this.config = this.embark.pluginConfig; this.embarkConfig = this.config.embarkConfig; this.registerCommand(); } registerCommand() { const self = this; self.embark.registerConsoleCommand((cmd, _options) => { let cmdArray = cmd.split(' '); cmdArray = cmdArray.filter(cmd => cmd.trim().length > 0); let cmdName = cmdArray[0]; return { match: () => cmdName === 'plugin', process: (callback) => { if(cmdArray.length < 3 || cmdArray[1] !== 'install' || typeof cmdArray[2] === 'undefined') { return callback('invalid use of plugin command. Please use plugin install '); } let npmInstall = ['npm', 'install', '--save']; npmInstall = npmInstall.concat(cmdArray.slice(2)); let npmPackage = npmInstall[3]; self.embark.logger.info(`Installing npm package ${npmPackage} ...`); async.waterfall([ function npmInstallAsync(cb) { utils.runCmd(npmInstall.join(' '), {silent: false, exitOnError: false}, (err) => { if(err) { return cb(err); } cb(); }); }, function addToEmbarkConfig(cb) { // get the installed package from package.json let packageFile = fs.readJSONSync(self.config.packageFile); let dependencies = Object.keys(packageFile.dependencies); let installedPackage = dependencies.filter((dep) => npmPackage.indexOf(dep) >=0); self.embarkConfig.plugins[installedPackage[0]] = {}; fs.writeFile(self.config.embarkConfigFile, JSON.stringify(self.embarkConfig, null, 2), cb); } ], (err) => { if(err) { let errorMessage = `Error installing npm package ${npmPackage}. Please visit https://embark.status.im/plugins/ for all supported plugins`; self.embark.logger.error(errorMessage); return callback('Error occurred'); } callback(null, `npm package ${npmPackage} successfully installed as a plugin`); }); } }; }); } } module.exports = PluginCommand;