Hapi.js报错UnhandledPromiseRejectionWarning：reply被调用两次求助

你碰到的这个reply interface called twice错误，其实是Hapi的核心机制导致的——同一个请求生命周期里，Hapi只允许调用一次reply()来返回响应，多次调用就会触发这个断言错误，不是Hapi的bug，是你的代码逻辑没控制好调用时机。

先看你原来的代码问题：嵌套了多层.then()回调，而且每个分支调用reply后没有终止后续代码执行，再加上混用了async/await和Promise回调，很容易出现“某个条件触发了reply，但后续代码还在继续跑，又不小心触发了另一个reply”的情况，同时还存在未处理的Promise拒绝（就是那个UnhandledPromiseRejectionWarning）。

给你调整后的代码，完全用async/await扁平化逻辑，同时确保每个分支只调用一次reply：

export default async function (request, reply) {
  // 先判断最外层的条件：不能加自己为好友
  if (request.auth.credentials.email === request.payload.email) {
    return reply(Boom.conflict('Cannot add yourself as a friend'));
  }

  try {
    // 用await替代嵌套的.then()，代码结构更清晰
    const user = await User.findOne({ email: request.auth.credentials.email });
    if (!user) {
      return reply(Boom.notFound('Cannot find user'));
    }

    const friend = await User.findOne({ email: request.payload.email });
    if (!friend) {
      return reply(Boom.notFound(`Friend ${request.payload.email} doesn't exist`));
    }

    // 用some替代filter，性能更好，找到匹配项就停止遍历
    const friendExists = user.friends.some(friendId => `${friendId}` === `${friend._id}`);
    if (friendExists) {
      return reply(Boom.conflict('You have already added this friend'));
    }

    // 保存前要await，确保数据库操作完成再返回响应
    user.friends.push(friend);
    await user.save();
    
    return reply({
      friend: {
        fullName: friend.fullName,
        _id: friend._id
      }
    });
  } catch (error) {
    // 捕获所有异步错误，避免未处理的Promise拒绝
    return reply(Boom.internal('Server error', error));
  }
}

关键修改点说明： #

• 用async/await替代嵌套回调：彻底摆脱回调地狱，每个异步操作按顺序执行，逻辑一目了然。
• 每个reply前加return：调用reply后立即终止函数执行，绝对不会进入后续的代码分支，从根源避免多次调用reply。
• 添加try/catch块：捕获所有数据库操作可能出现的错误，同时用Boom返回标准的服务器错误响应，解决了UnhandledPromiseRejectionWarning的问题。
• 优化好友存在判断：用Array.some()替代filter().length > 0，前者找到匹配项就停止遍历，性能更优。
• await user.save()：确保好友添加操作完全写入数据库后再返回响应，避免出现“返回成功但数据库没更新”的情况。

这样调整后，你的代码逻辑会更健壮，也不会再触发reply多次调用的错误了。

内容的提问来源于stack exchange，提问作者labike