gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Ericsson. All rights reserved.
   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 package org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks;
  21
  22 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.CREATE_VNF_NODE_STATUS;
  23 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.DELETE_VNF_NODE_STATUS;
  24 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.VNF_ASSIGNED;
  25 import static org.onap.so.bpmn.infrastructure.adapter.vnfm.tasks.Constants.VNF_CREATED;
  26 import static org.onap.so.bpmn.servicedecomposition.entities.ResourceKey.GENERIC_VNF_ID;
  27 import org.onap.aai.domain.yang.GenericVnf;
  28 import org.onap.so.bpmn.common.BuildingBlockExecution;
  29 import org.onap.so.bpmn.servicedecomposition.tasks.ExtractPojosForBB;
  30 import org.onap.so.client.exception.ExceptionBuilder;
  31 import org.slf4j.Logger;
  32 import org.slf4j.LoggerFactory;
  33 import org.springframework.beans.factory.annotation.Autowired;
  34 import org.springframework.stereotype.Component;
  35
  36
  37 /**
  38  *
  39  * @author Lathishbabu Ganesan (lathishbabu.ganesan@est.tech)
  40  *
  41  */
  42 @Component
  43 public class MonitorVnfmNodeTask {
  44
  45   private static final Logger LOGGER = LoggerFactory.getLogger(MonitorVnfmNodeTask.class);
  46
  47   private final ExtractPojosForBB extractPojosForBB;
  48   private final ExceptionBuilder exceptionUtil;
  49
  50   @Autowired
  51   public MonitorVnfmNodeTask(final ExtractPojosForBB extractPojosForBB, final ExceptionBuilder exceptionUtil) {
  52     this.exceptionUtil = exceptionUtil;
  53     this.extractPojosForBB = extractPojosForBB;
  54   }
  55
  56   /**
  57    * Check the final status of vnf in A&AI
  58    *
  59    * @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
  60    */
  61   public void getNodeStatus(final BuildingBlockExecution execution) {
  62     try {
  63       LOGGER.debug("Executing getNodeStatus  ...");
  64       final GenericVnf vnf = extractPojosForBB.extractByKey(execution, GENERIC_VNF_ID);
  65       String orchestrationStatus = vnf.getOrchestrationStatus();
  66       LOGGER.debug("Orchestration Status in AAI {}", orchestrationStatus);
  67       execution.setVariable(CREATE_VNF_NODE_STATUS, VNF_CREATED.equalsIgnoreCase(orchestrationStatus));
  68       execution.setVariable(DELETE_VNF_NODE_STATUS, VNF_ASSIGNED.equalsIgnoreCase(orchestrationStatus));
  69     } catch (final Exception exception) {
  70       LOGGER.error("Unable to get vnf from AAI", exception);
  71       exceptionUtil.buildAndThrowWorkflowException(execution, 1220, exception);
  72     }
  73   }
  74
  75   /**
  76    * Log and throw exception on timeout for job status
  77    *
  78    * @param execution {@link org.onap.so.bpmn.common.DelegateExecutionImpl}
  79    */
  80   public void timeOutLogFailue(final BuildingBlockExecution execution) {
  81     final String message = "Node operation time out";
  82     LOGGER.error(message);
  83     exceptionUtil.buildAndThrowWorkflowException(execution, 1221, message);
  84   }
  85 }