2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2019 Nokia Intellectual Property. All rights
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
12 * http://www.apache.org/licenses/LICENSE-2.0
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 * ===================================================================
24 package org.onap.clamp.loop;
26 import com.google.gson.JsonObject;
27 import java.util.List;
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;
43 public class LoopService {
46 private LoopsRepository loopsRepository;
49 private MicroServicePolicyService microservicePolicyService;
52 private OperationalPolicyService operationalPolicyService;
55 private PolicyModelsService policyModelsService;
58 private LoopTemplatesService loopTemplateService;
60 Loop saveOrUpdateLoop(Loop loop) {
61 return loopsRepository.save(loop);
64 List<String> getClosedLoopNames() {
65 return loopsRepository.getAllLoopNames();
68 public Loop getLoop(String loopName) {
69 return loopsRepository.findById(loopName).orElse(null);
72 public void deleteLoop(String loopName) {
73 loopsRepository.deleteById(loopName);
77 * Creates a Loop Instance from Loop Template Name.
79 * @param loopName Name of the Loop to be created
80 * @param templateName Loop Template to used for Loop
81 * @return Loop Instance
83 public Loop createLoopFromTemplate(String loopName, String templateName) {
84 return loopsRepository.save(new Loop(loopName,loopTemplateService.getLoopTemplate(templateName)));
88 * This method is used to refresh the DCAE deployment status fields.
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
94 public void updateDcaeDeploymentFields(Loop loop, String deploymentId, String deploymentUrl) {
95 loop.setDcaeDeploymentId(deploymentId);
96 loop.setDcaeDeploymentStatusUrl(deploymentUrl);
97 loopsRepository.save(loop);
100 public void updateLoopState(Loop loop, String newState) {
101 loop.setLastComputedState(LoopState.valueOf(newState));
102 loopsRepository.save(loop);
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) {
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);
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);
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);
132 Loop updateAndSaveGlobalPropertiesJson(String loopName, JsonObject newGlobalPropertiesJson) {
133 Loop loop = findClosedLoopByName(loopName);
134 loop.setGlobalPropertiesJson(newGlobalPropertiesJson);
135 return loopsRepository.save(loop);
138 MicroServicePolicy updateMicroservicePolicy(String loopName, MicroServicePolicy newMicroservicePolicy) {
139 Loop loop = findClosedLoopByName(loopName);
140 return microservicePolicyService.getAndUpdateMicroServicePolicy(loop, newMicroservicePolicy);
143 private Loop findClosedLoopByName(String loopName) {
144 return loopsRepository.findById(loopName)
145 .orElseThrow(() -> new EntityNotFoundException("Couldn't find closed loop named: " + loopName));
149 * Api to refresh the Operational Policy UI window.
151 * @param loopName The loop Name
152 * @return The refreshed loop object
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();
160 loop.setOperationalPolicies(policyList);
161 return loopsRepository.save(loop);