将验证纳入项目反应器的反应链中

Question

我想组成一个Reactor链，基本上可以做到以下几点：

1. 验证提交的User属性，例如firstName，lastName的长度或email的有效性。我会使用下面的验证器。
2. 验证提交的电子邮件是否已被其他人使用。为此，我将使用反应性存储库。
3. 保存User，如果以上所有验证检查都通过。

用户：

@Builder
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {

    @Id
    private Integer id;
    private String firstName;
    private String lastName;
    private String email;
}

反应性存储库：

public interface UserRepository extends ReactiveCrudRepository<User, Long> {

    @Query("select id, first_name, last_name, email from user u where u.email = :email")
    Mono<User> findByEmail(String email);
}

验证器：

@Component
public class UserValidator implements Validator {

    private final static String EMAIL = "email";
    private static final String FIRST_NAME = "firstName";
    private static final String LAST_NAME = "lastName";

    @Override
    public boolean supports(Class<?> clazz) {
        return User.class.equals(clazz);
    }

    @Override
    public void validate(Object target, Errors errors) {
        User user = (User) target;

        rejectIfEmptyOrWhitespace(errors, EMAIL, "email.required");
        rejectIfEmptyOrWhitespace(errors, FIRST_NAME, "firstName.required");
        rejectIfEmptyOrWhitespace(errors, LAST_NAME, "lastName.required");

        validateFirstName(errors, user.getFirstName());
        validateLastName(errors, user.getLastName());
        validateEmail(errors, user.getEmail());
    }

    private void validateEmail(Errors errors, String email) {
        EmailValidator emailValidator = EmailValidator.getInstance();
        if (!emailValidator.isValid(email)) {
            errors.rejectValue(EMAIL, "email.invalid");
        }
    }

    private void validateFirstName(Errors errors, String firstName) {
        if (firstName.length() < 2) {
            errors.rejectValue(FIRST_NAME, "firstName.min");
        }
    }

    private void validateLastName(Errors errors, String lastName) {
        if (lastName.length() < 2) {
            errors.rejectValue(LAST_NAME, "lastName.min");
        }
    }
}

处理程序方法：

public Mono<ServerResponse> saveUser(ServerRequest serverRequest) {
    return serverRequest.bodyToMono(User.class)
        // Use validator here
        .flatMap(this::createUserIfEmailNotExists);
}

助手方法：

private Mono<ServerResponse> createUserIfEmailNotExists(User user) {
    return userRepository.findByEmail(user.getEmail())
        .flatMap(existingUser ->
            status(BAD_REQUEST).contentType(APPLICATION_JSON)
                .body(BodyInserters.fromObject("User already exists."))
        )
        .switchIfEmpty(
            userRepository.save(user)
                .flatMap(newUser -> status(CREATED).contentType(APPLICATION_JSON)
                    .body(BodyInserters.fromObject(newUser)))
        );
}

从被动的角度来看，我不确定如何实现这一目标。理想情况下，反应链将有3个步骤映射到上面的点。

这是我尝试过的，但我在方法参数和返回类型破坏序列流方面遇到了问题。。。

private Mono<ServerResponse> validateUser(User user) {
    Errors errors = new BeanPropertyBindingResult(user, User.class.getName());
    userValidator.validate(user, errors);
    if (errors.hasErrors()) {
        return status(BAD_REQUEST).contentType(APPLICATION_JSON)
            .body(BodyInserters.fromObject(errors.getAllErrors()));
    } else {
        return Mono.empty();
    }
}

有人能帮忙吗？

Answer 1

这样怎么样？

private Mono<ServerResponse> validateUser(User user) {
    return Mono.just(new BeanPropertyBindingResult(user, User.class.getName()))
        .doOnNext(err -> userValidator.validate(user, err))
        .filter(AbstractBindingResult::hasErrors)
        .flatMap(err ->
            status(BAD_REQUEST)
                .contentType(APPLICATION_JSON)
                .body(BodyInserters.fromObject(err.getAllErrors()))
        );
}

private Mono<ServerResponse> createUserIfEmailNotExists(User user) {
    return userRepository.findByEmail(user.getEmail())
        .flatMap(existingUser ->
            status(BAD_REQUEST).contentType(APPLICATION_JSON)
                .body(BodyInserters.fromObject("User already exists."))
        )
        .switchIfEmpty(
            validateUser(user)
                .switchIfEmpty(
                    userRepository.save(user)
                        .flatMap(newUser -> status(CREATED).contentType(APPLICATION_JSON)
                            .body(BodyInserters.fromObject(newUser)))
                )
        );
}