gerrit.onap Code Review - usecase-ui/intent-analysis.git/blob

   1 /*
   2  * Copyright (C) 2022 CMCC, Inc. and others. All rights reserved.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16 package org.onap.usecaseui.intentanalysis.cllassuranceIntentmgt.cllassurancemodule;
  17
  18 import lombok.extern.slf4j.Slf4j;
  19 import org.apache.commons.lang.StringUtils;
  20 import org.onap.usecaseui.intentanalysis.adapters.policy.PolicyService;
  21 import org.onap.usecaseui.intentanalysis.bean.enums.ExpectationType;
  22 import org.onap.usecaseui.intentanalysis.bean.enums.IntentGoalType;
  23 import org.onap.usecaseui.intentanalysis.bean.models.*;
  24 import org.onap.usecaseui.intentanalysis.intentBaseService.IntentManagementFunction;
  25 import org.onap.usecaseui.intentanalysis.intentBaseService.intentModule.ActuationModule;
  26 import org.onap.usecaseui.intentanalysis.service.IntentService;
  27 import org.springframework.beans.factory.annotation.Autowired;
  28 import org.springframework.stereotype.Component;
  29 import org.springframework.util.CollectionUtils;
  30
  31 import java.util.List;
  32 import java.util.stream.Collectors;
  33
  34 @Slf4j
  35 @Component
  36 public class CLLAssuranceActuationModule extends ActuationModule {
  37     @Autowired
  38     private IntentService intentService;
  39
  40     @Autowired
  41     private PolicyService policyService;
  42
  43     @Override
  44     public void toNextIntentHandler(IntentGoalBean intentGoalBean, IntentManagementFunction IntentHandler) {
  45
  46     }
  47
  48     @Override
  49     public void directOperation(IntentGoalBean intentGoalBean) {
  50         Intent intent = intentGoalBean.getIntent();
  51         String cllId = getCLLId(intent);
  52         String bandwidth = getBandwidth(cllId);
  53         IntentGoalType intentGoalType = intentGoalBean.getIntentGoalType();
  54         if (StringUtils.equalsIgnoreCase("create", intentGoalType.name())) {
  55             policyService.updateIntentConfigPolicy(cllId, bandwidth, "true");
  56         } else if (StringUtils.equalsIgnoreCase("update", intentGoalType.name())) {
  57             policyService.updateIntentConfigPolicy(cllId, bandwidth, "false");
  58         } else if (StringUtils.equalsIgnoreCase("delete", intentGoalType.name())) {
  59             policyService.updateIntentConfigPolicy(cllId, bandwidth, "false");
  60         }
  61     }
  62
  63     @Override
  64     public void interactWithIntentHandle() {
  65
  66     }
  67
  68     @Override
  69     public void fulfillIntent(IntentGoalBean intentGoalBean, IntentManagementFunction intentHandler) {
  70         directOperation(intentGoalBean);
  71     }
  72
  73     @Override
  74     public void updateIntentOperationInfo(Intent originIntent, IntentGoalBean intentGoalBean){
  75     }
  76
  77     private String getBandwidth(String cllId) {
  78         List<Intent> deliveryIntentList = intentService.getIntentByName("CLL Delivery Intent");
  79         if (CollectionUtils.isEmpty(deliveryIntentList)) {
  80             log.info("get CLL Delivery Intent from the database is empty");
  81             return null;
  82         }
  83         for (Intent deliveryIntent : deliveryIntentList) {
  84             List<Expectation> deliveryExpectationList = deliveryIntent.getIntentExpectations().stream()
  85                     .filter(expectation -> ExpectationType.DELIVERY.equals(expectation.getExpectationType()))
  86                     .collect(Collectors.toList());
  87             if (CollectionUtils.isEmpty(deliveryExpectationList)) {
  88                 log.info("expectation is empty,intentId is {}", deliveryIntent.getIntentId());
  89                 continue;
  90             }
  91             for (Expectation deliveryExpectation : deliveryExpectationList) {
  92                 ExpectationObject expectationObject = deliveryExpectation.getExpectationObject();
  93                 if (expectationObject == null) {
  94                     log.info("expectationObject is empty,expectationId is {}", deliveryExpectation.getExpectationId());
  95                     continue;
  96                 }
  97                 String objectInstance = expectationObject.getObjectInstance();
  98                 if (!StringUtils.equalsIgnoreCase(cllId, objectInstance)) {
  99                     log.info("cllId and objectInstance are not equal,cllId is {},objectInstance is {}", cllId, objectInstance);
 100                     continue;
 101                 }
 102                 List<ExpectationTarget> deliveryTargetList = deliveryExpectation.getExpectationTargets();
 103                 List<ExpectationTarget> bandwidth = deliveryTargetList.stream()
 104                         .filter(target -> StringUtils.equalsIgnoreCase("bandwidth", target.getTargetName()))
 105                         .collect(Collectors.toList());
 106                 if (CollectionUtils.isEmpty(bandwidth)) {
 107                     log.info("bandwidth target is empty,expectation is {}", deliveryExpectation.getExpectationId());
 108                     continue;
 109                 }
 110                 List<Condition> deliveryConditionList = bandwidth.get(0).getTargetConditions();
 111                 List<Condition> collect = deliveryConditionList.stream()
 112                         .filter(condition -> StringUtils.equalsIgnoreCase("condition of the cll service bandwidth", condition.getConditionName()))
 113                         .collect(Collectors.toList());
 114                 if (CollectionUtils.isEmpty(collect)) {
 115                     log.info("condition of the cll service bandwidth is empty,targetId is {}", bandwidth.get(0).getTargetId());
 116                     continue;
 117                 }
 118                 return collect.get(0).getConditionValue();
 119             }
 120         }
 121         return null;
 122     }
 123
 124     public String getCLLId(Intent intent) {
 125         List<Expectation> expectationList = intent.getIntentExpectations();
 126         for (Expectation expectation : expectationList) {
 127             if (StringUtils.equalsIgnoreCase("assurance", expectation.getExpectationType().name())) {
 128                 return expectation.getExpectationObject().getObjectInstance();
 129             }
 130         }
 131         return null;
 132     }
 133 }