Guest User

Untitled

a guest
Nov 19th, 2017
95
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.10 KB | None | 0 0
  1. var Grid = require('gridfs-stream');
  2. var conn = mongoose.createConnection('localhost', 'Test', 27017);
  3. var gfs = Grid(conn.db, mongoose);
  4.  
  5. var fileId = new ObjectID(uniqId);
  6. var fileType = req.header('X-File-Type');
  7. var fileName = req.header('X-File-Name');
  8. var uniqId = req.param('uniqId', '112211112111');
  9.  
  10. console.log('upload start');
  11. // streaming to gridfs
  12. var writestream = gfs.createWriteStream(fileId, [{ "content_type": fileType, "metadata": { "fileName": fileName, "uploaded_at": (new Date()).toString() } }]);
  13. fs.createReadStream('/some/path').pipe(writestream);
  14.  
  15. // streaming from gridfs
  16. var readstream = gfs.createReadStream(fileId, [{ "content_type": fileType, "metadata": { "fileName": fileName, "uploaded_at": (new Date()).toString() } }]);
  17.  
  18. //error handling, e.g. file does not exist
  19. readstream.on('error', function (err) {
  20. console.log('An error occurred!', err);
  21. throw err;
  22. });
  23.  
  24. readstream.pipe(response);
  25. console.log('upload done');
  26.  
  27. var fileId = mongoose.Types.ObjectId();
  28.  
  29. var ObjectId = require('mongodb').ObjectID;
Add Comment
Please, Sign In to add comment