/*-
 * ============LICENSE_START=======================================================
 * ONAP - SO
 * ================================================================================
 * 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.openecomp.mso.apihandlerinfra;

import static org.junit.Assert.*;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;

import javax.ws.rs.core.Response;

import org.apache.http.HttpResponse;
import org.apache.http.ProtocolVersion;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.entity.BasicHttpEntity;
import org.apache.http.message.BasicHttpResponse;
import org.hibernate.Session;
import org.junit.BeforeClass;
import org.junit.Test;
import org.openecomp.mso.apihandler.common.CamundaClient;
import org.openecomp.mso.apihandler.common.RequestClient;
import org.openecomp.mso.apihandler.common.RequestClientFactory;
import org.openecomp.mso.apihandler.common.RequestClientParamater;
import org.openecomp.mso.apihandler.common.ValidationException;
import org.openecomp.mso.db.AbstractSessionFactoryManager;
import org.openecomp.mso.db.catalog.CatalogDatabase;
import org.openecomp.mso.db.catalog.beans.Service;
import org.openecomp.mso.db.catalog.beans.ServiceRecipe;
import org.openecomp.mso.properties.MsoJavaProperties;
import org.openecomp.mso.properties.MsoPropertiesFactory;
import org.openecomp.mso.requestsdb.OperationStatus;
import org.openecomp.mso.requestsdb.RequestsDatabase;
import org.openecomp.mso.serviceinstancebeans.ServiceInstancesRequest;

import mockit.Expectations;
import mockit.Mock;
import mockit.MockUp;
import mockit.Mocked;

public class E2EServiceInstancesTest {

    private final String compareModelsRequest = "{" +
            "\"globalSubscriberId\": \"60c3e96e-0970-4871-b6e0-3b6de7561519\"," +
            "\"serviceType\": \"vnf\"," +
            "\"modelInvariantIdTarget\": \"60c3e96e-0970-4871-b6e0-3b6de1234567\"," +
            "\"modelVersionIdTarget\": \"modelVersionIdTarget\"" +
            "}";

    private final String scaleRequest = "{\"service\":{\"serviceType\":\"example-service-type\",\"globalSubscriberId\":\"test_custormer\",\"resources\":[{\"resourceInstanceId\":\"ns111\",\"scaleType\":\"SCALE_NS\",\"scaleNsData\":{\"scaleNsByStepsData\":{\"numberOfSteps\":\"4\",\"aspectId\":\"TIC_EDGE_HW\",\"scalingDirection\":\"UP\"}}}],\"serviceInstanceName\":\"XXXX\"}}";

	String jsonBody = "{" +
			"\"service\": {" +
			"\"name\": \"so_test4\"," +
			"\"description\": \"so_test2\"," +
			"\"serviceInvariantUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561519\"," +
			"\"serviceUuid\": \"592f9437-a9c0-4303-b9f6-c445bb7e9814\"," +
			"\"globalSubscriberId\": \"123457\"," +
			"\"serviceType\": \"voLTE\"," +
			"\"parameters\": {" +
			"\"resources\": [" +
			"{" +
			"\"resourceName\": \"vIMS\"," +
			"\"resourceInvariantUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561516\"," +
			"\"resourceUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561512\"," +
			"\"parameters\": {" +
			"\"locationConstraints\": [" +
			"{" +
			"\"vnfProfileId\": \"zte-vBAS-1.0\"," +
			"\"locationConstraints\": {" +
			"\"vimId\": \"4050083f-465f-4838-af1e-47a545222ad0\"" +
			"}" +
			"}," +
			"{" +
			"\"vnfProfileId\": \"zte-vMME-1.0\"," +
			"\"locationConstraints\": {" +
			"\"vimId\": \"4050083f-465f-4838-af1e-47a545222ad0\"" +
			"}" +
			"}" +
			"]" +
			"}" +
			"}," +
			"{" +
			"\"resourceName\": \"vEPC\"," +
			"\"resourceInvariantUuid\": \"61c3e96e-0970-4871-b6e0-3b6de7561516\"," +
			"\"resourceUuid\": \"62c3e96e-0970-4871-b6e0-3b6de7561512\"," +
			"\"parameters\": {" +
			"\"locationConstraints\": [" +
			"{" +
			"\"vnfProfileId\": \"zte-CSCF-1.0\"," +
			"\"locationConstraints\": {" +
			"\"vimId\": \"4050083f-465f-4838-af1e-47a545222ad1\"" +
			"}" +
			"}" +
			"]" +
			"}" +
			"}," +
			"{" +
			"\"resourceName\": \"underlayvpn\"," +
			"\"resourceInvariantUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561513\"," +
			"\"resourceUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561514\"," +
			"\"parameters\": {" +
			"\"locationConstraints\": []" +
			"}" +
			"}," +
			"{" +
			"\"resourceName\": \"overlayvpn\"," +
			"\"resourceInvariantUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561517\"," +
			"\"resourceUuid\": \"60c3e96e-0970-4871-b6e0-3b6de7561518\"," +
			"\"parameters\": {" +
			"\"locationConstraints\": []" +
			"}" +
			"}" +
			"]," +
			"\"requestInputs\": {" +
			"\"externalDataNetworkName\": \"Flow_out_net\"," +
			"\"m6000_mng_ip\": \"181.18.20.2\"," +
			"\"externalCompanyFtpDataNetworkName\": \"Flow_out_net\"," +
			"\"externalPluginManageNetworkName\": \"plugin_net_2014\"," +
			"\"externalManageNetworkName\": \"mng_net_2017\"," +
			"\"sfc_data_network\": \"sfc_data_net_2016\"," +
			"\"NatIpRange\": \"210.1.1.10-210.1.1.20\"," +
			"\"location\": \"4050083f-465f-4838-af1e-47a545222ad0\"," +
			"\"sdncontroller\": \"9b9f02c0-298b-458a-bc9c-be3692e4f35e\"" +
			"}" +
			"}" +
			"}" +
			"}";

    @BeforeClass
    public static void setUp() throws Exception {

        MsoPropertiesFactory msoPropertiesFactory = new MsoPropertiesFactory();
        msoPropertiesFactory.removeAllMsoProperties();
        msoPropertiesFactory.initializeMsoProperties(Constants.MSO_PROP_APIHANDLER_INFRA, "src/test/resources/mso.apihandler-infra.properties");
    }

	@Test
	public void createE2EServiceInstanceTestSuccess() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(RequestClientParamater requestClientParamater) {
				ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
				HttpResponse resp = new BasicHttpResponse(pv, 202,
						"test response");
				BasicHttpEntity entity = new BasicHttpEntity();
				String body = "{\"content\":\"success\",\"message\":\"success\"}";
				InputStream instream = new ByteArrayInputStream(body.getBytes());
				entity.setContent(instream);
				resp.setEntity(entity);
				return resp;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("success"));
	}

	@Test
	public void createE2EServiceInstanceTestBpelHTTPException() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};
		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(RequestClientParamater requestClientParamater) {
				ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
				HttpResponse resp = new BasicHttpResponse(pv, 500,
						"test response");
				BasicHttpEntity entity = new BasicHttpEntity();
				String body = "{\"content\":\"success\",\"message\":\"success\"}";
				InputStream instream = new ByteArrayInputStream(body.getBytes());
				entity.setContent(instream);
				resp.setEntity(entity);
				return resp;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("SVC2000"));
	}

	@Test
	public void createE2EServiceInstanceTestBpelHTTPExceptionWithNullREsponseBody() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(RequestClientParamater requestClientParamater) {
				ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
				HttpResponse resp = new BasicHttpResponse(pv, 500,
						"test response");
				BasicHttpEntity entity = new BasicHttpEntity();
				String body = "{\"content\":\"\",\"message\":\"success\"}";
				InputStream instream = new ByteArrayInputStream(body.getBytes());
				entity.setContent(instream);
				resp.setEntity(entity);
				return resp;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("SVC2000"));
	}

	@Test
	public void createE2EServiceInstanceTestNullBPELResponse() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(RequestClientParamater requestClientParamater) {
				HttpResponse resp = null;
				return resp;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestBPMNNullREsponse() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(String camundaReqXML, String requestId,
					String requestTimeout, String schemaVersion,
					String serviceInstanceId, String action) {
				HttpResponse resp = null;
				return resp;
			}
		};
		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestNullBpmn() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};


		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};
		E2EServiceInstances instance = new E2EServiceInstances();
        String request = jsonBody;
        ;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestNullReceipe() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestNullDBResponse() {

		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};


		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestInvalidRequest() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};


		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestEmptyDBQuery() {


		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
		// assertTrue(true);
	}

	@Test
	public void createE2EServiceInstanceTestDBQueryFail() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceName(
					String serviceName) {
				OperationStatus operationStatus = new OperationStatus();
				return operationStatus;
			}
		};


		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("serviceException"));
	}

	@Test
	public void createE2EServiceInstanceTestForEmptyRequest() {


		E2EServiceInstances instance = new E2EServiceInstances();
		String request = "";
		Response resp = instance.createE2EServiceInstance(request, "v3");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr
            .contains("Mapping of request to JSON object failed.  No content to map due to end-of-input"));
	}

	@Test
	public void deleteE2EServiceInstanceTestNormal() {

        final MockUp<CatalogDatabase> mockCDB = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }

            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                rec.setOrchestrationUri("/test/delE2E");
                rec.setRecipeTimeout(180);
                return rec;
            }
        };

        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        final MockUp<CamundaClient> mockCmaundaClient = new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) {
                ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
                HttpResponse resp = new BasicHttpResponse(pv, 200, "test response");
                BasicHttpEntity entity = new BasicHttpEntity();
                String body = "{\"content\":\"success\",\"message\":\"success\"}";
                InputStream instream = new ByteArrayInputStream(body.getBytes());
                entity.setContent(instream);
                resp.setEntity(entity);
                return resp;
            }
        };


		E2EServiceInstances instance = new E2EServiceInstances();
		String request = "{\"globalSubscriberId\":\"299392392\",\"serviceType\":\"VoLTE\"}";

        instance.deleteE2EServiceInstance(request, "v3", "12345678");
        mockCDB.tearDown();
        mockMsoRequest.tearDown();
        mockCmaundaClient.tearDown();

    }

    @Test
    public void deleteE2EServiceInstanceTestFail() {
        E2EServiceInstances instance = new E2EServiceInstances();
        String request = "{\"globalSubscriberId\":\"299392392\",\"serviceType\":\"VoLTE\"}";
        instance.deleteE2EServiceInstance(request, "v3", "12345678");
    }

    @Test
    public void deleteE2EServiceInstanceTestFailClient(@Mocked AbstractSessionFactoryManager sessionFactoryManager,
                                                       @Mocked Session session) {
        final MockUp<CatalogDatabase> mockCDB = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }

            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                rec.setOrchestrationUri("/test/delE2E");
                rec.setRecipeTimeout(180);
                return rec;
            }
        };

        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        String request = "{\"globalSubscriberId\":\"299392392\",\"serviceType\":\"VoLTE\"}";

        instance.deleteE2EServiceInstance(request, "v3", "12345678");
        mockCDB.tearDown();
        mockMsoRequest.tearDown();

    }

    @Test
    public void deleteE2EServiceInstanceTestFailRecipe(@Mocked AbstractSessionFactoryManager sessionFactoryManager,
                                                       @Mocked Session session) {
        final MockUp<CatalogDatabase> mockCDB = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }

            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                return rec;
            }
        };

        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        String request = "{\"globalSubscriberId\":\"299392392\",\"serviceType\":\"VoLTE\"}";

        instance.deleteE2EServiceInstance(request, "v3", "12345678");
        mockCDB.tearDown();
        mockMsoRequest.tearDown();

    }

    @Test
    public void deleteE2EServiceInstanceTestFailModelName(@Mocked AbstractSessionFactoryManager sessionFactoryManager,
                                                          @Mocked Session session) {
        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        new Expectations() {{
            sessionFactoryManager.getSessionFactory().openSession();
            result = session;
        }};

        E2EServiceInstances instance = new E2EServiceInstances();
        String request = "{\"globalSubscriberId\":\"299392392\",\"serviceType\":\"VoLTE\"}";

        instance.deleteE2EServiceInstance(request, "v3", "12345678");
        mockMsoRequest.tearDown();

	}

	@Test
	public void getE2EServiceInstanceTest() {

		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatus(String serviceId,
					String operationId) {
				OperationStatus os = new OperationStatus();
				os.setOperation("");
				os.setOperationContent("");
				os.setOperationId("123456");
				os.setProgress("");
				os.setServiceId("12345");
				os.setServiceName("VoLTE");
				os.setReason("");
				os.setResult("");
				os.setUserId("");
				return os;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		Response resp = instance
				.getE2EServiceInstances("12345", "v3", "123456");

	}
	
	@Test
	public void updateE2EServiceInstanceTestNormal() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceId(
					String serviceID) {
				OperationStatus operationStatus = new OperationStatus();
				operationStatus.setProgress("100");
				operationStatus.setResult("finish");
				return operationStatus;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(RequestClientParamater requestClientParamater) {
				ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
				HttpResponse resp = new BasicHttpResponse(pv, 202,
						"test response");
				BasicHttpEntity entity = new BasicHttpEntity();
				String body = "{\"content\":\"success\",\"message\":\"success\"}";
				InputStream instream = new ByteArrayInputStream(body.getBytes());
				entity.setContent(instream);
				resp.setEntity(entity);
				return resp;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.updateE2EServiceInstance(request, "v3", "12345");
		String respStr = resp.getEntity().toString();
		assertTrue(respStr.contains("success"));
	}
	
	@Test
	public void updateE2EServiceInstanceTestChkStatusFalse() {
		new MockUp<RequestsDatabase>() {
			@Mock
			public OperationStatus getOperationStatusByServiceId(
					String serviceID) {
				OperationStatus operationStatus = new OperationStatus();
				operationStatus.setResult("processing");
				return operationStatus;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public Service getServiceByModelName(String modelName) {
				Service svc = new Service();
				return svc;
			}
		};

		new MockUp<CatalogDatabase>() {
			@Mock
			public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
					String action) {
				ServiceRecipe rec = new ServiceRecipe();
				return rec;
			}
		};

		new MockUp<RequestClientFactory>() {
			@Mock
			public RequestClient getRequestClient(String orchestrationURI,
					MsoJavaProperties props) throws IllegalStateException {
				RequestClient client = new CamundaClient();
				client.setUrl("/test/url");
				return client;
			}
		};

		new MockUp<CamundaClient>() {
			@Mock
			public HttpResponse post(RequestClientParamater requestClientParamater) {
				ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
				HttpResponse resp = new BasicHttpResponse(pv, 202,
						"test response");
				BasicHttpEntity entity = new BasicHttpEntity();
				String body = "{\"content\":\"success\",\"message\":\"success\"}";
				InputStream instream = new ByteArrayInputStream(body.getBytes());
				entity.setContent(instream);
				resp.setEntity(entity);
				return resp;
			}
		};

		E2EServiceInstances instance = new E2EServiceInstances();
		String request = jsonBody;
		Response resp = instance.updateE2EServiceInstance(request, "v3", "12345");
		String respStr = resp.getEntity().toString();
		assertTrue(!respStr.contains("SVC2000"));
	}

    @Test
    public void updateE2EServiceInstanceExceptionMsoRequestTest() {
        new MockUp<RequestsDatabase>() {
            @Mock
            public OperationStatus getOperationStatusByServiceId(
                    String serviceID) {
                OperationStatus operationStatus = new OperationStatus();
                operationStatus.setProgress("100");
                operationStatus.setResult("finish");
                return operationStatus;
            }
        };

        new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }
        };

        new MockUp<CatalogDatabase>() {
            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                return rec;
            }
        };

        new MockUp<RequestClientFactory>() {
            @Mock
            public RequestClient getRequestClient(String orchestrationURI,
                                                  MsoJavaProperties props) throws IllegalStateException {
                RequestClient client = new CamundaClient();
                client.setUrl("/test/url");
                return client;
            }
        };

        new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) {
                ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
                HttpResponse resp = new BasicHttpResponse(pv, 202,
                        "test response");
                BasicHttpEntity entity = new BasicHttpEntity();
                String body = "{\"content\":\"success\",\"message\":\"success\"}";
                InputStream instream = new ByteArrayInputStream(body.getBytes());
                entity.setContent(instream);
                resp.setEntity(entity);
                return resp;
            }
        };
        MockUp<MsoRequest> msoRequest = new MockUp<MsoRequest>() {
        	@Mock
            void parse (ServiceInstancesRequest sir, HashMap<String,String> instanceIdMap, Action action, String version, String originalRequestJSON) throws ValidationException {

        		throw new ValidationException("mock failure");
        	}
        };
        E2EServiceInstances instance = new E2EServiceInstances();
        String request = jsonBody;
        Response resp = instance.updateE2EServiceInstance(request, "v3", "12345");
        assertEquals(Response.Status.BAD_REQUEST.getStatusCode(), resp.getStatus());
        msoRequest.tearDown();
    }
    
    @Test
    public void updateE2EServiceInstanceExceptionCatalogDbTest() {
        new MockUp<RequestsDatabase>() {
            @Mock
            public OperationStatus getOperationStatusByServiceId(
                    String serviceID) {
                OperationStatus operationStatus = new OperationStatus();
                operationStatus.setProgress("100");
                operationStatus.setResult("finish");
                return operationStatus;
            }
        };

        MockUp<CatalogDatabase> catalog = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) throws Exception {
                throw new Exception();
            }
        };

        new MockUp<CatalogDatabase>() {
            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                return rec;
            }
        };

        new MockUp<RequestClientFactory>() {
            @Mock
            public RequestClient getRequestClient(String orchestrationURI,
                                                  MsoJavaProperties props) throws IllegalStateException {
                RequestClient client = new CamundaClient();
                client.setUrl("/test/url");
                return client;
            }
        };

        new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) {
                ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
                HttpResponse resp = new BasicHttpResponse(pv, 202,
                        "test response");
                BasicHttpEntity entity = new BasicHttpEntity();
                String body = "{\"content\":\"success\",\"message\":\"success\"}";
                InputStream instream = new ByteArrayInputStream(body.getBytes());
                entity.setContent(instream);
                resp.setEntity(entity);
                return resp;
            }
        };
       
        E2EServiceInstances instance = new E2EServiceInstances();
        String request = jsonBody;
        Response resp = instance.updateE2EServiceInstance(request, "v3", "12345");
        assertEquals(Response.Status.NOT_FOUND.getStatusCode(), resp.getStatus());
        catalog.tearDown();
    }
    
    @Test
    public void updateE2EServiceInstanceNullServiceTest() {
        new MockUp<RequestsDatabase>() {
            @Mock
            public OperationStatus getOperationStatusByServiceId(
                    String serviceID) {
                OperationStatus operationStatus = new OperationStatus();
                operationStatus.setProgress("100");
                operationStatus.setResult("finish");
                return operationStatus;
            }
        };

        new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
            	Service svc = new Service();
                return svc;
            }
        };

        MockUp<CatalogDatabase> catalog = new MockUp<CatalogDatabase>() {
            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                return null;
            }
        };

        new MockUp<RequestClientFactory>() {
            @Mock
            public RequestClient getRequestClient(String orchestrationURI,
                                                  MsoJavaProperties props) throws IllegalStateException {
                RequestClient client = new CamundaClient();
                client.setUrl("/test/url");
                return client;
            }
        };

        new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) {
                ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
                HttpResponse resp = new BasicHttpResponse(pv, 202,
                        "test response");
                BasicHttpEntity entity = new BasicHttpEntity();
                String body = "{\"content\":\"success\",\"message\":\"success\"}";
                InputStream instream = new ByteArrayInputStream(body.getBytes());
                entity.setContent(instream);
                resp.setEntity(entity);
                return resp;
            }
        };
       
        E2EServiceInstances instance = new E2EServiceInstances();
        String request = jsonBody;
        Response resp = instance.updateE2EServiceInstance(request, "v3", "12345");
        assertEquals(Response.Status.NOT_FOUND.getStatusCode(), resp.getStatus());
        catalog.tearDown();
    }
    
    @Test
    public void updateE2EServiceInstanceRequestClientExceptionTest() {
        new MockUp<RequestsDatabase>() {
            @Mock
            public OperationStatus getOperationStatusByServiceId(
                    String serviceID) {
                OperationStatus operationStatus = new OperationStatus();
                operationStatus.setProgress("100");
                operationStatus.setResult("finish");
                return operationStatus;
            }
        };

        new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
            	Service svc = new Service();
                return svc;
            }
        };

        new MockUp<CatalogDatabase>() {
            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                return rec;
            }
        };

        new MockUp<RequestClientFactory>() {
            @Mock
            public RequestClient getRequestClient(String orchestrationURI,
                                                  MsoJavaProperties props) throws IllegalStateException {
                RequestClient client = new CamundaClient();
                client.setUrl("/test/url");
                return client;
            }
        };

        MockUp<CamundaClient> client = new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) throws Exception {
                throw new Exception();
            }
        };
       
        E2EServiceInstances instance = new E2EServiceInstances();
        String request = jsonBody;
        Response resp = instance.updateE2EServiceInstance(request, "v3", "12345");
        assertEquals(Response.Status.BAD_GATEWAY.getStatusCode(), resp.getStatus());
        client.tearDown();
    }
    
    @Test
    public void compareModelwithTargetVersionBadRequest(){

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.compareModelwithTargetVersion("", "12345", "v3");

        assertNotNull(response);
        assertTrue(response.getEntity().toString().contains("Mapping of request to JSON object failed."));

    }
    @Test
    public void compareModelwithTargetVersionFailedBPMNCall(){

        new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) throws IOException {
                throw new ClientProtocolException();
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.compareModelwithTargetVersion(compareModelsRequest, "12345", "v3");

        assertNotNull(response);
        assertTrue(response.getEntity().toString().contains("Failed calling bpmn"));

    }

    @Test
    public void compareModelwithTargetVersionSuccess(){

        new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) {
                ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
                HttpResponse resp = new BasicHttpResponse(pv, 202,
                        "compareModelwithTargetVersion, test response");
                BasicHttpEntity entity = new BasicHttpEntity();
                String body = "{\"content\":\"success\",\"message\":\"success\"}";
                InputStream instream = new ByteArrayInputStream(body.getBytes());
                entity.setContent(instream);
                resp.setEntity(entity);

                return resp;
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.compareModelwithTargetVersion(compareModelsRequest, "12345", "v3");

        assertNotNull(response);
        assertTrue(response.getStatus()==202);

    }

    @Test
    public void scaleE2EserviceInstancesTestFailInvalidRequest(@Mocked AbstractSessionFactoryManager sessionFactoryManager,
                                                               @Mocked Session session ) {

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.scaleE2EServiceInstance(jsonBody, "v3", "12345");
    }

    @Test
    public void scaleE2EserviceInstancesTestNormal() {

        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        final MockUp<CatalogDatabase> mockCDB = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }

            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                rec.setOrchestrationUri("/test/delE2E");
                rec.setRecipeTimeout(180);
                return rec;
            }
        };

        final MockUp<RequestClientFactory> mockRequestClient = new MockUp<RequestClientFactory>() {
            @Mock
            public RequestClient getRequestClient(String orchestrationURI,
                                                  MsoJavaProperties props) throws IllegalStateException {
                RequestClient client = new CamundaClient();
                client.setUrl("/test/url");
                return client;
            }
        };

        final MockUp<CamundaClient> mockCamundaClient = new MockUp<CamundaClient>() {
            @Mock
            public HttpResponse post(RequestClientParamater requestClientParamater) {
                ProtocolVersion pv = new ProtocolVersion("HTTP", 1, 1);
                HttpResponse resp = new BasicHttpResponse(pv, 202,
                        "test response");
                BasicHttpEntity entity = new BasicHttpEntity();
                String body = "{\"content\":\"success\",\"message\":\"success\"}";
                InputStream instream = new ByteArrayInputStream(body.getBytes());
                entity.setContent(instream);
                resp.setEntity(entity);
                return resp;
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.scaleE2EServiceInstance(scaleRequest, "v3", "12345");
        mockMsoRequest.tearDown();
        mockCDB.tearDown();
        mockRequestClient.tearDown();
        mockCamundaClient.tearDown();
    }

    @Test
    public void scaleE2EserviceInstancesTestFailCamundaClient(@Mocked AbstractSessionFactoryManager sessionFactoryManager,
                                                              @Mocked Session session) {

        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        final MockUp<CatalogDatabase> mockCDB = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }

            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                rec.setOrchestrationUri("/test/delE2E");
                rec.setRecipeTimeout(180);
                return rec;
            }
        };

        final MockUp<RequestClientFactory> mockRequestClient = new MockUp<RequestClientFactory>() {
            @Mock
            public RequestClient getRequestClient(String orchestrationURI,
                                                  MsoJavaProperties props) throws IllegalStateException {
                RequestClient client = new CamundaClient();
                client.setUrl("/test/url");
                return client;
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.scaleE2EServiceInstance(scaleRequest, "v3", "12345");
        mockMsoRequest.tearDown();
        mockCDB.tearDown();
        mockRequestClient.tearDown();
    }

    @Test
    public void scaleE2EserviceInstancesTestFailRequestClient(@Mocked AbstractSessionFactoryManager sessionFactoryManager,
                                                              @Mocked Session session) {

        final MockUp<MsoRequest> mockMsoRequest = new MockUp<MsoRequest>() {
            @Mock
            public void createRequestRecord(Status status, Action action) {
                return;
            }
        };

        final MockUp<CatalogDatabase> mockCDB = new MockUp<CatalogDatabase>() {
            @Mock
            public Service getServiceByModelName(String modelName) {
                Service svc = new Service();
                return svc;
            }

            @Mock
            public ServiceRecipe getServiceRecipeByModelUUID(String modelUUID,
                                                             String action) {
                ServiceRecipe rec = new ServiceRecipe();
                rec.setOrchestrationUri("/test/delE2E");
                rec.setRecipeTimeout(180);
                return rec;
            }
        };

        E2EServiceInstances instance = new E2EServiceInstances();
        Response response = instance.scaleE2EServiceInstance(scaleRequest, "v3", "12345");
        mockMsoRequest.tearDown();
        mockCDB.tearDown();
    }

}