Массив ссылок файлов пуст в Mongodb после асинхронных операций - PullRequest
Новая
       7

Массив ссылок файлов пуст в Mongodb после асинхронных операций

0 голосов
/ 20 января 2020

Моя мутационная функция Apollo получает 2 массива файлов в качестве аргументов. Затем я записываю это в файловую систему, помещая их расположение в массивы. После этого я хочу, чтобы массивы записывались в MongoDB, но mon go имеет пустые поля из-за асинхронности. Как я могу справиться с этим? 

const { createWriteStream } = require("fs");
const path = require('path');
const Post = require('../../models/Post');
const checkAuth = require('../../utils/check-auth');

module.exports = {
  Mutation: {
    async addPost(_, { postInput: { title, description, pictures, panoramas, price, location } }, ctx) {
      const anon = checkAuth(ctx);
      let pics = [];
      let pans = [];

      pictures.map(async (el) => {
        const { createReadStream, filename } = await el;

        await new Promise(res =>
          createReadStream()
            .pipe(createWriteStream(path.join("static/images", filename)))
            .on("close", res)
        );
        pics.push(`static/images/, ${filename}`);
      })
      panoramas.map(async (el) => {
        const { createReadStream, filename } = await el;

        await new Promise(res =>
          createReadStream()
            .pipe(createWriteStream(path.join("static/images", filename)))
            .on("close", res)
        );
        pans.push(path.join("static/images", filename));
      })

      const newPost = new Post({
        title,
        description,
        price,
        pictures: pics,
        panoramas: pans,
        createdAt: new Date().toISOString(),
        userId: anon.id,
        location,
      });

      const res = await newPost.save();
      console.log(res)
      return true;
    }
  }
}

1 Ответ

2 голосов
/ 20 января 2020

Вы должны просто подождать, пока все обещания не разрешатся, и только затем приступить к созданию нового документа. 

async function addPost(_, {postInput: {title, description, pictures, panoramas, price, location}}, ctx) {
    const anon = checkAuth(ctx);
    let pans = [];
    let pics = [];

    pictures.map(async (el) => {
        pics.push(
            new Promise(async (resolve, reject) => {
                const {createReadStream, filename} = await el;

                await new Promise(res =>
                    createReadStream()
                        .pipe(createWriteStream(path.join("static/images", filename)))
                        .on("close", res)
                );
                resolve(`static/images/, ${filename}`);
            })
        )
    });

    await Promise.all(pics);

    panoramas.map(async (el) => {
        pans.push(
            new Promise(async (resolve, reject) => {
                const {createReadStream, filename} = await el;

                await new Promise(res =>
                    createReadStream()
                        .pipe(createWriteStream(path.join("static/images", filename)))
                        .on("close", res)
                );
                resolve(path.join("static/images", filename));
            }));
    });

    await Promise.all(pans);

    const newPost = new Post({
        title,
        description,
        price,
        pictures: pics,
        panoramas: pans,
        createdAt: new Date().toISOString(),
        userId: anon.id,
        location,
    });

    const res = await newPost.save();
    console.log(res)
    return true;
}

Это быстрый пример, я рекомендую немного его исправить и добавить обработку ошибок для что-то вроде этого.

...