拒绝（）调用后承诺不会终止

Question

您好，我正在尝试在执行数据库操作之前检查无效案例。出于某种原因，我的代码将运行reject('Invalid E-mail address.');，但随后它还将继续运行await User.findOne({email}) 行。有几种方法可以重写它，但我想保留这段代码的当前结构。如何在拒绝后终止函数并阻止其余代码运行？谢谢

user.database.ts

export const registerUser = async (email: string, password: string): Promise<User> => {
    return new Promise(async (resolve, reject) => {
        // check if email or password are null
        if (!email || !password) {
            reject('Invalid E-mail address or Password.');
        }

        // check if email is invalid
        if (!EmailValidator.validate(email)) {
            reject('Invalid E-mail address.');
        }

        // check if database already contains E-mail address
        await User.findOne({email}).then((user: any) => {
            if (user) {
                reject('E-mail address already in use.'); // code should stop here
            }
        });

        // anything below should not run

        // create user object
        const user = new User({
            _id: new mongoose.Types.ObjectId(),
            email: email,
            password: password
        });

        // save user object to database
        await user.save().then((result: any) => {
            resolve(result);
        }).catch((error: any) => {
            reject(error);
        });
    });
};

auth.controller.ts

export const register = (req: Request, res: Response) => {
    const email = req.body.email;
    const password = req.body.password;
    registerUser(email, password).then((user: User) => {
        res.status(200).json(user);
    }).catch((error: any) => {
        res.status(300).json(error);
    });
};

Answer 1

在async 函数中返回new Promise() 是一种反模式：async 函数已经返回一个promise，因此您只需要显式返回promise 应该解析的值到。

您描述的问题是由于您知道函数失败原因后没有退出函数造成的：如果您也没有return或throw，该函数仍将继续其余代码.

解决这两个问题，您的代码可以重写如下：

const registerUser = async (email: string, password: string): Promise<User> => {
    if (!email || !password) {
        throw new Error('Invalid E-mail address or Password.');
    }

    if (!EmailValidator.validate(email)) {
        throw new Error('Invalid E-mail address.');
    }

    let user: any = await User.findOne({email})
    if (user) {
        throw new Error('E-mail address already in use.');
    }

    user = new User({
        _id: new mongoose.Types.ObjectId(),
        email: email,
        password: password
    });

    return user.save();
};

请注意，async 函数中的 throw 将使承诺（async 函数始终返回）以您提供的原因拒绝。

还要注意，在成功的情况下，分辨率值在这里是一个承诺（user.save()），这意味着async 函数的承诺会将其分辨率链接到 的分辨率em> 承诺。