Update: Restrict config properties (closes #92) (#94)

Author: sttk

.eslintrc

@@ -1,3 +1,6 @@
 {
-  "extends": "gulp"
+  "extends": "gulp",
+  "rules": {
+    "max-statements": [1, 40]
+  }
 }

index.js

@@ -9,8 +9,6 @@ var Liftoff = require('liftoff');
 var tildify = require('tildify');
 var interpret = require('interpret');
 var v8flags = require('v8flags');
-var merge = require('lodash.merge');
-var isString = require('lodash.isstring');
 var findRange = require('semver-greatest-satisfied-range');
 var exit = require('./lib/shared/exit');
 var cliOptions = require('./lib/shared/cliOptions');
@@ -20,6 +18,10 @@ var cliVersion = require('./package.json').version;
 var getBlacklist = require('./lib/shared/getBlacklist');
 var toConsole = require('./lib/shared/log/toConsole');
 
+var loadConfigFiles = require('./lib/shared/config/load-files');
+var mergeConfigToCliFlags = require('./lib/shared/config/cli-flags');
+var mergeConfigToEnvFlags = require('./lib/shared/config/env-flags');
+
 // Logging functions
 var logVerify = require('./lib/shared/log/verify');
 var logBlacklistError = require('./lib/shared/log/blacklistError');
@@ -65,7 +67,7 @@ if (opts.continue) {
   process.env.UNDERTAKER_SETTLE = 'true';
 }
 
-// Set up event listeners for logging.
+// Set up event listeners for logging temporarily.
 toConsole(log, opts);
 
 cli.on('require', function(name) {
@@ -96,14 +98,13 @@ module.exports = run;
 
 // The actual logic
 function handleArguments(env) {
+  var cfgLoadOrder = ['home', 'cwd'];
+  var cfg = loadConfigFiles(env.configFiles['.gulp'], cfgLoadOrder);
+  opts = mergeConfigToCliFlags(opts, cfg);
+  env = mergeConfigToEnvFlags(env, cfg);
 
-  // Map an array of keys to preserve order
-  var configFilePaths = ['home', 'cwd'].map(function(key) {
-    return env.configFiles['.gulp'][key];
-  });
-  configFilePaths.filter(isString).forEach(function(filePath) {
-    merge(opts, require(filePath));
-  });
+  // Set up event listeners for logging again after configuring.
+  toConsole(log, opts);
 
   if (opts.help) {
     console.log(parser.help());
@@ -169,5 +170,5 @@ function handleArguments(env) {
   }
 
   // Load and execute the CLI version
-  require(path.join(__dirname, '/lib/versioned/', range, '/'))(opts, env);
+  require(path.join(__dirname, '/lib/versioned/', range, '/'))(opts, env, cfg);
 }

lib/shared/config/cli-flags.js

@@ -0,0 +1,13 @@
+'use strict';
+
+var copyProps = require('copy-props');
+
+var fromTo = {
+  'flags.silent': 'silent',
+};
+
+function mergeConfigToCliFlags(opt, config) {
+  return copyProps(config, opt, fromTo);
+}
+
+module.exports = mergeConfigToCliFlags;

lib/shared/config/env-flags.js

@@ -0,0 +1,22 @@
+'use strict';
+
+var path = require('path');
+var copyProps = require('copy-props');
+
+var toFrom = {
+  configPath: 'flags.gulpfile',
+  configBase: 'flags.gulpfile',
+};
+
+function mergeConfigToEnvFlags(env, config) {
+  return copyProps(env, config, toFrom, convert, true);
+}
+
+function convert(value, configKey, envKey) {
+  if (envKey === 'configBase') {
+    return path.dirname(value);
+  }
+  return value;
+}
+
+module.exports = mergeConfigToEnvFlags;

lib/shared/config/load-files.js

@@ -0,0 +1,30 @@
+'use strict';
+
+var copyProps = require('copy-props');
+var path = require('path');
+
+function loadConfigFiles(configFiles, configFileOrder) {
+  var config = {};
+
+  configFileOrder.forEach(loadFile);
+
+  function loadFile(key) {
+    var filePath = configFiles[key];
+    if (!filePath) {
+      return;
+    }
+
+    copyProps(require(filePath), config, convert);
+
+    function convert(value, name) {
+      if (name === 'flags.gulpfile') {
+        return path.resolve(path.dirname(filePath), value);
+      }
+      return value;
+    }
+  }
+
+  return config;
+}
+
+module.exports = loadConfigFiles;

lib/shared/log/toConsole.js

@@ -13,7 +13,23 @@ var levels = [
   'debug', // -LLLL: Logs all log levels.
 ];
 
+function cleanup(log) {
+  levels.forEach(removeListeners);
+
+  function removeListeners(level) {
+    if (level === 'error') {
+      log.removeListener(level, noop);
+      log.removeListener(level, fancyLog.error);
+    } else {
+      log.removeListener(level, fancyLog);
+    }
+  }
+}
+
 function toConsole(log, opts) {
+  // Remove previous listeners to enable to call this twice.
+  cleanup(log);
+
   // Return immediately if logging is
   // not desired.
   if (opts.tasksSimple || opts.silent) {

lib/versioned/^3.7.0/index.js

@@ -12,7 +12,7 @@ var logEvents = require('./log/events');
 var logTasksSimple = require('./log/tasksSimple');
 var registerExports = require('../../shared/registerExports');
 
-function execute(opts, env) {
+function execute(opts, env, config) {
   var tasks = opts._;
   var toRun = tasks.length ? tasks : ['default'];
 
@@ -39,8 +39,8 @@ function execute(opts, env) {
     }
     if (opts.tasks) {
       var tree = taskTree(gulpInst.tasks);
-      if (opts.description && isString(opts.description)) {
-        tree.label = opts.description;
+      if (config.description && isString(config.description)) {
+        tree.label = config.description;
       } else {
         tree.label = 'Tasks for ' + chalk.magenta(tildify(env.configPath));
       }

lib/versioned/^4.0.0-alpha.1/index.js

@@ -16,7 +16,7 @@ var logSyncTask = require('../^4.0.0/log/syncTask');
 var logTasksSimple = require('../^4.0.0/log/tasksSimple');
 var registerExports = require('../../shared/registerExports');
 
-function execute(opts, env) {
+function execute(opts, env, config) {
 
   var tasks = opts._;
   var toRun = tasks.length ? tasks : ['default'];
@@ -44,8 +44,8 @@ function execute(opts, env) {
     }
     if (opts.tasks) {
       var tree = {};
-      if (opts.description && isString(opts.description)) {
-        tree.label = opts.description;
+      if (config.description && isString(config.description)) {
+        tree.label = config.description;
       } else {
         tree.label = 'Tasks for ' + chalk.magenta(tildify(env.configPath));
       }

lib/versioned/^4.0.0-alpha.2/index.js

@@ -18,7 +18,7 @@ var registerExports = require('../../shared/registerExports');
 
 var getTask = require('../^4.0.0/log/getTask');
 
-function execute(opts, env) {
+function execute(opts, env, config) {
 
   var tasks = opts._;
   var toRun = tasks.length ? tasks : ['default'];
@@ -49,8 +49,8 @@ function execute(opts, env) {
     }
     if (opts.tasks) {
       tree = gulpInst.tree({ deep: true });
-      if (opts.description && isString(opts.description)) {
-        tree.label = opts.description;
+      if (config.description && isString(config.description)) {
+        tree.label = config.description;
       } else {
         tree.label = 'Tasks for ' + chalk.magenta(tildify(env.configPath));
       }
@@ -59,8 +59,8 @@ function execute(opts, env) {
     }
     if (opts.tasksJson) {
       tree = gulpInst.tree({ deep: true });
-      if (opts.description && isString(opts.description)) {
-        tree.label = opts.description;
+      if (config.description && isString(config.description)) {
+        tree.label = config.description;
       } else {
         tree.label = 'Tasks for ' + tildify(env.configPath);
       }

lib/versioned/^4.0.0/index.js

@@ -18,7 +18,7 @@ var registerExports = require('../../shared/registerExports');
 
 var getTask = require('./log/getTask');
 
-function execute(opts, env) {
+function execute(opts, env, config) {
 
   var tasks = opts._;
   var toRun = tasks.length ? tasks : ['default'];
@@ -49,8 +49,8 @@ function execute(opts, env) {
     }
     if (opts.tasks) {
       tree = gulpInst.tree({ deep: true });
-      if (opts.description && isString(opts.description)) {
-        tree.label = opts.description;
+      if (config.description && isString(config.description)) {
+        tree.label = config.description;
       } else {
         tree.label = 'Tasks for ' + chalk.magenta(tildify(env.configPath));
       }
@@ -59,8 +59,8 @@ function execute(opts, env) {
     }
     if (opts.tasksJson) {
       tree = gulpInst.tree({ deep: true });
-      if (opts.description && isString(opts.description)) {
-        tree.label = opts.description;
+      if (config.description && isString(config.description)) {
+        tree.label = config.description;
       } else {
         tree.label = 'Tasks for ' + tildify(env.configPath);
       }