public Mono listConnections()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java [182:209]
28 lines of code
2 McCabe index (conditional complexity)

    public Mono<ListConnectionResponse> listConnections(@RequestBody ListConnectionRequest listConnectionRequest) {
        return Mono.subscriberContext()
            .map(ctx -> {
                final Set<ConstraintViolation<ListConnectionRequest>> validate = validator.validate(
                    listConnectionRequest);
                List<String> errMessage = validate.stream()
                    .map(ConstraintViolation::getMessage)
                    .collect(Collectors.toList());
                if (!CollectionUtils.isEmpty(errMessage)) {
                    return new ListConnectionResponse(null, null, null, 0).parameterCheckFailRes(errMessage.toString());
                }
                listConnectionRequest.checkMaxResultsAndNextToken();
                final PaginationResult<List<ConnectionDTO>> listPaginationResult = connectionService.listConnections(
                    accountAPI.getResourceOwnerAccountId(ctx), listConnectionRequest.getConnectionNamePrefix(),
                    listConnectionRequest.getNextToken(), listConnectionRequest.getMaxResults());
                List<ConnectionResponse> connectionResponses = Lists.newArrayList();
                listPaginationResult.getData()
                    .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 ListConnectionResponse(connectionResponses, listPaginationResult.getNextToken(),
                    listPaginationResult.getTotal(), listConnectionRequest.getMaxResults()).success();
            });
    }