FIWARE / contract-management / #14

Committed 26 Sep 2023 06:16AM UTC coverage: 1.63%. First build

Build # #14

Build Type

Committed by

Commit Message

remove IDE dependent stuff

Pull Request Pull Request #1: init

Run Details

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

241 of 14788 relevant lines covered (1.63%)

0.02 hits per line

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

54.84

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

package org.fiware.iam.tmforum;

import io.micronaut.http.HttpResponse;
import io.micronaut.http.HttpResponseFactory;
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> listenToProductOrderCreateEvent(ProductOrderCreateEventVO data) {
        log.info("Received a ProductOrder Created Event: {}", data);
        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."));

        adapter.allowIssuer(didOrderingOrganization);
        log.info("Successfully added {}", didOrderingOrganization);

        return HttpResponseFactory.INSTANCE.status(HttpStatus.CREATED);
    }

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

FIWARE / contract-management / #14

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