mso-api-handlers/mso-requests-db-repositories/src/test/java/org/onap/so/db/request/data/repository/InfraActiveRequestsRepositoryImplTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2018 Ericsson. All rights reserved.
   4  * ================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License");
   6  * you may not use this file except in compliance with the License.
   7  * You may obtain a copy of the License at
   8  *
   9  *      http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  * Unless required by applicable law or agreed to in writing, software
  12  * distributed under the License is distributed on an "AS IS" BASIS,
  13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  * See the License for the specific language governing permissions and
  15  * limitations under the License.
  16  *
  17  * SPDX-License-Identifier: Apache-2.0
  18  * ============LICENSE_END=========================================================
  19  */
  20 package org.onap.so.db.request.data.repository;
  21
  22 import static org.junit.Assert.assertEquals;
  23 import static org.junit.Assert.assertFalse;
  24 import static org.junit.Assert.assertNotEquals;
  25 import static org.junit.Assert.assertNull;
  26 import static org.junit.Assert.assertTrue;
  27 import static org.onap.so.db.request.data.repository.InfraActiveRequestsRepositoryImpl.ACTION;
  28 import static org.onap.so.db.request.data.repository.InfraActiveRequestsRepositoryImpl.REQUEST_ID;
  29 import static org.onap.so.db.request.data.repository.InfraActiveRequestsRepositoryImpl.SERVICE_INSTANCE_ID;
  30
  31 import java.util.Collections;
  32 import java.util.HashMap;
  33 import java.util.List;
  34 import java.util.Map;
  35 import java.util.concurrent.TimeUnit;
  36
  37 import org.junit.Test;
  38 import org.junit.runner.RunWith;
  39 import org.onap.so.TestApplication;
  40 import org.onap.so.db.request.beans.InfraActiveRequests;
  41 import org.springframework.beans.factory.annotation.Autowired;
  42 import org.springframework.boot.test.context.SpringBootTest;
  43 import org.springframework.test.context.ActiveProfiles;
  44 import org.springframework.test.context.junit4.SpringRunner;
  45
  46
  47 @RunWith(SpringRunner.class)
  48 @SpringBootTest(classes = TestApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  49 @ActiveProfiles("test")
  50 public class InfraActiveRequestsRepositoryImplTest {
  51
  52     /**
  53      * January 1, 2019 2:00:00 PM
  54      */
  55     private static final long END_TIME = 1546351200000l;
  56
  57     /**
  58      * January 1, 2019 12:45:00 PM
  59      */
  60     private static final long START_TIME = 1546346700000l;
  61     private static final int MAX_LIMIT = 1;
  62
  63     /**
  64      * December 23, 2016 23:59 PM
  65      */
  66     private static final long END_TIME_IN_MILISEC = 1482580740000l;
  67
  68     /**
  69      * December 21, 2016 01:00 AM
  70      */
  71     private static final long START_TIME_IN_MILISEC = 1482282000000l;
  72     private static final String REQUEST_ID_VALUE = "00032ab7-3fb3-42e5-965d-8ea592502017";
  73     private static final String SERVICE_INSTANCE_ID_VALUE = "e3b5744d-2ad1-4cdd-8390-c999a38829bc";
  74
  75     @Autowired
  76     private InfraActiveRequestsRepository objUnderTest;
  77
  78     @Test
  79     public void test_GetInfraActiveRequests_emptyFiltersMap() {
  80         final List<InfraActiveRequests> actualRequests = objUnderTest.getInfraActiveRequests(Collections.emptyMap(),
  81                 START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
  82         assertFalse(actualRequests.isEmpty());
  83     }
  84
  85     @Test
  86     public void test_GetInfraActiveRequests_invalidFiltersMap() {
  87         final Map<String, String[]> filters = new HashMap<>();
  88         filters.put("OverTheMoon", new String[] {"Humpty Dumpty Sat On The Wall"});
  89         final long startTime = START_TIME_IN_MILISEC - TimeUnit.DAYS.toMillis(20);
  90         final long endTime = END_TIME_IN_MILISEC - TimeUnit.DAYS.toMillis(20);
  91         final List<InfraActiveRequests> actualRequests =
  92                 objUnderTest.getInfraActiveRequests(filters, startTime, endTime, null);
  93         assertTrue(actualRequests.isEmpty());
  94     }
  95
  96     @Test
  97     public void test_GetInfraActiveRequests_invalidFiltersMapWithInvalidKey() {
  98         final Map<String, String[]> filters = new HashMap<>();
  99         filters.put("OverTheMoon", new String[] {"Avengers", "Humpty Dumpty Sat On The Wall"});
 100         final List<InfraActiveRequests> actualRequests =
 101                 objUnderTest.getInfraActiveRequests(filters, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
 102         assertFalse(actualRequests.isEmpty());
 103     }
 104
 105     @Test
 106     public void test_GetInfraActiveRequestsData_withEqualServiceInstanceId() {
 107         final Map<String, String[]> values = new HashMap<>();
 108         values.put(SERVICE_INSTANCE_ID, new String[] {QueryOperationType.EQ.name(), SERVICE_INSTANCE_ID_VALUE});
 109         final List<InfraActiveRequests> actualRequests =
 110                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, 1);
 111         assertFalse(actualRequests.isEmpty());
 112
 113         assertEquals(SERVICE_INSTANCE_ID_VALUE, actualRequests.get(0).getServiceInstanceId());
 114     }
 115
 116     @Test
 117     public void test_GetInfraActiveRequestsData_withLikeRequestID() {
 118         final Map<String, String[]> values = new HashMap<>();
 119         values.put(REQUEST_ID, new String[] {QueryOperationType.LIKE.name(), "00032ab7"});
 120         final List<InfraActiveRequests> actualRequests =
 121                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, 1);
 122         assertFalse(actualRequests.isEmpty());
 123
 124         assertEquals(REQUEST_ID_VALUE, actualRequests.get(0).getRequestId());
 125         assertEquals(SERVICE_INSTANCE_ID_VALUE, actualRequests.get(0).getServiceInstanceId());
 126     }
 127
 128
 129     @Test
 130     public void test_GetInfraActiveRequestsData_withLikeRequestIDAndEqualToServiceInstanceId() {
 131         final Map<String, String[]> values = new HashMap<>();
 132         values.put(REQUEST_ID, new String[] {QueryOperationType.LIKE.name(), "00032ab7"});
 133         values.put(SERVICE_INSTANCE_ID, new String[] {QueryOperationType.EQ.name(), SERVICE_INSTANCE_ID_VALUE});
 134         final List<InfraActiveRequests> actualRequests =
 135                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, 1);
 136         assertFalse(actualRequests.isEmpty());
 137
 138         assertEquals(REQUEST_ID_VALUE, actualRequests.get(0).getRequestId());
 139         assertEquals(SERVICE_INSTANCE_ID_VALUE, actualRequests.get(0).getServiceInstanceId());
 140     }
 141
 142
 143     @Test
 144     public void test_GetInfraActiveRequestsData_withNotEqualAction() {
 145         final Map<String, String[]> values = new HashMap<>();
 146         values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
 147         final List<InfraActiveRequests> actualRequests =
 148                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
 149         assertFalse(actualRequests.isEmpty());
 150         for (final InfraActiveRequests actualActiveRequests : actualRequests) {
 151             assertNotEquals("createInstance", actualActiveRequests.getAction());
 152         }
 153     }
 154
 155
 156     @Test
 157     public void test_GetInfraActiveRequestsData_withNotEqualToServiceInstanceNameAndServiceInstanceIdNul() {
 158         final Map<String, String[]> values = new HashMap<>();
 159         values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
 160         values.put(SERVICE_INSTANCE_ID, new String[] {QueryOperationType.EQ.name(), SERVICE_INSTANCE_ID_VALUE});
 161
 162         final List<InfraActiveRequests> actualRequests =
 163                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
 164         assertFalse(actualRequests.isEmpty());
 165         for (final InfraActiveRequests actualActiveRequests : actualRequests) {
 166             assertNotEquals("createInstance", actualActiveRequests.getAction());
 167             assertEquals(SERVICE_INSTANCE_ID_VALUE, actualActiveRequests.getServiceInstanceId());
 168         }
 169     }
 170
 171     @Test
 172     public void test_GetInfraActiveRequestsData_withStartEndDateTimeNotEqualAction() {
 173         final Map<String, String[]> values = new HashMap<>();
 174         values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
 175         final List<InfraActiveRequests> actualRequests =
 176                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, null);
 177         assertFalse(actualRequests.isEmpty());
 178         for (final InfraActiveRequests actualActiveRequests : actualRequests) {
 179             assertNotEquals("createInstance", actualActiveRequests.getAction());
 180         }
 181     }
 182
 183     @Test
 184     public void test_GetInfraActiveRequestsData_withLimitNotEqualAction() {
 185         final Map<String, String[]> values = new HashMap<>();
 186         values.put(ACTION, new String[] {QueryOperationType.NEQ.name(), "createInstance"});
 187         final List<InfraActiveRequests> actualRequests =
 188                 objUnderTest.getInfraActiveRequests(values, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, MAX_LIMIT);
 189         assertFalse(actualRequests.isEmpty());
 190         for (final InfraActiveRequests actualActiveRequests : actualRequests) {
 191             assertNotEquals("createInstance", actualActiveRequests.getAction());
 192         }
 193     }
 194
 195     @Test
 196     public void test_GetInfraActiveRequestsData_withNullFilters() {
 197         final List<InfraActiveRequests> actualRequests =
 198                 objUnderTest.getInfraActiveRequests(null, START_TIME_IN_MILISEC, END_TIME_IN_MILISEC, MAX_LIMIT);
 199         assertTrue(actualRequests.isEmpty());
 200     }
 201
 202     @Test
 203     public void checkInstanceNameDuplicateNullInstanceNameTest() {
 204         final Map<String, String> instanceIdMap = new HashMap<>();
 205         instanceIdMap.put("serviceInstanceId", "e05864f0-ab35-47d0-8be4-56fd9619ba3b");
 206         final InfraActiveRequests results =
 207                 objUnderTest.checkInstanceNameDuplicate((HashMap<String, String>) instanceIdMap, null, "vnf");
 208         assertNull(results);
 209     }
 210
 211     @Test
 212     public void test_GetInfraActiveRequestsData_returnRecordWithNullEndTime() {
 213         final Map<String, String[]> values = new HashMap<>();
 214         values.put(SERVICE_INSTANCE_ID,
 215                 new String[] {QueryOperationType.EQ.name(), "f7712652-b516-4925-a243-64550d26fd84"});
 216         final List<InfraActiveRequests> actualRequests =
 217                 objUnderTest.getInfraActiveRequests(values, START_TIME, END_TIME, null);
 218         assertFalse(actualRequests.isEmpty());
 219
 220         assertEquals(3, actualRequests.size());
 221         final Map<String, InfraActiveRequests> result = new HashMap<>();
 222         for (final InfraActiveRequests actualActiveRequests : actualRequests) {
 223             result.put(actualActiveRequests.getRequestId(), actualActiveRequests);
 224
 225         }
 226         final InfraActiveRequests actualInfraActiveRequests = result.get("9383dc81-7a6c-4673-8082-650d50a82a1a");
 227         assertNull(actualInfraActiveRequests.getEndTime());
 228         assertEquals("IN_PROGRESS", actualInfraActiveRequests.getRequestStatus());
 229     }
 230
 231 }