2 * ============LICENSE_START=======================================================
3 * Copyright (C) 2023 Nordix Foundation
4 * ================================================================================
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
17 * SPDX-License-Identifier: Apache-2.0
18 * ============LICENSE_END=========================================================
21 package org.onap.cps.ncmp.api.impl.events.cmsubscription;
23 import io.cloudevents.CloudEvent;
24 import java.util.List;
26 import java.util.stream.Collectors;
27 import lombok.RequiredArgsConstructor;
28 import lombok.extern.slf4j.Slf4j;
29 import org.onap.cps.ncmp.api.NcmpEventResponseCode;
30 import org.onap.cps.ncmp.api.impl.events.EventsPublisher;
31 import org.onap.cps.ncmp.api.impl.subscriptions.SubscriptionPersistence;
32 import org.onap.cps.ncmp.api.impl.subscriptions.SubscriptionStatus;
33 import org.onap.cps.ncmp.api.impl.utils.DataNodeHelper;
34 import org.onap.cps.ncmp.api.impl.utils.SubscriptionOutcomeCloudMapper;
35 import org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.CmSubscriptionDmiOutEvent;
36 import org.onap.cps.ncmp.events.cmsubscription1_0_0.ncmp_to_client.CmSubscriptionNcmpOutEvent;
37 import org.springframework.beans.factory.annotation.Value;
38 import org.springframework.stereotype.Component;
42 @RequiredArgsConstructor
43 public class CmSubscriptionNcmpOutEventPublisher {
45 private final SubscriptionPersistence subscriptionPersistence;
47 private final EventsPublisher<CloudEvent> outcomeEventsPublisher;
49 private final CmSubscriptionDmiOutEventToCmSubscriptionNcmpOutEventMapper
50 cmSubscriptionDmiOutEventToCmSubscriptionNcmpOutEventMapper;
52 private final SubscriptionOutcomeCloudMapper subscriptionOutcomeCloudMapper;
54 @Value("${app.ncmp.avc.subscription-outcome-topic:subscription-response}")
55 private String subscriptionOutcomeEventTopic;
58 * This is for construction of outcome message to be published for client apps.
60 * @param cmSubscriptionDmiOutEvent event produced by Dmi Plugin
62 public void sendResponse(final CmSubscriptionDmiOutEvent cmSubscriptionDmiOutEvent, final String eventKey) {
63 final CmSubscriptionNcmpOutEvent cmSubscriptionNcmpOutEvent =
64 formCmSubscriptionNcmpOutEvent(cmSubscriptionDmiOutEvent);
65 final String subscriptionClientId = cmSubscriptionDmiOutEvent.getData().getClientId();
66 final String subscriptionName = cmSubscriptionDmiOutEvent.getData().getSubscriptionName();
67 final String subscriptionEventId = subscriptionClientId + subscriptionName;
68 final CloudEvent subscriptionOutcomeCloudEvent =
69 subscriptionOutcomeCloudMapper.toCloudEvent(cmSubscriptionNcmpOutEvent,
70 subscriptionEventId, eventKey);
71 outcomeEventsPublisher.publishCloudEvent(subscriptionOutcomeEventTopic,
72 subscriptionEventId, subscriptionOutcomeCloudEvent);
75 private CmSubscriptionNcmpOutEvent formCmSubscriptionNcmpOutEvent(
76 final CmSubscriptionDmiOutEvent cmSubscriptionDmiOutEvent) {
77 final Map<String, Map<String, String>> cmHandleIdToStatusAndDetailsAsMap =
78 DataNodeHelper.cmHandleIdToStatusAndDetailsAsMapFromDataNode(
79 subscriptionPersistence.getCmHandlesForSubscriptionEvent(
80 cmSubscriptionDmiOutEvent.getData().getClientId(),
81 cmSubscriptionDmiOutEvent.getData().getSubscriptionName()));
82 final List<org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus>
83 subscriptionStatusList =
84 mapCmHandleIdStatusDetailsMapToSubscriptionStatusList(cmHandleIdToStatusAndDetailsAsMap);
85 cmSubscriptionDmiOutEvent.getData().setSubscriptionStatus(subscriptionStatusList);
86 return fromDmiOutEvent(cmSubscriptionDmiOutEvent,
87 decideOnNcmpEventResponseCodeForSubscription(cmHandleIdToStatusAndDetailsAsMap));
90 private static List<org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus>
91 mapCmHandleIdStatusDetailsMapToSubscriptionStatusList(
92 final Map<String, Map<String, String>> cmHandleIdToStatusAndDetailsAsMap) {
93 return cmHandleIdToStatusAndDetailsAsMap.entrySet()
94 .stream().map(entryset -> {
95 final org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp.SubscriptionStatus
96 subscriptionStatus = new org.onap.cps.ncmp.events.cmsubscription1_0_0
97 .dmi_to_ncmp.SubscriptionStatus();
98 final String cmHandleId = entryset.getKey();
99 final Map<String, String> statusAndDetailsMap = entryset.getValue();
100 final String status = statusAndDetailsMap.get("status");
101 final String details = statusAndDetailsMap.get("details");
102 subscriptionStatus.setId(cmHandleId);
103 subscriptionStatus.setStatus(
104 org.onap.cps.ncmp.events.cmsubscription1_0_0.dmi_to_ncmp
105 .SubscriptionStatus.Status.fromValue(status));
106 subscriptionStatus.setDetails(details);
107 return subscriptionStatus;
108 }).collect(Collectors.toList());
111 private NcmpEventResponseCode decideOnNcmpEventResponseCodeForSubscription(
112 final Map<String, Map<String, String>> cmHandleIdToStatusAndDetailsAsMap) {
114 final boolean isAllTargetsPending = isAllTargetCmHandleStatusMatch(cmHandleIdToStatusAndDetailsAsMap,
115 SubscriptionStatus.PENDING);
117 final boolean isAllTargetsRejected = isAllTargetCmHandleStatusMatch(cmHandleIdToStatusAndDetailsAsMap,
118 SubscriptionStatus.REJECTED);
120 final boolean isAllTargetsAccepted = isAllTargetCmHandleStatusMatch(cmHandleIdToStatusAndDetailsAsMap,
121 SubscriptionStatus.ACCEPTED);
123 if (isAllTargetsAccepted) {
124 return NcmpEventResponseCode.SUCCESSFULLY_APPLIED_SUBSCRIPTION;
125 } else if (isAllTargetsRejected) {
126 return NcmpEventResponseCode.SUBSCRIPTION_NOT_APPLICABLE;
127 } else if (isAllTargetsPending) {
128 return NcmpEventResponseCode.SUBSCRIPTION_PENDING;
130 return NcmpEventResponseCode.PARTIALLY_APPLIED_SUBSCRIPTION;
134 private boolean isAllTargetCmHandleStatusMatch(
135 final Map<String, Map<String, String>> cmHandleIdToStatusAndDetailsAsMap,
136 final SubscriptionStatus subscriptionStatus) {
137 return cmHandleIdToStatusAndDetailsAsMap.values().stream()
138 .allMatch(entryset -> entryset.containsValue(subscriptionStatus.toString()));
141 private CmSubscriptionNcmpOutEvent fromDmiOutEvent(
142 final CmSubscriptionDmiOutEvent cmSubscriptionDmiOutEvent,
143 final NcmpEventResponseCode ncmpEventResponseCode) {
145 final CmSubscriptionNcmpOutEvent cmSubscriptionNcmpOutEvent =
146 cmSubscriptionDmiOutEventToCmSubscriptionNcmpOutEventMapper.toCmSubscriptionNcmpOutEvent(
147 cmSubscriptionDmiOutEvent);
148 cmSubscriptionNcmpOutEvent.getData().setStatusCode(Integer.parseInt(ncmpEventResponseCode.getStatusCode()));
149 cmSubscriptionNcmpOutEvent.getData().setStatusMessage(ncmpEventResponseCode.getStatusMessage());
151 return cmSubscriptionNcmpOutEvent;