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.io.IOException;
28 import java.util.List;
30 import javax.persistence.EntityNotFoundException;
31 import org.onap.clamp.clds.tosca.update.ToscaConverterWithDictionarySupport;
32 import org.onap.clamp.loop.template.LoopTemplatesService;
33 import org.onap.clamp.loop.template.PolicyModel;
34 import org.onap.clamp.loop.template.PolicyModelsService;
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;
61 private ToscaConverterWithDictionarySupport toscaConverter;
63 Loop saveOrUpdateLoop(Loop loop) {
64 return loopsRepository.save(loop);
67 List<String> getClosedLoopNames() {
68 return loopsRepository.getAllLoopNames();
71 public Loop getLoop(String loopName) {
72 return loopsRepository.findById(loopName).orElse(null);
75 public void deleteLoop(String loopName) {
76 loopsRepository.deleteById(loopName);
80 * Creates a Loop Instance from Loop Template Name.
82 * @param loopName Name of the Loop to be created
83 * @param templateName Loop Template to used for Loop
84 * @return Loop Instance
86 public Loop createLoopFromTemplate(String loopName, String templateName) {
87 return loopsRepository
88 .save(new Loop(loopName, loopTemplateService.getLoopTemplate(templateName), toscaConverter));
92 * This method is used to refresh the DCAE deployment status fields.
94 * @param loop The loop instance to be modified
95 * @param deploymentId The deployment ID as returned by DCAE
96 * @param deploymentUrl The Deployment URL as returned by DCAE
98 public void updateDcaeDeploymentFields(Loop loop, String deploymentId, String deploymentUrl) {
99 loop.setDcaeDeploymentId(deploymentId);
100 loop.setDcaeDeploymentStatusUrl(deploymentUrl);
101 loopsRepository.saveAndFlush(loop);
104 public void updateLoopState(Loop loop, String newState) {
105 loop.setLastComputedState(LoopState.valueOf(newState));
106 loopsRepository.save(loop);
110 * This method add an operational policy to a loop instance.
111 * This creates an operational policy from the policy model info and not the loop element model
113 * @param loopName The loop name
114 * @param policyType The policy model type
115 * @param policyVersion The policy model version
116 * @return The loop modified
118 Loop addOperationalPolicy(String loopName, String policyType, String policyVersion) throws IOException {
119 Loop loop = getLoop(loopName);
120 PolicyModel policyModel = policyModelsService.getPolicyModel(policyType, policyVersion);
121 Set<OperationalPolicy> opPolicySet = loop.getOperationalPolicies();
122 for (OperationalPolicy opPolicy : opPolicySet) {
123 if (opPolicy.getPolicyModel().equals(policyModel)) {
124 throw new IllegalArgumentException("This type of Operational Policy is already added to the loop. Please choose another one.");
127 if (policyModel == null) {
130 loop.addOperationalPolicy(
131 new OperationalPolicy(loop, loop.getModelService(), policyModel, toscaConverter));
132 return loopsRepository.saveAndFlush(loop);
136 * This method remove an operational policy to a loop instance.
138 * @param loopName The loop name
139 * @param policyType The policy model type
140 * @param policyVersion The policy model version
141 * @return The loop modified
143 Loop removeOperationalPolicy(String loopName, String policyType, String policyVersion) {
144 Loop loop = getLoop(loopName);
145 PolicyModel policyModel = policyModelsService.getPolicyModel(policyType, policyVersion);
146 if (policyModel == null) {
149 for (OperationalPolicy opPolicy : loop.getOperationalPolicies()) {
150 if (opPolicy.getPolicyModel().getPolicyModelType().equals(policyType)
151 && opPolicy.getPolicyModel().getVersion().equals(policyVersion)) {
152 loop.removeOperationalPolicy(opPolicy);
156 return loopsRepository.saveAndFlush(loop);
159 Loop updateAndSaveOperationalPolicies(String loopName, List<OperationalPolicy> newOperationalPolicies) {
160 Loop loop = findClosedLoopByName(loopName);
161 Set<OperationalPolicy> newPolicies = operationalPolicyService.updatePolicies(loop, newOperationalPolicies);
162 loop.setOperationalPolicies(newPolicies);
163 return loopsRepository.save(loop);
166 Loop updateAndSaveMicroservicePolicies(String loopName, List<MicroServicePolicy> newMicroservicePolicies) {
167 Loop loop = findClosedLoopByName(loopName);
168 Set<MicroServicePolicy> newPolicies = microservicePolicyService.updatePolicies(loop, newMicroservicePolicies);
169 loop.setMicroServicePolicies(newPolicies);
170 return loopsRepository.save(loop);
173 Loop updateAndSaveGlobalPropertiesJson(String loopName, JsonObject newGlobalPropertiesJson) {
174 Loop loop = findClosedLoopByName(loopName);
175 loop.setGlobalPropertiesJson(newGlobalPropertiesJson);
176 return loopsRepository.save(loop);
179 MicroServicePolicy updateMicroservicePolicy(String loopName, MicroServicePolicy newMicroservicePolicy) {
180 Loop loop = findClosedLoopByName(loopName);
181 return microservicePolicyService.getAndUpdateMicroServicePolicy(loop, newMicroservicePolicy);
184 private Loop findClosedLoopByName(String loopName) {
185 return loopsRepository.findById(loopName)
186 .orElseThrow(() -> new EntityNotFoundException("Couldn't find closed loop named: " + loopName));