我有一些代码可以很好地处理REST端点,其中的消息是:
- 在数据库中创建
- 已处理stepA
- 当步骤A正常时,返回响应消息
- 步骤B被处理
这是代码:
// POST single message
app.post('/message', (req, res) => {
const url = req.body.properties.url
const image = req.body.properties.image
const extraField = req.body.properties.extraField
db.message.create({
url: url,
image: image,
})
.then(() => myProcess(extraField, 'stepA'))
.then(newMessage => res.json(newMessage))
.then(() => myProcess(extraField, 'stepB'))
})
现在我正在尝试使用feathersjs进行同样的操作,但我不知道如何准确地执行2、3、4。
我现在有一个用于消息服务的创建方法的AFTER钩子:
module.exports = function (options = {}) { // eslint-disable-line no-unused-vars
return function processNewMessage (hook) {
const { extraField } = hook.data.properties
Promise.resolve(myProcess(extraField, 'stepA'))
.then( <<NO-IDEA>> ) // Send RESPONSE!!
.then(() => myProcess(extraField, 'stepB'))
return Promise.resolve(hook);
};
};
因此,我的问题归结为:如何发送响应并随后使用feathersjs触发"myProcess stepB"?
尽管这是"遗产",但我认为它可能仍然相关。
在feathersjs的常见问题解答中有答案!如何在向用户发送响应后进行处理:
这取决于你兑现的承诺。下面是一个钩子的例子,它发送电子邮件,但不等待成功消息。
function (hook) {
// Send an email by calling to the email service.
hook.app.service('emails').create({
to: 'user@email.com',
body: 'You are so great!'
});
// Send a message to some logging service.
hook.app.service('logging').create(hook.data);
// Return a resolved promise to immediately move to the next hook
// and not wait for the two previous promises to resolve.
return Promise.resolve(hook);
}