task.js

  1. "use strict";
  2. import async from 'async';
  3. import fs from 'fs';
  4. import p from 'path';
  5. import util from 'util';
  7. /**
  8.  * Load Bob task files in parallel.
  9.  * Only task files in specified taskNames will be loaded.
  10.  *
  11.  * @param {Array} taskNames: an array of task names
  12.  * @param {String} dir: base directory where task files are located
  13.  * @param {Function} cb: standard cb(err, result) callback
  14.  */
  15. function load(taskNames, dir, cb) {
  17.   const jobs = {};
  19.   taskNames.forEach((taskName) => {
  20.     jobs[taskName] = function (cb) {
  21.       const file = p.join(dir, taskName + '.json');
  22.       fs.access(file, fs.constants.F_OK, (err) => {
  23.         if (err) {
  24.           const _err = new Error(util.format('Unknown command: %s, use --help for more info', taskName));
  25.           cb(_err);
  26.         } else {
  27.           fs.readFile(file, cb);
  28.         }
  29.       });
  30.     };
  31.   });
  33.   function parse(err, results) {
  34.     if (!err) {
  35.       Object.keys(results).forEach((taskName) => {
  36.         results[taskName] = JSON.parse(results[taskName]);
  37.       });
  38.     }
  39.     cb(err, results);
  40.   }
  42.   async.parallel(jobs, parse);
  43. }
  45. const exports = {
  46.   load: load
  47. };
  49. export {
  50.   exports as default
  51. };