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.dcae.main.handler;
  22
  23 import java.time.Instant;
  24 import java.util.UUID;
  25 import java.util.concurrent.TimeUnit;
  26 import lombok.Setter;
  27 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ClElementStatistics;
  28 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopElement;
  29 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopOrderedState;
  30 import org.onap.policy.clamp.controlloop.models.controlloop.concepts.ControlLoopState;
  31 import org.onap.policy.clamp.controlloop.participant.dcae.httpclient.ClampHttpClient;
  32 import org.onap.policy.clamp.controlloop.participant.dcae.httpclient.ConsulDcaeHttpClient;
  33 import org.onap.policy.clamp.controlloop.participant.dcae.model.Loop;
  34 import org.onap.policy.clamp.controlloop.participant.intermediary.api.ControlLoopElementListener;
  35 import org.onap.policy.clamp.controlloop.participant.intermediary.api.ParticipantIntermediaryApi;
  36 import org.onap.policy.models.base.PfModelException;
  37 import org.onap.policy.models.tosca.authorative.concepts.ToscaServiceTemplate;
  38 import org.slf4j.Logger;
  39 import org.slf4j.LoggerFactory;
  40 import org.springframework.stereotype.Component;
  41
  42 /**
  43  * This class handles implementation of controlLoopElement updates.
  44  */
  45 @Component
  46 public class ControlLoopElementHandler implements ControlLoopElementListener {
  47
  48     private static final Logger LOGGER = LoggerFactory.getLogger(ControlLoopElementHandler.class);
  49     private final ClampHttpClient clampClient;
  50     private final ConsulDcaeHttpClient consulClient;
  51
  52     @Setter
  53     private ParticipantIntermediaryApi intermediaryApi;
  54
  55     private static final String LOOP = "pmsh_loop";
  56     private static final String TEMPLATE = "LOOP_TEMPLATE_k8s_pmsh";
  57     private static final String POLICY = "policy";
  58
  59     private static final String BLUEPRINT_DEPLOYED = "BLUEPRINT_DEPLOYED";
  60     private static final String MICROSERVICE_INSTALLED_SUCCESSFULLY = "MICROSERVICE_INSTALLED_SUCCESSFULLY";
  61     private static final int CHECK_COUNT = 10;
  62
  63     private static final String BODY_CONSUL =
  64             "{ \"subscription\": { \"subscriptionName\": \"subscriptiona\", \"administrativeState\": \"UNLOCKED\", "
  65                     + "\"fileBasedGP\": 15, \"fileLocation\": \"/pm/pm.xml\", \"nfFilter\": "
  66                     + "{ \"nfNames\": [ \"^pnf1.*\" ], \"modelInvariantIDs\": "
  67                     + "[ \"5845y423-g654-6fju-po78-8n53154532k6\", \"7129e420-d396-4efb-af02-6b83499b12f8\" ], "
  68                     + "\"modelVersionIDs\": [ \"e80a6ae3-cafd-4d24-850d-e14c084a5ca9\" ] }, \"measurementGroups\": "
  69                     + "[ { \"measurementGroup\": { \"measurementTypes\": [ { \"measurementType\": \"countera\" }, "
  70                     + "{ \"measurementType\": \"counterb\" } ], \"managedObjectDNsBasic\": [ { \"DN\": \"dna\" }, "
  71                     + "{ \"DN\": \"dnb\" } ] } }, { \"measurementGroup\": { \"measurementTypes\": "
  72                     + "[ { \"measurementType\": \"counterc\" }, { \"measurementType\": \"counterd\" } ], "
  73                     + "\"managedObjectDNsBasic\": " + "[ { \"DN\": \"dnc\" }, { \"DN\": \"dnd\" } ] } } ] } }";
  74
  75     /**
  76      * Constructor.
  77      */
  78     public ControlLoopElementHandler(ClampHttpClient clampClient, ConsulDcaeHttpClient consulClient) {
  79         this.clampClient = clampClient;
  80         this.consulClient = consulClient;
  81     }
  82
  83     /**
  84      * Callback method to handle a control loop element state change.
  85      *
  86      * @param controlLoopElementId the ID of the control loop element
  87      * @param currentState the current state of the control loop element
  88      * @param newState the state to which the control loop element is changing to
  89      */
  90     @Override
  91     public void controlLoopElementStateChange(UUID controlLoopElementId, ControlLoopState currentState,
  92             ControlLoopOrderedState newState) {
  93         switch (newState) {
  94             case UNINITIALISED:
  95                 Loop loop = clampClient.getstatus(LOOP);
  96                 if (loop != null) {
  97                     clampClient.undeploy(LOOP);
  98                     intermediaryApi.updateControlLoopElementState(controlLoopElementId, newState,
  99                             ControlLoopState.UNINITIALISED);
 100                 }
 101                 break;
 102             case PASSIVE:
 103                 intermediaryApi.updateControlLoopElementState(controlLoopElementId, newState, ControlLoopState.PASSIVE);
 104                 break;
 105             case RUNNING:
 106                 intermediaryApi.updateControlLoopElementState(controlLoopElementId, newState, ControlLoopState.RUNNING);
 107                 break;
 108             default:
 109                 LOGGER.debug("Unknown orderedstate {}", newState);
 110                 break;
 111         }
 112     }
 113
 114     private Loop getStatus() throws PfModelException {
 115         Loop loop = clampClient.getstatus(LOOP);
 116         if (loop == null) {
 117             loop = clampClient.create(LOOP, TEMPLATE);
 118         }
 119         if (loop == null) {
 120             throw new PfModelException(null, "");
 121         }
 122         return loop;
 123     }
 124
 125     private void deploy() throws PfModelException {
 126         if (!consulClient.deploy(POLICY, BODY_CONSUL)) {
 127             throw new PfModelException(null, "deploy to consul failed");
 128         }
 129         if (!clampClient.deploy(LOOP)) {
 130             throw new PfModelException(null, "deploy failed");
 131         }
 132     }
 133
 134     /**
 135      * Callback method to handle an update on a control loop element.
 136      *
 137      * @param element the information on the control loop element
 138      * @param controlLoopDefinition toscaServiceTemplate
 139      * @throws PfModelException in case of an exception
 140      */
 141     @Override
 142     public void controlLoopElementUpdate(ControlLoopElement element, ToscaServiceTemplate controlLoopDefinition)
 143             throws PfModelException {
 144         try {
 145             Loop loop = getStatus();
 146
 147             if (BLUEPRINT_DEPLOYED.equals(ClampHttpClient.getStatusCode(loop))) {
 148                 deploy();
 149                 boolean deployedFlag = false;
 150                 for (int i = 0; i < CHECK_COUNT; i++) {
 151                     // sleep 10 seconds
 152                     TimeUnit.SECONDS.sleep(CHECK_COUNT);
 153                     loop = getStatus();
 154                     String status = ClampHttpClient.getStatusCode(loop);
 155                     if (MICROSERVICE_INSTALLED_SUCCESSFULLY.equals(status)) {
 156                         intermediaryApi.updateControlLoopElementState(element.getId(), element.getOrderedState(),
 157                                 ControlLoopState.PASSIVE);
 158                         deployedFlag = true;
 159                         break;
 160                     }
 161                 }
 162                 if (!deployedFlag) {
 163                     LOGGER.warn("DCAE is not deployed properly, ClElement state will be UNINITIALISED2PASSIVE");
 164                     intermediaryApi.updateControlLoopElementState(element.getId(), element.getOrderedState(),
 165                             ControlLoopState.UNINITIALISED2PASSIVE);
 166                 }
 167             }
 168         } catch (PfModelException e) {
 169             throw e;
 170         } catch (Exception e) {
 171             throw new PfModelException(null, e.getMessage(), e);
 172         }
 173     }
 174
 175     /**
 176      * Handle controlLoopElement statistics.
 177      *
 178      * @param controlLoopElementId controlloop element id
 179      */
 180     @Override
 181     public void handleStatistics(UUID controlLoopElementId) {
 182         ControlLoopElement clElement = intermediaryApi.getControlLoopElement(controlLoopElementId);
 183         if (clElement != null) {
 184             ClElementStatistics clElementStatistics = new ClElementStatistics();
 185             clElementStatistics.setControlLoopState(clElement.getState());
 186             clElementStatistics.setTimeStamp(Instant.now());
 187             intermediaryApi.updateControlLoopElementStatistics(controlLoopElementId, clElementStatistics);
 188         }
 189     }
 190 }