public Mono listApiDestinations()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java [158:191]
34 lines of code
2 McCabe index (conditional complexity)

    public Mono<ListApiDestinationsResponse> listApiDestinations(
        @RequestBody ListApiDestinationsRequest listApiDestinationsRequest) {
        return Mono.subscriberContext()
            .map(ctx -> {
                final Set<ConstraintViolation<ListApiDestinationsRequest>> validate = validator.validate(
                    listApiDestinationsRequest);
                List<String> errMessage = validate.stream()
                    .map(ConstraintViolation::getMessage)
                    .collect(Collectors.toList());
                if (!CollectionUtils.isEmpty(errMessage)) {
                    return new ListApiDestinationsResponse(null, null, null, 0).parameterCheckFailRes(
                        errMessage.toString());
                }
                listApiDestinationsRequest.checkMaxResultsAndNextToken();
                final PaginationResult<List<ApiDestinationDTO>> listPaginationResult
                    = apiDestinationService.listApiDestinations(accountAPI.getResourceOwnerAccountId(ctx),
                    listApiDestinationsRequest.getApiDestinationNamePrefix(),
                        listApiDestinationsRequest.getConnectionName(), listApiDestinationsRequest.getNextToken(),
                    listApiDestinationsRequest.getMaxResults());
                List<ApiDestinationsResponse> apiDestinationsResponses = Lists.newArrayList();
                listPaginationResult.getData()
                    .forEach(eventApiDestination -> {
                        ApiDestinationsResponse apiDestinationsResponse = new ApiDestinationsResponse();
                        BeanUtils.copyProperties(eventApiDestination, apiDestinationsResponse);
                        apiDestinationsResponse.setApiDestinationName(eventApiDestination.getName());
                        apiDestinationsResponse.setHttpApiParameters(eventApiDestination.getApiParams());
                        apiDestinationsResponse.setGmtCreate(eventApiDestination.getGmtCreate()
                            .getTime());
                        apiDestinationsResponses.add(apiDestinationsResponse);
                    });
                return new ListApiDestinationsResponse(apiDestinationsResponses, listPaginationResult.getNextToken(),
                    listPaginationResult.getTotal(), listApiDestinationsRequest.getMaxResults()).success();
            });
    }