bin.js

#!/usr/bin/env node

var minimist = require('minimist')
var ldjson = require('ldjson-stream')
var fs = require('fs')
var csv = require('./')

var argv = minimist(process.argv, {
  alias: {
    h: 'headers',
    v: 'version',
    o: 'output',
    s: 'separator'
  },
  default: {
    s: ','
  },
  boolean: ['version', 'help']
})

var headers = argv.headers && argv.headers.toString().split(argv.separator)
var filename = argv._[2]

if (argv.version) {
  console.log(require('./package').version)
  process.exit(0)
}

if (argv.help || (process.stdin.isTTY && !filename)) {
  console.error(
    'Usage: csv-parser [filename?] [options]\n\n'+
    '  --headers,-h   Explicitly specify csv headers as a comma separated list\n'+
    '  --output,-o    Set output file. Defaults to stdout\n'+
    '  --separator,-s Set the separator character ("," by default)\n'+
    '  --version,-v   Print out the installed version\n'+
    '  --help         Show this help\n'
  )
  process.exit(1)
}

var input
var output = (argv.output && argv.output !== '-') ? fs.createWriteStream(argv.output) : process.stdout

if (filename === '-' || !filename) input = process.stdin
else if (fs.existsSync(filename)) input = fs.createReadStream(filename)
else {
  console.error('File: %s does not exist', filename)
  process.exit(2)
}

input.pipe(csv({headers:headers, separator:argv.separator})).pipe(ldjson.serialize()).pipe(output)