用于自定义 api 的 Nodejs Promise

Question

我是nodejs 的新手并使用promise，实际上这是我第一个使用nodejs 的真正应用程序。

所以我看了一整天，有点迷茫。

这是我的模块：

function User() {
    var self   = this;
    self.users = {};

    self.start = function (user, botId) {
        return new Promise(function () {
           return get(user).then(function (data) {
                debug(data);
                if (data.botId.indexOf(botId) === false) {
                    return Repo.UserBotModel.addUser(user.id, botId).then(function () {
                        data.botId.push(botId);
                        return data;
                    });
                } else
                    return data;
            });
        });
    };

    self.getDisplayName = function (user) {
        if (user.real_name)
            return user.real_name;
        if (user.last_name)
            return user.firstname + ' ' + user.last_name;
        return user.first_name;
    };
    /**
     * check if user exist in our database/memory cache and return it,
     * otherwise insert in the database and cache it in memory and the return it
     * @param user
     */
    function get(user) {

        return new Promise(function () {

            //check if user is loaded in our memory cache
            if (self.users.hasOwnProperty(user.id))
                return self.users[user.id];
            else {
                //get from database if exist
                return Repo.UserModel.get(user.id).then(function (rows) {
                    if (rows && rows.length) {
                        //user exist cache it and resolve
                        var data = rows[0];
                        if (data.botId && data.botId.length)
                            data.botId = data.botId.split(',');
                        else
                            data.botId = [];

                        self.users[user.id] = data;
                        //------------------------------ code execution reaches here
                        return data;
                    }
                    else {
                        //user dose not exist lets insert it
                        return Repo.UserModel.insert(user).then(function (result) {
                            return get(user);
                        });
                    }
                });
            }
        });
    }
}

我调用start 方法，女巫调用私有get 方法，调用到达return data;（标有注释）但then 函数不会在start 方法中执行???

那我做错了什么？

更新：对不起，我忘了提到我使用的是bluebird，而不是native promise，如果这有什么不同？

Answer 1

你cannot return from the Promise constructor - 你必须打电话给resolve（预计会异步发生）。你根本不应该在这里use the Promise constructor。你可以省略它，它应该可以工作。

Answer 2

• Repo.UserModel 中的方法已经返回 Promise，因此您不必使用 new Promise 创建新的 Promise。
• 您可以使用then 读取这些承诺中的值。
• then 还提供了一种转换承诺的方法。如果您在传递给then 的函数中返回一个值，then 将返回一个包装您返回的值的 new 承诺。如果这个值是一个承诺，它将被等待。
• 要将值转换为承诺，您可以使用Promise.resolve。

知道了这一点，您可以像这样简化get：

function get(user) {
    if (...) {
        return Promise.resolve(...)
    } else {
        return Repo.UserModel.get(...).then(function(rows) {
            ...
            return ...
        })
    }
}

这个版本的get总是会返回一个你可以像这样使用的promise：

get(...).then(function(resultOfGet) {
    // process resultOfGet
})