FIWARE / contract-management / #11

Committed 22 Sep 2023 09:52AM UTC coverage: 0.311%. First build

Build # #11

Build Type

Committed by

Commit Message

cleanup pipeline to avoid double execution

Pull Request Pull Request #1: init

Run Details

141 of 141 new or added lines in 11 files covered. (100.0%)

46 of 14786 relevant lines covered (0.31%)

0.0 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/NotificationListener.java

package org.fiware.iam.tmforum;

import io.micronaut.http.HttpResponse;
import io.micronaut.http.HttpStatus;
import io.micronaut.http.annotation.Controller;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.fiware.iam.til.TrustedIssuersListAdapter;
import org.fiware.iam.tmforum.product.server.api.NotificationListenersClientSideApi;
import org.fiware.iam.tmforum.product.server.model.*;

import java.util.Collection;
import java.util.stream.Stream;

@Slf4j
@Controller("${general.basepath:/}")
@RequiredArgsConstructor
public class NotificationListener implements NotificationListenersClientSideApi {

    private final TrustedIssuersListAdapter adapter;

    private final OrganizationResolver organizationResolver;

    @Override
    public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderCreateEvent(CancelProductOrderCreateEventVO data) {
        log.warn("Received an unimplemented CancelProductOrderCreateEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderInformationRequiredEvent(CancelProductOrderInformationRequiredEventVO data) {
        log.warn("Received an unimplemented CancelProductOrderInformationRequiredEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderStateChangeEvent(CancelProductOrderStateChangeEventVO data) {
        log.warn("Received an unimplemented CancelProductOrderStateChangeEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderAttributeValueChangeEvent(ProductOrderAttributeValueChangeEventVO data) {
        log.warn("Received an unimplemented ProductOrderAttributeValueChangeEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }


    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderCreateEvent(ProductOrderCreateEventVO data) {
        // validate notification type
        log.info("Received a ProductOrder Created Event: {}", data);
        try {
            String didOrderingOrganization = Stream
                    .ofNullable(data)
                    .map(ProductOrderCreateEventVO::getEvent)
                    .map(ProductOrderCreateEventPayloadVO::getProductOrder)
                    .map(ProductOrderVO::getRelatedParty)
                    .flatMap(Collection::stream)
                    .map(RelatedPartyVO::getId)
                    .reduce((a, b) -> {
                        throw new IllegalArgumentException("Expected exactly one ordering organization.");
                    })
                    .map(organizationResolver::getDID)
                    .orElseThrow(() -> new IllegalArgumentException("Expected exactly one ordering organization, none found."));

            // call
            adapter.allowIssuer(didOrderingOrganization);
        } catch (Exception e) {
            log.error("Could not set up trusted issuer based on the event: {}", data, e);
        }
        // Notification sender does not care about the listeners issues
        return HttpResponse.noContent();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderDeleteEvent(ProductOrderDeleteEventVO data) {
        log.warn("Received an unimplemented ProductOrderDeleteEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderInformationRequiredEvent(ProductOrderInformationRequiredEventVO data) {
        log.warn("Received an unimplemented ProductOrderInformationRequiredEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderStateChangeEvent(ProductOrderStateChangeEventVO data) {
        log.warn("Received an unimplemented ProductOrderStateChangeEvent: {}", data);
        return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");
    }
}

1	package org.fiware.iam.tmforum;
2
3	import io.micronaut.http.HttpResponse;
4	import io.micronaut.http.HttpStatus;
5	import io.micronaut.http.annotation.Controller;
6	import lombok.RequiredArgsConstructor;
7	import lombok.extern.slf4j.Slf4j;
8	import org.fiware.iam.til.TrustedIssuersListAdapter;
9	import org.fiware.iam.tmforum.product.server.api.NotificationListenersClientSideApi;
10	import org.fiware.iam.tmforum.product.server.model.*;
11
12	import java.util.Collection;
13	import java.util.stream.Stream;
14
15	@Slf4j	×
16	@Controller("${general.basepath:/}")
17	@RequiredArgsConstructor	×
18	public class NotificationListener implements NotificationListenersClientSideApi {
19
20	private final TrustedIssuersListAdapter adapter;
21
22	private final OrganizationResolver organizationResolver;
23
24	@Override
25	public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderCreateEvent(CancelProductOrderCreateEventVO data) {
26	log.warn("Received an unimplemented CancelProductOrderCreateEvent: {}", data);	×
27	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
28	}
29
30	@Override
31	public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderInformationRequiredEvent(CancelProductOrderInformationRequiredEventVO data) {
32	log.warn("Received an unimplemented CancelProductOrderInformationRequiredEvent: {}", data);	×
33	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
34	}
35
36	@Override
37	public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderStateChangeEvent(CancelProductOrderStateChangeEventVO data) {
38	log.warn("Received an unimplemented CancelProductOrderStateChangeEvent: {}", data);	×
39	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
40	}
41
42	@Override
43	public HttpResponse<EventSubscriptionVO> listenToProductOrderAttributeValueChangeEvent(ProductOrderAttributeValueChangeEventVO data) {
44	log.warn("Received an unimplemented ProductOrderAttributeValueChangeEvent: {}", data);	×
45	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
46	}
47
48
49	@Override
50	public HttpResponse<EventSubscriptionVO> listenToProductOrderCreateEvent(ProductOrderCreateEventVO data) {
51	// validate notification type
52	log.info("Received a ProductOrder Created Event: {}", data);	×
53	try {
54	String didOrderingOrganization = Stream	×
55	.ofNullable(data)	×
56	.map(ProductOrderCreateEventVO::getEvent)	×
57	.map(ProductOrderCreateEventPayloadVO::getProductOrder)	×
58	.map(ProductOrderVO::getRelatedParty)	×
59	.flatMap(Collection::stream)	×
60	.map(RelatedPartyVO::getId)	×
61	.reduce((a, b) -> {	×
62	throw new IllegalArgumentException("Expected exactly one ordering organization.");	×
63	})
64	.map(organizationResolver::getDID)	×
65	.orElseThrow(() -> new IllegalArgumentException("Expected exactly one ordering organization, none found."));	×
66
67	// call
68	adapter.allowIssuer(didOrderingOrganization);	×
69	} catch (Exception e) {	×
70	log.error("Could not set up trusted issuer based on the event: {}", data, e);	×
71	}	×
72	// Notification sender does not care about the listeners issues
73	return HttpResponse.noContent();	×
74	}
75
76	@Override
77	public HttpResponse<EventSubscriptionVO> listenToProductOrderDeleteEvent(ProductOrderDeleteEventVO data) {
78	log.warn("Received an unimplemented ProductOrderDeleteEvent: {}", data);	×
79	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
80	}
81
82	@Override
83	public HttpResponse<EventSubscriptionVO> listenToProductOrderInformationRequiredEvent(ProductOrderInformationRequiredEventVO data) {
84	log.warn("Received an unimplemented ProductOrderInformationRequiredEvent: {}", data);	×
85	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
86	}
87
88	@Override
89	public HttpResponse<EventSubscriptionVO> listenToProductOrderStateChangeEvent(ProductOrderStateChangeEventVO data) {
90	log.warn("Received an unimplemented ProductOrderStateChangeEvent: {}", data);	×
91	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
92	}
93	}

FIWARE / contract-management / #11

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