我在尝试动态更新导出的Multer GridFS模块中的metadata
属性时遇到了一些困难。该模块包含一个“上传引擎”,用于处理将文件上传到我的数据库。这是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控制器中并按照这种方式进行,但我希望它是一个可以从其他控制器调用的模块。
我最后通过公开一个允许我更新变量的函数来解决这个问题,然后将其用作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
};
我不确定这是否是最好的方法,但它可以正常工作并且符合预期,所以我不会再进一步质疑它。希望这有助于某人!