Express MongoDB GridFs

index.js

const mongoose = require('mongoose');
const GridFs = require('gridfs-stream');
const fs = require('fs');
const express = require('express');
const app = express();

mongoose.connect('mongodb://localhost:27017/test');

GridFs.mongo = mongoose.mongo;

const connection = mongoose.connection;

connection.on('error', console.error.bind(console, 'connection error:'));
connection.once('open', () => {
  const gfs = GridFs(connection.db);

  app.get('/write', (req, res) => {
    const writeStream = gfs.createWriteStream({
      filename: 'testing_2.jpg',
    });

    fs.createReadStream('./testing_2.jpg').pipe(writeStream);

    writeStream.on('close', (file) => {
      res.send(`File stored: ${file.filename}`);
    });
  });

  app.get('/read/:image', (req, res) => {
    gfs.exist({
      filename: req.param('image'),
    }, (err, file) => {
      const readStream = gfs.createReadStream({
        filename: req.param('image'),
      });

      readStream.pipe(res);
    });
  });

  app.listen(3000, () => console.log('http://localhost:3000'));
});