Bluebird 承诺 express/mongoose 回来得太早
Bluebird promises returning too early in express/mongoose
我是 promises 的新手,想知道为什么以下内容不起作用。我假设是因为我需要将我的自定义方法设置为使用 Promises 的特定方式。
我正在使用 bluebird 作为我的 Promise 库。我正在尝试通过在这些各自的模型(即讨论和用户模型)上使用猫鼬静态和方法来获得给定 "user's" 用户名的 "discussions" 对象的列表。
下面是我在 Express 中的请求处理程序。现在只是尝试获取 JSON 并将其作为响应发送:
/* /routes/users.js */
var Promise = require('bluebird');
var User = require('../models/').User
/* ... express inclusions, other routes ... */
/* Get list of discussions for user */
router.get('/:username/discussions', function(req, res) {
User.findOne({username: req.params.username}).then(function(user) {
if (user) {
return user.getDiscussions();
} else {
res.send('no user found');
}
}).then(function(discussions) {
res.send(discussions);
}).catch(function(error) {
console.log('ERROR: ' + error);
res.send('ERROR: ' + error);
});
});
下面是user.getDiscussions():
/* /models/user.js */
var Promise = require('bluebird');
var mongoose = Promise.promisifyAll(require('mongoose'));
var Discussion = require('./discussion').Discussion;
var Schema = mongoose.Schema;
/* ... UserSchema defined here ... */
UserSchema.methods.getDiscussions = Promise.method(function() {
var self = this;
self.model('User').findById(self.id).then(function(user) {
if (!user) {
Promise.reject('User \'' + self.id + '\' does not exist.');
} else {
return Discussion.getDiscussionsForUser(self.username);
}
});
});
最后,Discussion.getDiscussionsForUser:
/* /models/discussion.js */
var Promise = require('bluebird');
var mongoose = Promise.promisifyAll(require('mongoose'));
var Schema = mongoose.Schema;
/* ... DiscussionSchema defined here ... */
DiscussionSchema.statics.getDiscussionsForUser = Promise.method(function(username) {
var self = this;
self.model('User').findOne({username: username}, 'discussions').then(function(user) {
if (!user) {
return Promise.reject('User with username \'' + username + '\' does not exist.');
} else {
var discussions = [];
return self.model('Discussion').find({
'_id': { $in : user.discussions }
});
}
});
});
路由中的请求似乎提前完成并在响应中发送未定义。知道为什么在讨论模型中从 Mongoose 获得的讨论没有冒泡到路由吗?
getDiscussions()
和 getDiscussionsForUser()
不是正确的 return 承诺。按如下方式更改它们:
UserSchema.methods.getDiscussions = Promise.method(function() {
var self = this;
// *** added a return to this next line
return self.model('User').findById(self.id).then(function(user) {
if (!user) {
// *** added a return to this next line
return Promise.reject('User \'' + self.id + '\' does not exist.');
} else {
return Discussion.getDiscussionsForUser(self.username);
}
});
});
与 getDiscussionsForUser()
相同,应该是这样的:
DiscussionSchema.statics.getDiscussionsForUser = Promise.method(function(username) {
var self = this;
// *** added a return to the next line
return self.model('User').findOne({username: username}, 'discussions').then(function(user) {
if (!user) {
return Promise.reject('User with username \'' + username + '\' does not exist.');
} else {
var discussions = [];
return self.model('Discussion').find({
'_id': { $in : user.discussions }
});
}
});
});
为了使调用者能够使用 promises 协调函数内异步操作的完成,通过该函数的所有代码路径必须始终 return 来自该函数的 promise。一旦进入 .then()
处理程序,如果还有进一步的嵌套异步操作,则必须 return 一个 promise,或者如果您希望该值成为你在里面的承诺。
我是 promises 的新手,想知道为什么以下内容不起作用。我假设是因为我需要将我的自定义方法设置为使用 Promises 的特定方式。
我正在使用 bluebird 作为我的 Promise 库。我正在尝试通过在这些各自的模型(即讨论和用户模型)上使用猫鼬静态和方法来获得给定 "user's" 用户名的 "discussions" 对象的列表。
下面是我在 Express 中的请求处理程序。现在只是尝试获取 JSON 并将其作为响应发送:
/* /routes/users.js */
var Promise = require('bluebird');
var User = require('../models/').User
/* ... express inclusions, other routes ... */
/* Get list of discussions for user */
router.get('/:username/discussions', function(req, res) {
User.findOne({username: req.params.username}).then(function(user) {
if (user) {
return user.getDiscussions();
} else {
res.send('no user found');
}
}).then(function(discussions) {
res.send(discussions);
}).catch(function(error) {
console.log('ERROR: ' + error);
res.send('ERROR: ' + error);
});
});
下面是user.getDiscussions():
/* /models/user.js */
var Promise = require('bluebird');
var mongoose = Promise.promisifyAll(require('mongoose'));
var Discussion = require('./discussion').Discussion;
var Schema = mongoose.Schema;
/* ... UserSchema defined here ... */
UserSchema.methods.getDiscussions = Promise.method(function() {
var self = this;
self.model('User').findById(self.id).then(function(user) {
if (!user) {
Promise.reject('User \'' + self.id + '\' does not exist.');
} else {
return Discussion.getDiscussionsForUser(self.username);
}
});
});
最后,Discussion.getDiscussionsForUser:
/* /models/discussion.js */
var Promise = require('bluebird');
var mongoose = Promise.promisifyAll(require('mongoose'));
var Schema = mongoose.Schema;
/* ... DiscussionSchema defined here ... */
DiscussionSchema.statics.getDiscussionsForUser = Promise.method(function(username) {
var self = this;
self.model('User').findOne({username: username}, 'discussions').then(function(user) {
if (!user) {
return Promise.reject('User with username \'' + username + '\' does not exist.');
} else {
var discussions = [];
return self.model('Discussion').find({
'_id': { $in : user.discussions }
});
}
});
});
路由中的请求似乎提前完成并在响应中发送未定义。知道为什么在讨论模型中从 Mongoose 获得的讨论没有冒泡到路由吗?
getDiscussions()
和 getDiscussionsForUser()
不是正确的 return 承诺。按如下方式更改它们:
UserSchema.methods.getDiscussions = Promise.method(function() {
var self = this;
// *** added a return to this next line
return self.model('User').findById(self.id).then(function(user) {
if (!user) {
// *** added a return to this next line
return Promise.reject('User \'' + self.id + '\' does not exist.');
} else {
return Discussion.getDiscussionsForUser(self.username);
}
});
});
与 getDiscussionsForUser()
相同,应该是这样的:
DiscussionSchema.statics.getDiscussionsForUser = Promise.method(function(username) {
var self = this;
// *** added a return to the next line
return self.model('User').findOne({username: username}, 'discussions').then(function(user) {
if (!user) {
return Promise.reject('User with username \'' + username + '\' does not exist.');
} else {
var discussions = [];
return self.model('Discussion').find({
'_id': { $in : user.discussions }
});
}
});
});
为了使调用者能够使用 promises 协调函数内异步操作的完成,通过该函数的所有代码路径必须始终 return 来自该函数的 promise。一旦进入 .then()
处理程序,如果还有进一步的嵌套异步操作,则必须 return 一个 promise,或者如果您希望该值成为你在里面的承诺。