node.js 使用 express 忽略 awaitZip 构建

Question

我想用 mongoose 从我们的 mongodb 数据库中的 gridfs 获取图标 PNGS。然后应该压缩这些图标并在特定路线上提供服务。

我目前的代码如下：

var zip = require("node-native-zip");
async function getZipFile() {
    //get the events out of the DB
    db.Category.find({}).populate('icons.file').exec(async function (err, cats) {
        if (err) {
            //oh oh something went wrong, better pass the error along
            return ({
                    "success": "false",
                    message: err
                });
        }
        else {
            //all good, build the message and return
            try {
                const result = await buildZip(cats);
                return ({
                    "success": "true",
                    message: result
                });
            }
            catch (err) {
                console.log("ZIP Build Failed")
            }
        }
    });
}
async function buildZip(cats) {
    let archive = new zip();
    for (let i = 0; i < cats.length; i++) {
        cats[i].icons.forEach(function (icon) {
            if (icon.size === "3x") {
                db.Attachment.readById(icon.file._id, function (err, buffer) {
                    if (err)
                        return;
                    archive.add(cats[i]._id + ".png", buffer);
                });
            }
        });
        //return when everything is done
        if (i === cats.length - 1) {
            return archive.toBuffer();
        }
    }
}
module.exports =
    {
        run: getZipFile
    };

我不想在运行前构建 zip，因为我想根据类别 ID 重命名图标。我尝试使用 async/await 结构，但我的回调在 zip 文件的构建开始之前就被返回了。

我正在调用函数

    case 'categoryZip':
        categoryHelper.getZipFile.run().then((result) => {
            callback(result);
        });
        break;

这应该（据我理解）在压缩完成时触发回调，但我认为我在这里遗漏了一些重要的东西。

Answer 1

我将您的两个回调方法都包装到了 Promise 中，并且还使用 Promise.all() 并行等待了您的双 for 回调循环，因为它们不相互依赖，我认为它们不需要特别压缩文件中的顺序：

async function getZipFile() {
  //get the events out of the DB
  return new Promise((resolve, reject) => {
    db.Category.find({}).populate('icons.file').exec(async function(err, cats) {
      if (err) {
        //oh oh something went wrong, better pass the error along
        reject({
          success: false,
          message: err
        });
      } else {
        //all good, build the message and return
        try {
          const result = await buildZip(cats);

          resolve({
            success: true,
            message: result
          });
        } catch (err) {
          console.log("ZIP Build Failed")
          reject({
            success: false,
            message: err
          });
        }
      }
    });
  });
}

async function buildZip(cats) {
  let archive = new zip();

  await Promise.all(
    cats.map(cat => Promise.all(cat.icons
      .filter(icon => icon.size === '3x')
      .map(icon => new Promise((resolve, reject) => {
        db.Attachment.readById(icon.file._id, function(err, buffer) {
          if (err) return reject(err);
          archive.add(cat._id + ".png", buffer);
          resolve();
        });
      }))
    ))
  );

  return archive.toBuffer()
}