diff options
author | waqas.ikram <waqas.ikram@est.tech> | 2021-02-18 10:43:20 +0000 |
---|---|---|
committer | waqas.ikram <waqas.ikram@est.tech> | 2021-02-18 11:05:55 +0000 |
commit | bb9977b738bcb0ff5436f519da0e88017e42573d (patch) | |
tree | e3fe100abf42b2a0e432b3cfb898cabddbd77956 /so-monitoring/so-monitoring-service/src/test/java/org/onap | |
parent | 48997934fa955d2b89eab9742634e4251113e6bf (diff) |
Removing so-monitoring module
Change-Id: I2b6ef2fd61d08925696cde63c53f16dd87700d52
Issue-ID: SO-3487
Signed-off-by: waqas.ikram <waqas.ikram@est.tech>
Diffstat (limited to 'so-monitoring/so-monitoring-service/src/test/java/org/onap')
2 files changed, 0 insertions, 489 deletions
diff --git a/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/Constants.java b/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/Constants.java deleted file mode 100644 index aef8234228..0000000000 --- a/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/Constants.java +++ /dev/null @@ -1,67 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2019 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 java.nio.file.Path; -import java.nio.file.Paths; -import java.util.UUID; - -/** - * @author andrei.barcovschi@ericsson.com - * - */ -public class Constants { - - public static final String PROCRESS_DEF_ID = "AFRFLOW:1:c6eea1b7-9722-11e8-8caf-022ac9304eeb"; - - public static final String EMPTY_ARRAY_RESPONSE = "[]"; - - public static final String PROCESS_INSTACE_ID = "5956a99d-9736-11e8-8caf-022ac9304eeb"; - - public static final String EMPTY_STRING = ""; - - public static final String SOURCE_TEST_FOLDER = "src/test/resources/camundaResponses/"; - - public static final Path PROCESS_DEF_RESPONSE_JSON_FILE = Paths.get(SOURCE_TEST_FOLDER + "processDefinition.json"); - - public static final Path ACTIVITY_INSTANCE_RESPONSE_JSON_FILE = - Paths.get(SOURCE_TEST_FOLDER + "activityInstance.json"); - - public static final Path PROCESS_INSTANCE_VARIABLES_RESPONSE_JSON_FILE = - Paths.get(SOURCE_TEST_FOLDER + "processInstanceVariables.json"); - - public static final Path PROCCESS_INSTANCE_RESPONSE_JSON_FILE = - Paths.get(SOURCE_TEST_FOLDER + "processInstance.json"); - - public static final Path SINGLE_PROCCESS_INSTANCE_RESPONSE_JSON_FILE = - Paths.get(SOURCE_TEST_FOLDER + "singleprocessInstance.json"); - - public static final Path SEARCH_RESULT_RESPONSE_JSON_FILE = - Paths.get("src/test/resources/databaseResponses/searchResult.json"); - - public static final String ID = UUID.randomUUID().toString(); - - public static final long END_TIME_IN_MS = 1546351200000l; - - public static final long START_TIME_IN_MS = 1546346700000l; - - private Constants() {} - -} 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)); - } - -} |