如何获取MongoDB查询返回值并用于Passport登录验证

核心问题在于MongoDB的findOne()和findById()是异步操作，而你之前用数组存储时是同步返回逻辑，直接return无法传递异步查询的结果。以下是具体修复步骤：

1. 重构用户查询函数为异步模式 #

将getUserByEmail和getUserById改为返回Promise或使用async/await，确保能正确传递查询到的用户对象：

方式一：用Promise包装回调 #

// passport-config.js
function getUserByEmail(email) {
  return new Promise((resolve, reject) => {
    db.collection('users').findOne({ email: email }, (err, user) => {
      if (err) return reject(err);
      resolve(user);
    });
  });
}

function getUserById(id) {
  return new Promise((resolve, reject) => {
    db.collection('users').findById(id, (err, user) => {
      if (err) return reject(err);
      resolve(user);
    });
  });
}

方式二：直接使用async/await（推荐，需MongoDB驱动支持Promise） #

// passport-config.js
async function getUserByEmail(email) {
  return await db.collection('users').findOne({ email: email });
}

async function getUserById(id) {
  return await db.collection('users').findById(id);
}

2. 修改认证函数为异步处理 #

在authenticateUser中使用await调用上述异步函数，确保拿到实际的用户对象：

async function authenticateUser(email, password, done) {
  try {
    // 等待异步查询返回用户
    const user = await getUserByEmail(email);
    
    if (!user) {
      return done(null, false, { message: '该邮箱未注册' });
    }

    // 示例：用bcrypt验证密码（根据你的实际加密方式调整）
    const isPasswordValid = await bcrypt.compare(password, user.password);
    if (!isPasswordValid) {
      return done(null, false, { message: '密码错误' });
    }

    // 验证通过，返回用户对象
    return done(null, user);
  } catch (err) {
    // 捕获数据库查询或密码验证的错误
    return done(err);
  }
}

3. 调整Passport序列化/反序列化逻辑 #

确保deserializeUser也使用异步方式获取用户：

passport.serializeUser((user, done) => {
  done(null, user._id);
});

passport.deserializeUser(async (id, done) => {
  try {
    const user = await getUserById(id);
    done(null, user);
  } catch (err) {
    done(err);
  }
});

关键说明 #

• 异步操作不能用同步return传递结果，必须通过Promise或async/await处理异步流
• Passport的LocalStrategy支持异步的verify函数（即上述的authenticateUser），只需标记为async即可
• 确保MongoDB驱动版本支持Promise（新版驱动默认支持，若使用旧版需手动包装）

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