/*-
 * ============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.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.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 io.swagger.annotations.ApiOperation;


@Path("/tasks")
@Component
public class ManualTasks {
	private static MsoLogger msoLogger = MsoLogger.getMsoLogger (MsoLogger.Catalog.APIH, ManualTasks.class);

	
	@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();



            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;
		}

		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());
  }
		
}