1 files changed, 247 insertions, 0 deletions
diff --git a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManualTasks.java b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManualTasks.java
new file mode 100644
index 0000000000..4d8c4ffbd8
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ManualTasks.java
@@ -0,0 +1,247 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ * Copyright (C) 2017 Huawei Technologies Co., Ltd. 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.apihandlerinfra;
+
+import java.io.IOException;
+
+import javax.transaction.Transactional;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.POST;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.container.ContainerRequestContext;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.onap.so.apihandler.common.ErrorNumbers;
+import org.onap.so.apihandler.common.RequestClient;
+import org.onap.so.apihandler.common.RequestClientFactory;
+import org.onap.so.apihandler.common.ResponseBuilder;
+import org.onap.so.apihandler.common.ResponseHandler;
+import org.onap.so.apihandlerinfra.exceptions.ApiException;
+import org.onap.so.apihandlerinfra.exceptions.BPMNFailureException;
+import org.onap.so.apihandlerinfra.exceptions.ValidateException;
+import org.onap.so.apihandlerinfra.logging.AlarmLoggerInfo;
+import org.onap.so.apihandlerinfra.logging.ErrorLoggerInfo;
+import org.onap.so.apihandlerinfra.tasksbeans.TaskRequestReference;
+import org.onap.so.apihandlerinfra.tasksbeans.TasksRequest;
+import org.onap.so.apihandlerinfra.tasksbeans.Value;
+import org.onap.so.apihandlerinfra.tasksbeans.Variables;
+import org.onap.so.db.request.beans.InfraActiveRequests;
+import org.onap.so.exceptions.ValidationException;
+import org.onap.so.logger.MessageEnum;
+import org.onap.so.logger.MsoAlarmLogger;
+import org.onap.so.logger.MsoLogger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+import com.wordnik.swagger.annotations.ApiOperation;
+
+
+@Path("/tasks")
+@Component
+public class ManualTasks {
+	private static MsoLogger msoLogger = MsoLogger.getMsoLogger (MsoLogger.Catalog.APIH, ManualTasks.class);
+	private static MsoAlarmLogger alarmLogger = new MsoAlarmLogger ();
+	
+	@org.springframework.beans.factory.annotation.Value("${mso.camunda.rest.task.uri}")
+	private String taskUri;
+    
+	@Autowired
+	private RequestClientFactory reqClientFactory;
+	
+	@Autowired
+	private MsoRequest msoRequest;
+	
+	@Autowired
+	private ResponseBuilder builder;
+	
+	@POST
+	@Path("/{version:[vV]1}/{taskId}/complete")
+	@Consumes(MediaType.APPLICATION_JSON)
+	@Produces(MediaType.APPLICATION_JSON)
+	@ApiOperation(value="Complete specified task",response=Response.class)
+	@Transactional
+	public Response completeTask(String request, @PathParam("version") String version, @PathParam("taskId") String taskId,
+								@Context ContainerRequestContext requestContext) throws ApiException {
+		
+		String requestId = requestContext.getProperty("requestId").toString();
+        MsoLogger.setLogContext(requestId, null);
+        msoLogger.info(MessageEnum.APIH_GENERATED_REQUEST_ID, requestId, "", "");
+		long startTime = System.currentTimeMillis ();
+		msoLogger.debug ("requestId is: " + requestId);
+		TasksRequest taskRequest = null;
+		String apiVersion = version.substring(1);
+		
+		try{
+			ObjectMapper mapper = new ObjectMapper();
+			taskRequest= mapper.readValue(request, TasksRequest.class);
+			
+			if (taskRequest.getRequestDetails() == null) {
+				throw new ValidationException("requestDetails");				
+			}
+			if (taskRequest.getRequestDetails().getRequestInfo() == null) {
+				throw new ValidationException("requestInfo");
+			}
+			if (empty(taskRequest.getRequestDetails().getRequestInfo().getSource())) {
+				throw new ValidationException("source");
+			}
+			if (empty(taskRequest.getRequestDetails().getRequestInfo().getRequestorId())) {
+				throw new ValidationException("requestorId");
+			}
+
+		}catch(IOException e){
+			ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_REQUEST_VALIDATION_ERROR, MsoLogger.ErrorCode.SchemaError).build();
+
+
+			ValidateException validateException = new ValidateException.Builder("Mapping of request to JSON object failed: " + e.getMessage(),
+					HttpStatus.SC_BAD_REQUEST, ErrorNumbers.SVC_BAD_PARAMETER).cause(e).errorInfo(errorLoggerInfo).build();
+
+			throw validateException;
+		}
+		catch(ValidationException e){
+			ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_REQUEST_VALIDATION_ERROR, MsoLogger.ErrorCode.SchemaError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
+
+
+			ValidateException validateException = new ValidateException.Builder("Mapping of request to JSON Object failed. " + e.getMessage(),
+					HttpStatus.SC_BAD_REQUEST,ErrorNumbers.SVC_BAD_PARAMETER).errorInfo(errorLoggerInfo).build();
+			throw validateException;
+
+		}
+		//Create Request Record
+		InfraActiveRequests currentActiveReq = msoRequest.createRequestObject(taskRequest,Action.completeTask,requestId,Status.PENDING,request);
+		
+		// Transform the request to Camunda-style Complete request
+		Variables variablesForComplete = new Variables();
+		Value sourceValue = new Value(); 
+		sourceValue.setValue(taskRequest.getRequestDetails().getRequestInfo().getSource());
+		Value responseValue = new Value(); 
+		responseValue.setValue(taskRequest.getRequestDetails().getRequestInfo().getResponseValue().name());
+		Value requestorIdValue = new Value(); 
+		requestorIdValue.setValue(taskRequest.getRequestDetails().getRequestInfo().getRequestorId());
+		variablesForComplete.setSource(sourceValue);
+		variablesForComplete.setResponseValue(responseValue);
+		variablesForComplete.setRequestorId(requestorIdValue);
+		
+		String camundaJsonReq = null;
+		try {
+			ObjectMapper mapper = new ObjectMapper();
+			mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);
+			camundaJsonReq = mapper.writeValueAsString(variablesForComplete);
+		} catch(JsonProcessingException e){
+
+			ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_GENERAL_EXCEPTION, MsoLogger.ErrorCode.UnknownError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
+
+
+			ValidateException validateException = new ValidateException.Builder("Mapping of JSON object to Camunda request failed",
+					HttpStatus.SC_INTERNAL_SERVER_ERROR,ErrorNumbers.SVC_GENERAL_SERVICE_ERROR).errorInfo(errorLoggerInfo).build();
+			throw validateException;
+		}
+		
+		RequestClient requestClient = null;
+		HttpResponse response = null;
+		long subStartTime = System.currentTimeMillis();
+		String requestUrl = taskUri + "/" + taskId + "/complete";
+		try {
+			requestClient = reqClientFactory.getRequestClient (requestUrl);
+			// Capture audit event
+			
+			response = requestClient.post(camundaJsonReq);
+
+		} catch (Exception e) {
+
+            ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_COMMUNICATE_ERROR, MsoLogger.ErrorCode.AvailabilityError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
+            AlarmLoggerInfo alarmLoggerInfo = new AlarmLoggerInfo.Builder("MsoConfigurationError", MsoAlarmLogger.CRITICAL, Messages.errors.get (ErrorNumbers.NO_COMMUNICATION_TO_BPEL)).build();
+
+
+
+            BPMNFailureException bpmnFailureException = new BPMNFailureException.Builder(String.valueOf(HttpStatus.SC_BAD_GATEWAY),
+                    HttpStatus.SC_BAD_GATEWAY,ErrorNumbers.SVC_NO_SERVER_RESOURCES).errorInfo(errorLoggerInfo).alarmInfo(alarmLoggerInfo).build();
+
+		    throw bpmnFailureException;
+		}
+
+		if (response == null) {
+            ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_COMMUNICATE_ERROR, MsoLogger.ErrorCode.BusinessProcesssError).errorSource(Constants.MSO_PROP_APIHANDLER_INFRA).build();
+
+
+            BPMNFailureException bpmnFailureException = new BPMNFailureException.Builder(String.valueOf(HttpStatus.SC_BAD_GATEWAY),
+                    HttpStatus.SC_BAD_GATEWAY,ErrorNumbers.SVC_NO_SERVER_RESOURCES).errorInfo(errorLoggerInfo).build();
+
+            throw bpmnFailureException;
+
+		}
+
+		ResponseHandler respHandler = new ResponseHandler (response, requestClient.getType ());
+		int bpelStatus = respHandler.getStatus ();
+
+		// BPEL accepted the request, the request is in progress
+		if (bpelStatus == HttpStatus.SC_NO_CONTENT || bpelStatus == HttpStatus.SC_ACCEPTED) {			
+			msoLogger.debug ("Received good response from Camunda");
+		
+			msoLogger.recordAuditEvent (startTime, MsoLogger.StatusCode.COMPLETE, MsoLogger.ResponseCode.Suc, "BPMN completed the request");
+			TaskRequestReference trr = new TaskRequestReference();
+			trr.setTaskId(taskId);
+			String completeResp = null;
+			try {
+				ObjectMapper mapper = new ObjectMapper();
+				mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);
+				completeResp = mapper.writeValueAsString(trr);
+			}
+			catch (JsonProcessingException e) {
+
+                ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, MsoLogger.ErrorCode.BusinessProcesssError).build();
+
+
+                ValidateException validateException = new ValidateException.Builder("Request Failed due to bad response format" ,
+                        bpelStatus,ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).errorInfo(errorLoggerInfo).build();
+
+                throw validateException;
+			}
+			msoLogger.debug("Response to the caller: " + completeResp);			
+			msoLogger.debug ("End of the transaction, the final response is: " + (String) completeResp);
+			return builder.buildResponse(HttpStatus.SC_ACCEPTED, requestId, completeResp, apiVersion);
+		} else {
+            ErrorLoggerInfo errorLoggerInfo = new ErrorLoggerInfo.Builder(MessageEnum.APIH_BPEL_RESPONSE_ERROR, MsoLogger.ErrorCode.BusinessProcesssError).build();
+
+
+            BPMNFailureException bpmnFailureException = new BPMNFailureException.Builder(String.valueOf(bpelStatus),
+                    bpelStatus,ErrorNumbers.SVC_DETAILED_SERVICE_ERROR).errorInfo(errorLoggerInfo).build();
+
+            throw bpmnFailureException;
+            
+		}	
+	
+	}
+	
+	private static boolean empty(String s) {
+  	  return (s == null || s.trim().isEmpty());
+  }
+		
+}