猫鼬异步/等待

Question

我正在使用 mongodb 和 apollo 服务器学习 node js 和 graphql，下面的代码按预期工作，但是我感觉代码可以改进。这是我的 graphql 解析器上的 sn-p：

Mutation: {
...,
createJob: async (parent, args, { Customer, Employee, Job }) => {
  const newJob = await new Job(args).save();
  newJob.assigned.map(async(employeeId) => {
    const assignedEmployee = await Employee.findById(employeeId);
    assignedEmployee.jobsHistory.push(newJob._id);
    await assignedEmployee.save()
  });
  const customer = await Customer.findById(newJob.customer);
  customer.jobs.push(newJob._id);
  await customer.save();
  return newJob;
}

正如我所说，代码按预期工作，但看着许多等待，我不能停下来想知道是否可以进行改进。任何帮助将不胜感激

Answer 1

多个awaits 只是async/await 的本质。你必须标记每一个你等待异步操作发生的地方。

该代码的主要问题是您忽略了map 的返回值，因此忽略了您传递map 的async 函数创建的promise 的结果。 任何当您调用map 并且不对它的返回值做任何事情时，您就知道您使用了错误的工具（当您不需要数组@987654329 时使用forEach @returns) 或做其他错误。

假设您希望员工更新并行运行，并且您希望在更新客户之前等待所有更新完成，您希望 await Promise.all(...) 数组 map 返回：

createJob: async (parent, args, { Customer, Employee, Job }) => {
  const newJob = await new Job(args).save();
  await Promise.all(newJob.assigned.map(async(employeeId) => {    // ***
    const assignedEmployee = await Employee.findById(employeeId);
    assignedEmployee.jobsHistory.push(newJob._id);
    await assignedEmployee.save();
  }));
  const customer = await Customer.findById(newJob.customer);
  customer.jobs.push(newJob._id);
  await customer.save();
  return newJob;
}

但大概不需要在找到客户之前等待员工更新，因此我们可以通过在员工更新的同时搜索客户来稍微改进：

createJob: async (parent, args, { Customer, Employee, Job }) => {
  const newJob = await new Job(args).save();
  const customerPromise = Customer.findById(newJob.customer);     // ***
  await Promise.all(newJob.assigned.map(async(employeeId) => {
    const assignedEmployee = await Employee.findById(employeeId);
    assignedEmployee.jobsHistory.push(newJob._id);
    await assignedEmployee.save();
  }));
  const customer = await customerPromise;                         // ***
  customer.jobs.push(newJob._id);
  await customer.save();
  return newJob;
}