FIWARE / contract-management / #9

Committed 21 Sep 2023 09:02AM UTC coverage: 0.196%. First build

Build # #9

Build Type

Committed by

Commit Message

api update

Pull Request Pull Request #1: init

Run Details

138 of 138 new or added lines in 10 files covered. (100.0%)

29 of 14769 relevant lines covered (0.2%)

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.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.ok();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderInformationRequiredEvent(CancelProductOrderInformationRequiredEventVO data) {
        log.warn("Received an unimplemented CancelProductOrderInformationRequiredEvent: {}", data);
        return HttpResponse.ok();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToCancelProductOrderStateChangeEvent(CancelProductOrderStateChangeEventVO data) {
        log.warn("Received an unimplemented CancelProductOrderStateChangeEvent: {}", data);
        return HttpResponse.ok();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderAttributeValueChangeEvent(ProductOrderAttributeValueChangeEventVO data) {
        log.warn("Received an unimplemented ProductOrderAttributeValueChangeEvent: {}", data);
        return HttpResponse.ok();
    }


    @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.ok();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderDeleteEvent(ProductOrderDeleteEventVO data) {
        log.warn("Received an unimplemented ProductOrderDeleteEvent: {}", data);
        return HttpResponse.ok();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderInformationRequiredEvent(ProductOrderInformationRequiredEventVO data) {
        log.warn("Received an unimplemented ProductOrderInformationRequiredEvent: {}", data);
        return HttpResponse.ok();
    }

    @Override
    public HttpResponse<EventSubscriptionVO> listenToProductOrderStateChangeEvent(ProductOrderStateChangeEventVO data) {
        log.warn("Received an unimplemented ProductOrderStateChangeEvent: {}", data);
        return HttpResponse.ok();
    }
}

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

FIWARE / contract-management / #9

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