在我的 db.collection forEach 上使用 Promise.all

Question

如何使用 promise.all 和这个函数：

function getUsersGroups(users, req) {
  users.forEach(function(user) {
    user.groups = [];

    db.collection("groups")
      .find({ "users._id": String(user._id) })
      .toArray(function(err, docs) {
          user.groups = docs;
      });
  });

  return users;
}

我不知道该怎么做，谢谢。

PS：用户数组没有通过文档实现（他们控制台日志正常）。

这是我的第二次尝试：

function getUsersGroups(users, req) {
  users.forEach(
    (user, index, array) => (
      array[index].user =[]
      array[index].user.groups = myApiCall(user))
  );

  function myApiCall(user) {
    db.collection("groups")
      .find({ "users._id": String(user._id) })
      .toArray(function(err, docs) {
        console.log(docs);
        return docs;
      });
  }

  return users;
}



  array[index].user.groups = myApiCall(user))
      ^^^^^

SyntaxError: Unexpected identifier

编辑：

所以最后，我正在使用这个功能，就像 Ashish 所说的（它获取用户所在的所有组，并更新用户模型）：

async function getUsersGroups(users, req) {
  await Promise.all(users.map(user => {
    return db.collection("groups")
      .find({ "users._id": String(user._id) })
      .toArray()
      .then(group => {
        user.groups = group;
      })
  }));

  return users;
}

我在另一个 node.js 函数中这样调用：

 getUsersGroups(docs, req)
          .then(users => {
            res.send(users);
          })
          .catch(error => {
            // if you have an error
          });

非常感谢！

Answer 1

async function getUsersGroups(users, req) {
  await Promise.all(users.map(user => {
    return db.collection("groups")
      .find({ "users._id": String(user._id) })
      .toArray()
      .then(group => {
        user.groups = group;
      })
  }));

  return users;
}

希望对你有帮助

Answer 2

查看toArray 的文档，如果未指定回调，它将返回Promise。然后我们可以使用.map 而不是.forEach 来生成一组promise，然后我们可以将其传递给Promise.all：

function getUsersGroups(users, req) {
  const promises = users.map(function(user) {
    user.groups = []
    return db
      .collection("groups")
      .find({ "users._id": String(user._id) })
      .toArray()
      .then(groups => {
        user.groups = groups
      })
  });

  return Promise.all(promises);
}

请注意，这会改变用户对象。也就是说，无论您传递给函数的users 都将被设置为groups 字段。