gerrit.onap Code Review - policy/clamp.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2021 Nordix Foundation.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.clamp.controlloop.participant.http.main.handler;
  22
  23 import java.io.Closeable;
  24 import java.io.IOException;
  25 import java.lang.invoke.MethodHandles;
  26 import java.util.Map;
  27 import java.util.Set;
  28 import java.util.UUID;
  29 import java.util.concurrent.ConcurrentHashMap;
  30 import java.util.concurrent.ExecutorService;
  31 import java.util.concurrent.Executors;
  32 import javax.validation.ConstraintViolation;
  33 import javax.validation.Validation;
  34 import javax.validation.ValidationException;
  35 import lombok.Getter;
  36 import lombok.Setter;
  37 import org.apache.commons.lang3.tuple.Pair;
  38 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopElement;
  39 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState;
  40 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopState;
  41 import org.onap.policy.clamp.controlloop.participant.http.main.models.ConfigRequest;
  42 import org.onap.policy.clamp.controlloop.participant.http.main.webclient.ClHttpClient;
  43 import org.onap.policy.clamp.controlloop.participant.intermediary.api.ControlLoopElementListener;
  44 import org.onap.policy.clamp.controlloop.participant.intermediary.api.ParticipantIntermediaryApi;
  45 import org.onap.policy.common.utils.coder.Coder;
  46 import org.onap.policy.common.utils.coder.CoderException;
  47 import org.onap.policy.common.utils.coder.StandardCoder;
  48 import org.onap.policy.models.base.PfModelException;
  49 import org.onap.policy.models.tosca.authorative.concepts.ToscaConceptIdentifier;
  50 import org.onap.policy.models.tosca.authorative.concepts.ToscaNodeTemplate;
  51 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  52 import org.slf4j.Logger;
  53 import org.slf4j.LoggerFactory;
  54 import org.springframework.stereotype.Component;
  55
  56 /**
  57  * This class handles implementation of controlLoopElement updates.
  58  */
  59 @Component
  60 public class ControlLoopElementHandler implements ControlLoopElementListener, Closeable {
  61
  62     private static final Coder CODER = new StandardCoder();
  63
  64     private static final Logger LOGGER = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
  65
  66     private ExecutorService executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
  67
  68     private Map<ToscaConceptIdentifier, Pair<Integer, String>> restResponseMap = new ConcurrentHashMap<>();
  69
  70     @Setter
  71     private ParticipantIntermediaryApi intermediaryApi;
  72
  73     /**
  74      * Handle controlLoopElement statistics.
  75      *
  76      * @param controlLoopElementId controlloop element id
  77      */
  78     @Override
  79     public void handleStatistics(UUID controlLoopElementId) throws PfModelException {
  80         // Implementation not needed for http participant
  81
  82     }
  83
  84     /**
  85      * Handle a control loop element state change.
  86      *
  87      * @param controlLoopElementId the ID of the control loop element
  88      * @param currentState         the current state of the control loop element
  89      * @param newState             the state to which the control loop element is changing to
  90      * @throws PfModelException in case of a model exception
  91      */
  92     @Override
  93     public void controlLoopElementStateChange(UUID controlLoopElementId, ControlLoopState currentState,
  94                                               ControlLoopOrderedState newState) throws PfModelException {
  95         // Implementation not needed for http participant
  96     }
  97
  98     /**
  99      * Callback method to handle an update on a control loop element.
 100      *
 101      * @param element the information on the control loop element
 102      * @param controlLoopDefinition toscaServiceTemplate
 103      */
 104     @Override
 105     public void controlLoopElementUpdate(ControlLoopElement element, ToscaServiceTemplate controlLoopDefinition) {
 106
 107         for (Map.Entry<String, ToscaNodeTemplate> nodeTemplate : controlLoopDefinition.getToscaTopologyTemplate()
 108             .getNodeTemplates().entrySet()) {
 109             // Fetching the node template of corresponding CL element
 110             if (element.getDefinition().getName().equals(nodeTemplate.getKey())) {
 111                 try {
 112                     var configRequest = CODER.convert(nodeTemplate.getValue().getProperties(), ConfigRequest.class);
 113                     Set<ConstraintViolation<ConfigRequest>> violations = Validation.buildDefaultValidatorFactory()
 114                         .getValidator().validate(configRequest);
 115                     if (violations.isEmpty()) {
 116                         invokeHttpClient(configRequest);
 117                     } else {
 118                         LOGGER.error("Violations found in the config request parameters: {}", violations);
 119                         throw new ValidationException("Constraint violations in the config request");
 120                     }
 121                 } catch (CoderException | ValidationException e) {
 122                     LOGGER.error("Error invoking the http request for the config ", e);
 123                 }
 124             }
 125         }
 126     }
 127
 128     /**
 129      * Invoke a runnable thread to execute http requests.
 130      * @param configRequest ConfigRequest
 131      */
 132     public void invokeHttpClient(ConfigRequest configRequest) {
 133         // Invoke runnable thread to execute https requests of all config entities
 134         executor.execute(new ClHttpClient(configRequest, restResponseMap));
 135     }
 136
 137     /**
 138      * Closes this stream and releases any system resources associated
 139      * with it. If the stream is already closed then invoking this
 140      * method has no effect.
 141      *
 142      * @throws IOException if an I/O error occurs
 143      */
 144     @Override
 145     public void close() throws IOException {
 146         executor.shutdown();
 147     }
 148 }