gerrit.onap Code Review - cps.git/blob

   1 /*
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2024 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
   8  *
   9  *        http://www.apache.org/licenses/LICENSE-2.0
  10  *
  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.
  16  *
  17  *  SPDX-License-Identifier: Apache-2.0
  18  *  ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.cps.ncmp.impl.cmnotificationsubscription.ncmp;
  22
  23 import java.util.ArrayList;
  24 import java.util.List;
  25 import java.util.Map;
  26 import lombok.RequiredArgsConstructor;
  27 import org.onap.cps.ncmp.impl.cmnotificationsubscription.models.CmSubscriptionStatus;
  28 import org.onap.cps.ncmp.impl.cmnotificationsubscription.models.DmiCmSubscriptionDetails;
  29 import org.onap.cps.ncmp.impl.cmnotificationsubscription.models.DmiCmSubscriptionPredicate;
  30 import org.onap.cps.ncmp.impl.cmnotificationsubscription_1_0_0.ncmp_to_client.Data;
  31 import org.onap.cps.ncmp.impl.cmnotificationsubscription_1_0_0.ncmp_to_client.NcmpOutEvent;
  32 import org.springframework.stereotype.Component;
  33
  34 @Component
  35 @RequiredArgsConstructor
  36 public class NcmpOutEventMapper {
  37
  38     /**
  39      * Mapper to form a response for the client for the Cm Notification Subscription.
  40      *
  41      * @param subscriptionId                          Cm Notification Subscription Id
  42      * @param dmiSubscriptionsPerDmi contains CmNotificationSubscriptionDetails per dmi plugin
  43      * @return CmNotificationSubscriptionNcmpOutEvent to sent back to the client
  44      */
  45     public NcmpOutEvent toNcmpOutEvent(final String subscriptionId,
  46             final Map<String, DmiCmSubscriptionDetails> dmiSubscriptionsPerDmi) {
  47
  48         final NcmpOutEvent ncmpOutEvent = new NcmpOutEvent();
  49         final Data cmSubscriptionData = new Data();
  50         cmSubscriptionData.setSubscriptionId(subscriptionId);
  51         populateNcmpOutEventWithCmHandleIds(dmiSubscriptionsPerDmi,
  52                 cmSubscriptionData);
  53         ncmpOutEvent.setData(cmSubscriptionData);
  54
  55         return ncmpOutEvent;
  56     }
  57
  58     /**
  59      * Mapper to form a rejected response for the client for the Cm Notification Subscription Request.
  60      *
  61      * @param subscriptionId subscription id
  62      * @param rejectedTargetFilters list of rejected target filters for the subscription request
  63      * @return to sent back to the client
  64      */
  65     public NcmpOutEvent toNcmpOutEventForRejectedRequest(final String subscriptionId,
  66             final List<String> rejectedTargetFilters) {
  67         final NcmpOutEvent ncmpOutEvent = new NcmpOutEvent();
  68         final Data cmSubscriptionData = new Data();
  69         cmSubscriptionData.setSubscriptionId(subscriptionId);
  70         cmSubscriptionData.setRejectedTargets(rejectedTargetFilters);
  71         ncmpOutEvent.setData(cmSubscriptionData);
  72         return ncmpOutEvent;
  73     }
  74
  75     private void populateNcmpOutEventWithCmHandleIds(
  76             final Map<String, DmiCmSubscriptionDetails> dmiSubscriptionsPerDmi,
  77             final Data cmSubscriptionData) {
  78
  79         final List<String> acceptedCmHandleIds = new ArrayList<>();
  80         final List<String> pendingCmHandleIds = new ArrayList<>();
  81         final List<String> rejectedCmHandleIds = new ArrayList<>();
  82
  83         dmiSubscriptionsPerDmi.forEach((dmiPluginName, dmiSubscriptionDetails) -> {
  84             final CmSubscriptionStatus cmSubscriptionStatus =
  85                     dmiSubscriptionDetails.getCmSubscriptionStatus();
  86             final List<DmiCmSubscriptionPredicate> dmiCmSubscriptionPredicates =
  87                     dmiSubscriptionDetails.getDmiCmSubscriptionPredicates();
  88
  89             switch (cmSubscriptionStatus) {
  90                 case ACCEPTED -> acceptedCmHandleIds.addAll(
  91                         extractCmHandleIds(dmiCmSubscriptionPredicates));
  92                 case PENDING -> pendingCmHandleIds.addAll(extractCmHandleIds(dmiCmSubscriptionPredicates));
  93                 default -> rejectedCmHandleIds.addAll(extractCmHandleIds(dmiCmSubscriptionPredicates));
  94             }
  95         });
  96
  97         cmSubscriptionData.setAcceptedTargets(acceptedCmHandleIds);
  98         cmSubscriptionData.setPendingTargets(pendingCmHandleIds);
  99         cmSubscriptionData.setRejectedTargets(rejectedCmHandleIds);
 100
 101     }
 102
 103     private List<String> extractCmHandleIds(
 104             final List<DmiCmSubscriptionPredicate> dmiCmSubscriptionPredicates) {
 105         final List<String> cmHandleIds = new ArrayList<>();
 106         dmiCmSubscriptionPredicates.forEach(dmiSubscriptionPredicate -> cmHandleIds.addAll(
 107                 dmiSubscriptionPredicate.getTargetCmHandleIds()));
 108
 109         return cmHandleIds;
 110     }
 111
 112 }