src/main/java/org/onap/clamp/policy/operational/OperationalPolicyService.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.operational;
  25
  26 import java.util.List;
  27 import java.util.Set;
  28 import java.util.stream.Collectors;
  29 import org.onap.clamp.loop.Loop;
  30 import org.onap.clamp.loop.template.PolicyModelsRepository;
  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 OperationalPolicyService implements PolicyService<OperationalPolicy> {
  37
  38     private final OperationalPolicyRepository operationalPolicyRepository;
  39
  40     private final PolicyModelsRepository policyModelsRepository;
  41
  42     @Autowired
  43     public OperationalPolicyService(OperationalPolicyRepository repository,
  44                                     PolicyModelsRepository policyModelsRepository) {
  45         this.operationalPolicyRepository = repository;
  46         this.policyModelsRepository = policyModelsRepository;
  47     }
  48
  49     @Override
  50     public Set<OperationalPolicy> updatePolicies(Loop loop, List<OperationalPolicy> operationalPolicies) {
  51         return operationalPolicies
  52                 .parallelStream()
  53                 .map(policy ->
  54                         operationalPolicyRepository
  55                                 .findById(policy.getName())
  56                                 .map(p -> setConfiguration(p, policy))
  57                                 .orElse(initializeMissingFields(loop,policy)))
  58                 .collect(Collectors.toSet());
  59     }
  60
  61     @Override
  62     public boolean isExisting(String policyName) {
  63         return operationalPolicyRepository.existsById(policyName);
  64     }
  65
  66     private OperationalPolicy initializeMissingFields(Loop loop, OperationalPolicy policy) {
  67         policy.setLoop(loop);
  68         return policy;
  69     }
  70
  71     private OperationalPolicy setConfiguration(OperationalPolicy policy, OperationalPolicy newPolicy) {
  72         policy.setConfigurationsJson(newPolicy.getConfigurationsJson());
  73         policy.setPdpGroup(newPolicy.getPdpGroup());
  74         policy.setPdpSubgroup(newPolicy.getPdpSubgroup());
  75         return policy;
  76     }
  77 }