如何使passport.authenticate本地策略与异步/等待模式一起工作

// 导入所需模块
const passport = require('passport');
const LocalStrategy = require('passport-local').Strategy;

// 定义本地策略
passport.use(new LocalStrategy(async (username, password, done) => {
  try {
    // 异步查询数据库验证用户凭据
    const user = await User.findOne({ username: username });
    
    if (!user) {
      return done(null, false, { message: '用户名不存在' });
    }
    
    if (!user.validPassword(password)) {
      return done(null, false, { message: '密码不正确' });
    }
    
    return done(null, user);
  } catch (error) {
    return done(error);
  }
}));

// 配置passport序列化和反序列化用户
passport.serializeUser((user, done) => {
  done(null, user.id);
});

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

// 创建登录路由处理程序
app.post('/login', (req, res, next) => {
  passport.authenticate('local', async (err, user, info) => {
    try {
      if (err) {
        return next(err);
      }
      
      if (!user) {
        return res.redirect('/login');
      }
      
      req.logIn(user, (err) => {
        if (err) {
          return next(err);
        }
        
        return res.redirect('/dashboard');
      });
    } catch (error) {
      next(error);
    }
  })(req, res, next);
});