Promise链式调用退出策略问题：返回语句未终止链的原因分析

问题现象 #

当优惠券代码无效时，接口返回了状态码400、标识为invalidInput的「无效代码」响应，但同时日志中抛出错误：

crash Cannot set headers after they are sent to the client

调试发现，执行return res.fail(...)后，Promise链并未终止，后续的then块仍然会执行。

核心原因 #

你当前的Promise链式调用退出策略不正确，具体原因：

• res.fail()的作用是直接向客户端发送HTTP响应（设置响应头、返回响应体），但它的返回值并不是一个被rejected的Promise。
• 在Promise链的then回调中，只要返回的不是被拒绝的Promise，Promise就会判定该回调执行成功，进而继续调用下一个then回调。
• 后续then回调执行时，又会尝试调用res.xxx方法发送响应，此时响应已经被之前的res.fail()发送完毕，就会触发"Cannot set headers after they are sent to the client"错误。

正确实现方式 #

要终止Promise链，需在错误分支中抛出错误（或返回被拒绝的Promise），让流程直接跳转到catch块，而非直接发送响应。

修改后的代码示例：

MasterOrder.findOne({
    where: {
        fk_user_id: uid,
        id: orderId,
        status: 0,
    }
}).then(function(orderObj) {  
    if (!orderObj) {
        // 抛出包含错误信息的对象，交由catch统一处理
        throw { message: "Invalid Order ID", status: 400, code: "invalidInput" };
    }

    return HUSListing.findByPk(orderObj.fk_listing_id);
}).then(function(listingDetails) {  
    if (!listingDetails) {
        throw { message: "Invalid Order ID With Listing", status: 400, code: "invalidInput" };
    }
    
    return isValidBooking({at: req.body.time, listingId: req.body.listing_id});

}).then(function(isValidBookingResult) {
    if (!isValidBookingResult) {
        throw { message: "The requested not available", status: 400, code: "invalidInput" };
    }

   return db.sequelize.query(
        `SELECT user.firstName, user.lastName FROM HUSListing`); // 修正原SQL多余逗号的语法错误

}).then(function(HUSResultData) {
    if (HUSResultData.length == 0) {
        throw { message: "Listing not found", status: 400, code: "invalidInput" };
    }

    let couponCodeObj = {
        couponCode: couponCode,
        uid: uid
    }

    return validateCoupon(couponCodeObj);
}).then(function(couponData) {

    if (!couponData.isApplicable) {
        throw { message: couponData.message, status: 400, code: "invalidInput" };
    }
    console.log("COMMING HERE");
    couponID = couponData.data.id;
    
    return upsertUserCoupon({
        fk_user_id: uid,
        fk_coupon_id: couponData.id,
        isUsed: 1,
        fk_masterOrder_id: orderId
    }, {
        fk_masterOrder_id: orderId,
    });
}).then(function(r) {

    if (!r || !r.id) { 
        console.log("COMMING HERE 1");
        throw { message: "FAILED TO upsertUserCoupon", status: 500, code: "internalServerError" };
    }

    return upsertMasterOrder({
        taxAmount: taxAmount,
        payableAmount: payableAmount,
        payableAmountInCent: payableAmount * 100,
        fk_coupon_id: couponID,
        discountedPrice: discountedPrice,
    }, {
        id: orderId
    });
}).then(function(upsertMasterOrderResult) {

    if (upsertMasterOrderResult && upsertMasterOrderResult.id > 0) {
        console.log("COMMING HERE 2");
        return res.respondCreated(upsertMasterOrderResult);
    } else {
        console.log("COMMING HERE 3");
        throw { message: "FAILED TO APPLY COUPON CODE", status: 500, code: "internalServerError" };
    }
}).catch(err => {
    console.log("crash", err.message);
    // 统一处理所有错误响应
    if (err.status && err.code) {
        res.fail(err.message, err.status, err.code);
    } else {
        res.fail(err.message, 500, "internalServerError");
    }
});

关键修改点 #

• 将所有错误分支的return res.fail(...)替换为throw包含错误信息、状态码、错误标识的对象。
• 在catch块中统一处理所有错误，确保整个流程仅发送一次响应。
• 修正了原SQL语句中的语法错误（多余逗号）。

内容的提问来源于stack exchange，提问作者匿名用户