var mongodb = require('mongodb');
var gridstream = require('gridfs-stream');
var fs = require('fs');

var filename = 'zero.100MB';

mongodb.MongoClient.connect('mongodb://localhost:27017/test', function(err, db) {

  var start = process.hrtime();

  var fileId = new mongodb.ObjectID();

  var gridStore = new mongodb.GridStore(db, fileId, filename, "w");
  var stream = gridStore.stream();
  var fileStream = fs.createReadStream(filename);

  var size = 0;
  fileStream.on('data', function logInputData(data) {
    size += data.length;
    console.log('fs input data sent', size);
  });

  fileStream.pipe(stream)
    .once('end', function gfsDone() {

      var diff = process.hrtime(start),
          time = diff[0]*1e9+diff[1];
      console.log('mongodb driver 2.0 gridfs-stream write complete for "%s", total time was %dns.',filename,time);

      db.close();
    });
});