blob: 3efe095e53598735394df4ebe22f5679071db88a [file] [log] [blame]
#!/usr/bin/env node
var insert = require('../');
var through = require('through2');
var concat = require('concat-stream');
var JSONStream = require('JSONStream');
var basedir = process.argv[2] || process.cwd();
process.stdin
.pipe(JSONStream.parse([ true ]))
.pipe(through.obj(write))
.pipe(JSONStream.stringify())
.pipe(process.stdout)
;
function write (row, enc, next) {
var self = this;
var s = insert(row.id, { basedir: basedir });
s.pipe(concat(function (src) {
row.source = src.toString('utf8');
self.push(row);
next();
}));
s.end(row.source);
}