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, 184 insertions, 0 deletions

diff --git a/mso-api-handlers/mso-requests-db/src/test/java/org/onap/so/db/request/data/repository/InfraActiveRequestsRepositoryImplTest.java b/mso-api-handlers/mso-requests-db/src/test/java/org/onap/so/db/request/data/repository/InfraActiveRequestsRepositoryImplTest.java
new file mode 100644
index 0000000000..d889a15fc4
--- /dev/null
+++ b/mso-api-handlers/mso-requests-db/src/test/java/org/onap/so/db/request/data/repository/InfraActiveRequestsRepositoryImplTest.java
@@ -0,0 +1,184 @@
+/*-
+ * ============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.db.request.data.repository;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertTrue;
+import static org.onap.so.db.request.data.repository.InfraActiveRequestsRepositoryImpl.ACTION;
+import static org.onap.so.db.request.data.repository.InfraActiveRequestsRepositoryImpl.REQUEST_ID;
+import static org.onap.so.db.request.data.repository.InfraActiveRequestsRepositoryImpl.SERVICE_INSTANCE_ID;
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.onap.so.TestApplication;
+import org.onap.so.db.request.beans.InfraActiveRequests;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.junit4.SpringRunner;
+
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = TestApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
+@ActiveProfiles("test")
+public class InfraActiveRequestsRepositoryImplTest {
+
+    private static final int MAX_LIMIT = 1;
+    private static final long END_TIME_IN_MILISEC = 1482436800000l;
+    private static final long START_TIME_IN_MILISEC = 1482429600000l;
+    private static final String REQUEST_ID_VALUE = "00032ab7-3fb3-42e5-965d-8ea592502017";
+    private static final String SERVICE_INSTANCE_ID_VALUE = "e3b5744d-2ad1-4cdd-8390-c999a38829bc";
+
+    @Autowired
+    private InfraActiveRequestsRepository objUnderTest;
+
+    @Test
+    public void test_GetInfraActiveRequests_emptyFiltersMap() {
+        final List<InfraActiveRequests> actualRequests = objUnderTest.getInfraActiveRequests(Collections.emptyMap(),
+                START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
+        assertFalse(actualRequests.isEmpty());
+    }
+
+    @Test
+    public void test_GetInfraActiveRequests_invalidFiltersMap() {
+        final Map<String, String[]> filters = new HashMap<>();
+        filters.put("OverTheMoon", new String[] {"Humpty Dumpty Sat On The Wall"});
+        final long startTime = START_TIME_IN_MILISEC - TimeUnit.DAYS.toMillis(20);
+        final long endTime = END_TIME_IN_MILISEC - TimeUnit.DAYS.toMillis(20);
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(filters, startTime, endTime, null);
+        assertTrue(actualRequests.isEmpty());
+    }
+
+    @Test
+    public void test_GetInfraActiveRequests_invalidFiltersMapWithInvalidKey() {
+        final Map<String, String[]> filters = new HashMap<>();
+        filters.put("OverTheMoon", new String[] {"Avengers", "Humpty Dumpty Sat On The Wall"});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(filters, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
+        assertFalse(actualRequests.isEmpty());
+    }
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withEqualServiceInstanceId() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(SERVICE_INSTANCE_ID, new String[] {QueryOperationType.EQ.name(), SERVICE_INSTANCE_ID_VALUE});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, 1);
+        assertFalse(actualRequests.isEmpty());
+
+        assertEquals(SERVICE_INSTANCE_ID_VALUE, actualRequests.get(0).getServiceInstanceId());
+    }
+
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withLikeRequestID() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(REQUEST_ID, new String[] {QueryOperationType.LIKE.name(), "00032ab7"});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, 1);
+        assertFalse(actualRequests.isEmpty());
+
+        assertEquals(REQUEST_ID_VALUE, actualRequests.get(0).getRequestId());
+        assertEquals(SERVICE_INSTANCE_ID_VALUE, actualRequests.get(0).getServiceInstanceId());
+    }
+
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withLikeRequestIDAndEqualToServiceInstanceId() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(REQUEST_ID, new String[] {QueryOperationType.LIKE.name(), "00032ab7"});
+        values.put(SERVICE_INSTANCE_ID, new String[] {QueryOperationType.EQ.name(), SERVICE_INSTANCE_ID_VALUE});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, 1);
+        assertFalse(actualRequests.isEmpty());
+
+        assertEquals(REQUEST_ID_VALUE, actualRequests.get(0).getRequestId());
+        assertEquals(SERVICE_INSTANCE_ID_VALUE, actualRequests.get(0).getServiceInstanceId());
+    }
+
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withNotEqualAction() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
+        assertFalse(actualRequests.isEmpty());
+        for (final InfraActiveRequests actualActiveRequests : actualRequests) {
+            assertNotEquals("createInstance", actualActiveRequests.getAction());
+        }
+    }
+
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withNotEqualToServiceInstanceNameAndServiceInstanceIdNul() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
+        values.put(SERVICE_INSTANCE_ID, new String[] {QueryOperationType.EQ.name(), SERVICE_INSTANCE_ID_VALUE});
+
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
+        assertFalse(actualRequests.isEmpty());
+        for (final InfraActiveRequests actualActiveRequests : actualRequests) {
+            assertNotEquals("createInstance", actualActiveRequests.getAction());
+            assertEquals(SERVICE_INSTANCE_ID_VALUE, actualActiveRequests.getServiceInstanceId());
+        }
+    }
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withStartEndDateTimeNotEqualAction() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
+        assertFalse(actualRequests.isEmpty());
+        for (final InfraActiveRequests actualActiveRequests : actualRequests) {
+            assertNotEquals("createInstance", actualActiveRequests.getAction());
+        }
+    }
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withLimitNotEqualAction() {
+        final Map<String, String[]> values = new HashMap<>();
+        values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, MAX_LIMIT);
+        assertFalse(actualRequests.isEmpty());
+        for (final InfraActiveRequests actualActiveRequests : actualRequests) {
+            assertNotEquals("createInstance", actualActiveRequests.getAction());
+        }
+    }
+
+    @Test
+    public void test_GetInfraActiveRequestsData_withNullFilters() {
+        final List<InfraActiveRequests> actualRequests =
+                objUnderTest.getInfraActiveRequests(null, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, MAX_LIMIT);
+        assertTrue(actualRequests.isEmpty());
+    }
+}