使用 mongoose 将带有 graphql 的文件上传到 mongodb

Question

我想使用 graphql 解析器将文件上传到 mongodb。 在 server.js 中，我有这个帮助功能来存储文件，该文件被导出以在我的解析器中使用。 该函数基于我在此处找到的内容：https://github.com/jaydenseric/graphql-upload/issues/8)，但现在 graphql 中的某些内容发生了变化。例如解构文件对象。我不知道应该在路径变量中找到什么以及我应该如何使用这个 createReadStream（从文件中解构的函数）。

const mongoose = require('mongoose');
const Grid = require('gridfs-stream');
const fs = require('fs');

//...

// Connect to Mongo
mongoose
  .connect(process.env.mongoURI, {
    useNewUrlParser: true,
    useCreateIndex: true,
    useUnifiedTopology: true,
    useFindAndModify: false
  }) // Adding new mongo url parser
  .then(() => console.log('MongoDB Connected...'))
  .catch(err => console.log(err));




const storeFile = async (upload) => {
   const { filename, createReadStream, mimetype } = await upload.then(result => result);

   const bucket = new mongoose.mongo.GridFSBucket(mongoose.connection.db, { bucketName: 'files' });

   const uploadStream = bucket.openUploadStream(filename, {
     contentType: mimetype
   });
   createReadStream()
     .pipe(uploadStream)
     .on('error', console.log('error'))
     .on('finish', console.log('finish'));
 }

module.exports = { storeFile }
//...

我的解析器（这里是最小版本，因为现在我只想将文件上传到我的数据库中。在我的一次尝试中，它甚至创建了 fs.files 和 fs.chunks 集合，但没有数据）：

Mutation: {
    uploadFile: async (_, { file }) => {
      console.log(file);
      const fileId = await storeFile(file);

      return true;
     
    }
  }

我现在有这个错误：

未处理的拒绝（错误）：GraphQL 错误：“侦听器”参数 必须是函数类型。收到未定义

并且在终端中我打印了“错误”（例如在 pipe.on('error', console.log('error') 语句中）

我只能上传小文件（最大 60 kb），所有更大的文件都不要上传，但所有尝试都会显示错误。

Answer 1

好的，我设法解决了。

解析器突变：

const { storeFile } = require('../../server');
//...

uploadFile: async (_, { file }) => {
      const fileId = await storeFile(file).then(result => result);

      return true;
// later I will return something more and create some object etc.
    }

来自 server.js 的支持函数

 const storeFile = async (upload) => {
    const { filename, createReadStream, mimetype } = await upload.then(result => result);

    const bucket = new mongoose.mongo.GridFSBucket(mongoose.connection.db, { bucketName: 'files' });
    
    const uploadStream = bucket.openUploadStream(filename, {
      contentType: mimetype
    });
    return new Promise((resolve, reject) => {
      createReadStream()
        .pipe(uploadStream)
        .on('error', reject)
        .on('finish', () => {
            resolve(uploadStream.id)
        })
    })
  }

  module.exports = { storeFile }