aboutsummaryrefslogtreecommitdiffstats
path: root/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java')
-rw-r--r--so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java422
1 files changed, 0 insertions, 422 deletions
diff --git a/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java b/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java
deleted file mode 100644
index e22f1a359f..0000000000
--- a/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java
+++ /dev/null
@@ -1,422 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * Copyright (C) 2018 Ericsson. 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.
- *
- * SPDX-License-Identifier: Apache-2.0
- * ============LICENSE_END=========================================================
- */
-package org.onap.so.monitoring.rest.api;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.onap.so.client.RestTemplateConfig.CONFIGURABLE_REST_TEMPLATE;
-import static org.onap.so.configuration.rest.BasicHttpHeadersProvider.AUTHORIZATION_HEADER;
-import static org.onap.so.monitoring.rest.api.Constants.ACTIVITY_INSTANCE_RESPONSE_JSON_FILE;
-import static org.onap.so.monitoring.rest.api.Constants.EMPTY_ARRAY_RESPONSE;
-import static org.onap.so.monitoring.rest.api.Constants.EMPTY_STRING;
-import static org.onap.so.monitoring.rest.api.Constants.END_TIME_IN_MS;
-import static org.onap.so.monitoring.rest.api.Constants.ID;
-import static org.onap.so.monitoring.rest.api.Constants.PROCCESS_INSTANCE_RESPONSE_JSON_FILE;
-import static org.onap.so.monitoring.rest.api.Constants.PROCESS_DEF_RESPONSE_JSON_FILE;
-import static org.onap.so.monitoring.rest.api.Constants.PROCESS_INSTACE_ID;
-import static org.onap.so.monitoring.rest.api.Constants.PROCESS_INSTANCE_VARIABLES_RESPONSE_JSON_FILE;
-import static org.onap.so.monitoring.rest.api.Constants.PROCRESS_DEF_ID;
-import static org.onap.so.monitoring.rest.api.Constants.SEARCH_RESULT_RESPONSE_JSON_FILE;
-import static org.onap.so.monitoring.rest.api.Constants.SINGLE_PROCCESS_INSTANCE_RESPONSE_JSON_FILE;
-import static org.onap.so.monitoring.rest.api.Constants.START_TIME_IN_MS;
-import static org.springframework.test.web.client.match.MockRestRequestMatchers.header;
-import static org.springframework.test.web.client.match.MockRestRequestMatchers.requestTo;
-import static org.springframework.test.web.client.response.MockRestResponseCreators.withBadRequest;
-import static org.springframework.test.web.client.response.MockRestResponseCreators.withSuccess;
-import static org.springframework.test.web.client.response.MockRestResponseCreators.withUnauthorizedRequest;
-import java.io.IOException;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.util.Collections;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import javax.ws.rs.core.Response;
-import javax.ws.rs.core.Response.Status;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.onap.so.monitoring.configuration.camunda.CamundaRestUrlProvider;
-import org.onap.so.monitoring.configuration.database.DatabaseUrlProvider;
-import org.onap.so.monitoring.model.ActivityInstanceDetail;
-import org.onap.so.monitoring.model.ProcessDefinitionDetail;
-import org.onap.so.monitoring.model.ProcessInstanceDetail;
-import org.onap.so.monitoring.model.ProcessInstanceIdDetail;
-import org.onap.so.monitoring.model.ProcessInstanceVariableDetail;
-import org.onap.so.monitoring.model.SoInfraRequest;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Qualifier;
-import org.springframework.boot.test.context.SpringBootTest;
-import org.springframework.http.MediaType;
-import org.springframework.test.context.ActiveProfiles;
-import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-import org.springframework.test.web.client.MockRestServiceServer;
-import org.springframework.web.client.RestTemplate;
-
-
-/**
- * @author waqas.ikram@ericsson.com, andrei.barcovschi@ericsson.com
- */
-@RunWith(SpringJUnit4ClassRunner.class)
-@ActiveProfiles("test")
-@SpringBootTest
-public class SoMonitoringControllerTest {
- private static final String CAMUNDA_BASIC_AUTH =
- "Basic YWRtaW46S3A4Yko0U1hzek0wV1hsaGFrM2VIbGNzZTJnQXc4NHZhb0dHbUp2VXkyVQ==";
-
- private static final String DATABASE_BASIC_AUTH = "Basic YnBlbDpwYXNzd29yZDEk";
-
- @Autowired
- @Qualifier(CONFIGURABLE_REST_TEMPLATE)
- private RestTemplate restTemplate;
-
- @Autowired
- private CamundaRestUrlProvider urlProvider;
-
- @Autowired
- private DatabaseUrlProvider databaseUrlProvider;
-
- private MockRestServiceServer mockRestServiceServer;
-
-
- @Autowired
- private SoMonitoringController objUnderTest;
-
- @Before
- public void setUp() throws Exception {
- mockRestServiceServer = MockRestServiceServer.bindTo(restTemplate).build();
- }
-
- @Test
- public void test_GetProcessInstance_SuccessResponseWithDataFromCamunda() throws Exception {
- final String jsonString = getJsonResponse(PROCCESS_INSTANCE_RESPONSE_JSON_FILE);
- this.mockRestServiceServer.expect(requestTo(urlProvider.getHistoryProcessInstanceUrl(ID)))
- .andExpect(header(AUTHORIZATION_HEADER, CAMUNDA_BASIC_AUTH))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getProcessInstanceId(ID);
-
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- final ProcessInstanceIdDetail actualProcessInstance = (ProcessInstanceIdDetail) response.getEntity();
- assertEquals("dba707b6-8c02-11e8-a6ba-022a5dba5402", actualProcessInstance.getProcessInstanceId());
- }
-
- @Test
- public void test_GetProcessInstance_SuccessResponseWithEmptyDataFromCamunda() throws Exception {
- final String jsonString = EMPTY_ARRAY_RESPONSE;
- this.mockRestServiceServer.expect(requestTo(urlProvider.getHistoryProcessInstanceUrl(ID)))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getProcessInstanceId(ID);
- assertEquals(Status.NO_CONTENT.getStatusCode(), response.getStatus());
- assertNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessInstance_FailureResponseWithEmptyDataFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getHistoryProcessInstanceUrl(ID)))
- .andRespond(withBadRequest());
-
- final Response response = objUnderTest.getProcessInstanceId(ID);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- }
-
- @Test
- public void test_GetProcessInstance_UnauthorizedRequestFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getHistoryProcessInstanceUrl(ID)))
- .andRespond(withUnauthorizedRequest());
-
- final Response response = objUnderTest.getProcessInstanceId(ID);
- assertEquals(Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetSinlgeProcessInstance_SuccessResponseWithDataFromCamunda() throws Exception {
- final String jsonString = getJsonResponse(SINGLE_PROCCESS_INSTANCE_RESPONSE_JSON_FILE);
- this.mockRestServiceServer.expect(requestTo(urlProvider.getSingleProcessInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getSingleProcessInstance(PROCESS_INSTACE_ID);
-
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- final ProcessInstanceDetail actualProcessInstance = (ProcessInstanceDetail) response.getEntity();
- assertEquals(PROCESS_INSTACE_ID, actualProcessInstance.getProcessInstanceId());
- assertEquals("EricssonNetworkSliceV1:3:28f9e0fc-9b00-11e8-a57a-022ac90273ed",
- actualProcessInstance.getProcessDefinitionId());
- assertEquals("EricssonNetworkSliceV1", actualProcessInstance.getProcessDefinitionName());
- assertNull(actualProcessInstance.getSuperProcessInstanceId());
- }
-
- @Test
- public void test_GetSingleProcessInstance_WithBadRequestResponseFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getSingleProcessInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withBadRequest());
-
- final Response response = objUnderTest.getSingleProcessInstance(PROCESS_INSTACE_ID);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetSingleProcessInstance_WithUnauthorizedRequestResponseFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getSingleProcessInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withUnauthorizedRequest());
-
- final Response response = objUnderTest.getSingleProcessInstance(PROCESS_INSTACE_ID);
- assertEquals(Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetSingleProcessInstance_NullAndEmptyProcessInstanceIdFromCamunda() throws Exception {
-
- Response response = objUnderTest.getSingleProcessInstance(null);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
-
- response = objUnderTest.getSingleProcessInstance("");
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
-
- @Test
- public void test_GetProcessInstance_EmptyRequestID() throws Exception {
-
- Response response = objUnderTest.getProcessInstanceId(EMPTY_STRING);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
-
- response = objUnderTest.getProcessInstanceId(null);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- }
-
-
- @Test
- public void test_GetProcessDefinitionXml_SuccessResponseWithDataFromCamunda() throws Exception {
- final String jsonString = getJsonResponse(PROCESS_DEF_RESPONSE_JSON_FILE);
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessDefinitionUrl(PROCRESS_DEF_ID)))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getProcessDefinitionXml(PROCRESS_DEF_ID);
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
-
- final ProcessDefinitionDetail actual = (ProcessDefinitionDetail) response.getEntity();
- assertEquals(PROCRESS_DEF_ID, actual.getProcessDefinitionId());
- }
-
- @Test
- public void test_GetProcessDefinitionXml_BadRequestResponseFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessDefinitionUrl(PROCRESS_DEF_ID)))
- .andRespond(withBadRequest());
-
- final Response response = objUnderTest.getProcessDefinitionXml(PROCRESS_DEF_ID);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessDefinitionXml_UnauthorizedRequestFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessDefinitionUrl(PROCRESS_DEF_ID)))
- .andRespond(withUnauthorizedRequest());
-
- final Response response = objUnderTest.getProcessDefinitionXml(PROCRESS_DEF_ID);
- assertEquals(Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessDefinitionXml_NullValues() throws Exception {
- Response response = objUnderTest.getProcessDefinitionXml(EMPTY_STRING);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
-
- response = objUnderTest.getProcessDefinitionXml(null);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetActivityInstanceDetail_SuccessResponseWithDataFromCamunda() throws Exception {
- final String jsonString = getJsonResponse(ACTIVITY_INSTANCE_RESPONSE_JSON_FILE);
- this.mockRestServiceServer.expect(requestTo(urlProvider.getActivityInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getActivityInstanceDetail(PROCESS_INSTACE_ID);
- @SuppressWarnings("unchecked")
- final List<ActivityInstanceDetail> actual = (List<ActivityInstanceDetail>) response.getEntity();
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- assertEquals(12, actual.size());
- final ActivityInstanceDetail activityInstanceDetail = actual.get(0);
- assertEquals("createVCPE_startEvent", activityInstanceDetail.getActivityId());
- assertEquals("Start Flow", activityInstanceDetail.getActivityName());
- assertEquals("startEvent", activityInstanceDetail.getActivityType());
- assertEquals(PROCESS_INSTACE_ID, activityInstanceDetail.getProcessInstanceId());
- assertNull(activityInstanceDetail.getCalledProcessInstanceId());
- assertEquals("26", activityInstanceDetail.getDurationInMillis());
- assertEquals("2018-08-03T16:00:31.815+0000", activityInstanceDetail.getStartTime());
- assertEquals("2018-08-03T16:00:31.841+0000", activityInstanceDetail.getEndTime());
-
- final ActivityInstanceDetail callActivityInstanceDetail = actual.get(4);
- assertEquals("DecomposeService", callActivityInstanceDetail.getActivityId());
- assertEquals("Call Decompose Service", callActivityInstanceDetail.getActivityName());
- assertEquals("callActivity", callActivityInstanceDetail.getActivityType());
- assertEquals("59d99609-9736-11e8-8caf-022ac9304eeb", callActivityInstanceDetail.getCalledProcessInstanceId());
- }
-
- @Test
- public void test_GetActivityInstanceDetail_SuccessResponseWithEmptyDataFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getActivityInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withSuccess(EMPTY_ARRAY_RESPONSE, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getActivityInstanceDetail(PROCESS_INSTACE_ID);
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetActivityInstanceDetail_UnauthorizedRequestFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getActivityInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withUnauthorizedRequest());
-
- final Response response = objUnderTest.getActivityInstanceDetail(PROCESS_INSTACE_ID);
- assertEquals(Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetActivityInstanceDetail_BadRequestFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getActivityInstanceUrl(PROCESS_INSTACE_ID)))
- .andRespond(withBadRequest());
-
- final Response response = objUnderTest.getActivityInstanceDetail(PROCESS_INSTACE_ID);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetActivityInstanceDetail_NullValues() throws Exception {
- Response response = objUnderTest.getActivityInstanceDetail(EMPTY_STRING);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
-
- response = objUnderTest.getActivityInstanceDetail(null);
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessInstanceVariables_SuccessResponseWithDataFromCamunda() throws Exception {
- final String jsonString = getJsonResponse(PROCESS_INSTANCE_VARIABLES_RESPONSE_JSON_FILE);
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessInstanceVariablesUrl(PROCESS_INSTACE_ID)))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getProcessInstanceVariables(PROCESS_INSTACE_ID);
-
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- @SuppressWarnings("unchecked")
- final List<ProcessInstanceVariableDetail> actual = (List<ProcessInstanceVariableDetail>) response.getEntity();
- assertEquals(230, actual.size());
-
- final ProcessInstanceVariableDetail variableDetail = actual.get(0);
- assertEquals("serviceType", variableDetail.getName());
- assertEquals("String", variableDetail.getType());
- assertEquals("PNFSERVICE", variableDetail.getValue());
- }
-
- @Test
- public void test_GetProcessInstanceVariables_SuccessResponseWithEmptyDataFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessInstanceVariablesUrl(PROCESS_INSTACE_ID)))
- .andRespond(withSuccess(EMPTY_ARRAY_RESPONSE, MediaType.APPLICATION_JSON));
-
- final Response response = objUnderTest.getProcessInstanceVariables(PROCESS_INSTACE_ID);
-
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessInstanceVariables_BadRequestFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessInstanceVariablesUrl(PROCESS_INSTACE_ID)))
- .andRespond(withBadRequest());
-
- final Response response = objUnderTest.getProcessInstanceVariables(PROCESS_INSTACE_ID);
-
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessInstanceVariables_UnauthorizedRequestFromCamunda() throws Exception {
- this.mockRestServiceServer.expect(requestTo(urlProvider.getProcessInstanceVariablesUrl(PROCESS_INSTACE_ID)))
- .andRespond(withUnauthorizedRequest());
-
- final Response response = objUnderTest.getProcessInstanceVariables(PROCESS_INSTACE_ID);
-
- assertEquals(Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
- }
-
- @Test
- public void test_GetProcessInstanceVariables_NullAndEmptyValues() throws Exception {
-
- Response response = objUnderTest.getProcessInstanceVariables(EMPTY_STRING);
-
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
-
- response = objUnderTest.getProcessInstanceVariables(null);
-
- assertEquals(Status.BAD_REQUEST.getStatusCode(), response.getStatus());
- assertNotNull(response.getEntity());
-
- }
-
- @Test
- public void test_GetInfraActiveRequests_SuccessResponseWithSoInfraRequestList() throws Exception {
- final String jsonString = getJsonResponse(SEARCH_RESULT_RESPONSE_JSON_FILE);
- this.mockRestServiceServer
- .expect(requestTo(databaseUrlProvider.getSearchUrl(START_TIME_IN_MS, END_TIME_IN_MS, null)))
- .andExpect(header(AUTHORIZATION_HEADER, DATABASE_BASIC_AUTH))
- .andRespond(withSuccess(jsonString, MediaType.APPLICATION_JSON));
-
- final Response response =
- objUnderTest.getInfraActiveRequests(Collections.emptyMap(), START_TIME_IN_MS, END_TIME_IN_MS, null);
-
- assertEquals(Status.OK.getStatusCode(), response.getStatus());
- @SuppressWarnings("unchecked")
- final List<SoInfraRequest> actual = (List<SoInfraRequest>) response.getEntity();
- assertEquals(3, actual.size());
-
- final Map<String, SoInfraRequest> actualRequests = new HashMap<>();
- for (final SoInfraRequest soInfraRequest : actual) {
- actualRequests.put(soInfraRequest.getRequestId(), soInfraRequest);
- }
- final SoInfraRequest infraRequest = actualRequests.get("9383dc81-7a6c-4673-8082-650d50a82a1a");
- assertNull(infraRequest.getEndTime());
- assertEquals("IN_PROGRESS", infraRequest.getRequestStatus());
- }
-
- private String getJsonResponse(final Path path) throws IOException {
- return new String(Files.readAllBytes(path));
- }
-
-}