gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.so.apihandlerinfra;
  22
  23 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
  24 import static org.junit.Assert.assertEquals;
  25 import static org.junit.Assert.assertThat;
  26 import static org.mockito.Mockito.doNothing;
  27 import static org.mockito.Mockito.doReturn;
  28 import java.io.IOException;
  29 import java.nio.file.Files;
  30 import java.nio.file.Paths;
  31 import java.sql.Timestamp;
  32 import org.junit.Before;
  33 import org.junit.Rule;
  34 import org.junit.Test;
  35 import org.junit.rules.ExpectedException;
  36 import org.junit.runner.RunWith;
  37 import org.mockito.InjectMocks;
  38 import org.mockito.Mock;
  39 import org.mockito.Spy;
  40 import org.mockito.junit.MockitoJUnitRunner;
  41 import org.onap.so.apihandlerinfra.exceptions.ApiException;
  42 import org.onap.so.apihandlerinfra.exceptions.VfModuleNotFoundException;
  43 import org.onap.so.db.catalog.beans.VfModule;
  44 import org.onap.so.db.catalog.client.CatalogDbClient;
  45 import org.onap.so.db.request.beans.InfraActiveRequests;
  46 import org.onap.so.serviceinstancebeans.ModelInfo;
  47 import org.onap.so.serviceinstancebeans.ModelType;
  48
  49 @RunWith(MockitoJUnitRunner.class)
  50 public class RequestHandlerUtilsUnitTest {
  51
  52     @Mock
  53     private CatalogDbClient catDbClient;
  54
  55     @InjectMocks
  56     @Spy
  57     private RequestHandlerUtils requestHandler;
  58
  59     @Rule
  60     public ExpectedException thrown = ExpectedException.none();
  61
  62     private static final String CURRENT_REQUEST_ID = "eca3a1b1-43ab-457e-ab1c-367263d148b4";
  63     private static final String RESUMED_REQUEST_ID = "59c7247f-839f-4923-90c3-05faa3ab354d";
  64     private static final String SERVICE_INSTANCE_ID = "00032ab7-na18-42e5-965d-8ea592502018";
  65     private static final String SERVICE_INSTANCE_NAME = "serviceInstanceName";
  66     private static final String VNF_ID = "00032ab7-na18-42e5-965d-8ea592502017";
  67     private static final String VFMODULE_ID = "00032ab7-na18-42e5-965d-8ea592502016";
  68     private static final String NETWORK_ID = "00032ab7-na18-42e5-965d-8ea592502015";
  69     private static final String VOLUME_GROUP_ID = "00032ab7-na18-42e5-965d-8ea592502014";
  70     private static final String VNF_NAME = "vnfName";
  71     private static final String VFMODULE_NAME = "vfModuleName";
  72     private static final String NETWORK_NAME = "networkName";
  73     private static final String VOLUME_GROUP_NAME = "volumeGroupName";
  74     private static final String MODEL_VERSION_ID = "883f4a7a-b5a5-44e0-8738-361c6413d24c";
  75     private static final String MODEL_VERSION = "1.0";
  76     private static final String MODEL_INVARIANT_ID = "d358b828-e7f8-4833-ac96-2782bed1a9a9";
  77     private static final String MODEL_NAME = "modelName";
  78     private final Timestamp startTimeStamp = new Timestamp(System.currentTimeMillis());
  79     private String requestUri =
  80             "http:localhost:6746/onap/so/infra/orchestrationRequests/v7/00032ab7-na18-42e5-965d-8ea592502019/resume";
  81     private InfraActiveRequests infraActiveRequest = new InfraActiveRequests();
  82     private InfraActiveRequests currentActiveRequest = new InfraActiveRequests();
  83     private InfraActiveRequests currentActiveRequestIARNull = new InfraActiveRequests();
  84     private Action action = Action.createInstance;
  85     private String vnfType = "vnfType";
  86     private String sdcServiceModelVersion = "7";
  87
  88     public String getRequestBody(String request) throws IOException {
  89         request = "src/test/resources/ResumeOrchestrationRequest" + request;
  90         return new String(Files.readAllBytes(Paths.get(request)));
  91     }
  92
  93     @Before
  94     public void setup() throws IOException {
  95         setInfraActiveRequest();
  96         setCurrentActiveRequest();
  97         setCurrentActiveRequestNullInfraActive();
  98     }
  99
 100     private void setInfraActiveRequest() throws IOException {
 101         infraActiveRequest.setTenantId("tenant-id");
 102         infraActiveRequest.setRequestBody(getRequestBody("/RequestBody.json"));
 103         infraActiveRequest.setAicCloudRegion("cloudRegion");
 104         infraActiveRequest.setRequestScope("service");
 105         infraActiveRequest.setServiceInstanceId(SERVICE_INSTANCE_ID);
 106         infraActiveRequest.setServiceInstanceName(SERVICE_INSTANCE_NAME);
 107         infraActiveRequest.setRequestStatus(Status.IN_PROGRESS.toString());
 108         infraActiveRequest.setRequestAction(Action.createInstance.toString());
 109         infraActiveRequest.setServiceType("serviceType");
 110     }
 111
 112     private void setCurrentActiveRequest() throws IOException {
 113         currentActiveRequest.setRequestId(CURRENT_REQUEST_ID);
 114         currentActiveRequest.setSource("VID");
 115         currentActiveRequest.setStartTime(startTimeStamp);
 116         currentActiveRequest.setTenantId("tenant-id");
 117         currentActiveRequest.setRequestBody(getRequestBody("/RequestBody.json"));
 118         currentActiveRequest.setAicCloudRegion("cloudRegion");
 119         currentActiveRequest.setRequestScope("service");
 120         currentActiveRequest.setRequestStatus(Status.IN_PROGRESS.toString());
 121         currentActiveRequest.setLastModifiedBy(Constants.MODIFIED_BY_APIHANDLER);
 122         currentActiveRequest.setRequestAction(Action.createInstance.toString());
 123         currentActiveRequest.setRequestUrl(requestUri);
 124         currentActiveRequest.setRequestorId("xxxxxx");
 125         currentActiveRequest.setProgress(new Long(5));
 126         currentActiveRequest.setOriginalRequestId(RESUMED_REQUEST_ID);
 127     }
 128
 129     private void setCurrentActiveRequestNullInfraActive() throws IOException {
 130         currentActiveRequestIARNull.setRequestId(CURRENT_REQUEST_ID);
 131         currentActiveRequestIARNull.setSource("VID");
 132         currentActiveRequestIARNull.setStartTime(startTimeStamp);
 133         currentActiveRequestIARNull.setRequestStatus(Status.IN_PROGRESS.toString());
 134         currentActiveRequestIARNull.setLastModifiedBy(Constants.MODIFIED_BY_APIHANDLER);
 135         currentActiveRequestIARNull.setRequestUrl(requestUri);
 136         currentActiveRequestIARNull.setRequestorId("xxxxxx");
 137         currentActiveRequestIARNull.setProgress(new Long(5));
 138         currentActiveRequestIARNull.setOriginalRequestId(RESUMED_REQUEST_ID);
 139     }
 140
 141
 142     @Test
 143     public void createNewRecordCopyFromInfraActiveRequestTest() {
 144         doNothing().when(requestHandler).setInstanceIdAndName(infraActiveRequest, currentActiveRequest);
 145         InfraActiveRequests result = requestHandler.createNewRecordCopyFromInfraActiveRequest(infraActiveRequest,
 146                 CURRENT_REQUEST_ID, startTimeStamp, "VID", requestUri, "xxxxxx", RESUMED_REQUEST_ID);
 147         assertThat(currentActiveRequest, sameBeanAs(result));
 148     }
 149
 150     @Test
 151     public void createNewRecordCopyFromInfraActiveRequestNullIARTest() {
 152         InfraActiveRequests result = requestHandler.createNewRecordCopyFromInfraActiveRequest(null, CURRENT_REQUEST_ID,
 153                 startTimeStamp, "VID", requestUri, "xxxxxx", RESUMED_REQUEST_ID);
 154         assertThat(currentActiveRequestIARNull, sameBeanAs(result));
 155     }
 156
 157     @Test
 158     public void setInstanceIdAndNameServiceTest() {
 159         InfraActiveRequests serviceRequest = new InfraActiveRequests();
 160
 161         InfraActiveRequests expected = new InfraActiveRequests();
 162         expected.setServiceInstanceId(SERVICE_INSTANCE_ID);
 163         expected.setServiceInstanceName(SERVICE_INSTANCE_NAME);
 164
 165         requestHandler.setInstanceIdAndName(infraActiveRequest, serviceRequest);
 166         assertThat(serviceRequest, sameBeanAs(expected));
 167     }
 168
 169     @Test
 170     public void setInstanceIdAndNameRequestScopeNotValidTest() {
 171         InfraActiveRequests originalServiceRequest = new InfraActiveRequests();
 172         originalServiceRequest.setRequestScope("test");
 173         InfraActiveRequests serviceRequest = new InfraActiveRequests();
 174
 175         InfraActiveRequests expected = new InfraActiveRequests();
 176
 177         requestHandler.setInstanceIdAndName(originalServiceRequest, serviceRequest);
 178         assertThat(serviceRequest, sameBeanAs(expected));
 179     }
 180
 181     @Test
 182     public void setInstanceIdAndNameVnfTest() {
 183         InfraActiveRequests vnfRequestOriginal = new InfraActiveRequests();
 184         vnfRequestOriginal.setRequestScope("vnf");
 185         vnfRequestOriginal.setVnfId(VNF_ID);
 186         vnfRequestOriginal.setVnfName(VNF_NAME);
 187         InfraActiveRequests vnfRequest = new InfraActiveRequests();
 188
 189         InfraActiveRequests expected = new InfraActiveRequests();
 190         expected.setVnfId(VNF_ID);
 191         expected.setVnfName(VNF_NAME);
 192
 193         requestHandler.setInstanceIdAndName(vnfRequestOriginal, vnfRequest);
 194         assertThat(vnfRequest, sameBeanAs(expected));
 195     }
 196
 197     @Test
 198     public void setInstanceIdAndNameVfModuleTest() {
 199         InfraActiveRequests vfModuleRequestOriginal = new InfraActiveRequests();
 200         vfModuleRequestOriginal.setRequestScope("vfModule");
 201         vfModuleRequestOriginal.setVfModuleId(VFMODULE_ID);
 202         vfModuleRequestOriginal.setVfModuleName(VFMODULE_NAME);
 203         InfraActiveRequests vfModuleRequest = new InfraActiveRequests();
 204
 205         InfraActiveRequests expected = new InfraActiveRequests();
 206         expected.setVfModuleId(VFMODULE_ID);
 207         expected.setVfModuleName(VFMODULE_NAME);
 208
 209         requestHandler.setInstanceIdAndName(vfModuleRequestOriginal, vfModuleRequest);
 210         assertThat(vfModuleRequest, sameBeanAs(expected));
 211     }
 212
 213     @Test
 214     public void setInstanceIdAndNameNetworkTest() {
 215         InfraActiveRequests networkRequestOriginal = new InfraActiveRequests();
 216         networkRequestOriginal.setRequestScope("network");
 217         networkRequestOriginal.setNetworkId(NETWORK_ID);
 218         networkRequestOriginal.setNetworkName(NETWORK_NAME);
 219         InfraActiveRequests networkRequest = new InfraActiveRequests();
 220
 221         InfraActiveRequests expected = new InfraActiveRequests();
 222         expected.setNetworkId(NETWORK_ID);
 223         expected.setNetworkName(NETWORK_NAME);
 224
 225         requestHandler.setInstanceIdAndName(networkRequestOriginal, networkRequest);
 226         assertThat(networkRequest, sameBeanAs(expected));
 227     }
 228
 229     @Test
 230     public void setInstanceIdAndNameVolumeGroupTest() {
 231         InfraActiveRequests volumeGroupRequestOriginal = new InfraActiveRequests();
 232         volumeGroupRequestOriginal.setRequestScope("volumeGroup");
 233         volumeGroupRequestOriginal.setVolumeGroupId(VOLUME_GROUP_ID);
 234         volumeGroupRequestOriginal.setVolumeGroupName(VOLUME_GROUP_NAME);
 235         InfraActiveRequests volumeGroupRequest = new InfraActiveRequests();
 236
 237         InfraActiveRequests expected = new InfraActiveRequests();
 238         expected.setVolumeGroupId(VOLUME_GROUP_ID);
 239         expected.setVolumeGroupName(VOLUME_GROUP_NAME);
 240
 241         requestHandler.setInstanceIdAndName(volumeGroupRequestOriginal, volumeGroupRequest);
 242         assertThat(volumeGroupRequest, sameBeanAs(expected));
 243     }
 244
 245     @Test
 246     public void getIsBaseVfModuleTrueTest() throws ApiException {
 247         VfModule vfModule = new VfModule();
 248         vfModule.setIsBase(true);
 249         ModelInfo modelInfo = new ModelInfo();
 250         modelInfo.setModelVersionId(MODEL_VERSION_ID);
 251
 252         doReturn(vfModule).when(catDbClient).getVfModuleByModelUUID(MODEL_VERSION_ID);
 253         Boolean expected = true;
 254
 255         Boolean result = requestHandler.getIsBaseVfModule(modelInfo, action, vnfType, sdcServiceModelVersion,
 256                 currentActiveRequest);
 257         assertEquals(result, expected);
 258     }
 259
 260     @Test
 261     public void getIsBaseVfModuleFalseTest() throws ApiException {
 262         VfModule vfModule = new VfModule();
 263         vfModule.setIsBase(false);
 264         ModelInfo modelInfo = new ModelInfo();
 265         modelInfo.setModelVersionId(MODEL_VERSION_ID);
 266
 267         doReturn(vfModule).when(catDbClient).getVfModuleByModelUUID(MODEL_VERSION_ID);
 268         Boolean expected = false;
 269
 270         Boolean result = requestHandler.getIsBaseVfModule(modelInfo, action, vnfType, sdcServiceModelVersion,
 271                 currentActiveRequest);
 272         assertEquals(result, expected);
 273     }
 274
 275     @Test
 276     public void getIsBaseVfModuleNullTest() throws ApiException {
 277         ModelInfo modelInfo = new ModelInfo();
 278         modelInfo.setModelVersionId(MODEL_VERSION_ID);
 279         modelInfo.setModelName(MODEL_NAME);
 280         String errorMessage =
 281                 "VnfType vnfType and VF Module Model Name modelName with version 7 not found in MSO Catalog DB";
 282
 283         doNothing().when(requestHandler).updateStatus(currentActiveRequest, Status.FAILED, errorMessage);
 284         doReturn(null).when(catDbClient).getVfModuleByModelUUID(MODEL_VERSION_ID);
 285
 286         thrown.expect(VfModuleNotFoundException.class);
 287         thrown.expectMessage(errorMessage);
 288         requestHandler.getIsBaseVfModule(modelInfo, action, vnfType, sdcServiceModelVersion, currentActiveRequest);
 289     }
 290
 291     @Test
 292     public void getIsBaseVfModuleModelVersionIdNullTest() throws ApiException {
 293         ModelInfo modelInfo = new ModelInfo();
 294         modelInfo.setModelInvariantId(MODEL_INVARIANT_ID);
 295         modelInfo.setModelVersion(MODEL_VERSION);
 296         modelInfo.setModelName(MODEL_NAME);
 297         Boolean expected = false;
 298
 299         doReturn(null).when(catDbClient).getVfModuleByModelInvariantUUIDAndModelVersion(MODEL_INVARIANT_ID,
 300                 MODEL_VERSION);
 301
 302         Boolean result = requestHandler.getIsBaseVfModule(modelInfo, Action.deleteInstance, vnfType,
 303                 sdcServiceModelVersion, currentActiveRequest);
 304         assertEquals(result, expected);
 305     }
 306
 307     @Test
 308     public void getIsBaseVfModuleModelInfoNotSetTest() throws ApiException {
 309         ModelInfo modelInfo = new ModelInfo();
 310         Boolean expected = false;
 311
 312         Boolean result = requestHandler.getIsBaseVfModule(modelInfo, Action.deleteInstance, vnfType,
 313                 sdcServiceModelVersion, currentActiveRequest);
 314         assertEquals(result, expected);
 315     }
 316
 317     @Test
 318     public void getIsBaseVfModuleModelVersionNullTest() throws ApiException {
 319         ModelInfo modelInfo = new ModelInfo();
 320         modelInfo.setModelInvariantId(MODEL_INVARIANT_ID);
 321         modelInfo.setModelName(MODEL_NAME);
 322         Boolean expected = false;
 323
 324         Boolean result = requestHandler.getIsBaseVfModule(modelInfo, Action.deleteInstance, vnfType,
 325                 sdcServiceModelVersion, currentActiveRequest);
 326         assertEquals(result, expected);
 327     }
 328
 329     @Test
 330     public void getIsBaseVfModuleModelVersionNullUpdateTest() throws ApiException {
 331         ModelInfo modelInfo = new ModelInfo();
 332         modelInfo.setModelInvariantId(MODEL_INVARIANT_ID);
 333         modelInfo.setModelName(MODEL_NAME);
 334         String errorMessage = "VnfType vnfType and VF Module Model Name modelName not found in MSO Catalog DB";
 335
 336         doNothing().when(requestHandler).updateStatus(currentActiveRequest, Status.FAILED, errorMessage);
 337
 338         thrown.expect(VfModuleNotFoundException.class);
 339         thrown.expectMessage(errorMessage);
 340         requestHandler.getIsBaseVfModule(modelInfo, Action.updateInstance, vnfType, null, currentActiveRequest);
 341     }
 342
 343     @Test
 344     public void getIsBaseVfModulesdcModelVersionEmptyTest() throws ApiException {
 345         ModelInfo modelInfo = new ModelInfo();
 346         modelInfo.setModelInvariantId(MODEL_INVARIANT_ID);
 347         modelInfo.setModelName(MODEL_NAME);
 348         String errorMessage = "VnfType vnfType and VF Module Model Name modelName not found in MSO Catalog DB";
 349
 350         doNothing().when(requestHandler).updateStatus(currentActiveRequest, Status.FAILED, errorMessage);
 351
 352         thrown.expect(VfModuleNotFoundException.class);
 353         thrown.expectMessage(errorMessage);
 354         requestHandler.getIsBaseVfModule(modelInfo, Action.updateInstance, vnfType, "", currentActiveRequest);
 355     }
 356
 357     @Test
 358     public void getModelTypeApplyUpdatedConfigTest() {
 359         ModelType modelTypeExpected = ModelType.vnf;
 360
 361         ModelType modelTypeResult = requestHandler.getModelType(Action.applyUpdatedConfig, null);
 362         assertEquals(modelTypeResult, modelTypeExpected);
 363     }
 364
 365     @Test
 366     public void getModelTypeInPlaceSoftwareUpdateTest() {
 367         ModelType modelTypeExpected = ModelType.vnf;
 368
 369         ModelType modelTypeResult = requestHandler.getModelType(Action.inPlaceSoftwareUpdate, null);
 370         assertEquals(modelTypeResult, modelTypeExpected);
 371     }
 372
 373     @Test
 374     public void getModelTypeAddMembersTest() {
 375         ModelType modelTypeExpected = ModelType.instanceGroup;
 376
 377         ModelType modelTypeResult = requestHandler.getModelType(Action.addMembers, null);
 378         assertEquals(modelTypeResult, modelTypeExpected);
 379     }
 380
 381     @Test
 382     public void getModelTypeRemoveMembersTest() {
 383         ModelType modelTypeExpected = ModelType.instanceGroup;
 384
 385         ModelType modelTypeResult = requestHandler.getModelType(Action.removeMembers, null);
 386         assertEquals(modelTypeResult, modelTypeExpected);
 387     }
 388
 389     @Test
 390     public void getModelTypeTest() {
 391         ModelType modelTypeExpected = ModelType.service;
 392         ModelInfo modelInfo = new ModelInfo();
 393         modelInfo.setModelType(ModelType.service);
 394
 395         ModelType modelTypeResult = requestHandler.getModelType(Action.createInstance, modelInfo);
 396         assertEquals(modelTypeResult, modelTypeExpected);
 397     }
 398
 399 }