whistle/lib/plugins/get-plugins-sync.js

var path = require('path');
var fs = require('fs');
var fse = require('fs-extra2');
var util = require('../util');
var pluginUtil = require('./util');
var mp = require('./module-paths');
var config = require('../config');

var systemPluginPath = config.systemPluginPath;
var CUSTOM_PLUGIN_PATH = config.CUSTOM_PLUGIN_PATH;
var customPluginPaths = config.customPluginPaths || [];
var projectPluginPaths = config.projectPluginPaths || [];
var paths = mp.getPaths();

function readPluginMoudlesSync(dir, plugins) {
  plugins = plugins || {};
  var isCustom = CUSTOM_PLUGIN_PATH === dir;
  var isSys = isCustom || systemPluginPath === dir || customPluginPaths.indexOf(dir) !== -1;
  var isProj = projectPluginPaths.indexOf(dir) !== -1;
  
  try {
    var list = fs.readdirSync(dir).filter(function(name) {
      if (pluginUtil.isWhistleModule(name)) {
        return true;
      }

      if (pluginUtil.isOrgModule(name)) {
        try {
          var _dir = path.join(dir, name);
          var org = name;
          fs.readdirSync(_dir).forEach(function(name) {
            if (!plugins[name] && pluginUtil.isWhistleModule(name)) {
              plugins[name] = {
                root: isCustom ? path.join(_dir, name, 'node_modules', org, name) : path.join(_dir, name),
                isSys: isSys,
                isProj: isProj
              };
            }
          });
        } catch(e) {}
      }
      return false;
    });

    list.forEach(function(name) {
      if (!plugins[name]) {
        plugins[name] = {
          root: isCustom ? path.join(dir, name, 'node_modules', name) : path.join(dir, name),
          isSys: isSys,
          isProj: isProj
        };
      }
    });
  } catch(e) {}

  return plugins;
}

module.exports = function() {
  var plugins = {};
  paths.forEach(function(dir) {
    readPluginMoudlesSync(dir, plugins);
  });

  var _plugins = {};
  Object.keys(plugins).forEach(function(name) {
    var simpleName = name.split('.', 2)[1];
    if (pluginUtil.excludePlugin(simpleName)) {
      return;
    }
    var dir = plugins[name];
    var isSys = dir.isSys;
    var isProj = dir.isProj;
    dir = dir.root;
    try {
      var pkgPath = path.join(dir, 'package.json');
      var pkg = fse.readJsonSync(pkgPath);
      if (pkg && pkg.version) {
        var stats = fs.statSync(pkgPath);
        var conf = pkg.whistleConfig || '';
        var hintList = util.getHintList(conf);
        var plugin = {
          isSys: isSys,
          isProj: isProj,
          moduleName: pkg.name,
          networkMenus: util.getPluginMenu(conf.networkMenus || conf.networkMenu, simpleName),
          rulesMenus: util.getPluginMenu(conf.rulesMenus || conf.rulesMenu, simpleName),
          valuesMenus: util.getPluginMenu(conf.valuesMenus || conf.valuesMenu, simpleName),
          pluginHomepage: pluginUtil.getPluginHomepage(pkg),
          priority: parseInt(conf.priority, 10) || parseInt(pkg.pluginPriority, 10) || 0,
          rulesUrl: util.getCgiUrl(conf.rulesUrl),
          valuesUrl: util.getCgiUrl(conf.valuesUrl),
          hintUrl: hintList ? undefined : util.getCgiUrl(conf.hintUrl),
          hideShortProtocol: !!conf.hideShortProtocol,
          hideLongProtocol: !!conf.hideLongProtocol,
          hintList: hintList,
          registry: util.getRegistry(pkg),
          path: dir,
          pkgPath: pkgPath,
          mtime: stats.mtime.getTime(),
          version: pkg.version,
          description: pkg.description,
          homepage: pluginUtil.getHomePageFromPackage(pkg),
          rules: util.renderPluginRules(util.trim(util.readFileSync(path.join(dir, 'rules.txt'))), pkg, simpleName),
          _rules: util.renderPluginRules(util.trim(util.readFileSync(path.join(dir, '_rules.txt')))
            || util.trim(util.readFileSync(path.join(dir, 'reqRules.txt'))), pkg, simpleName),
          resRules: util.renderPluginRules(util.trim(util.readFileSync(path.join(dir, 'resRules.txt'))), pkg, simpleName)
        };

        plugin[util.PLUGIN_VALUES] = pluginUtil.parseValues(util.renderPluginRules(util.readFileSync(path.join(dir, '_values.txt')), pkg, simpleName));
        plugin[util.PLUGIN_MENU_CONFIG] = util.getPluginMenuConfig(conf);

        _plugins[simpleName + ':'] = plugin;
      }
    } catch(e) {}
  });

  return _plugins;
};