Adding rest service for so monitoring

Change-Id: I9dac918998901d54b3cbc5477cc9c057c3019cb3
Issue-ID: SO-724
Signed-off-by: waqas.ikram <waqas.ikram@ericsson.com>

1 files changed, 400 insertions, 0 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
new file mode 100644
index 0000000000..13953b0331
--- /dev/null
+++ b/so-monitoring/so-monitoring-service/src/test/java/org/onap/so/monitoring/rest/api/SoMonitoringControllerTest.java
@@ -0,0 +1,400 @@
+/*-
+ * ============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.montoring.configuration.rest.RestTemplateConfigration.CAMUNDA_REST_TEMPLATE;
+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.nio.file.Paths;
+import java.util.List;
+import java.util.UUID;
+
+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.montoring.configuration.camunda.CamundaRestUrlProvider;
+import org.onap.so.montoring.model.ActivityInstanceDetail;
+import org.onap.so.montoring.model.ProcessDefinitionDetail;
+import org.onap.so.montoring.model.ProcessInstanceDetail;
+import org.onap.so.montoring.model.ProcessInstanceIdDetail;
+import org.onap.so.montoring.model.ProcessInstanceVariableDetail;
+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
+ */
+@RunWith(SpringJUnit4ClassRunner.class)
+@ActiveProfiles("test")
+@SpringBootTest
+public class SoMonitoringControllerTest {
+
+    private static final String PROCRESS_DEF_ID = "AFRFLOW:1:c6eea1b7-9722-11e8-8caf-022ac9304eeb";
+
+    private static final String EMPTY_ARRAY_RESPONSE = "[]";
+
+    private static final String PROCESS_INSTACE_ID = "5956a99d-9736-11e8-8caf-022ac9304eeb";
+
+    private static final String EMPTY_STRING = "";
+
+    private static final String SOURCE_TEST_FOLDER = "src/test/resources/camundaResponses/";
+
+    private static final Path PROCESS_DEF_RESPONSE_JSON_FILE = Paths.get(SOURCE_TEST_FOLDER + "processDefinition.json");
+
+    private static final Path ACTIVITY_INSTANCE_RESPONSE_JSON_FILE =
+            Paths.get(SOURCE_TEST_FOLDER + "activityInstance.json");
+
+    private static final Path PROCESS_INSTANCE_VARIABLES_RESPONSE_JSON_FILE =
+            Paths.get(SOURCE_TEST_FOLDER + "processInstanceVariables.json");
+
+    private static final Path PROCCESS_INSTANCE_RESPONSE_JSON_FILE =
+            Paths.get(SOURCE_TEST_FOLDER + "processInstance.json");
+
+    private static final Path SINGLE_PROCCESS_INSTANCE_RESPONSE_JSON_FILE =
+            Paths.get(SOURCE_TEST_FOLDER + "singleprocessInstance.json");
+
+    private static final String ID = UUID.randomUUID().toString();
+
+    @Autowired
+    @Qualifier(CAMUNDA_REST_TEMPLATE)
+    private RestTemplate restTemplate;
+
+    @Autowired
+    private CamundaRestUrlProvider urlProvider;
+
+    private MockRestServiceServer camundaMockServer;
+
+    @Autowired
+    private SoMonitoringController objUnderTest;
+
+    @Before
+    public void setUp() throws Exception {
+        camundaMockServer = MockRestServiceServer.bindTo(restTemplate).build();
+    }
+
+    @Test
+    public void test_GetProcessInstance_SuccessResponseWithDataFromCamunda() throws Exception {
+        final String jsonString = getJsonResponse(PROCCESS_INSTANCE_RESPONSE_JSON_FILE);
+        this.camundaMockServer.expect(requestTo(urlProvider.getHistoryProcessInstanceUrl(ID)))
+                .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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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());
+
+        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.camundaMockServer.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.camundaMockServer.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.camundaMockServer.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());
+
+    }
+
+    private String getJsonResponse(final Path path) throws IOException {
+        return new String(Files.readAllBytes(path));
+    }
+
+}