FIWARE / contract-management / #12

Committed 25 Sep 2023 06:23AM UTC coverage: 0.345%. First build

Build # #12

Build Type

Committed by

Commit Message

Pr remarks

Pull Request Pull Request #1: init

Run Details

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

51 of 14788 relevant lines covered (0.34%)

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) {
        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 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	log.info("Received a ProductOrder Created Event: {}", data);	×
52	String didOrderingOrganization = Stream	×
53	.ofNullable(data)	×
54	.map(ProductOrderCreateEventVO::getEvent)	×
55	.map(ProductOrderCreateEventPayloadVO::getProductOrder)	×
56	.map(ProductOrderVO::getRelatedParty)	×
57	.flatMap(Collection::stream)	×
58	.map(RelatedPartyVO::getId)	×
59	.reduce((a, b) -> {	×
60	throw new IllegalArgumentException("Expected exactly one ordering organization.");	×
61	})
62	.map(organizationResolver::getDID)	×
63	.orElseThrow(() -> new IllegalArgumentException("Expected exactly one ordering organization, none found."));	×
64
65	adapter.allowIssuer(didOrderingOrganization);	×
66	log.info("Successfully added {}", didOrderingOrganization);	×
67	return HttpResponse.noContent();	×
68	}
69
70	@Override
71	public HttpResponse<EventSubscriptionVO> listenToProductOrderDeleteEvent(ProductOrderDeleteEventVO data) {
72	log.warn("Received an unimplemented ProductOrderDeleteEvent: {}", data);	×
73	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
74	}
75
76	@Override
77	public HttpResponse<EventSubscriptionVO> listenToProductOrderInformationRequiredEvent(ProductOrderInformationRequiredEventVO data) {
78	log.warn("Received an unimplemented ProductOrderInformationRequiredEvent: {}", data);	×
79	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
80	}
81
82	@Override
83	public HttpResponse<EventSubscriptionVO> listenToProductOrderStateChangeEvent(ProductOrderStateChangeEventVO data) {
84	log.warn("Received an unimplemented ProductOrderStateChangeEvent: {}", data);	×
85	return HttpResponse.status(HttpStatus.NOT_IMPLEMENTED, "Not supported yet.");	×
86	}
87	}

FIWARE / contract-management / #12

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