public Mono listEventSources()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventSourceController.java [116:139]

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

    public Mono<ListEventSourcesResponse> listEventSources(
        @RequestBody ListEventSourcesRequest listEventSourcesRequest) {
        return Mono.subscriberContext()
            .map(ctx -> {
                EventSourceService eventSourceService = eventSourceServiceFactory.getDefaultEventSourceService();
                PaginationResult<List<EventSource>> paginationResult = eventSourceService.listEventSources(
                    accountAPI.getResourceOwnerAccountId(ctx), listEventSourcesRequest.getEventBusName(),
                    listEventSourcesRequest.getNextToken(), listEventSourcesRequest.getMaxResults());
                List<EventSourceDTO> eventSourceDTOS = Lists.newArrayList();
                paginationResult.getData()
                    .forEach(eventSource -> {
                        EventSourceDTO eventSourceDTO = EventSourceDTO.builder()
                            .eventBusName(eventSource.getEventBusName())
                            .eventSourceName(eventSource.getName())
                            .description(eventSource.getDescription())
                            .gmtCreate(eventSource.getGmtCreate())
                            .gmtModify(eventSource.getGmtModify())
                            .build();
                        eventSourceDTOS.add(eventSourceDTO);
                    });
                return new ListEventSourcesResponse(eventSourceDTOS, paginationResult.getNextToken(),
                    paginationResult.getTotal(), listEventSourcesRequest.getMaxResults());
            });
    }