adapters/mso-vnfm-adapter/mso-vnfm-etsi-adapter/src/test/java/org/onap/so/adapters/vnfmadapter/rest/VnfmAdapterControllerTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  *  Copyright (C) 2019 Nordix Foundation.
   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
  21 package org.onap.so.adapters.vnfmadapter.rest;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import static org.mockito.ArgumentMatchers.eq;
  26 import static org.mockito.Mockito.doReturn;
  27 import static org.mockito.Mockito.verify;
  28 import static org.onap.so.client.RestTemplateConfig.CONFIGURABLE_REST_TEMPLATE;
  29 import static org.springframework.test.web.client.match.MockRestRequestMatchers.requestTo;
  30 import static org.springframework.test.web.client.response.MockRestResponseCreators.withSuccess;
  31 import com.google.gson.Gson;
  32 import java.net.URI;
  33 import java.util.Optional;
  34 import org.hamcrest.BaseMatcher;
  35 import org.hamcrest.Description;
  36 import org.hamcrest.core.StringStartsWith;
  37 import org.junit.Before;
  38 import org.junit.Test;
  39 import org.junit.runner.RunWith;
  40 import org.mockito.ArgumentCaptor;
  41 import org.mockito.hamcrest.MockitoHamcrest;
  42 import org.onap.aai.domain.yang.EsrSystemInfo;
  43 import org.onap.aai.domain.yang.EsrSystemInfoList;
  44 import org.onap.aai.domain.yang.EsrVnfm;
  45 import org.onap.aai.domain.yang.EsrVnfmList;
  46 import org.onap.aai.domain.yang.GenericVnf;
  47 import org.onap.aai.domain.yang.Relationship;
  48 import org.onap.aai.domain.yang.RelationshipData;
  49 import org.onap.aai.domain.yang.RelationshipList;
  50 import org.onap.so.adapters.vnfmadapter.VnfmAdapterApplication;
  51 import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200;
  52 import org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse201;
  53 import org.onap.so.adapters.vnfmadapter.rest.exceptions.VnfmNotFoundException;
  54 import org.onap.so.client.aai.AAIResourcesClient;
  55 import org.onap.so.client.aai.entities.uri.AAIResourceUri;
  56 import org.onap.vnfmadapter.v1.model.CreateVnfRequest;
  57 import org.onap.vnfmadapter.v1.model.CreateVnfResponse;
  58 import org.onap.vnfmadapter.v1.model.DeleteVnfResponse;
  59 import org.onap.vnfmadapter.v1.model.OperationEnum;
  60 import org.onap.vnfmadapter.v1.model.OperationStateEnum;
  61 import org.onap.vnfmadapter.v1.model.QueryJobResponse;
  62 import org.onap.vnfmadapter.v1.model.Tenant;
  63 import org.springframework.beans.factory.annotation.Autowired;
  64 import org.springframework.beans.factory.annotation.Qualifier;
  65 import org.springframework.boot.test.context.SpringBootTest;
  66 import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
  67 import org.springframework.boot.test.mock.mockito.MockBean;
  68 import org.springframework.boot.test.web.client.TestRestTemplate;
  69 import org.springframework.boot.web.server.LocalServerPort;
  70 import org.springframework.http.HttpStatus;
  71 import org.springframework.http.MediaType;
  72 import org.springframework.http.RequestEntity;
  73 import org.springframework.http.ResponseEntity;
  74 import org.springframework.test.context.ActiveProfiles;
  75 import org.springframework.test.context.junit4.SpringRunner;
  76 import org.springframework.test.web.client.MockRestServiceServer;
  77 import org.springframework.web.client.RestTemplate;
  78 import org.threeten.bp.LocalDateTime;
  79 import org.threeten.bp.OffsetDateTime;
  80 import org.threeten.bp.ZoneOffset;
  81
  82
  83 @RunWith(SpringRunner.class)
  84 @SpringBootTest(classes = VnfmAdapterApplication.class, webEnvironment = WebEnvironment.RANDOM_PORT)
  85 @ActiveProfiles("test")
  86
  87 public class VnfmAdapterControllerTest {
  88
  89     private static final OffsetDateTime JAN_1_2019_12_00 =
  90             OffsetDateTime.of(LocalDateTime.of(2019, 1, 1, 12, 0), ZoneOffset.UTC);
  91     private static final OffsetDateTime JAN_1_2019_1_00 =
  92             OffsetDateTime.of(LocalDateTime.of(2019, 1, 1, 1, 0), ZoneOffset.UTC);
  93
  94     @LocalServerPort
  95     private int port;
  96     @Autowired
  97     @Qualifier(CONFIGURABLE_REST_TEMPLATE)
  98     private RestTemplate testRestTemplate;
  99     private MockRestServiceServer mockRestServer;
 100
 101     @MockBean
 102     AAIResourcesClient aaiResourcesClient;
 103
 104     @Autowired
 105     VnfmAdapterController controller;
 106     Gson gson = new Gson();
 107
 108     @Before
 109     public void setUp() throws Exception {
 110         mockRestServer = MockRestServiceServer.bindTo(testRestTemplate).build();
 111     }
 112
 113     @Test
 114     public void createVnf_ValidRequest_Returns202AndJobId() throws Exception {
 115         final Tenant tenant =
 116                 new Tenant().cloudOwner("myTestCloudOwner").regionName("myTestRegion").tenantId("myTestTenantId");
 117         final CreateVnfRequest createVnfRequest = new CreateVnfRequest().name("myTestName").tenant(tenant);
 118
 119         final GenericVnf genericVnf = new GenericVnf();
 120         genericVnf.setVnfId("myTestVnfId");
 121         genericVnf.setNfType("vnfmType2");
 122
 123         doReturn(Optional.of(genericVnf)).when(aaiResourcesClient).get(eq(GenericVnf.class), MockitoHamcrest
 124                 .argThat(new AaiResourceUriMatcher("/network/generic-vnfs/generic-vnf/myTestVnfId?depth=1")));
 125
 126         final EsrSystemInfo esrSystemInfo1 = new EsrSystemInfo();
 127         esrSystemInfo1.setServiceUrl("http://vnfm1:8080");
 128         esrSystemInfo1.setType("vnfmType1");
 129         esrSystemInfo1.setSystemType("VNFM");
 130         final EsrSystemInfoList esrSystemInfoList1 = new EsrSystemInfoList();
 131         esrSystemInfoList1.getEsrSystemInfo().add(esrSystemInfo1);
 132
 133         final EsrVnfm esrVnfm1 = new EsrVnfm();
 134         esrVnfm1.setVnfmId("vnfm1");
 135         esrVnfm1.setEsrSystemInfoList(esrSystemInfoList1);
 136         esrVnfm1.setResourceVersion("1234");
 137
 138         final EsrSystemInfo esrSystemInfo2 = new EsrSystemInfo();
 139         esrSystemInfo2.setServiceUrl("http://vnfm2:8080");
 140         esrSystemInfo2.setType("vnfmType2");
 141         esrSystemInfo2.setSystemType("VNFM");
 142         final EsrSystemInfoList esrSystemInfoList2 = new EsrSystemInfoList();
 143         esrSystemInfoList2.getEsrSystemInfo().add(esrSystemInfo2);
 144
 145         final EsrVnfm esrVnfm2 = new EsrVnfm();
 146         esrVnfm2.setVnfmId("vnfm2");
 147         esrVnfm2.setEsrSystemInfoList(esrSystemInfoList2);
 148         esrVnfm2.setResourceVersion("1234");
 149
 150         final EsrVnfmList esrVnfmList = new EsrVnfmList();
 151         esrVnfmList.getEsrVnfm().add(esrVnfm1);
 152         esrVnfmList.getEsrVnfm().add(esrVnfm2);
 153
 154         doReturn(Optional.of(esrVnfmList)).when(aaiResourcesClient).get(eq(EsrVnfmList.class),
 155                 MockitoHamcrest.argThat(new AaiResourceUriMatcher("/external-system/esr-vnfm-list")));
 156
 157         doReturn(Optional.of(esrSystemInfoList1)).when(aaiResourcesClient).get(eq(EsrSystemInfoList.class),
 158                 MockitoHamcrest.argThat(new AaiResourceUriMatcher(
 159                         "/external-system/esr-vnfm-list/esr-vnfm/vnfm1/esr-system-info-list")));
 160         doReturn(Optional.of(esrSystemInfoList2)).when(aaiResourcesClient).get(eq(EsrSystemInfoList.class),
 161                 MockitoHamcrest.argThat(new AaiResourceUriMatcher(
 162                         "/external-system/esr-vnfm-list/esr-vnfm/vnfm2/esr-system-info-list")));
 163
 164         final InlineResponse200 firstOperationQueryResponse = createOperationQueryResponse(
 165                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationEnum.INSTANTIATE,
 166                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationStateEnum.PROCESSING);
 167         mockRestServer.expect(requestTo(new StringStartsWith("http://vnfm2:8080/vnf_lcm_op_occs")))
 168                 .andRespond(withSuccess(gson.toJson(firstOperationQueryResponse), MediaType.APPLICATION_JSON));
 169
 170         final InlineResponse200 secondOperationQueryReponse = createOperationQueryResponse(
 171                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationEnum.INSTANTIATE,
 172                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationStateEnum.COMPLETED);
 173         mockRestServer.expect(requestTo(new StringStartsWith("http://vnfm2:8080/vnf_lcm_op_occs")))
 174                 .andRespond(withSuccess(gson.toJson(secondOperationQueryReponse), MediaType.APPLICATION_JSON));
 175
 176         // Invoke the create request
 177
 178         final ResponseEntity<CreateVnfResponse> createVnfResponse =
 179                 controller.vnfCreate("myTestVnfId", createVnfRequest, "asadas", "so", "1213");
 180         assertEquals(HttpStatus.ACCEPTED, createVnfResponse.getStatusCode());
 181         assertNotNull(createVnfResponse.getBody().getJobId());
 182
 183         final ArgumentCaptor<GenericVnf> genericVnfArgument = ArgumentCaptor.forClass(GenericVnf.class);
 184         final ArgumentCaptor<AAIResourceUri> uriArgument = ArgumentCaptor.forClass(AAIResourceUri.class);
 185
 186         verify(aaiResourcesClient).update(uriArgument.capture(), genericVnfArgument.capture());
 187
 188         assertEquals("/network/generic-vnfs/generic-vnf/myTestVnfId", uriArgument.getValue().build().toString());
 189
 190         assertEquals("myTestVnfId", genericVnfArgument.getValue().getVnfId());
 191         assertEquals(1, genericVnfArgument.getValue().getRelationshipList().getRelationship().size());
 192         final Relationship createdRelationship =
 193                 genericVnfArgument.getValue().getRelationshipList().getRelationship().get(0);
 194         assertEquals("esr-vnfm", createdRelationship.getRelatedTo());
 195         assertEquals("tosca.relationships.DependsOn", createdRelationship.getRelationshipLabel());
 196         assertEquals("/aai/v15/external-system/esr-vnfm-list/esr-vnfm/vnfm2", createdRelationship.getRelatedLink());
 197
 198         // check the job status
 199
 200         final ResponseEntity<QueryJobResponse> firstJobQueryResponse =
 201                 controller.jobQuery(createVnfResponse.getBody().getJobId(), "", "so", "1213");
 202         assertEquals(OperationEnum.INSTANTIATE, firstJobQueryResponse.getBody().getOperation());
 203         assertEquals(OperationStateEnum.PROCESSING, firstJobQueryResponse.getBody().getOperationState());
 204         assertEquals(JAN_1_2019_12_00, firstJobQueryResponse.getBody().getStartTime());
 205         assertEquals(JAN_1_2019_1_00, firstJobQueryResponse.getBody().getStateEnteredTime());
 206
 207         final ResponseEntity<QueryJobResponse> secondJobQueryResponse =
 208                 controller.jobQuery(createVnfResponse.getBody().getJobId(), "", "so", "1213");
 209         assertEquals(OperationEnum.INSTANTIATE, secondJobQueryResponse.getBody().getOperation());
 210         assertEquals(OperationStateEnum.COMPLETED, secondJobQueryResponse.getBody().getOperationState());
 211         assertEquals(JAN_1_2019_12_00, secondJobQueryResponse.getBody().getStartTime());
 212         assertEquals(JAN_1_2019_1_00, secondJobQueryResponse.getBody().getStateEnteredTime());
 213     }
 214
 215     @Test(expected = IllegalArgumentException.class)
 216     public void createVnf_VnfAlreadyExistsOnVnfm_ThrowsIllegalArgumentException() throws Exception {
 217         final Tenant tenant =
 218                 new Tenant().cloudOwner("myTestCloudOwner").regionName("myTestRegion").tenantId("myTestTenantId");
 219         final CreateVnfRequest createVnfRequest = new CreateVnfRequest().name("myTestName").tenant(tenant);
 220
 221         final GenericVnf genericVnf = new GenericVnf();
 222         genericVnf.setVnfId("myTestVnfId");
 223         genericVnf.setNfType("vnfmType");
 224         genericVnf.setSelflink("http://vnfm:8080/vnfs/myTestVnfIdOnVnfm");
 225
 226         doReturn(Optional.of(genericVnf)).when(aaiResourcesClient).get(eq(GenericVnf.class), MockitoHamcrest
 227                 .argThat(new AaiResourceUriMatcher("/network/generic-vnfs/generic-vnf/myTestVnfId?depth=1")));
 228
 229         final EsrSystemInfo esrSystemInfo = new EsrSystemInfo();
 230         esrSystemInfo.setServiceUrl("http://vnfm:8080");
 231         esrSystemInfo.setType("vnfmType");
 232         esrSystemInfo.setSystemType("VNFM");
 233         final EsrSystemInfoList esrSystemInfoList = new EsrSystemInfoList();
 234         esrSystemInfoList.getEsrSystemInfo().add(esrSystemInfo);
 235
 236         final EsrVnfm esrVnfm = new EsrVnfm();
 237         esrVnfm.setVnfmId("vnfm");
 238         esrVnfm.setEsrSystemInfoList(esrSystemInfoList);
 239         esrVnfm.setResourceVersion("1234");
 240
 241         final EsrVnfmList esrVnfmList = new EsrVnfmList();
 242         esrVnfmList.getEsrVnfm().add(esrVnfm);
 243
 244         final InlineResponse201 reponse = new InlineResponse201();
 245         mockRestServer.expect(requestTo(new URI("http://vnfm:8080/vnfs/myTestVnfIdOnVnfm")))
 246                 .andRespond(withSuccess(gson.toJson(reponse), MediaType.APPLICATION_JSON));
 247
 248         doReturn(Optional.of(esrVnfmList)).when(aaiResourcesClient).get(eq(EsrVnfmList.class),
 249                 MockitoHamcrest.argThat(new AaiResourceUriMatcher("/external-system/esr-vnfm-list")));
 250
 251         controller.vnfCreate("myTestVnfId", createVnfRequest, "asadas", "so", "1213");
 252     }
 253
 254     @Test(expected = VnfmNotFoundException.class)
 255     public void createVnf_NoMatchingVnfmFound_ThrowsException() throws Exception {
 256         final Tenant tenant =
 257                 new Tenant().cloudOwner("myTestCloudOwner").regionName("myTestRegion").tenantId("myTestTenantId");
 258         final CreateVnfRequest createVnfRequest = new CreateVnfRequest().name("myTestName").tenant(tenant);
 259
 260         final GenericVnf genericVnf = new GenericVnf();
 261         genericVnf.setVnfId("myTestVnfId");
 262         genericVnf.setNfType("anotherType");
 263
 264         doReturn(Optional.of(genericVnf)).when(aaiResourcesClient).get(eq(GenericVnf.class), MockitoHamcrest
 265                 .argThat(new AaiResourceUriMatcher("/network/generic-vnfs/generic-vnf/myTestVnfId?depth=1")));
 266
 267         final EsrSystemInfo esrSystemInfo1 = new EsrSystemInfo();
 268         esrSystemInfo1.setServiceUrl("http://vnfm1:8080");
 269         esrSystemInfo1.setType("vnfmType1");
 270         esrSystemInfo1.setSystemType("VNFM");
 271         final EsrSystemInfoList esrSystemInfoList1 = new EsrSystemInfoList();
 272         esrSystemInfoList1.getEsrSystemInfo().add(esrSystemInfo1);
 273
 274         final EsrVnfm esrVnfm1 = new EsrVnfm();
 275         esrVnfm1.setVnfmId("vnfm1");
 276         esrVnfm1.setEsrSystemInfoList(esrSystemInfoList1);
 277         esrVnfm1.setResourceVersion("1234");
 278
 279         final EsrSystemInfo esrSystemInfo2 = new EsrSystemInfo();
 280         esrSystemInfo2.setServiceUrl("http://vnfm2:8080");
 281         esrSystemInfo2.setType("vnfmType2");
 282         esrSystemInfo2.setSystemType("VNFM");
 283         final EsrSystemInfoList esrSystemInfoList2 = new EsrSystemInfoList();
 284         esrSystemInfoList2.getEsrSystemInfo().add(esrSystemInfo2);
 285
 286         final EsrVnfm esrVnfm2 = new EsrVnfm();
 287         esrVnfm2.setVnfmId("vnfm2");
 288         esrVnfm2.setEsrSystemInfoList(esrSystemInfoList2);
 289         esrVnfm2.setResourceVersion("1234");
 290
 291         final EsrVnfmList esrVnfmList = new EsrVnfmList();
 292         esrVnfmList.getEsrVnfm().add(esrVnfm1);
 293         esrVnfmList.getEsrVnfm().add(esrVnfm2);
 294
 295         doReturn(Optional.of(esrVnfmList)).when(aaiResourcesClient).get(eq(EsrVnfmList.class),
 296                 MockitoHamcrest.argThat(new AaiResourceUriMatcher("/external-system/esr-vnfm-list")));
 297
 298
 299         doReturn(Optional.of(esrSystemInfoList1)).when(aaiResourcesClient).get(eq(EsrSystemInfoList.class),
 300                 MockitoHamcrest.argThat(new AaiResourceUriMatcher(
 301                         "/external-system/esr-vnfm-list/esr-vnfm/vnfm1/esr-system-info-list")));
 302
 303         doReturn(Optional.of(esrSystemInfoList2)).when(aaiResourcesClient).get(eq(EsrSystemInfoList.class),
 304                 MockitoHamcrest.argThat(new AaiResourceUriMatcher(
 305                         "/external-system/esr-vnfm-list/esr-vnfm/vnfm2/esr-system-info-list")));
 306
 307         controller.vnfCreate("myTestVnfId", createVnfRequest, "asadas", "so", "1213");
 308     }
 309
 310     @Test
 311     public void createVnf_VnfmAlreadyAssociatedWithVnf_Returns202AndJobId() throws Exception {
 312         final Tenant tenant =
 313                 new Tenant().cloudOwner("myTestCloudOwner").regionName("myTestRegion").tenantId("myTestTenantId");
 314         final CreateVnfRequest createVnfRequest = new CreateVnfRequest().name("myTestName").tenant(tenant);
 315
 316         final GenericVnf genericVnf = new GenericVnf();
 317         genericVnf.setVnfId("myTestVnfId");
 318         genericVnf.setNfType("vnfmType2");
 319
 320         final Relationship relationshipToVnfm = new Relationship();
 321         relationshipToVnfm.setRelatedLink("/aai/v15/external-system/esr-vnfm-list/esr-vnfm/vnfm1");
 322         relationshipToVnfm.setRelatedTo("esr-vnfm");
 323         final RelationshipData relationshipData = new RelationshipData();
 324         relationshipData.setRelationshipKey("esr-vnfm.vnfm-id");
 325         relationshipData.setRelationshipValue("vnfm1");
 326         relationshipToVnfm.getRelationshipData().add(relationshipData);
 327
 328         final RelationshipList relationshipList = new RelationshipList();
 329         relationshipList.getRelationship().add(relationshipToVnfm);
 330         genericVnf.setRelationshipList(relationshipList);
 331
 332         doReturn(Optional.of(genericVnf)).when(aaiResourcesClient).get(eq(GenericVnf.class), MockitoHamcrest
 333                 .argThat(new AaiResourceUriMatcher("/network/generic-vnfs/generic-vnf/myTestVnfId?depth=1")));
 334
 335         final EsrSystemInfo esrSystemInfo1 = new EsrSystemInfo();
 336         esrSystemInfo1.setServiceUrl("http://vnfm1:8080");
 337         esrSystemInfo1.setType("vnfmType1");
 338         esrSystemInfo1.setSystemType("VNFM");
 339         final EsrSystemInfoList esrSystemInfoList1 = new EsrSystemInfoList();
 340         esrSystemInfoList1.getEsrSystemInfo().add(esrSystemInfo1);
 341
 342         final EsrVnfm esrVnfm1 = new EsrVnfm();
 343         esrVnfm1.setVnfmId("vnfm1");
 344         esrVnfm1.setEsrSystemInfoList(esrSystemInfoList1);
 345         esrVnfm1.setResourceVersion("1234");
 346
 347         doReturn(Optional.of(esrVnfm1)).when(aaiResourcesClient).get(eq(EsrVnfm.class),
 348                 MockitoHamcrest.argThat(new AaiResourceUriMatcher("/external-system/esr-vnfm-list/esr-vnfm/vnfm1")));
 349
 350         final ResponseEntity<CreateVnfResponse> response =
 351                 controller.vnfCreate("myTestVnfId", createVnfRequest, "asadas", "so", "1213");
 352         assertEquals(HttpStatus.ACCEPTED, response.getStatusCode());
 353         assertNotNull(response.getBody().getJobId());
 354     }
 355
 356     @Test
 357     public void createVnf_UnauthorizedUser_Returns401() throws Exception {
 358         final TestRestTemplate restTemplateWrongPassword = new TestRestTemplate("test", "wrongPassword");
 359         final Tenant tenant =
 360                 new Tenant().cloudOwner("myTestCloudOwner").regionName("myTestRegion").tenantId("myTestTenantId");
 361         final CreateVnfRequest createVnfRequest = new CreateVnfRequest().name("myTestName").tenant(tenant);
 362
 363         final RequestEntity<CreateVnfRequest> request =
 364                 RequestEntity.post(new URI("http://localhost:" + port + "/so/vnfm-adapter/v1/vnfs/myVnfId"))
 365                         .accept(MediaType.APPLICATION_JSON).contentType(MediaType.APPLICATION_JSON)
 366                         .header("X-ONAP-RequestId", "myRequestId").header("X-ONAP-InvocationID", "myInvocationId")
 367                         .body(createVnfRequest);
 368         final ResponseEntity<CreateVnfResponse> response =
 369                 restTemplateWrongPassword.exchange(request, CreateVnfResponse.class);
 370         assertEquals(401, response.getStatusCode().value());
 371     }
 372
 373     @Test
 374     public void deleteVnf_ValidRequest_Returns202AndJobId() throws Exception {
 375         final TestRestTemplate restTemplate = new TestRestTemplate("test", "test");
 376         final RequestEntity<Void> request = RequestEntity
 377                 .delete(new URI("http://localhost:" + port + "/so/vnfm-adapter/v1/vnfs/myVnfId"))
 378                 .accept(MediaType.APPLICATION_JSON).header("X-ONAP-RequestId", "myRequestId")
 379                 .header("X-ONAP-InvocationID", "myInvocationId").header("Content-Type", "application/json").build();
 380         final ResponseEntity<DeleteVnfResponse> deleteVnfResponse =
 381                 restTemplate.exchange(request, DeleteVnfResponse.class);
 382         assertEquals(202, deleteVnfResponse.getStatusCode().value());
 383         assertNotNull(deleteVnfResponse.getBody().getJobId());
 384
 385
 386         final EsrSystemInfo esrSystemInfo = new EsrSystemInfo();
 387         esrSystemInfo.setServiceUrl("http://vnfm:8080");
 388         esrSystemInfo.setType("vnfmType");
 389         esrSystemInfo.setSystemType("VNFM");
 390         final EsrSystemInfoList esrSystemInfoList = new EsrSystemInfoList();
 391         esrSystemInfoList.getEsrSystemInfo().add(esrSystemInfo);
 392
 393         doReturn(Optional.of(esrSystemInfoList)).when(aaiResourcesClient).get(eq(EsrSystemInfoList.class),
 394                 MockitoHamcrest.argThat(new AaiResourceUriMatcher("/external-system/esr-vnfm-list/esr-vnfm/...")));
 395
 396         final InlineResponse200 firstOperationQueryResponse = createOperationQueryResponse(
 397                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationEnum.TERMINATE,
 398                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationStateEnum.PROCESSING);
 399         mockRestServer.expect(requestTo(new StringStartsWith("http://vnfm:8080/vnf_lcm_op_occs")))
 400                 .andRespond(withSuccess(gson.toJson(firstOperationQueryResponse), MediaType.APPLICATION_JSON));
 401
 402
 403         final InlineResponse200 secondOperationQueryReponse = createOperationQueryResponse(
 404                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationEnum.TERMINATE,
 405                 org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationStateEnum.COMPLETED);
 406         mockRestServer.expect(requestTo(new StringStartsWith("http://vnfm:8080/vnf_lcm_op_occs")))
 407                 .andRespond(withSuccess(gson.toJson(secondOperationQueryReponse), MediaType.APPLICATION_JSON));
 408
 409
 410         final ResponseEntity<QueryJobResponse> firstJobQueryResponse =
 411                 controller.jobQuery(deleteVnfResponse.getBody().getJobId(), "", "so", "1213");
 412         assertEquals(OperationEnum.TERMINATE, firstJobQueryResponse.getBody().getOperation());
 413         assertEquals(OperationStateEnum.PROCESSING, firstJobQueryResponse.getBody().getOperationState());
 414         assertEquals(JAN_1_2019_12_00, firstJobQueryResponse.getBody().getStartTime());
 415         assertEquals(JAN_1_2019_1_00, firstJobQueryResponse.getBody().getStateEnteredTime());
 416
 417         final ResponseEntity<QueryJobResponse> secondJobQueryResponse =
 418                 controller.jobQuery(deleteVnfResponse.getBody().getJobId(), "", "so", "1213");
 419         assertEquals(OperationEnum.TERMINATE, secondJobQueryResponse.getBody().getOperation());
 420         assertEquals(OperationStateEnum.PROCESSING, secondJobQueryResponse.getBody().getOperationState());
 421         assertEquals(JAN_1_2019_12_00, secondJobQueryResponse.getBody().getStartTime());
 422         assertEquals(JAN_1_2019_1_00, secondJobQueryResponse.getBody().getStateEnteredTime());
 423     }
 424
 425     private InlineResponse200 createOperationQueryResponse(
 426             final org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationEnum operation,
 427             final org.onap.so.adapters.vnfmadapter.extclients.vnfm.model.InlineResponse200.OperationStateEnum operationState) {
 428         final InlineResponse200 response = new InlineResponse200();
 429         response.setId("9876");
 430         response.setOperation(operation);
 431         response.setOperationState(operationState);
 432         response.setStartTime(JAN_1_2019_12_00);
 433         response.setStateEnteredTime(JAN_1_2019_1_00);
 434         response.setVnfInstanceId("myVnfInstanceId");
 435         return response;
 436     }
 437
 438     private class AaiResourceUriMatcher extends BaseMatcher<AAIResourceUri> {
 439
 440         final String uriAsString;
 441
 442         public AaiResourceUriMatcher(final String uriAsString) {
 443             this.uriAsString = uriAsString;
 444         }
 445
 446         @Override
 447         public boolean matches(final Object item) {
 448             if (item instanceof AAIResourceUri) {
 449                 if (uriAsString.endsWith("...")) {
 450                     return ((AAIResourceUri) item).build().toString()
 451                             .startsWith(uriAsString.substring(0, uriAsString.indexOf("...")));
 452                 }
 453                 return ((AAIResourceUri) item).build().toString().equals(uriAsString);
 454             }
 455             return false;
 456         }
 457
 458         @Override
 459         public void describeTo(final Description description) {}
 460
 461     }
 462
 463
 464 }