export.js

var pumpify = require('pumpify')
var through = require('through2')
var formatData = require('format-data')
var debug = require('debug')('src/export')

module.exports = function createExportStream (db, opts) {
  var parseOutput = through.obj(function (data, enc, next) {
    debug('exporting through data', data)
    if (data.content === 'file' && !opts.files) return next()
    if (opts.full) return next(null, data)
    next(null, data.value)
  })

  return pumpify(db.createReadStream(opts), parseOutput, formatData(opts.format))
}