src/main/java/org/onap/clamp/loop/LoopService.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP CLAMP
   4  * ================================================================================
   5  * Copyright (C) 2019 Nokia Intellectual Property. All rights
   6  *                             reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  * http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END============================================
  20  * ===================================================================
  21  *
  22  */
  23
  24 package org.onap.clamp.loop;
  25
  26 import com.google.gson.JsonObject;
  27 import java.util.List;
  28 import java.util.Set;
  29 import javax.persistence.EntityNotFoundException;
  30 import org.apache.commons.lang3.RandomStringUtils;
  31 import org.onap.clamp.loop.template.LoopTemplatesService;
  32 import org.onap.clamp.loop.template.PolicyModel;
  33 import org.onap.clamp.loop.template.PolicyModelsService;
  34 import org.onap.clamp.policy.Policy;
  35 import org.onap.clamp.policy.microservice.MicroServicePolicy;
  36 import org.onap.clamp.policy.microservice.MicroServicePolicyService;
  37 import org.onap.clamp.policy.operational.OperationalPolicy;
  38 import org.onap.clamp.policy.operational.OperationalPolicyService;
  39 import org.springframework.beans.factory.annotation.Autowired;
  40 import org.springframework.stereotype.Service;
  41
  42 @Service
  43 public class LoopService {
  44
  45     @Autowired
  46     private LoopsRepository loopsRepository;
  47
  48     @Autowired
  49     private MicroServicePolicyService microservicePolicyService;
  50
  51     @Autowired
  52     private OperationalPolicyService operationalPolicyService;
  53
  54     @Autowired
  55     private PolicyModelsService policyModelsService;
  56
  57     @Autowired
  58     private LoopTemplatesService loopTemplateService;
  59
  60     Loop saveOrUpdateLoop(Loop loop) {
  61         return loopsRepository.save(loop);
  62     }
  63
  64     List<String> getClosedLoopNames() {
  65         return loopsRepository.getAllLoopNames();
  66     }
  67
  68     public Loop getLoop(String loopName) {
  69         return loopsRepository.findById(loopName).orElse(null);
  70     }
  71
  72     public void deleteLoop(String loopName) {
  73         loopsRepository.deleteById(loopName);
  74     }
  75
  76     /**
  77      * Creates a Loop Instance from Loop Template Name.
  78      *
  79      * @param loopName Name of the Loop to be created
  80      * @param templateName Loop Template to used for Loop
  81      * @return Loop Instance
  82      */
  83     public Loop createLoopFromTemplate(String loopName, String templateName) {
  84         return loopsRepository.save(new Loop(loopName,loopTemplateService.getLoopTemplate(templateName)));
  85     }
  86
  87     /**
  88      * This method is used to refresh the DCAE deployment status fields.
  89      *
  90      * @param loop          The loop instance to be modified
  91      * @param deploymentId  The deployment ID as returned by DCAE
  92      * @param deploymentUrl The Deployment URL as returned by DCAE
  93      */
  94     public void updateDcaeDeploymentFields(Loop loop, String deploymentId, String deploymentUrl) {
  95         loop.setDcaeDeploymentId(deploymentId);
  96         loop.setDcaeDeploymentStatusUrl(deploymentUrl);
  97         loopsRepository.save(loop);
  98     }
  99
 100     public void updateLoopState(Loop loop, String newState) {
 101         loop.setLastComputedState(LoopState.valueOf(newState));
 102         loopsRepository.save(loop);
 103     }
 104
 105     Loop addOperationalPolicy(String loopName, String policyType, String policyVersion) {
 106         Loop loop = findClosedLoopByName(loopName);
 107         PolicyModel policyModel = policyModelsService.getPolicyModel(policyType, policyVersion);
 108         if (policyModel == null) {
 109             return null;
 110         }
 111         loop.addOperationalPolicy(
 112                 new OperationalPolicy(Policy.generatePolicyName("OPERATIONAL", loop.getModelService().getName(),
 113                         loop.getModelService().getVersion(), RandomStringUtils.randomAlphanumeric(3),
 114                         RandomStringUtils.randomAlphanumeric(4)), loop, null, policyModel, null));
 115         return loopsRepository.save(loop);
 116     }
 117
 118     Loop updateAndSaveOperationalPolicies(String loopName, List<OperationalPolicy> newOperationalPolicies) {
 119         Loop loop = findClosedLoopByName(loopName);
 120         Set<OperationalPolicy> newPolicies = operationalPolicyService.updatePolicies(loop, newOperationalPolicies);
 121         loop.setOperationalPolicies(newPolicies);
 122         return loopsRepository.save(loop);
 123     }
 124
 125     Loop updateAndSaveMicroservicePolicies(String loopName, List<MicroServicePolicy> newMicroservicePolicies) {
 126         Loop loop = findClosedLoopByName(loopName);
 127         Set<MicroServicePolicy> newPolicies = microservicePolicyService.updatePolicies(loop, newMicroservicePolicies);
 128         loop.setMicroServicePolicies(newPolicies);
 129         return loopsRepository.save(loop);
 130     }
 131
 132     Loop updateAndSaveGlobalPropertiesJson(String loopName, JsonObject newGlobalPropertiesJson) {
 133         Loop loop = findClosedLoopByName(loopName);
 134         loop.setGlobalPropertiesJson(newGlobalPropertiesJson);
 135         return loopsRepository.save(loop);
 136     }
 137
 138     MicroServicePolicy updateMicroservicePolicy(String loopName, MicroServicePolicy newMicroservicePolicy) {
 139         Loop loop = findClosedLoopByName(loopName);
 140         return microservicePolicyService.getAndUpdateMicroServicePolicy(loop, newMicroservicePolicy);
 141     }
 142
 143     private Loop findClosedLoopByName(String loopName) {
 144         return loopsRepository.findById(loopName)
 145                 .orElseThrow(() -> new EntityNotFoundException("Couldn't find closed loop named: " + loopName));
 146     }
 147
 148     /**
 149      * Api to refresh the Operational Policy UI window.
 150      *
 151      * @param loopName The loop Name
 152      * @return The refreshed loop object
 153      */
 154     public Loop refreshOpPolicyJsonRepresentation(String loopName) {
 155         Loop loop = findClosedLoopByName(loopName);
 156         Set<OperationalPolicy> policyList = loop.getOperationalPolicies();
 157         for (OperationalPolicy policy : policyList) {
 158             policy.updateJsonRepresentation();
 159         }
 160         loop.setOperationalPolicies(policyList);
 161         return loopsRepository.save(loop);
 162     }
 163 }