var RethinkDBFS = require('rethinkdbfs')
 
var dbfs = RethinkDBFS({db: 'example'})
 
// prepDB creates tables and indexes if they don't exist, returns a promise.
dbfs.prepDB().then(function () {
  // We are now ready to read and write files
 
  // create read stream from file
  var fileStream = fs.createReadStream('./bigvid.mp4')
 
  // Pipe it to a RethinkDBFS write stream
  fileStream.pipe(dbfs.writeFile({filename: '/videos/bigvid.mp4'}))
 
  fileStream.on('end', function () {
    // File is now written to the database
 
    //Read the file and pipe it to a write stream to save the file back out to the file system.
    dbfs.readFile({filename: '/videos/bigvid.mp4'}).pipe(fs.createWriteStream('./test-bigvid.mp4'))
  })
 
})