2

我在这里尝试动态更新metadata导出的 Multer GridFS 模块中的属性时遇到了一些困难。该模块包含一个“上传引擎”，用于处理将文件上传到我的数据库。这是multer-gridfs-storage图书馆。

这是我的 GridFs 上传模块gridFs_upload_engine.js：

> //Upload Engine const mongoose = require('mongoose'); const path =
> require('path'); const crypto = require('crypto'); const multer =
> require('multer'); const GridFsStorage =
> require('multer-gridfs-storage'); const Grid =
> require('gridfs-stream');
> 
> //Init Upload Engine let gfs; const database = mongoose.connection;
> const mongoDb = process.env.MONGODB_URI || process.env.MLAB_URL;
> 
> database.once('open', () => {   //Init Stream   gfs =
> Grid(database.db, mongoose.mongo);   gfs.collection('uploads'); });
> 
> //Create Storage Engine const storage = new GridFsStorage({   url:
> mongoDb,   file: (req, file) => {
>     return new Promise((resolve, reject) => {
>       crypto.randomBytes(16, (err, buf) => {
>         if (err) {
>           return reject(err);
>         }
>         const filename = buf.toString('hex') + path.extname(file.originalname);
>         const fileInfo = {
>           filename: filename,
>           bucketName: 'uploads',
>           metadata: 'Add Metadata here'
>         };
>         resolve(fileInfo);
>       });
>     });   } });
> 
> const uploadEngine = multer({ storage });
> 
> module.exports = {   engine: uploadEngine,   gfs };

上面的metadata属性是我需要更改的。此fileinfo对象GridFs在上传时添加到每个文件。该req参数是我认为可以访问req.body调用此中间件的路由的位置，但它以undefined.

这是我的测试路线：

const express = require('express');
const router = express.Router();

//Controllers
const upload_controller = require('../../controllers/uploader');

//Dependencies
const upload = require('../../utils/gridFs_upload_engine');

const { engine } = upload;
//Upload Single File
router.post(
  '/single',
  engine.single('file'),
  upload_controller.upload_single_file
);

这是我将GridFs中间件传递到我的 API 路由的地方。这让控制器可以利用它。

这是我的upload controller：

exports.upload_single_file = (req, res, next) => {
  console.log({ file: req.file });
  res.redirect('/');
};

console.log按预期注销使用GridFs上传引擎上传的文件的信息。

我知道我需要以某种方式将参数传递给gridFs_upload_engine.js某种方式。由于这个文件是一个导出的模块，我不完全确定如何完成这个。我可以将这段代码直接放入我的 API 控制器并以这种方式进行，但我希望它是一个可以从其他控制器调用的模块。

4

2 回答 2

2

我最终通过公开一个让我更新变量的函数来解决这个问题，然后将其用作metadata值。

API路线：

//Dependencies
const upload = require('../../utils/gridFs_upload_engine');

const { engine, updateMetadata } = upload;

//Upload Single File
router.post(
  '/single',
  (req, res, next) => {
    updateMetadata('xxxxxx'); //Static test value
    next();
  },
  engine.single('file'),
  upload_controller.upload_single_file
);

在这里，我添加了一个回调，其中包含updateMetadata()来自上传引擎的公开函数。在这里，我设置metadata了暴露的updateMetadata()功能。之后，通过使用next(),router移动到engine.single('file')实际处理上传文件的位置。

这是GridFs上传引擎：

//Create Storage Engine
let updatedMetadata;

const updateMetadata = id => {
  updatedMetadata = id;
};

const storage = new GridFsStorage({
  url: mongoDb,
  file: (req, file) => {
    return new Promise((resolve, reject) => {
      crypto.randomBytes(16, (err, buf) => {
        if (err) {
          return reject(err);
        }
        const filename = buf.toString('hex') + path.extname(file.originalname);
        const fileInfo = {
          filename: filename,
          bucketName: 'uploads',
          metadata: updatedMetadata ? updatedMetadata : null
        };
        resolve(fileInfo);
      });
    });
  }
});

const uploadEngine = multer({ storage });

module.exports = {
  engine: uploadEngine,
  updateMetadata,
  gfs
};

我不确定这是否是最好的方法，但它可以正常工作并且符合预期，所以我不会进一步质疑它。希望这对某人有帮助！

于 2019-04-15T19:00:22.823 回答
0

上面的解决方案不起作用，经过一堆谷歌搜索后，我发现这无法访问元数据中的 req.body 。· 问题 #1 · devconcept/multer-gridfs-storage

在创建存储引擎时访问req之前我没有看到它感到很傻

const storage = new GridFsStorage({
url: db,
options: { useNewUrlParser: true, useUnifiedTopology: true },
file: (req, file) => {
    return new Promise((resolve, reject) => {
        crypto.randomBytes(16, (err, buf) => {
            if (err) {
                return reject(err);
            }
            let metaData;
            if(req.body && req.body.checked){
              metaData = true
            }
            const filename = buf.toString("hex") + path.extname(file.originalname);
            const fileInfo = {
                filename: filename,
                bucketName: "uploads",
                metadata: metaData ? metaData : null
                
            };
            resolve(fileInfo);
        });
    });
}

});

于 2020-09-21T21:19:22.190 回答