public Mono listRules()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventRuleController.java [122:145]

24 lines of code
1 McCabe index (conditional complexity)


    public Mono<ListRulesResponse> listRules(@RequestBody ListRulesRequest listRulesRequest) {
        return Mono.subscriberContext()
            .map(ctx -> {
                PaginationResult<List<EventRule>> paginationResult = eventRuleService.listEventRules(
                    accountAPI.getResourceOwnerAccountId(ctx), listRulesRequest.getEventBusName(),
                    listRulesRequest.getNextToken(), listRulesRequest.getMaxResults());
                List<EventRuleDTO> eventRules = Lists.newArrayList();
                paginationResult.getData()
                    .forEach(eventRule -> {
                        EventRuleDTO eventRuleDTO = EventRuleDTO.builder()
                            .eventBusName(eventRule.getEventBusName())
                            .eventRuleName(eventRule.getName())
                            .description(eventRule.getDescription())
                            .filterPattern(eventRule.getFilterPattern())
                            .status(eventRule.getStatus())
                            .gmtCreate(eventRule.getGmtCreate())
                            .gmtModify(eventRule.getGmtModify())
                            .build();
                        eventRules.add(eventRuleDTO);
                    });
                return new ListRulesResponse(eventRules, paginationResult.getNextToken(), paginationResult.getTotal(),
                    listRulesRequest.getMaxResults());
            });
    }