在模块之间共享 Promise 与拥有多个 Promise

Question

我正在使用 Kris Kowal 的 Q 库通过控制器和存储库实现 Node.js 逻辑。我有一种感觉，我在下面的例子中使用 Promise 的方式是不正确的。但是我找不到任何关于如何通过多层或功能使用承诺的正确模式的指导。

我做得对吗？实现这个逻辑的正确方法是什么？

// 模块：存储库

exports.findOne = function (query) {
    var deferred = Q.defer();

    db.query(query, function (err, data) {
        if (err) {
            deferred.reject(err);
        } else {
            deferred.resolve(data);
        }
    });

    return deferred.promise;
};

// 模块：用户

var isEmailAvailable = function (value) {
    var deferred = Q.defer();

    Repository.findOne({email: value})
        .then(function (user) {
            if (user) {
                if (self.id === user.id) {
                    deferred.resolve(true);
                }
                else {
                    deferred.resolve(false);
                }
            } else {
                deferred.resolve(true);
            }
        })
        .fail(function (err) {
            deferred.reject(err);
        });

    return deferred.promise;
};

this.save = function () {
    var deferred = Q.defer();

    isEmailAvailable(this.email)
        .then(function (result) {
            if (result) {
                Repository.upsert(self)
                    .then(function (user) {
                        deferred.resolve(user); //--- Yey!!!
                    }).fail(function () {
                        deferred.reject('Account save error')
                    });
            } else {
                deferred.reject('The email is already in use');
            }
        }).fail(function () {
            deferred.reject('Account validation error')
        });

    return deferred.promise;
};

Answer 1

感觉我使用promise的方式不正确

是的，您经常使用deferred antipattern。 Promises do chain，这意味着您可以简单地从您的then 回调中获得return 值甚至承诺，并且.then() 调用将为这些返回值产生承诺。而当你throw时，结果promise会被拒绝。

您在存储库模块中对延迟的使用是正确的，因为db.query api 需要是promisified。但是用户模块可以大幅收缩，当你已经有承诺时，你不需要使用任何延迟。

function isEmailAvailable(value) {
    return Repository.findOne({email: value})
    .then(function (user) {
        return !user || self.id === user.id;
    });
}

this.save = function() {
    return isEmailAvailable(this.email)
    .then(function (result) {
        if (result) {
            return Repository.upsert(self)
            .then(null, function(err) {
                throw new Error('Account save error');
            });
        } else {
            throw new Error('The email is already in use');
        }
    }, function(err) {
        throw new Error('Account validation error');
    });
};

或者，按照@Roamer-1888 的建议，使用exceptions for control flow：

function isEmailAvailable(value) {
    return Repository.findOne({email: value})
    .then(function (user) {
        if (user && self.id !== user.id)
            throw new Error('The email is already in use');
    }, function(err) {
        throw new Error('Account validation error');
    });
}

this.save = function() {
    return isEmailAvailable(this.email)
    .then(function () {
        return Repository.upsert(self)
        .then(null, function(err) {
            throw new Error('Account save error');
        });
    });
};