index.js

/*
  Import tsv file into Neo4J
  ---
  
  Import UTF8 tsv data into neo4j.
  Schema
  languages: en,fr comma separated
    
  all other fields will be stored as well.
  Note that if a slug field is present.
  
  task=
*/
var fs          = require('fs'),
    settings    = require('./settings'),
    options     = require('minimist')(process.argv.slice(2));
    async       = require('async'),
    _           = require('lodash'),
    clc         = require('cli-color'),
    
    tasks       = require('require-all')({
                    dirname: __dirname + '/tasks',
                    filter  :  /(.*).js$/
                  }),
    
    availableTasks = _.assign({
      demo: [],

      syncone: [
        tasks.eibio.getPerson,
        tasks.eibio.cleanMedia,
        tasks.histograph.getMediaByEibio,
        tasks.eibio.assignMedia,
        tasks.eibio.assignHistographLink
      ],

      sync: [
        tasks.eibio.getPeople,
        tasks.eibio.cleanMedia,
        tasks.histograph.getMediaByEibio,
        tasks.eibio.assignMedia,
        tasks.eibio.assignHistographLink
      ],
    }, settings.availableTasks || {});

console.log(clc.whiteBright( "\n\n +-+-+-+-+-+ +-+-+"));
console.log(clc.whiteBright( " |E|I|B|I|O|-|H|G| "));
console.log(clc.whiteBright( " +-+-+-+-+-+ +-+-+ \n\n"));

if(!availableTasks[options.task]) {
  console.log(clc.blackBright(' task', clc.whiteBright(options.task || 'null'), clc.redBright('not found'), 'please specify a valid', clc.whiteBright('--task'),'param'));
  console.log(clc.blackBright(' available tasks: '), _.keys(availableTasks));
  console.log("\n\n");
  return;
} 

// the waterfall specified for the task
async.waterfall([
  // send initial options
  function init(callback) {
    callback(null, options);
  },
  tasks.helpers.tick.start
].concat(_.map(availableTasks[options.task], function (d){
  if(typeof d == 'function')
    return d;
  return _.get(tasks, d.replace('tasks.', ''))
})).concat([tasks.helpers.tick.end]), function (err) {
  if(err) {
    console.warn(err);
    console.log(clc.blackBright('\n task'), clc.whiteBright(options.task), clc.redBright('exit with error'));
  } else
    console.log(clc.blackBright('\n task'), clc.whiteBright(options.task), clc.cyanBright('completed'));
  
  console.log("\n\n")
});