testdata.js

var debug = require('debug')('localdev:testdata');
var async = require('async');
var command = require('./command.js');
var _ = require('lodash');
var util = require('util');

module.exports = function (argv, systems, cb) {
  debug(system);

  var usage = 'Usage: testdata <system-name> [service-name]\n e.g. testdata phase3';
  var sysName = argv._[1];
  if (!sysName) return cb(usage);

  var system = systems[sysName];
  if (!system) return cb('System not found: ' + sysName);

  var workspace = 'workspace-' + sysName;
  console.log('System:', sysName, util.inspect(system.stringify(), true, null), 'workspace: ' + workspace);

  var serviceName = argv._[2];
  var services = system.services;
  if (serviceName) {
    var service = _.findWhere(system.services, {name: serviceName});
    if (!service) return cb('Service not found: ' + serviceName);
    services = [service];
  }

  // load the test data
  async.series([
    loadAllTestData
  ], cb);

  function loadAllTestData (cb) {
    async.mapSeries(services, loadTestData, cb);
  }

  function loadTestData (service, cb) {
    if (!service.testdata) return cb();
    var dir = workspace + '/' + service.name;
    var cmd = service.testdata;
    debug('loadTestData', dir, cmd);
    command(cmd, dir, service.env, cb);
  }
};