1 files changed, 0 insertions, 626 deletions
diff --git a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/VnfInPlaceUpdate.groovy b/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/VnfInPlaceUpdate.groovy
deleted file mode 100644
index 64894563bf..0000000000
--- a/bpmn/MSOInfrastructureBPMN/src/main/groovy/org/openecomp/mso/bpmn/infrastructure/scripts/VnfInPlaceUpdate.groovy
+++ /dev/null
@@ -1,626 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.mso.bpmn.infrastructure.scripts
-
-import groovy.json.JsonOutput
-import groovy.json.JsonSlurper
-import groovy.util.Node
-import groovy.util.XmlParser;
-import groovy.xml.QName
-
-import java.io.Serializable;
-import java.util.UUID;
-import org.openecomp.mso.bpmn.common.scripts.ExceptionUtil
-import org.camunda.bpm.engine.delegate.BpmnError
-import org.camunda.bpm.engine.impl.cmd.AbstractSetVariableCmd
-import org.camunda.bpm.engine.delegate.DelegateExecution
-import org.openecomp.mso.rest.APIResponse
-import org.openecomp.mso.rest.RESTClient
-import org.openecomp.mso.rest.RESTConfig
-import org.openecomp.mso.bpmn.common.scripts.AbstractServiceTaskProcessor;
-import org.openecomp.mso.bpmn.common.scripts.VidUtils;
-import org.openecomp.mso.bpmn.core.RollbackData
-import org.openecomp.mso.bpmn.core.WorkflowException
-import org.openecomp.mso.bpmn.core.json.JsonUtils
-import org.openecomp.mso.bpmn.core.domain.ModelInfo
-import org.openecomp.mso.bpmn.core.domain.ServiceDecomposition
-import org.openecomp.mso.bpmn.core.domain.VnfResource
-import org.openecomp.mso.client.aai.*
-
-import org.openecomp.mso.client.appc.ApplicationControllerClient;
-import org.openecomp.mso.client.appc.ApplicationControllerSupport;
-import org.openecomp.mso.client.aai.AAIResourcesClient
-import org.openecomp.mso.client.aai.entities.AAIResultWrapper
-import org.openecomp.mso.client.aai.entities.uri.AAIUri
-import org.openecomp.mso.client.aai.entities.uri.AAIUriFactory
-import org.onap.appc.client.lcm.model.Action;
-import org.onap.appc.client.lcm.model.ActionIdentifiers;
-import org.onap.appc.client.lcm.model.LockInput
-import org.onap.appc.client.lcm.model.UnlockInput
-import org.onap.appc.client.lcm.model.HealthCheckInput
-import org.onap.appc.client.lcm.model.StartInput
-import org.onap.appc.client.lcm.model.StopInput
-import org.onap.appc.client.lcm.model.Flags
-import org.onap.appc.client.lcm.model.Status
-
-
-
-public class VnfInPlaceUpdate extends VnfCmBase {
-
-	ExceptionUtil exceptionUtil = new ExceptionUtil()
-	JsonUtils jsonUtils = new JsonUtils()	
-	def prefix = "VnfIPU_"
-
-	/**
-	 * Initialize the flow's variables.
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void initProcessVariables(DelegateExecution execution) {
-		execution.setVariable('prefix', 'VnfIPU_')
-		execution.setVariable('Request', null)
-		execution.setVariable('requestInfo', null)		
-		execution.setVariable('source', null)
-		execution.setVariable('vnfInputs', null)	
-		execution.setVariable('tenantId', null)		
-		execution.setVariable('vnfParams', null)
-		execution.setVariable('controllerType', null)		
-		execution.setVariable('UpdateVnfSuccessIndicator', false)
-		execution.setVariable('serviceType', null)
-		execution.setVariable('nfRole', null)
-		execution.setVariable('currentActivity', 'VnfIPU')
-		execution.setVariable('workStep', null)
-		execution.setVariable('failedActivity', null)
-		execution.setVariable('errorCode', "0")
-		execution.setVariable('errorText', null)
-		execution.setVariable('healthCheckIndex0', 0)
-		execution.setVariable('healthCheckIndex1', 1)
-		execution.setVariable('maxRetryCount', 3)
-		execution.setVariable("rollbackSetClosedLoopDisabledFlag", false)
-		execution.setVariable("rollbackVnfStop", false)
-		execution.setVariable("rollbackVnfLock", false)
-		execution.setVariable("rollbackQuiesceTraffic", false)
-		execution.setVariable("rollbackSetVnfInMaintenanceFlag", false)		
-	}
-
-	/**
-	 * Check for missing elements in the received request.
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void preProcessRequest(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.preProcessRequest(' +
-		'execution=' + execution.getId() +
-		')'
-		initProcessVariables(execution)
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		logDebug('Entered ' + method, isDebugLogEnabled)
-
-		initProcessVariables(execution)		
-
-		def incomingRequest = execution.getVariable('bpmnRequest')
-
-		utils.log("DEBUG", "Incoming Infra Request: " + incomingRequest, isDebugLogEnabled)
-		try {
-			def jsonSlurper = new JsonSlurper()
-			def jsonOutput = new JsonOutput()
-			Map reqMap = jsonSlurper.parseText(incomingRequest)
-			utils.log("DEBUG", " Request is in JSON format.", isDebugLogEnabled)
-
-			def serviceInstanceId = execution.getVariable('serviceInstanceId')
-			def vnfId = execution.getVariable('vnfId')
-			
-			execution.setVariable('serviceInstanceId', serviceInstanceId)
-			execution.setVariable('vnfId', vnfId)
-			execution.setVariable("isVidRequest", "true")
-			execution.setVariable('serviceType', 'Mobility')
-			execution.setVariable('payload', "")
-			execution.setVariable('actionSnapshot', Action.Snapshot)
-			execution.setVariable('actionLock', Action.Lock)
-			execution.setVariable('actionUnlock', Action.Unlock)			
-			execution.setVariable('actionUpgradePreCheck', Action.UpgradePreCheck)
-			execution.setVariable('actionUpgradePostCheck', Action.UpgradePostCheck)
-			execution.setVariable('actionQuiesceTraffic', Action.QuiesceTraffic)
-			execution.setVariable('actionUpgradeBackup', Action.UpgradeBackup)
-			execution.setVariable('actionUpgradeSoftware', Action.UpgradeSoftware)
-			execution.setVariable('actionResumeTraffic', Action.ResumeTraffic)
-			
-			def controllerType = reqMap.requestDetails?.requestParameters?.controllerType
-			execution.setVariable('controllerType', controllerType)
-			
-			utils.log("DEBUG", 'Controller Type: ' + controllerType, isDebugLogEnabled)
-		
-			def payload = reqMap.requestDetails?.requestParameters?.payload
-			execution.setVariable('payload', payload)
-			
-			utils.log("DEBUG", 'Processed payload: ' + payload, isDebugLogEnabled)			
-					
-						
-			def requestId = execution.getVariable("mso-request-id")
-			execution.setVariable('requestId', requestId)
-			execution.setVariable('msoRequestId', requestId)
-			
-			def requestorId = reqMap.requestDetails?.requestInfo?.requestorId ?: null
-			execution.setVariable('requestorId', requestorId)
-								
-			def cloudConfiguration = reqMap.requestDetails?.cloudConfiguration
-			def lcpCloudRegionId	= cloudConfiguration.lcpCloudRegionId
-			execution.setVariable('lcpCloudRegionId', lcpCloudRegionId)
-			def tenantId = cloudConfiguration.tenantId
-			execution.setVariable('tenantId', tenantId)			
-
-			execution.setVariable("UpdateVnfInfraSuccessIndicator", false)
-						
-			execution.setVariable("isDebugLogEnabled", isDebugLogEnabled)			
-			
-			def source = reqMap.requestDetails?.requestInfo?.source
-			execution.setVariable("source", source)
-			
-			//For Completion Handler & Fallout Handler
-			String requestInfo =
-			"""<request-info xmlns="http://org.openecomp/mso/infra/vnf-request/v1">
-					<request-id>${requestId}</request-id>
-					<action>UPDATE</action>
-					<source>${source}</source>
-				   </request-info>"""
-			
-			execution.setVariable("requestInfo", requestInfo)			
-			
-			logDebug('RequestInfo: ' + execution.getVariable("requestInfo"), isDebugLogEnabled)		
-			
-			logDebug('Exited ' + method, isDebugLogEnabled)
-
-		}
-		catch(groovy.json.JsonException je) {
-			utils.log("DEBUG", " Request is not in JSON format.", isDebugLogEnabled)
-			exceptionUtil.buildAndThrowWorkflowException(execution, 5000, "Invalid request format")
-
-		}
-		catch(Exception e) {
-			String restFaultMessage = e.getMessage()
-			utils.log("ERROR", " Exception Encountered - " + "\n" + restFaultMessage, isDebugLogEnabled)
-			exceptionUtil.buildAndThrowWorkflowException(execution, 5000, restFaultMessage)
-		}	
-	}
-
-	/**
-	 * Prepare and send the sychronous response for this flow.
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void sendSynchResponse(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.sendSynchResponse(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		logDebug('Entered ' + method, isDebugLogEnabled)
-
-
-		try {
-			def requestInfo = execution.getVariable('requestInfo')
-			def requestId = execution.getVariable('requestId')
-			def source = execution.getVariable('source')
-			def progress = getNodeTextForce(requestInfo, 'progress')
-			if (progress.isEmpty()) {
-				progress = '0'
-			}
-			def startTime = getNodeTextForce(requestInfo, 'start-time')
-			if (startTime.isEmpty()) {
-				startTime = System.currentTimeMillis()
-			}
-
-			// RESTResponse (for API Handler (APIH) Reply Task)
-			def vnfId = execution.getVariable("vnfId")
-			String synchResponse = """{"requestReferences":{"instanceId":"${vnfId}","requestId":"${requestId}"}}""".trim()
-
-			sendWorkflowResponse(execution, 200, synchResponse)
-
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			throw e;
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)
-			exceptionUtil.buildAndThrowWorkflowException(execution, 1002, 'Error in sendResponse(): ' + e.getMessage())
-		}
-	}
-
-	
-	/**
-	 * Check if this VNF is already in maintenance in A&AI.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void checkIfVnfInMaintInAAI(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.checkIfVnfInMaintInAAI(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		execution.setVariable('errorCode', "0")
-		execution.setVariable("workStep", "checkIfVnfInMaintInAAI")
-		execution.setVariable("failedActivity", "AAI")
-		logDebug('Entered ' + method, isDebugLogEnabled)
-
-		try {
-			def transactionLoggingUuid = UUID.randomUUID().toString()
-			AAIRestClientImpl client = new AAIRestClientImpl()
-			AAIValidatorImpl aaiValidator = new AAIValidatorImpl()
-			aaiValidator.setClient(client)
-			def vnfId = execution.getVariable("vnfId")
-			boolean isInMaint = aaiValidator.isVNFLocked(vnfId, transactionLoggingUuid)
-			logDebug("isInMaint result: " + isInMaint, isDebugLogEnabled)
-			execution.setVariable('isVnfInMaintenance', isInMaint)
-			
-			if (isInMaint) {
-				execution.setVariable("errorCode", "1003")
-				execution.setVariable("errorText", "VNF is in maintenance in A&AI")
-			}
-
-
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			throw e;
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)			
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())
-			//exceptionUtil.buildAndThrowWorkflowException(execution, 1002, 'Error in checkIfVnfInMaintInAAI(): ' + e.getMessage())
-		}
-	}
-	
-	
-	/**
-	 * Check if this VNF's pservers are locked in A&AI.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void checkIfPserversInMaintInAAI(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.checkIfPserversInMaintInAAI(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		execution.setVariable('errorCode', "0")
-		logDebug('Entered ' + method, isDebugLogEnabled)
-		execution.setVariable("workStep", "checkIfPserversInMaintInAAI")
-		execution.setVariable("failedActivity", "AAI")
-
-		try {
-			def transactionLoggingUuid = UUID.randomUUID().toString()
-			AAIRestClientImpl client = new AAIRestClientImpl()
-			AAIValidatorImpl aaiValidator = new AAIValidatorImpl()
-			aaiValidator.setClient(client)
-			def vnfId = execution.getVariable("vnfId")			
-			boolean areLocked = aaiValidator.isPhysicalServerLocked(vnfId, transactionLoggingUuid)
-			logDebug("areLocked result: " + areLocked, isDebugLogEnabled)
-			execution.setVariable('arePserversLocked', areLocked)
-			
-			if (areLocked) {
-				execution.setVariable("errorCode", "1003")
-				execution.setVariable("errorText", "pServers are locked in A&AI")
-			}			
-
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			throw e;
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())
-			//exceptionUtil.buildAndThrowWorkflowException(execution, 1002, 'Error in checkIfPserversInMaintInAAI(): ' + e.getMessage())
-		}
-	}
-	
-	/**
-	 * Set inMaint flag for this VNF to the specified value in A&AI.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 * @param inMaint The boolean value of the flag to set
-	 */
-	public void setVnfInMaintFlagInAAI(DelegateExecution execution, boolean inMaint) {
-		def method = getClass().getSimpleName() + '.setVnfInMaintFlagInAAI(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		execution.setVariable('errorCode', "0")
-		logDebug('Entered ' + method, isDebugLogEnabled)
-		if (inMaint) {
-			execution.setVariable("workStep", "setVnfInMaintFlagInAAI")
-		}
-		else {
-			execution.setVariable("workStep", "unsetVnfInMaintFlagInAAI")
-		}
-		execution.setVariable("failedActivity", "AAI")
-
-		try {
-			def transactionLoggingUuid = UUID.randomUUID().toString()
-			AAIRestClientImpl client = new AAIRestClientImpl()
-			AAIUpdatorImpl aaiUpdator = new AAIUpdatorImpl()
-			aaiUpdator.setClient(client)
-			def vnfId = execution.getVariable("vnfId")
-			if (inMaint) {
-				aaiUpdator.updateVnfToLocked(vnfId, transactionLoggingUuid)
-				execution.setVariable("rollbackSetVnfInMaintenanceFlag", true)
-			}
-			else {
-				aaiUpdator.updateVnfToUnLocked(vnfId, transactionLoggingUuid)				
-			}
-							
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			throw e;
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())
-			//exceptionUtil.buildAndThrowWorkflowException(execution, 1002, 'Error in setVnfInMaintFlagInAAI(): ' + e.getMessage())
-		}
-	}
-	
-	/**
-	 * Check if VF Closed Loop Disabled in A&AI.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void checkIfClosedLoopDisabledInAAI(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.checkIfClosedLoopDisabledInAAI(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		execution.setVariable('errorCode', "0")
-		execution.setVariable("workStep", "checkClosedLoopDisabledFlagInAAI")
-		execution.setVariable("failedActivity", "AAI")
-		logDebug('Entered ' + method, isDebugLogEnabled)
-
-		try {
-			def transactionLoggingUuid = UUID.randomUUID().toString()			
-			def vnfId = execution.getVariable("vnfId")
-			logDebug("vnfId is: " + vnfId, isDebugLogEnabled)
-			AAIResourcesClient client = new AAIResourcesClient()			
-			AAIUri genericVnfUri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId)
-			AAIResultWrapper aaiRW = client.get(genericVnfUri)
-			Map<String, Object> result = aaiRW.asMap()
-			boolean isClosedLoopDisabled = result.getOrDefault("is-closed-loop-disabled", false)
-		
-			logDebug("isClosedLoopDisabled result: " + isClosedLoopDisabled, isDebugLogEnabled)
-			execution.setVariable('isClosedLoopDisabled', isClosedLoopDisabled)
-			
-			if (isClosedLoopDisabled) {
-				execution.setVariable("errorCode", "1004")
-				execution.setVariable("errorText", "closedLoop is disabled in A&AI")
-			}
-
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			throw e;
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())		
-		}
-	}
-	
-	/**
-	 * Set VF Closed Loop Disabled Flag in A&AI.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void setClosedLoopDisabledInAAI(DelegateExecution execution, boolean setDisabled) {
-		def method = getClass().getSimpleName() + '.setClosedLoopDisabledInAAI(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		execution.setVariable('errorCode', "0")
-		if (setDisabled) {
-			execution.setVariable("workStep", "setClosedLoopDisabledFlagInAAI")
-			execution.setVariable("rollbackSetClosedLoopDisabledFlag", true)
-		}
-		else {
-			execution.setVariable("workStep", "unsetClosedLoopDisabledFlagInAAI")
-		}
-		
-		execution.setVariable("failedActivity", "AAI")
-		logDebug('Entered ' + method, isDebugLogEnabled)
-
-		try {
-			def transactionLoggingUuid = UUID.randomUUID().toString()
-			def vnfId = execution.getVariable("vnfId")
-			AAIResourcesClient client = new AAIResourcesClient()			
-			AAIUri genericVnfUri = AAIUriFactory.createResourceUri(AAIObjectType.GENERIC_VNF, vnfId)
-			
-			Map<String, Boolean> request = new HashMap<>()
-			request.put("is-closed-loop-disabled", setDisabled)
-			client.update(genericVnfUri, request)
-			logDebug("set isClosedLoop to: " + setDisabled, isDebugLogEnabled)		
-
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			throw e;
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())			
-		}
-	}
-	
-	
-	
-	
-	/**
-	 * Call APP-C client to execute specified APP-C command for this VNF.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 * @param action The action to take in APP-C.
-	 */
-	public void runAppcCommand(DelegateExecution execution, Action action) {
-		def method = getClass().getSimpleName() + '.runAppcCommand(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		execution.setVariable('errorCode', "0")
-		logDebug('Entered ' + method, isDebugLogEnabled)
-		
-		ApplicationControllerClient appcClient = null
-		
-		try {
-			logDebug("Running APP-C action: " + action.toString(), isDebugLogEnabled)
-			String vnfId = execution.getVariable('vnfId')
-			String msoRequestId = execution.getVariable('requestId')
-			execution.setVariable('msoRequestId', msoRequestId)			
-			execution.setVariable("failedActivity", "APP-C")
-			
-			appcClient = new ApplicationControllerClient()				
-			ApplicationControllerSupport support = new ApplicationControllerSupport()			
-			appcClient.appCSupport=support			
-			org.springframework.test.util.ReflectionTestUtils.setField(support, "lcmModelPackage", "org.onap.appc.client.lcm.model");			
-			Flags flags = new Flags();			
-			ActionIdentifiers actionIdentifiers = new ActionIdentifiers();			
-			actionIdentifiers.setVnfId(vnfId);
-			Status appcStatus
-			switch(action) {
-				case Action.Lock:
-					execution.setVariable('workStep', "LockVNF")
-					appcStatus = appcClient.runCommand(Action.Lock,actionIdentifiers,null,msoRequestId)					
-					break
-				case Action.Unlock:
-					execution.setVariable('workStep', "UnlockVNF")
-					appcStatus = appcClient.runCommand(Action.Unlock,actionIdentifiers,null,msoRequestId)					
-					break
-				case Action.HealthCheck:
-					def healthCheckIndex = execution.getVariable('healthCheckIndex')
-					execution.setVariable('workStep', "HealthCheckVNF" + healthCheckIndex)
-					execution.setVariable('healthCheckIndex', healthCheckIndex + 1)
-					appcStatus = appcClient.runCommand(Action.HealthCheck,actionIdentifiers,null,msoRequestId)					
-					break
-				case Action.Start:
-					execution.setVariable('workStep', "StartVNF")
-					appcStatus = appcClient.runCommand(Action.Start,actionIdentifiers,null,msoRequestId)					
-					break
-				case Action.Stop:
-					execution.setVariable('workStep', "StopVNF")
-					appcStatus = appcClient.runCommand(Action.Stop,actionIdentifiers,null,msoRequestId)					
-					break
-				default:
-					break
-			}
-			logDebug("Completed AppC request", isDebugLogEnabled)			
-			int appcCode = appcStatus.getCode()
-			logDebug("AppC status code is: " + appcCode, isDebugLogEnabled)
-			logDebug("AppC status message is: " + appcStatus.getMessage(), isDebugLogEnabled)
-			if (support.getCategoryOf(appcStatus) == ApplicationControllerSupport.StatusCategory.ERROR) {
-				execution.setVariable("errorCode", Integer.toString(appcCode))
-				execution.setVariable("errorText", appcStatus.getMessage())				
-			}
-				
-			logDebug('Exited ' + method, isDebugLogEnabled)
-		} catch (BpmnError e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())
-			
-		} catch (java.lang.NoSuchMethodError e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())		
-			
-		} catch (Exception e) {
-			logError('Caught exception in ' + method, e)
-			execution.setVariable("errorCode", "1002")
-			execution.setVariable("errorText", e.getMessage())	
-			
-		}
-	}
-	
-	/**
-	 * Placeholder for a call to APP-C client to execute specified APP-C command for this VNF.
-	 *
-	 *
-	 * @param execution The flow's execution instance.
-	 * @param action The action to take in APP-C.
-	 */
-	public void runAppcCommandPlaceholder(DelegateExecution execution, String action) {
-		def method = getClass().getSimpleName() + '.runAppcCommandPlaceholder(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')		
-		execution.setVariable('errorCode', "0")
-		logDebug('Entered ' + method, isDebugLogEnabled)		
-		execution.setVariable("failedActivity", "APP-C")
-		execution.setVariable("workStep", action)		
-	}
-
-
-
-	/**
-	 * Handle Abort disposition from RainyDayHandler
-	 *
-	 * @param execution The flow's execution instance.	 
-	 */
-	public void abortProcessing(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.abortProcessing(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		logDebug('Entered ' + method, isDebugLogEnabled)
-		
-		def errorText = execution.getVariable("errorText")
-		def errorCode = execution.getVariable("errorCode")
-		
-		exceptionUtil.buildAndThrowWorkflowException(execution, errorCode as Integer, errorText)
-	}	
-	
-	/**
-	 * Increment Retry Count for Current Work Step
-	 *
-	 * @param execution The flow's execution instance.
-	 */
-	public void incrementRetryCount(DelegateExecution execution) {
-		def method = getClass().getSimpleName() + '.incrementRetryCount(' +
-			'execution=' + execution.getId() +
-			')'
-		def isDebugLogEnabled = execution.getVariable('isDebugLogEnabled')
-		logDebug('Entered ' + method, isDebugLogEnabled)
-		
-		String retryCountVariableName = execution.getVariable("workStep") + "RetryCount"
-		execution.setVariable("retryCountVariableName", retryCountVariableName)
-		
-		def retryCountVariable = execution.getVariable(retryCountVariableName)
-		int retryCount = 0
-		
-		if (retryCountVariable != null) {
-			retryCount = (int) retryCountVariable
-		}
-		
-		retryCount += 1
-		
-		execution.setVariable(retryCountVariableName, retryCount)
-		
-		logDebug("value of " + retryCountVariableName + " is " + retryCount, isDebugLogEnabled)
-		logDebug('Exited ' + method, isDebugLogEnabled)
-			
-		
-	}
-
-	
-}