src/main/java/org/onap/clamp/policy/microservice/MicroServicePolicyService.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.policy.microservice;
  25
  26 import java.util.List;
  27 import java.util.Set;
  28 import java.util.stream.Collectors;
  29 import org.onap.clamp.clds.tosca.update.ToscaConverterWithDictionarySupport;
  30 import org.onap.clamp.loop.Loop;
  31 import org.onap.clamp.policy.PolicyService;
  32 import org.springframework.beans.factory.annotation.Autowired;
  33 import org.springframework.stereotype.Service;
  34
  35 @Service
  36 public class MicroServicePolicyService implements PolicyService<MicroServicePolicy> {
  37
  38     private final MicroServicePolicyRepository microServiceRepository;
  39
  40     @Autowired
  41     public MicroServicePolicyService(MicroServicePolicyRepository microServiceRepository) {
  42         this.microServiceRepository = microServiceRepository;
  43     }
  44
  45     @Override
  46     public Set<MicroServicePolicy> updatePolicies(Loop loop, List<MicroServicePolicy> newMicroservicePolicies) {
  47         return newMicroservicePolicies.stream().map(policy -> getAndUpdateMicroServicePolicy(loop, policy))
  48                 .collect(Collectors.toSet());
  49     }
  50
  51     @Override
  52     public boolean isExisting(String policyName) {
  53         return microServiceRepository.existsById(policyName);
  54     }
  55
  56     /**
  57      * Get and update the MicroService policy properties.
  58      *
  59      * @param loop   The loop
  60      * @param policy The new MicroService policy
  61      * @return The updated MicroService policy
  62      */
  63     public MicroServicePolicy getAndUpdateMicroServicePolicy(Loop loop, MicroServicePolicy policy) {
  64         return microServiceRepository.save(
  65                 microServiceRepository
  66                         .findById(policy.getName()).map(p -> updateMicroservicePolicyProperties(p, policy, loop))
  67                         .orElse(new MicroServicePolicy(policy.getName(), policy.getPolicyModel(),
  68                                 policy.getShared(), policy.getJsonRepresentation(), null, policy.getPdpGroup(),
  69                                 policy.getPdpSubgroup())));
  70     }
  71
  72     private MicroServicePolicy updateMicroservicePolicyProperties(MicroServicePolicy oldPolicy,
  73                                                                   MicroServicePolicy newPolicy, Loop loop) {
  74         oldPolicy.setConfigurationsJson(newPolicy.getConfigurationsJson());
  75         if (!oldPolicy.getUsedByLoops().contains(loop)) {
  76             oldPolicy.getUsedByLoops().add(loop);
  77         }
  78         oldPolicy.setPdpGroup(newPolicy.getPdpGroup());
  79         oldPolicy.setPdpSubgroup(newPolicy.getPdpSubgroup());
  80         return oldPolicy;
  81     }
  82
  83     /**
  84      * Update the MicroService policy deployment related parameters.
  85      *
  86      * @param microServicePolicy The micro service policy
  87      * @param deploymentId       The deployment ID as returned by DCAE
  88      * @param deploymentUrl      The Deployment URL as returned by DCAE
  89      */
  90     public void updateDcaeDeploymentFields(MicroServicePolicy microServicePolicy, String deploymentId,
  91                                            String deploymentUrl) {
  92         microServicePolicy.setDcaeDeploymentId(deploymentId);
  93         microServicePolicy.setDcaeDeploymentStatusUrl(deploymentUrl);
  94         microServiceRepository.save(microServicePolicy);
  95     }
  96
  97
  98     /**
  99      * Api to refresh the MicroService Policy UI window.
 100      *
 101      * @param microServicePolicy The micro Service policy object
 102      * @param toscaConverter     the tosca converter required to convert the tosca model to json schema
 103      */
 104     public void refreshMicroServicePolicyJsonRepresentation(MicroServicePolicy microServicePolicy,
 105                                                             ToscaConverterWithDictionarySupport toscaConverter) {
 106         microServicePolicy.updateJsonRepresentation(toscaConverter);
 107         this.microServiceRepository.saveAndFlush(microServicePolicy);
 108
 109     }
 110 }