private List converterEventBridgeEvent()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventDataController.java [81:109]

29 lines of code
3 McCabe index (conditional complexity)


    private List<EventBridgeEvent> converterEventBridgeEvent(List<CloudEvent> cloudEvents) {
        List<EventBridgeEvent> eventList = Lists.newArrayListWithCapacity(cloudEvents.size());
        if (CollectionUtils.isEmpty(cloudEvents)) {
            return eventList;
        }
        cloudEvents.forEach(cloudEvent -> {
            EventBridgeEvent event = EventBridgeEvent.builder()
                .id(cloudEvent.getId())
                .source(cloudEvent.getSource())
                .type(cloudEvent.getType())
                .subject(cloudEvent.getSubject())
                .specversion(cloudEvent.getSpecVersion()
                    .toString())
                .dataschema(cloudEvent.getDataSchema())
                .datacontenttype(cloudEvent.getDataContentType())
                .time(cloudEvent.getTime())
                .data(cloudEvent.getData()
                    .toBytes())
                .build();
            if (cloudEvent.getExtensionNames() != null) {
                cloudEvent.getExtensionNames()
                    .forEach(extensionName -> {
                        event.addExtension(extensionName, cloudEvent.getExtension(extensionName));
                    });
            }
            eventList.add(event);
        });
        return eventList;
    }