CLI子命令擴展-插件機制實現

// Load plugins
return ctx.loadPlugin(path).then(function {
ctx.log.debug("Plugin loaded: %s", chalk.magenta(name));
}).catch(function(err) {
ctx.log.error({err: err}, "Plugin load failed: %s", chalk.magenta(name));
});
});
}

/**
* Read external plugins.
*/
loadModuleList(ctx) {
const packagePath = pathFn.join(ctx.base_dir, "package.json");
const pluginDir = ctx.plugin_dir;

// Make sure package.json exists
return fs.exists(packagePath).then(function(exist) {
if (!exist) return ;

// Read package.json and find dependencies
return fs.readFile(packagePath).then(function(content) {
const json = JSON.parse(content);
const deps = json.dependencies || json.devDependencies || {};

return Object.keys(deps);
});
}).filter(function(name) {
// Ignore plugins whose name is not started with "feflow-plugin-"
if (!/^feflow-plugin-|^@[^/]+/feflow-plugin-/.test(name)) return false;

...
loadPlugin(path, callback) {
const self = this;

return fs.readFile(path).then(function(script) {
// Based on: https://github.com/joyent/node/blob/v0.10.33/src/node.js#L516
var module = new Module(path);
module.filename = path;
module.paths = Module._nodeModulePaths(path);

function require(path) {
return module.require(path);
}

require.resolve = function(request) {
return Module._resolveFilename(request, module);
};

require.main = process.mainModule;
require.extensions = Module._extensions;
require.cache = Module._cache;

script = "(function(exports, require, module, __filename, __dirname, feflow){" +
script + "});";

var fn = vm.runInThisContext(script, path);

constructor {
this.store = {};
this.alias = {};
}

get(name) {
name = name.toLowerCase;
return this.store[this.alias[name]];
}

list {
return this.store;
}

register(name, desc, options, fn) {
if (!name) throw new TypeError("name is required");

if (!fn) {
if (options) {
if (typeof options === "function") {
fn = options;

if (typeof desc === "object") { // name, options, fn
options = desc;
desc = "";
} else { // name, desc, fn
options = {};
}
} else {
throw new TypeError("fn must be a function");
}
} else {
// name, fn
if (typeof desc === "function") {
fn = desc;
options = {};
desc = "";
} else {
throw new TypeError("fn must be a function");
}
}
}

if (fn.length > 1) {
fn = Promise.promisify(fn);
} else {
fn = Promise.method(fn);
}

const c = this.store[name.toLowerCase()] = fn;
c.options = options;
c.desc = desc;

var self = this;

return new Promise(function(resolve, reject) {
var c = self.plugin.get(name);