private CloudEventBuilder addAttributes()

in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/HttpEventConverter.java [114:144]

27 lines of code
4 McCabe index (conditional complexity)


    private CloudEventBuilder addAttributes(String regionId, String accountId, String sourceName, String busName,
        Map<String, Object> schema, CloudEventBuilder cloudEventBuilder) {
        CloudEventBuilder newBuilder = cloudEventBuilder.newBuilder();
        newBuilder.withId(UUID.randomUUID().toString())
            .withSource(URI.create(sourceName))
            .withDataContentType(DATA_CONTENT_TYPE)
            .withDataSchema(null);

        String subject = (String) schema.get("subject");
        String time = (String) schema.get("time");
        String type = (String) schema.get("type");

        if (StringUtils.isNotBlank(subject)) {
            newBuilder.withSubject(subject);
        } else {
            newBuilder.withSubject(httpEventAPI.generateSubject(regionId, accountId, busName, sourceName));
        }

        if (StringUtils.isNotBlank(time)) {
            newBuilder.withTime(OffsetDateTime.from(ZonedDateTime.parse(time)));
        } else {
            newBuilder.withTime(OffsetDateTime.from(ZonedDateTime.now()));

        }
        if (StringUtils.isNotBlank(type)) {
            newBuilder.withType(type);
        } else {
            newBuilder.withType(TYPE);
        }
        return newBuilder;
    }