FIWARE / contract-management / #69

Committed 30 Oct 2025 07:38AM UTC coverage: 1.686% (+0.04%) from 1.651%

Build # #69

Build Type

Committed by

Commit Message

improve organization creation and cleanup

Pull Request Pull Request #12: Support for central marketplace and policy creation

Run Details

117 of 1238 new or added lines in 31 files covered. (9.45%)

5 existing lines in 2 files now uncovered.

587 of 34807 relevant lines covered (1.69%)

0.02 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/org/fiware/iam/tmforum/notification/NotificationListener.java

package org.fiware.iam.tmforum.notification;

import io.micronaut.context.annotation.Requires;
import io.micronaut.http.HttpResponse;
import io.micronaut.http.annotation.Body;
import io.micronaut.http.annotation.Controller;
import io.micronaut.http.annotation.Post;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.fiware.iam.configuration.NotificationProperties;
import org.fiware.iam.tmforum.handlers.TMForumEventHandler;
import reactor.core.publisher.Mono;

import java.util.List;
import java.util.Map;

/**
 * Listener endpoint for TMForum notifications
 */
@Requires(condition = NotificationProperties.NotificationCondition.class)
@Slf4j
@Controller("${general.basepath:/}")
@RequiredArgsConstructor
public class NotificationListener {

    public static final String EVENT_TYPE_KEY = "eventType";

    private final List<TMForumEventHandler> eventHandlers;

    @Post("/listener/event")
    public Mono<HttpResponse<?>> listenToEvent(@Body Map<String, Object> event) {
        log.debug("Received an Event: {}", event);
        if (!event.containsKey(EVENT_TYPE_KEY)) {
            throw new IllegalArgumentException("Data did not contain the eventType.");
        }

        if (event.get(EVENT_TYPE_KEY) instanceof String eventType) {
            return eventHandlers.stream()
                    .filter(handler -> handler.isEventTypeSupported(eventType))
                    .findAny()
                    .orElseThrow(() -> new IllegalArgumentException("Event type %s is not supported.".formatted(eventType)))
                    .handleEvent(eventType, event)
                    .doOnNext(r -> log.debug("Returned {} for {}", r, eventType));
        }
        throw new IllegalArgumentException("Event type is invalid.");
    }
}

1	package org.fiware.iam.tmforum.notification;
2
3	import io.micronaut.context.annotation.Requires;
4	import io.micronaut.http.HttpResponse;
5	import io.micronaut.http.annotation.Body;
6	import io.micronaut.http.annotation.Controller;
7	import io.micronaut.http.annotation.Post;
8	import lombok.RequiredArgsConstructor;
9	import lombok.extern.slf4j.Slf4j;
10	import org.fiware.iam.configuration.NotificationProperties;
11	import org.fiware.iam.tmforum.handlers.TMForumEventHandler;
12	import reactor.core.publisher.Mono;
13
14	import java.util.List;
15	import java.util.Map;
16
17	/**
18	* Listener endpoint for TMForum notifications
19	*/
20	@Requires(condition = NotificationProperties.NotificationCondition.class)
NEW 21	@Slf4j	×
22	@Controller("${general.basepath:/}")
23	@RequiredArgsConstructor
24	public class NotificationListener {
25
26	public static final String EVENT_TYPE_KEY = "eventType";
27
28	private final List<TMForumEventHandler> eventHandlers;
29
30	@Post("/listener/event")
31	public Mono<HttpResponse<?>> listenToEvent(@Body Map<String, Object> event) {
NEW 32	log.debug("Received an Event: {}", event);	×
NEW 33	if (!event.containsKey(EVENT_TYPE_KEY)) {	×
NEW 34	throw new IllegalArgumentException("Data did not contain the eventType.");	×
35	}
36
NEW 37	if (event.get(EVENT_TYPE_KEY) instanceof String eventType) {	×
NEW 38	return eventHandlers.stream()	×
NEW 39	.filter(handler -> handler.isEventTypeSupported(eventType))	×
NEW 40	.findAny()	×
NEW 41	.orElseThrow(() -> new IllegalArgumentException("Event type %s is not supported.".formatted(eventType)))	×
NEW 42	.handleEvent(eventType, event)	×
NEW 43	.doOnNext(r -> log.debug("Returned {} for {}", r, eventType));	×
44	}
NEW 45	throw new IllegalArgumentException("Event type is invalid.");	×
46	}
47	}

FIWARE / contract-management / #69

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous