Workflow Activities Execution Environment

Add a license header to ExecuteActivity.java
Fix a JUnit by modifying the values for the expected variables.
BBInput changes to support CM flows
Implement JavaDelegate for activities execution

Change-Id: I9cfc51241d414b85441d1a8443a950b97d14b65f
Issue-ID: SO-827
Signed-off-by: Elena Kuleshov <EK1439@att.com>

1 files changed, 144 insertions, 0 deletions

diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/activity/ExecuteActivity.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/activity/ExecuteActivity.java
new file mode 100644
index 0000000000..94eead2d05
--- /dev/null
+++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/activity/ExecuteActivity.java
@@ -0,0 +1,144 @@
+/*-
+ * ============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.onap.so.bpmn.infrastructure.activity;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+
+import org.camunda.bpm.engine.RuntimeService;
+import org.camunda.bpm.engine.delegate.DelegateExecution;
+import org.camunda.bpm.engine.delegate.JavaDelegate;
+import org.camunda.bpm.engine.runtime.ProcessInstanceWithVariables;
+import org.camunda.bpm.engine.variable.VariableMap;
+import org.onap.so.bpmn.core.WorkflowException;
+import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock;
+import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock;
+import org.onap.so.bpmn.servicedecomposition.entities.WorkflowResourceIds;
+import org.onap.so.client.exception.ExceptionBuilder;
+import org.onap.so.logger.MessageEnum;
+import org.onap.so.logger.MsoLogger;
+import org.onap.so.serviceinstancebeans.RequestDetails;
+import org.onap.so.serviceinstancebeans.ServiceInstancesRequest;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+@Component("ExecuteActivity")
+public class ExecuteActivity implements JavaDelegate {
+
+	private static final MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.BPEL, ExecuteActivity.class);	
+	private static final String G_BPMN_REQUEST = "bpmnRequest";	
+	private static final String VNF_TYPE = "vnfType";
+	private static final String G_ACTION = "requestAction";	
+	private static final String G_REQUEST_ID = "mso-request-id";
+	private static final String VNF_ID = "vnfId";
+	private static final String SERVICE_INSTANCE_ID = "serviceInstanceId";
+	
+	private static final String SERVICE_TASK_IMPLEMENTATION_ATTRIBUTE = "implementation";
+	private static final String ACTIVITY_PREFIX = "activity:";
+	
+	private ObjectMapper mapper = new ObjectMapper();
+
+	@Autowired
+	private RuntimeService runtimeService;
+	@Autowired
+	private ExceptionBuilder exceptionBuilder;
+	
+	@Override
+	public void execute(DelegateExecution execution) throws Exception {		
+		final String requestId = (String) execution.getVariable(G_REQUEST_ID);		
+		
+		try {
+			final String implementationString = execution.getBpmnModelElementInstance().getAttributeValue(SERVICE_TASK_IMPLEMENTATION_ATTRIBUTE);
+			msoLogger.debug("activity implementation String: " + implementationString);
+			if (!implementationString.startsWith(ACTIVITY_PREFIX)) {
+				buildAndThrowException(execution, "Implementation attribute has a wrong format");
+			}
+			String activityName = implementationString.replaceFirst(ACTIVITY_PREFIX, "");
+			msoLogger.info("activityName is: " + activityName);	
+			
+			BuildingBlock buildingBlock = buildBuildingBlock(activityName);
+			ExecuteBuildingBlock executeBuildingBlock = buildExecuteBuildingBlock(execution, requestId, buildingBlock);
+						
+			Map<String, Object> variables = new HashMap<>();
+			variables.put("buildingBlock", executeBuildingBlock);
+			variables.put("mso-request-id", requestId);
+			variables.put("retryCount", 1);	
+		
+		    ProcessInstanceWithVariables buildingBlockResult = runtimeService.createProcessInstanceByKey("ExecuteBuildingBlock").setVariables(variables).executeWithVariablesInReturn();
+			VariableMap variableMap = buildingBlockResult.getVariables();
+			
+			WorkflowException workflowException = (WorkflowException) variableMap.get("WorklfowException");
+			if (workflowException != null) {
+				msoLogger.error("Workflow exception is: " + workflowException.getErrorMessage());
+			}
+			execution.setVariable("WorkflowException", workflowException);
+		}
+		catch (Exception e) {
+			buildAndThrowException(execution, e.getMessage());		
+		}
+	}
+	
+	protected BuildingBlock buildBuildingBlock(String activityName) {
+		BuildingBlock buildingBlock = new BuildingBlock();
+		buildingBlock.setBpmnFlowName(activityName);
+		buildingBlock.setMsoId(UUID.randomUUID().toString());
+		buildingBlock.setKey("");
+		buildingBlock.setIsVirtualLink(false);
+		buildingBlock.setVirtualLinkKey("");
+		return buildingBlock;
+	}
+	
+	protected ExecuteBuildingBlock buildExecuteBuildingBlock(DelegateExecution execution, String requestId, 
+			BuildingBlock buildingBlock) throws Exception {
+		ExecuteBuildingBlock executeBuildingBlock = new ExecuteBuildingBlock();
+		String bpmnRequest = (String) execution.getVariable(G_BPMN_REQUEST);
+		ServiceInstancesRequest sIRequest = mapper.readValue(bpmnRequest, ServiceInstancesRequest.class);
+		RequestDetails requestDetails = sIRequest.getRequestDetails();
+		executeBuildingBlock.setaLaCarte(true);
+		executeBuildingBlock.setRequestAction((String) execution.getVariable(G_ACTION));
+		executeBuildingBlock.setResourceId((String) execution.getVariable(VNF_ID));
+		executeBuildingBlock.setVnfType((String) execution.getVariable(VNF_TYPE));
+		WorkflowResourceIds workflowResourceIds = new WorkflowResourceIds();
+		workflowResourceIds.setServiceInstanceId((String) execution.getVariable(SERVICE_INSTANCE_ID));
+		workflowResourceIds.setVnfId((String) execution.getVariable(VNF_ID));
+		executeBuildingBlock.setWorkflowResourceIds(workflowResourceIds);
+		executeBuildingBlock.setRequestId(requestId);
+		executeBuildingBlock.setBuildingBlock(buildingBlock);
+		executeBuildingBlock.setRequestDetails(requestDetails);
+		return executeBuildingBlock;
+	}
+	
+	protected void buildAndThrowException(DelegateExecution execution, String msg, Exception ex) {
+		msoLogger.error(MessageEnum.BPMN_GENERAL_EXCEPTION_ARG, msg, "BPMN", MsoLogger.getServiceName(),
+				MsoLogger.ErrorCode.UnknownError, msg, ex);
+		execution.setVariable("ExecuteActivityErrorMessage", msg);
+		exceptionBuilder.buildAndThrowWorkflowException(execution, 7000, msg);
+	}
+
+	protected void buildAndThrowException(DelegateExecution execution, String msg) {
+		msoLogger.error(msg);
+		execution.setVariable("ExecuteActuvityErrorMessage", msg);
+		exceptionBuilder.buildAndThrowWorkflowException(execution, 7000, msg);
+	}
+}