未处理的承诺拒绝：发送后无法设置标头

Question

我有一个这样的路由处理程序：

router.route('/callcenter/:callcenter_id/contactgroup/:contactgroup_id')
    .delete((req, res) => {
        if (typeof req.body.creator === 'undefined') {
            return res.status(400).json({
                success: false,
                error: { message: 'Invalid input' }
            });
        }
        const ContactGroup = new ContactGroupModel(db, req.params.callcenter_id, logger);
        ContactGroup.read(req.params.contactgroup_id)
            .then((result) => {
                if (!result) {
                    return res.status(404).json({
                        success: false,
                        error: { message: 'Contact group not found' }
                    });
                }
                if (req.body.creator !== result.creator) {
                    return res.status(400).json({
                        success: false,
                        error: { message: 'Invalid input' }
                    });
                }
                return ContactGroup.delete(req.params.contactgroup_id);
            })
            .then((result) => {
                if (!result) {
                    return res.status(404).json({
                        success: false,
                        error: { message: 'Contact group not found' }
                    });
                }
                return res.json({ success: true });
            })
            .catch((error) => res.status(400).json({
                success: false,
                error: { message: error }
            }));
    });

ContactGroup 的 read 和 delete 函数都是承诺。我写了几个测试：

describe('DELETE', () => {
            let id;
            beforeEach(() => ContactGroup.create(data).then((result) => id = result._id));
            it('Should return 200 if successful', (done) => {
                chai.request(app)
                    .delete('/callcenter/test/contactgroup/' + id)
                    .send({ creator: 'user__1' })
                    .end((err, res) => {
                        expect(res.status).to.equal(200);
                        expect(res.body.success).to.equal(true);
                        return done();
                    });
            });
            it('Should return 400 if input is invalid (without creator)', (done) => {
                chai.request(app)
                    .delete('/callcenter/test/contactgroup/' + id)
                    .end((err, res) => {
                        expect(res.status).to.equal(400);
                        expect(res.body.success).to.equal(false);
                        expect(res.body.error.message).to.equal('Invalid input');
                        return done();
                    });
            });
            it('Should return 400 if input is invalid (unmatched creator)', (done) => {
                chai.request(app)
                    .delete('/callcenter/test/contactgroup/' + id)
                    .send({ creator: 'user__2' })
                    .end((err, res) => {
                        expect(res.status).to.equal(400);
                        expect(res.body.success).to.equal(false);
                        expect(res.body.error.message).to.equal('Invalid input');
                        return done();
                    });
            });
            it('Should return 404 if not found', (done) => {
                ContactGroup.delete(id).then(
                    () => {
                        chai.request(app)
                            .delete('/callcenter/test/contactgroup/' + id)
                            .send({ creator: 'user__1' })
                            .end((err, res) => {
                                expect(res.status).to.equal(404);
                                expect(res.body.success).to.equal(false);
                                expect(res.body.error.message).to.equal('Contact group not found');
                                return done();
                            });
                    });
            });
            afterEach(() => ContactGroup.delete(id));
        });

它们都通过了，但是记录器在最后两个测试中记录了一些警告，包含UnhandledPromiseRejectionWarning: Unhandled promise rejection、Can't set headers after they are sent

我不明白为什么路由处理程序中的最终 catch 块被调用。我以为只有当 promise 函数被拒绝时，catch 才会发生

Answer 1

您的代码尝试为同一请求发送多个响应，这就是您收到“标头已发送”消息的原因。

你有这样的代码：

ContactGroup.read(req.params.contactgroup_id).then(...).then(...).catch(...)

而且，有一些代码路径，您最终可以在这两个 .then() 处理程序中发送响应，这会导致该错误。在您的第一个 .then() 处理程序中，您似乎认为这样做：

return res.status(404).json(...)

停止承诺链。它不是。承诺链继续并直接进入下一个 .then() 处理程序。由于res.status() 不返回任何内容，它将转到下一个.then() 处理程序，并将undefined 作为解析值。这将导致你这样做：

return res.status(404).json(...)

这会导致有关标头的消息已被发送。

---

我不确定您想要的确切流程，但也许您想要这样的东西，您可以在其中嵌套第二个 .then()，以便在您之前完成 return 时它不会执行：

router.route('/callcenter/:callcenter_id/contactgroup/:contactgroup_id').delete((req, res) => {
    if (typeof req.body.creator === 'undefined') {
        return res.status(400).json({
            success: false,
            error: {
                message: 'Invalid input'
            }
        });
    }
    const ContactGroup = new ContactGroupModel(db, req.params.callcenter_id, logger);
    ContactGroup.read(req.params.contactgroup_id).then((result) => {
        if (!result) {
            return res.status(404).json({
                success: false,
                error: {
                    message: 'Contact group not found'
                }
            });
        }
        if (req.body.creator !== result.creator) {
            return res.status(400).json({
                success: false,
                error: {
                    message: 'Invalid input'
                }
            });
        }
        return ContactGroup.delete(req.params.contactgroup_id).then((result) => {
            if (!result) {
                return res.status(404).json({
                    success: false,
                    error: {
                        message: 'Contact group not found'
                    }
                });
            }
            return res.json({
                success: true
            });
        });
    }).catch((error) => res.status(400).json({
        success: false,
        error: {
            message: error
        }
    }));
});