node.js 将我的 express 方法转换为 async/await

Question

我怀疑将我的 express 方法转换为使用 async/await。

此时，我的方法如下：

app.post('/', (req, res) => {
const body = req.body;

let hospital = new Hospital({
    name: body.name,
    user: req.user._id
});

hospital.save((err, hospitalCreated) => {
    if (err) {
        return res.status(400).json({
            ok: false,
            mensagem: "Error to create hospital",
            errors: err
        });
    }

    res.status(201).json({
        ok: true,
        hospital: hospitalCreated
    });
});

});

作为我的新节点，我尝试这样写：

app.post('/', async (req, res) => {
const body = req.body;

let hospital = new Hospital({
    name: body.name,
    user: req.user._id
});

await hospital.save((err, hospitalCreated) => {
    if (err) {
        return res.status(400).json({
            ok: false,
            mensagem: "Error to create hospital",
            errors: err
        });
    }

    res.status(201).json({
        ok: true,
        hospital: hospitalCreated
    });
});

这是实现这一目标的正确方法吗？我必须使用 try/catch 吗？最好的方法是什么？

谢谢

Answer 1

async 和 await 生成器的目的是避免使用回调。如果save 方法总是返回Promise 并调用回调，那么您所做的可能会起作用，但是这种方法破坏了生成器的全部目的。您应该删除回调并改用try 和catch。

try {
    await hospital.save();
    res.status(201).json({
        ok: true,
        hospital: hospital
    });
} catch (err) {
    res.status(400).json({
        ok: false,
        mensagem: "Error to create hospital",
        errors: err
    });
}

Answer 2

我认为您可以使用 Promise resolve 将 hospital.save 移动到异步函数，然后使用 await 获取响应并使用 catch 从 Promise 中获取错误，例如：

使用猫鼬回调更新：

function saveHospital(hospital) {
        return new Promise((resolve, reject) => {
            hospital.save((err, hospitalCreated) => {
                if (err) {
                    reject(error);
                }

                resolve(hospitalCreated);
            });
        });
    }

    app.post('/', async (req, res) => {
        const body = req.body;

        let hospital = new Hospital({
            name: body.name,
            user: req.user._id
        });

        try {
            const hospitalCreated = await saveHospital(hospital)

            res.status(201).json({
                ok: true,
                hospital: hospitalCreated
            });
        } catch(error) {
            res.status(400).json({
                ok: false,
                mensagem: "Error to create hospital",
                errors: err
            })
        }
    }