csv parsing + transform pipeline

index.js

var csv = require('csv-parser')
var through = require('through2')
var ndjson = require('ndjson')
var fs = require('fs')

fs.createReadStream(process.argv[2])
  .pipe(csv())
  .pipe(through.obj(map))
  .pipe(ndjson.serialize())
  .pipe(process.stdout)
  
function map(obj, enc, next) {
  obj.foo = "bar"
  this.push(obj)
  next()
}

could use https://www.npmjs.com/package/csv-write-stream for generating a csv at the end