javascript - 无法通过自定义快速验证器检查

Question

以下代码的目的是使用 express-validator 检查 MongoDB 中是否已存在电子邮件：

    app.post('/registerPage',[check('email').custom((email) => {
    // connect to database
    let MongoClient = require('mongodb').MongoClient;
    let url = 'mongodb://localhost';
    MongoClient.connect(url, function(err, client) {
        if (err) throw err;
        let db = client.db('Mydatabase');
        // search database
        return db.collection('users').findOne({
            email: email
        }).then(user => {
                if (user) {
                   console.log(user); // here console shows correct record in database
                   return Promise.reject('E-mail already in use');
                }
                // otherwise, it returns null
        });
    })
}).withMessage('Error Message Example')], (req, res) => {
    // Handle the request
    const errors = validationResult(req);
    if (!errors.isEmpty()) {
       return res.status(422).json({ errors: errors.array() })
    }
  });

当电子邮件已经存在时，控制台会显示Promise.reject('E-mail already in use');。

问题是当email不存在时，虽然没有显示Promise.reject，但代码不能进一步处理，validationResult(req)不是空的，所以它仍然打印出错误消息'错误消息示例'。但是可以成功通过检查的非自定义验证器没有任何问题。

我试图添加一个else语句 where !user，它不起作用。

问题是如何通过自定义验证检查，或者为什么数组validationResult(req)不是空的，即使它应该是空的？validationResult通过所有检查后，如何确保为空。

标签： javascriptnode.jsexpress-validator

Answer 1

问题是您在回调MongoClient.connect而不是验证器函数中返回承诺。尝试使用 Promise 包装器，例如：

app.post('/registerPage',[check('email').custom((email) => {
    return new Promise((resolve, reject) => {
        // connect to database
        let MongoClient = require('mongodb').MongoClient;
        let url = 'mongodb://localhost';
        MongoClient.connect(url, function(err, client) {
            if (err) throw err;
            let db = client.db('Mydatabase');
            // search database
            return db.collection('users').findOne({
                email: email
            }).then(user => {
                if (user) {
                console.log(user); // here console shows correct record in database
                return reject('E-mail already in use');
                }
                return resolve();
            });
        })

    });
}).withMessage('Error Message Example')], (req, res) => {
    // Handle the request
    const errors = validationResult(req);
    if (!errors.isEmpty()) {
    return res.status(422).json({ errors: errors.array() })
    }
});

希望这可以帮助！