appc-lifecycle-management/appc-lifecycle-management-core/src/main/java/org/onap/appc/lifecyclemanager/impl/LifecycleManagerImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP : APPC
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Copyright (C) 2017 Amdocs
   8  * =============================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  *
  21  * ============LICENSE_END=========================================================
  22  */
  23
  24 package org.onap.appc.lifecyclemanager.impl;
  25
  26 import com.att.eelf.configuration.EELFLogger;
  27 import com.att.eelf.configuration.EELFManager;
  28 import com.att.eelf.i18n.EELFResourceManager;
  29 import org.onap.appc.exceptions.InvalidInputException;
  30 import org.onap.appc.i18n.Msg;
  31 import org.onap.appc.lifecyclemanager.LifecycleManager;
  32 import org.onap.appc.lifecyclemanager.objects.LifecycleException;
  33 import org.onap.appc.lifecyclemanager.objects.NoTransitionDefinedException;
  34 import org.onap.appc.statemachine.StateMachine;
  35 import org.onap.appc.statemachine.StateMetaDataReader;
  36 import org.onap.appc.statemachine.impl.StateMachineFactory;
  37 import org.onap.appc.statemachine.impl.readers.AppcOamMetaDataReader;
  38 import org.onap.appc.statemachine.impl.readers.VnfMetaDataReader;
  39 import org.onap.appc.statemachine.objects.*;
  40
  41 import java.util.Map;
  42 import java.util.concurrent.ConcurrentHashMap;
  43
  44 public class LifecycleManagerImpl implements LifecycleManager{
  45
  46     private StateMetaDataReader metadataReader;
  47     private static Map<String,StateMachine> stateMachineMap = new ConcurrentHashMap<>();
  48     private final EELFLogger logger = EELFManager.getInstance().getLogger(LifecycleManagerImpl.class);
  49     private final EELFLogger errorLogger = EELFManager.getInstance().getErrorLogger();
  50
  51     @Override
  52     public String getNextState(String vnfType, String currentState, String event) throws NoTransitionDefinedException,LifecycleException{
  53         if (logger.isTraceEnabled()) {
  54             logger.trace("Entering to getNextState with vnfType = "+ vnfType +    ", currentState = " + currentState + ", event = " + event);
  55         }
  56
  57         State nextState;
  58         StateMachine machine;
  59         StateMachineResponse response;
  60         try {
  61             machine = this.getStateMachine(vnfType);
  62             response = machine.handleEvent(new State(currentState),new Event(event));
  63             if(Response.NO_TRANSITION_DEFINED.equals(response.getResponse())){
  64                 errorLogger.error(EELFResourceManager.format(Msg.VF_ILLEGAL_COMMAND, vnfType,event,currentState));
  65                 throw new NoTransitionDefinedException("No Transition Defined for currentState = " +  currentState + ", event = " + event,currentState,event);
  66             }
  67             nextState = response.getNextState();
  68         } catch (InvalidInputException e) {
  69             logger.error(e.getMessage());
  70             throw new LifecycleException(e,currentState,event);
  71         }
  72         if (logger.isTraceEnabled()) {
  73             logger.trace("Exiting from getNextState with (nextState = " + nextState.getStateName() + ")");
  74         }
  75         return nextState.getStateName();
  76     }
  77
  78     private StateMachine getStateMachine(String vnfType) {
  79
  80         String vnfType1 = vnfType;
  81
  82         if (logger.isTraceEnabled()) {
  83             logger.trace("Entering to getNextState with vnfType = "+ vnfType1);
  84         }
  85         if(vnfType1 == null){
  86             vnfType1 = "DEFAULT";
  87         }
  88         StateMachine machine = stateMachineMap.get(vnfType1);
  89         if(machine == null){
  90             metadataReader = getMetadataReader(vnfType1);
  91             StateMachineMetadata metadata = metadataReader.readMetadata();
  92             machine = StateMachineFactory.getStateMachine(metadata);
  93             stateMachineMap.put(vnfType1,machine);
  94         }
  95
  96         logger.trace("Exiting getStateMachine with StateMachine = " + stateMachineMap.get(vnfType1).toString());
  97         return stateMachineMap.get(vnfType1);
  98     }
  99
 100     private StateMetaDataReader getMetadataReader(String vnfType) {
 101         return vnfType.equals("APPC") ? new AppcOamMetaDataReader() : new VnfMetaDataReader();
 102     }
 103
 104 }