Node.js调用createLead异步函数返回undefined问题排查

返回值为undefined的核心原因是两个异步函数都没有返回内部创建的Promise实例：

• createLead和findLeadById内部都用new Promise()封装了异步逻辑，但没有加return关键字把Promise实例返回给调用方。async函数如果没有显式return值，默认返回Promise.resolve(undefined)，所以外部不管是用.then()还是await，拿到的都是undefined。
• 你在models.js内部能正常打印result，是因为Promise内部的逻辑确实执行了，只是结果没有顺着Promise链传递到外部。
• 额外还有逻辑隐患：index.js里的路由回调没有加async，也没有等待异步逻辑执行完就直接调用res.send()，哪怕返回值修复了，也可能出现请求提前响应的问题；原代码里的error.log写法本身也会报错，Error对象没有log方法。

首先修复models.js，给两个内部创建的Promise加上return，同时简化冗余的.then嵌套，统一用async/await写法减少出错概率：

const createLead = async function (payload) {
    // 显式return Promise实例，让调用方能拿到异步执行结果
    return new Promise(async (resolve, reject) => {
        try {
            const _lead = await findLeadById(payload.lead.rid)
            let result
            if (!_lead) {
                if(payload.companyRid != payload.lead.rid){
                    const addRes = await db.collection('leads').add(payload.lead)
                    result = payload.lead
                    result['id'] = addRes.id
                }
            } else {
                result = _lead
            }
            console.log(" result of create lead ",JSON.stringify(result))
            resolve(result)
        } catch (error) {
            console.log("reject", error)
            reject(error)
        }
    })
}

const findLeadById = async function (lead) {
    // 必须显式return创建的Promise，之前漏写这步是核心错误
    return new Promise(async (resolve, reject) => {
        try {
            const ref = db.collection('leads');
            console.log("finding lead", JSON.stringify(lead))
            const s = await ref.where("rid", "==", lead).get()
            let obj = null
            if(s){
                s.forEach(doc => {
                    console.log("found the lead in loop", JSON.stringify(doc.data()))
                    obj = doc.data()
                    obj['id'] = doc.id
                })
            }
            resolve(obj)
        } catch (error) {
            console.log("reject", error)
            reject(error)
        }
    })
}

exports.createLead = createLead;
exports.findLeadById = findLeadById;

再修复index.js的调用逻辑，给路由回调加async，等待异步逻辑执行完再返回响应，同时加上错误捕获：

const models = require("./modules/models.js");

// 路由回调加async才能正常使用await
app.post('/message', async (req, res) => {
    try {
        const l = await models.createLead(req.body)
        console.log("resulted in lead", JSON.stringify(l))
        // 此处可以正常拿到返回的lead对象
        // const _message = await models.createMessage(req.body.message)
        res.send();
    } catch (err) {
        res.status(500).send(err)
    }
});

• 所有手动创建的Promise，如果需要在外部获取resolve/reject的结果，必须在函数内return这个Promise实例，否则函数执行完无有效返回值，外部永远拿不到结果。
• 不要无意义嵌套.then和async/await，统一用try/catch+await的写法逻辑更清晰，也能减少漏写return的低级错误。
• 接口里的异步逻辑必须等待执行完成后再调用res.send()，否则会出现请求已经响应、后端逻辑还没跑完的时序问题。

内容的提问来源于stack exchange，提问作者CodeCabin