蓝鸟许诺猫鼬

Question

我只使用了几天的 Bluebird，仍然感到困惑。这是我正在处理的代码：

router.route('/:name')
        .get(function (req, res) {
                var values = [];
                 Tag.findOneAsync({'name': req.params.name}, {urlId: 1, _id: 0}).then(function (data) {
                    data['urlId'].forEach(function (urlId) {
                        Urls.findByIdAsync(urlId).then(function (result) {
                            values.push(result);
                        }).catch(function (err) {
                            res.status(500).send(err);
                        });
                    });
                }).catch(function (err) {
                    res.status(500).send(err);
                });

                res.send(values);
     });

在此代码中，响应为空 values 。所以我尝试以这种方式组织代码：

router.route('/:name')
        .get(function (req, res) {
            var  prom = new Promise(function(resolve, reject) {
                var values = [];
                Tag.findOneAsync({'name': req.params.name}, {urlId: 1, _id: 0}).then(function (data) {
                    data['urlId'].forEach(function (urlId) {
                        Urls.findByIdAsync(urlId).then(function (result) {
                            values.push(result);

                        }).catch(function (err) {
                            reject(err);
                        });
                    });
                }).catch(function (err) {
                    reject(err);
                });
                resolve(values);
            });
            prom.then(function (values) {
                res.send(values);
            });

结果还是一样。那么我如何组织代码，以便在完成data['urlId'].forEach 操作后得到响应。

Answer 1

见我的 cmets。您应该执行以下操作。因为你已经承诺了 mongoose，所以异步方法已经返回了 Promise，所以你不需要创建一个新的 Promise 来解决或拒绝它们。您还需要在 then 语句中返回任何返回承诺的代码。

router.route('/:name')
.get(function (req, res, next) {
    var values = [];
    Tag.findOneAsync({'name': req.params.name}, {urlId: 1, _id: 0}).then(function (data) {
        return promise.each(data['urlId'], function (urlId) {
            return Urls.findByIdAsync(urlId).then(function (result) {
                values.push(result);
            });
        });
    })
    .then(function () {
        res.send(values);
        //return next();    
    })
    .caught(function (err) {
        res.status(500).send(err);
        //return next();
    });
});

或者更干净地使用promise.map

var mongoose = require( 'mongoose' );
var Promise = require('bluebird');
Promise.promisifyAll( mongoose );

router.route('/:name')
.get(function (req, res, next) {
    Tag.findOneAsync({'name': req.params.name}, {urlId: 1, _id: 0}).then(function (data) {
        return Promise.map(data['urlId'], function (urlId) {
            return Urls.findByIdAsync(urlId).then(function (result) {
                return result;
            });
        });
    })
    .then(function (values) {
        res.send(values);
        //return next();    
    })
    .caught(function (err) {
        res.status(500).send(err);
        //return next();
    });
});