adapters/mso-requests-db-adapter/src/test/java/org/onap/so/adapters/requestsdb/adapters/MSORequestDBImplTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 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.adapters.requestsdb.adapters;
  22
  23 import static com.shazam.shazamcrest.MatcherAssert.assertThat;
  24 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
  25 import static org.junit.Assert.assertEquals;
  26 import static org.junit.Assert.assertNotNull;
  27 import static org.junit.Assert.fail;
  28
  29 import java.util.ArrayList;
  30 import java.util.List;
  31 import java.util.Map;
  32 import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
  33 import org.junit.Before;
  34 import org.junit.Rule;
  35 import org.junit.Test;
  36 import org.junit.rules.ExpectedException;
  37 import org.junit.runner.RunWith;
  38 import org.onap.so.adapters.requestsdb.application.TestAppender;
  39 import org.onap.logging.ref.slf4j.ONAPLogConstants;
  40 import org.onap.so.adapters.requestsdb.MsoRequestsDbAdapter;
  41 import org.onap.so.adapters.requestsdb.RequestStatusType;
  42 import org.onap.so.adapters.requestsdb.application.MSORequestDBApplication;
  43 import org.onap.so.adapters.requestsdb.exceptions.MsoRequestsDbException;
  44 import org.onap.so.db.request.beans.InfraActiveRequests;
  45 import org.onap.so.db.request.beans.OperationStatus;
  46 import org.onap.so.db.request.beans.ResourceOperationStatus;
  47 import org.onap.so.db.request.data.repository.OperationStatusRepository;
  48 import org.onap.so.db.request.data.repository.ResourceOperationStatusRepository;
  49 import org.onap.so.requestsdb.RequestsDbConstant;
  50 import org.springframework.beans.factory.annotation.Autowired;
  51 import org.springframework.beans.factory.annotation.Qualifier;
  52 import org.springframework.boot.web.server.LocalServerPort;
  53 import org.springframework.boot.test.context.SpringBootTest;
  54 import org.springframework.context.annotation.Bean;
  55 import org.springframework.test.context.ActiveProfiles;
  56 import org.springframework.test.context.ContextConfiguration;
  57 import org.springframework.test.context.junit4.SpringRunner;
  58 import ch.qos.logback.classic.spi.ILoggingEvent;
  59
  60 @RunWith(SpringRunner.class)
  61 @SpringBootTest(classes = MSORequestDBApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  62 @ActiveProfiles("test")
  63 public class MSORequestDBImplTest {
  64
  65         @LocalServerPort
  66         private int port;
  67
  68         private MsoRequestsDbAdapter dbAdapter;
  69
  70     @Autowired
  71     private OperationStatusRepository operationStatusRepository;
  72
  73     @Autowired
  74     private ResourceOperationStatusRepository resourceOperationStatusRepo;
  75
  76     @Rule
  77     public ExpectedException thrown = ExpectedException.none();
  78
  79         public InfraActiveRequests setupTestEntities()   {
  80                 return buildTestRequest();
  81         }
  82
  83         @Before
  84         public void before(){
  85         JaxWsProxyFactoryBean jaxWsProxyFactory = new JaxWsProxyFactoryBean();
  86         jaxWsProxyFactory.setServiceClass(MsoRequestsDbAdapter.class);
  87         jaxWsProxyFactory.setAddress("http://localhost:" + port + "/services/RequestsDbAdapter");
  88         jaxWsProxyFactory.setUsername("bpel");
  89         jaxWsProxyFactory.setPassword("mso-db-1507!");
  90         dbAdapter = (MsoRequestsDbAdapter) jaxWsProxyFactory.create();
  91         }
  92
  93         private InfraActiveRequests buildTestRequest() {
  94                 InfraActiveRequests testRequest= new InfraActiveRequests();
  95                 testRequest.setRequestId("00032ab7-3fb3-42e5-965d-8ea592502017");
  96                 testRequest.setClientRequestId("00032ab7-3fb3-42e5-965d-8ea592502016");
  97                 testRequest.setRequestStatus("COMPLETE");
  98                 testRequest.setStatusMessage("Vf Module has been deleted successfully.");
  99                 testRequest.setProgress((long) 100);
 100                 testRequest.setSource("VID");
 101                 testRequest.setTenantId("6accefef3cb442ff9e644d589fb04107");
 102                 testRequest.setServiceInstanceId("e3b5744d-2ad1-4cdd-8390-c999a38829bc");
 103                 testRequest.setRequestAction("deleteInstance");
 104                 testRequest.setRequestScope("vfModule");
 105                 testRequest.setAction("deleteInstance");
 106                 testRequest.setAicCloudRegion("mtn6");
 107                 testRequest.setLastModifiedBy("BPMN");
 108                 testRequest.setVfModuleId("c7d527b1-7a91-49fd-b97d-1c8c0f4a7992");
 109                 testRequest.setVfModuleModelName("vSAMP10aDEV::base::module-0");
 110                 testRequest.setVnfId("b92f60c8-8de3-46c1-8dc1-e4390ac2b005");
 111                 testRequest.setRequestUrl("http://localhost:8080/onap/so/infra/serviceInstantiation/v7/serviceInstances");
 112
 113                 return testRequest;
 114         }
 115
 116         @Test
 117         public void getByRequestId() throws MsoRequestsDbException  {
 118
 119                 InfraActiveRequests testRequest = setupTestEntities();
 120                 // Given
 121                 String requestId = "00032ab7-3fb3-42e5-965d-8ea592502017";
 122
 123                 // When
 124                 InfraActiveRequests infraRequest = dbAdapter.getInfraRequest(requestId);
 125                 if(infraRequest ==null)
 126                          fail("Null infraRequest");
 127
 128                 // Then
 129                 assertThat(infraRequest, sameBeanAs(testRequest).ignoring("requestBody").ignoring("endTime").ignoring("startTime").ignoring("modifyTime"));
 130         }
 131
 132
 133         @Test
 134         public void getByInvalidRequestId() throws MsoRequestsDbException  {
 135                 // Given
 136                 String requestId = "invalidRequestId";
 137
 138                 try {
 139                         dbAdapter.getInfraRequest(requestId);
 140                         fail("Expected MsoRequestsDbException to be thrown");
 141                 } catch (Exception e) {
 142                     assertEquals(e.getMessage(),"Error retrieving MSO Infra Requests DB for Request ID invalidRequestId");
 143                 }
 144         }
 145
 146         @Test
 147         public void getByClientRequestId() throws MsoRequestsDbException  {
 148                 InfraActiveRequests testRequest = setupTestEntities();
 149                 // Given
 150                 String clientRequestId = "00032ab7-3fb3-42e5-965d-8ea592502016";
 151
 152                 // When
 153                 InfraActiveRequests infraRequest = dbAdapter.getInfraRequest(clientRequestId);
 154                 if(infraRequest ==null)
 155                          fail("Null infraRequest");
 156
 157                 // Then
 158                 assertThat(infraRequest, sameBeanAs(testRequest).ignoring("requestBody").ignoring("endTime").ignoring("startTime").ignoring("modifyTime"));
 159         }
 160
 161
 162         @Test
 163         public void updateInfraRequest() throws MsoRequestsDbException  {
 164                 InfraActiveRequests testRequest = setupTestEntities();
 165                 // Given
 166                 String clientRequestId = "00032ab7-3fb3-42e5-965d-8ea592502016";
 167
 168
 169                 // When
 170                 String lastModifiedBy = "UNIT TEST";
 171                 String statusMessage = "TESTING THE UDPATES";
 172                 String progress = "50";
 173                 String vnfOutputs = "VNF OUTPUTS";
 174                 String networkId = "New NetworkID";
 175                 String vnfId = "NEWVNFID";
 176                 String volumeGroupId = "NewVolumeGroupId";
 177                 String serviceInstanceName = "NewServiceInstanceName";
 178                 String configurationId = "NewConfigurationId";
 179                 String configurationName = "NewConfigurationName";
 180                 String vfModuleName = "VFModuleName";
 181                 RequestStatusType requestStatus = RequestStatusType.COMPLETE ;
 182                 String responseBody = "NewResponseBody";
 183                 String vfModuleId = "NEW VF MODULEID";
 184                 String serviceInstanceId = " new serv ind";
 185
 186
 187                 testRequest.setVolumeGroupId(volumeGroupId);
 188                 testRequest.setServiceInstanceName(serviceInstanceName);
 189                 testRequest.setConfigurationId(configurationId);
 190                 testRequest.setConfigurationName(configurationName);
 191                 testRequest.setNetworkId(networkId);
 192                 testRequest.setResponseBody(responseBody);
 193                 testRequest.setStatusMessage(statusMessage);
 194                 testRequest.setProgress((long) 50);
 195                 testRequest.setServiceInstanceId(lastModifiedBy);
 196                 testRequest.setLastModifiedBy(lastModifiedBy);
 197                 testRequest.setVfModuleId(vfModuleId);
 198                 testRequest.setVfModuleName(vfModuleName);
 199                 testRequest.setVnfId(vnfId);
 200                 testRequest.setServiceInstanceId(serviceInstanceId);
 201                 testRequest.setVfModuleName(vfModuleName);
 202                 testRequest.setVnfOutputs(vnfOutputs);
 203
 204
 205                  dbAdapter.updateInfraRequest ( testRequest.getRequestId(),
 206                  lastModifiedBy,
 207                  statusMessage,
 208                  responseBody,
 209                  requestStatus,
 210                  progress,
 211                  vnfOutputs,
 212                  serviceInstanceId,
 213                  networkId,
 214                  vnfId,
 215                  vfModuleId,
 216                  volumeGroupId,
 217                  serviceInstanceName,
 218                  configurationId,
 219                  configurationName,
 220                  vfModuleName);
 221                 InfraActiveRequests infraRequest = dbAdapter.getInfraRequest(clientRequestId);
 222                 // Then
 223                 assertThat(infraRequest, sameBeanAs(testRequest).ignoring("requestBody").ignoring("endTime").ignoring("startTime").ignoring("modifyTime"));
 224         }
 225
 226         @Test
 227         public void UpdateByInvalidRequestId() throws MsoRequestsDbException  {
 228                 // Given
 229                 String requestId = "invalidRequestId";
 230
 231                 try {
 232                         dbAdapter.updateInfraRequest ( requestId,
 233                                         null,
 234                                         null,
 235                                         null,
 236                                         null,
 237                                         null,
 238                                         null,
 239                                         null,
 240                                         null,
 241                                         null,
 242                                         null,
 243                                         null,
 244                                         null,
 245                                         null,
 246                                         null,
 247                                         null);
 248                         fail("Expected MsoRequestsDbException to be thrown");
 249                 } catch (Exception e) {
 250                     assertEquals(e.getMessage(),"Error retrieving MSO Infra Requests DB for Request ID invalidRequestId");
 251                 }
 252         }
 253
 254
 255         @Test
 256         public void updateInfraRequestNulls() throws MsoRequestsDbException  {
 257                 InfraActiveRequests testRequest = setupTestEntities();
 258                 // Given
 259                 String clientRequestId = "00032ab7-3fb3-42e5-965d-8ea592502016";
 260
 261                 // When
 262                 dbAdapter.updateInfraRequest ( testRequest.getRequestId(),
 263                                 testRequest.getLastModifiedBy(),
 264                                 null,
 265                                 null,
 266                                 null,
 267                                 null,
 268                                 null,
 269                                 null,
 270                                 null,
 271                                 null,
 272                                 null,
 273                                 null,
 274                                 null,
 275                                 null,
 276                                 null,
 277                                 null);
 278                 InfraActiveRequests infraRequest = dbAdapter.getInfraRequest(clientRequestId);
 279                 // Then
 280                 assertThat(infraRequest, sameBeanAs(testRequest).ignoring("requestBody").ignoring("endTime").ignoring("startTime").ignoring("modifyTime"));
 281         }
 282
 283         @Test
 284         public void getSiteStatusNotDisabled() throws MsoRequestsDbException  {
 285                 setupTestEntities();
 286                 // Given
 287                 String siteName = "siteName";
 288
 289                 // When
 290                 boolean siteDisabled = dbAdapter.getSiteStatus(siteName);
 291
 292                 // Then
 293                 assertEquals(siteDisabled, true);
 294         }
 295
 296         @Test
 297         public void getSiteStatusDisabled() throws MsoRequestsDbException  {
 298                 setupTestEntities();
 299                 // Given
 300                 String siteName = "testSite";
 301
 302                 // When
 303                 boolean siteDisabled = dbAdapter.getSiteStatus(siteName);
 304
 305                 // Then
 306                 assertEquals(siteDisabled, false);
 307         }
 308
 309         @Test
 310         public void updateServiceOperation() throws MsoRequestsDbException{
 311                 String serviceId = "serviceid";
 312                 String operationId = "operationid";
 313                 String serviceName = "servicename";
 314                 String operation = "newOperationType";
 315                 String userId = "NewUserId";
 316                 String result = "NewResult";
 317                 String operationContent = "newOperationContent";
 318                 String progress = "Newprogress";
 319                 String reason = "NewReason";
 320
 321                 OperationStatus updatedOperationStatus = new OperationStatus();
 322
 323
 324
 325                 updatedOperationStatus.setServiceId(serviceId);
 326                 updatedOperationStatus.setServiceName(serviceName);
 327                 updatedOperationStatus.setOperationId(operationId);
 328                 updatedOperationStatus.setOperation(operation);
 329                 updatedOperationStatus.setUserId(userId);
 330                 updatedOperationStatus.setResult(result);
 331                 updatedOperationStatus.setProgress(progress);
 332                 updatedOperationStatus.setReason(reason);
 333                 updatedOperationStatus.setOperationContent(operationContent);
 334
 335                 dbAdapter.updateServiceOperationStatus(serviceId, operationId, operation,  userId,
 336                      result, operationContent,  progress, reason);
 337                 OperationStatus dbOpStatus = operationStatusRepository.findOneByServiceIdAndOperationId(serviceId,operationId);
 338                 assertThat(dbOpStatus, sameBeanAs(updatedOperationStatus).ignoring("operateAt").ignoring("finishedAt"));
 339         }
 340
 341
 342         @Test
 343         public void updateServiceOperation_Not_Found() throws MsoRequestsDbException{
 344             TestAppender.events.clear();
 345                 String serviceId = "badserviceId";
 346                 String operationId = "operationid";
 347                 String operation = "newOperationType";
 348                 String userId = "NewUserId";
 349                 String result = "NewResult";
 350                 String operationContent = "newOperationContent";
 351                 String progress = "Newprogress";
 352                 String reason = "NewReason";
 353
 354                 OperationStatus updatedOperationStatus = new OperationStatus();
 355
 356
 357
 358                 updatedOperationStatus.setServiceId(serviceId);
 359                 updatedOperationStatus.setOperationId(operationId);
 360                 updatedOperationStatus.setOperation(operation);
 361                 updatedOperationStatus.setUserId(userId);
 362                 updatedOperationStatus.setResult(result);
 363                 updatedOperationStatus.setProgress(progress);
 364                 updatedOperationStatus.setReason(reason);
 365                 updatedOperationStatus.setOperationContent(operationContent);
 366
 367                 dbAdapter.updateServiceOperationStatus(serviceId, operationId, operation,  userId,
 368                      result, operationContent,  progress, reason);
 369                 OperationStatus dbOpStatus = operationStatusRepository.findOneByServiceIdAndOperationId(serviceId,operationId);
 370                 assertThat(dbOpStatus, sameBeanAs(updatedOperationStatus).ignoring("operateAt").ignoring("finishedAt"));
 371         }
 372
 373         @Test
 374         public void initResourceOperationStatus() throws MsoRequestsDbException{
 375                 String resourceTemplateUUIDs = "template1:template2:template3:";
 376                 String serviceId = "serviceId";
 377                 String operationId = "operationId";
 378                 String operationType = "operationType";
 379
 380              ResourceOperationStatus resource1 = new ResourceOperationStatus();
 381              resource1.setOperationId(operationId);
 382              resource1.setServiceId(serviceId);
 383              resource1.setResourceTemplateUUID("template1");
 384              resource1.setOperType(operationType);
 385              resource1.setStatus(RequestsDbConstant.Status.PROCESSING);
 386              resource1.setStatusDescription("Waiting for start");
 387
 388          ResourceOperationStatus resource2 = new ResourceOperationStatus();
 389          resource2.setOperationId(operationId);
 390          resource2.setServiceId(serviceId);
 391          resource2.setResourceTemplateUUID("template2");
 392          resource2.setOperType(operationType);
 393          resource2.setStatus(RequestsDbConstant.Status.PROCESSING);
 394          resource2.setStatusDescription("Waiting for start");
 395
 396          ResourceOperationStatus resource3 = new ResourceOperationStatus();
 397          resource3.setOperationId(operationId);
 398          resource3.setServiceId(serviceId);
 399          resource3.setResourceTemplateUUID("template3");
 400          resource3.setOperType(operationType);
 401          resource3.setStatus(RequestsDbConstant.Status.PROCESSING);
 402          resource3.setStatusDescription("Waiting for start");
 403
 404          List<ResourceOperationStatus> expectedResult = new ArrayList<ResourceOperationStatus>();
 405          expectedResult.add(resource1);
 406          expectedResult.add(resource2);
 407          expectedResult.add(resource3);
 408
 409                 dbAdapter.initResourceOperationStatus(serviceId, operationId, operationType,resourceTemplateUUIDs);
 410                 List<ResourceOperationStatus> testList = resourceOperationStatusRepo.findByServiceIdAndOperationId(serviceId,operationId);
 411                 assertThat(testList, sameBeanAs(expectedResult));
 412         }
 413
 414         @Test
 415         public void getResourceOperationStatus() throws MsoRequestsDbException{
 416                 String resourceTemplateUUIDs = "template1";
 417                 String serviceId = "serviceId";
 418                 String operationId = "operationId";
 419                 String operationType = "operationType";
 420
 421                 ResourceOperationStatus resource1 = new ResourceOperationStatus();
 422                 resource1.setOperationId(operationId);
 423                 resource1.setServiceId(serviceId);
 424                 resource1.setResourceTemplateUUID("template1");
 425                 resource1.setOperType(operationType);
 426                 resource1.setStatus(RequestsDbConstant.Status.PROCESSING);
 427                 resource1.setStatusDescription("Waiting for start");
 428
 429
 430                 dbAdapter.initResourceOperationStatus(serviceId, operationId, operationType,resourceTemplateUUIDs);
 431
 432                 ResourceOperationStatus actualResource = dbAdapter.getResourceOperationStatus(serviceId, operationId,"template1");
 433                 assertThat(actualResource, sameBeanAs(resource1));
 434         }
 435
 436         @Test
 437         public void updateResourceOperationStatus() throws MsoRequestsDbException{
 438             TestAppender.events.clear();
 439                 String resourceTemplateUUID = "template1";
 440                 String serviceId = "serviceId";
 441                 String operationId = "operationId";
 442                 String operationType = "operationType";
 443                 String resourceInstanceID = "resourceInstanceID";
 444                 String jobId = "jobId";
 445                 String status = RequestsDbConstant.Status.FINISHED;
 446                 String progress = "50";
 447                 String errorCode = "errorCode";
 448                 String statusDescription = "statusDescription";
 449
 450
 451                 ResourceOperationStatus expectedResource = new ResourceOperationStatus();
 452                 expectedResource.setOperationId(operationId);
 453                 expectedResource.setServiceId(serviceId);
 454                 expectedResource.setResourceTemplateUUID(resourceTemplateUUID);
 455                 expectedResource.setOperType(operationType);
 456                 expectedResource.setJobId(jobId);
 457                 expectedResource.setErrorCode(errorCode);
 458                 expectedResource.setStatus(RequestsDbConstant.Status.FINISHED);
 459                 expectedResource.setStatusDescription(statusDescription);
 460                 expectedResource.setProgress(progress);
 461                 expectedResource.setResourceInstanceID(resourceInstanceID);
 462
 463
 464                 dbAdapter.updateResourceOperationStatus(serviceId, operationId, resourceTemplateUUID,
 465                                 operationType, resourceInstanceID, jobId, status, progress,
 466                                 errorCode, statusDescription);
 467
 468                 ResourceOperationStatus actualResource = dbAdapter.getResourceOperationStatus(serviceId, operationId,"template1");
 469                 assertThat(actualResource, sameBeanAs(expectedResource));
 470
 471                 for(ILoggingEvent logEvent : TestAppender.events)
 472             if(logEvent.getLoggerName().equals("org.onap.so.logging.cxf.interceptor.SOAPLoggingInInterceptor") &&
 473                     logEvent.getMarker().getName().equals("ENTRY")
 474                     ){
 475                 Map<String,String> mdc = logEvent.getMDCPropertyMap();
 476                 assertNotNull(mdc.get(ONAPLogConstants.MDCs.INSTANCE_UUID));
 477                 assertNotNull(mdc.get(ONAPLogConstants.MDCs.REQUEST_ID));
 478                 assertNotNull(mdc.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 479                 assertEquals("",mdc.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 480                 assertEquals("/services/RequestsDbAdapter",mdc.get(ONAPLogConstants.MDCs.SERVICE_NAME));
 481                 assertEquals("INPROGRESS",mdc.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
 482             }else if(logEvent.getLoggerName().equals("org.onap.so.logging.cxf.interceptor.SOAPLoggingOutInterceptor") &&
 483                     logEvent.getMarker().getName().equals("EXIT")){
 484                 Map<String,String> mdc = logEvent.getMDCPropertyMap();
 485                 assertNotNull(mdc.get(ONAPLogConstants.MDCs.REQUEST_ID));
 486                 assertNotNull(mdc.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 487                 assertEquals(null,mdc.get(ONAPLogConstants.MDCs.RESPONSE_CODE));
 488                 assertEquals("",mdc.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 489                 assertEquals("/services/RequestsDbAdapter",mdc.get(ONAPLogConstants.MDCs.SERVICE_NAME));
 490                 assertEquals("COMPLETED",mdc.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
 491             }
 492         }
 493
 494
 495 }