public Mono getConnection()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java [132:155]

• 24 lines of code
• 2 McCabe index (conditional complexity)

    public Mono<GetConnectionResponse> getConnection(@RequestBody GetConnectionRequest getConnectionRequest) {
        return Mono.subscriberContext()
            .map(ctx -> {
                final Set<ConstraintViolation<GetConnectionRequest>> validate = validator.validate(
                    getConnectionRequest);
                List<String> errMessage = validate.stream()
                    .map(ConstraintViolation::getMessage)
                    .collect(Collectors.toList());
                if (!CollectionUtils.isEmpty(errMessage)) {
                    return new GetConnectionResponse(null).parameterCheckFailRes(
                        errMessage.toString());
                }
                final List<ConnectionDTO> connectionDTOS = connectionService.getConnection(accountAPI.getResourceOwnerAccountId(ctx), getConnectionRequest.getConnectionName());
                List<ConnectionResponse> connectionResponses = Lists.newArrayList();
                connectionDTOS.forEach(connectionDTO -> {
                    ConnectionResponse connectionResponse = new ConnectionResponse();
                    BeanUtils.copyProperties(connectionDTO, connectionResponse);
                    connectionResponse.setGmtCreate(connectionDTO.getGmtCreate().getTime());
                    connectionResponse.setId(connectionDTO.getId());
                    connectionResponses.add(dataMasking(connectionResponse));
                });
                return new GetConnectionResponse(connectionResponses).success();
            });
    }