gerrit.onap Code Review - so.git/blob

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  # Copyright (c) 2019, CMCC Technologies Co., Ltd.
   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 package org.onap.so.bpmn.infrastructure.scripts
  21
  22 import static org.junit.Assert.assertEquals
  23 import static org.junit.Assert.assertNotNull
  24 import static org.mockito.Mockito.*
  25 import javax.ws.rs.NotFoundException
  26 import javax.ws.rs.core.Response
  27 import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
  28 import org.junit.Before
  29 import org.junit.Test
  30 import org.mockito.ArgumentCaptor
  31 import org.mockito.Captor
  32 import org.mockito.Mockito
  33 import org.onap.aaiclient.client.aai.AAIObjectType
  34 import org.onap.aaiclient.client.aai.entities.AAIResultWrapper
  35 import org.onap.aaiclient.client.aai.entities.uri.AAIPluralResourceUri
  36 import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri
  37 import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory
  38 import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder
  39 import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.Types
  40 import org.onap.logging.filter.base.ONAPComponents
  41 import org.onap.so.bpmn.common.scripts.MsoGroovyTest
  42 import org.onap.so.bpmn.core.WorkflowException
  43 import org.onap.so.client.HttpClient
  44 import org.onap.so.client.HttpClientFactory
  45
  46 class DeleteCommunicationServiceTest extends MsoGroovyTest {
  47
  48     private HttpClientFactory httpClientFactoryMock
  49     private HttpClient httpClientMock
  50
  51     @Before
  52     void init() throws IOException {
  53         super.init("DeleteCommunicationServiceTest")
  54     }
  55
  56     @Captor
  57     static ArgumentCaptor<ExecutionEntity> captor = ArgumentCaptor.forClass(ExecutionEntity.class)
  58
  59     @Test
  60     void testPreProcessRequest(){
  61         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("12345")
  62         when(mockExecution.getVariable("bpmnRequest")).thenReturn("""
  63         {
  64             "globalSubscriberId ":"5GCustomer",
  65             "serviceType ":"5G"
  66         }""".replaceAll("\\\\s+", ""))
  67         when(mockExecution.getVariable("mso-request-id")).thenReturn("4c614769-f58a-4556-8ad9-dcd903077c82")
  68
  69         DeleteCommunicationService delCS = new DeleteCommunicationService()
  70         delCS.preProcessRequest(mockExecution)
  71         Mockito.verify(mockExecution,times(3)).setVariable(captor.capture() as String, captor.capture())
  72         List<ExecutionEntity> values = captor.getAllValues()
  73         assertNotNull(values)
  74     }
  75
  76     @Test
  77     void testPreInitUpdateOperationStatus(){
  78         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
  79         when(mockExecution.getVariable("operationId")).thenReturn("998c2081-5a71-4a39-9ae6-d6b7c5bb50c0")
  80         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
  81         when(mockExecution.getVariable("serviceInstanceName")).thenReturn("5G-test")
  82         when(mockExecution.getVariable("result")).thenReturn("processing")
  83         when(mockExecution.getVariable("progress")).thenReturn("0")
  84         when(mockExecution.getVariable("operationContent")).thenReturn("delete communication service operation start")
  85
  86         DeleteCommunicationService delCS = new DeleteCommunicationService()
  87         delCS.preInitUpdateOperationStatus(mockExecution)
  88         Mockito.verify(mockExecution,times(1)).setVariable(eq("updateOperationStatus"), captor.capture())
  89         String updateOperationStatus= captor.getValue()
  90         assertNotNull(updateOperationStatus)
  91     }
  92
  93     @Test
  94     void testQueryCommunicationSeriveFromAAI(){
  95         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
  96         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
  97         when(mockExecution.getVariable("serviceType")).thenReturn("5G")
  98
  99         AAIResourceUri resourceUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer("5GCustomer").serviceSubscription("5G").serviceInstance("5ad89cf9-0569-4a93-9306-d8324321e2be"))
 100         DeleteCommunicationService obj = spy(DeleteCommunicationService.class)
 101
 102         AAIResultWrapper wrapper = new AAIResultWrapper(mockQueryCommunicationServiceReturn())
 103         when(obj.getAAIClient()).thenReturn(client)
 104         when(client.exists(resourceUri)).thenReturn(true)
 105         when(client.get(resourceUri, NotFoundException.class)).thenReturn(wrapper)
 106         obj.queryCommunicationSeriveFromAAI(mockExecution)
 107         Mockito.verify(mockExecution,times(1)).setVariable(eq("e2eSliceServiceInstanceId"), captor.capture())
 108         String e2eSliceServiceInstanceId = captor.getValue()
 109         assertNotNull(e2eSliceServiceInstanceId)
 110     }
 111
 112     @Test
 113     void testPrepareCallCheckProcessStatus(){
 114         DeleteCommunicationService dcs = new DeleteCommunicationService()
 115         dcs.prepareCallCheckProcessStatus(mockExecution)
 116         Mockito.verify(mockExecution,times(1)).setVariable(eq("endProgress"), captor.capture())
 117         int endProgress = captor.getValue()
 118         assertEquals(90,endProgress)
 119     }
 120
 121     @Test
 122     void testDelCSProfileFromAAI()
 123     {
 124         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
 125         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
 126         when(mockExecution.getVariable("serviceType")).thenReturn("5G")
 127
 128         AAIResultWrapper wrapper = new AAIResultWrapper(mockQueryCommunicationServiceProfile())
 129         AAIPluralResourceUri resourceUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer("5GCustomer").serviceSubscription("5G").serviceInstance("5ad89cf9-0569-4a93-9306-d8324321e2be").communicationServiceProfiles())
 130         AAIResourceUri profileUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer("5GCustomer").serviceSubscription("5G").serviceInstance("5ad89cf9-0569-4a93-9306-d8324321e2be").communicationServiceProfile("5G-111111"))
 131
 132         DeleteCommunicationService obj = spy(DeleteCommunicationService.class)
 133         when(obj.getAAIClient()).thenReturn(client)
 134         when(client.exists(resourceUri)).thenReturn(true)
 135         when(client.exists(profileUri)).thenReturn(true)
 136         when(client.get(resourceUri, NotFoundException.class)).thenReturn(wrapper)
 137         doNothing().when(client).delete(profileUri)
 138         obj.delCSProfileFromAAI(mockExecution)
 139         Mockito.verify(client,times(1)).delete(profileUri)
 140     }
 141
 142     @Test
 143     void testPrepareFailureStatus(){
 144         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
 145         when(mockExecution.getVariable("operationId")).thenReturn("998c2081-5a71-4a39-9ae6-d6b7c5bb50c0")
 146         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
 147         when(mockExecution.getVariable("serviceInstanceName")).thenReturn("5G-test")
 148         when(mockExecution.getVariable("result")).thenReturn("finished")
 149         when(mockExecution.getVariable("progress")).thenReturn("100")
 150         when(mockExecution.getVariable("operationContent")).thenReturn("terminate service failure.")
 151
 152         DeleteCommunicationService dcs = new DeleteCommunicationService()
 153         dcs.prepareFailureStatus(mockExecution)
 154         Mockito.verify(mockExecution,times(1)).setVariable(eq("updateOperationStatus"), captor.capture())
 155         String updateOperationStatus= captor.getValue()
 156         assertNotNull(updateOperationStatus)
 157     }
 158
 159     @Test
 160     void testDelCSFromAAI(){
 161         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
 162         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
 163         when(mockExecution.getVariable("serviceType")).thenReturn("5G")
 164
 165         AAIResourceUri serviceInstanceUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer("5GCustomer").serviceSubscription("5G").serviceInstance("5ad89cf9-0569-4a93-9306-d8324321e2be"))
 166         DeleteCommunicationService obj = spy(DeleteCommunicationService.class)
 167         when(obj.getAAIClient()).thenReturn(client)
 168         doNothing().when(client).delete(serviceInstanceUri)
 169
 170         obj.delCSFromAAI(mockExecution)
 171         Mockito.verify(mockExecution,times(1)).setVariable(eq("updateOperationStatus"), captor.capture())
 172         String updateOperationStatus= captor.getValue()
 173         assertNotNull(updateOperationStatus)
 174     }
 175
 176     @Test
 177     void testPreFailedOperationStatus(){
 178         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
 179         when(mockExecution.getVariable("operationId")).thenReturn("998c2081-5a71-4a39-9ae6-d6b7c5bb50c0")
 180         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
 181         when(mockExecution.getVariable("serviceInstanceName")).thenReturn("5G-test")
 182         when(mockExecution.getVariable("result")).thenReturn("error")
 183         when(mockExecution.getVariable("progress")).thenReturn("100")
 184         when(mockExecution.getVariable("operationContent")).thenReturn("terminate service failure")
 185
 186         DeleteCommunicationService deleteCommunicationService = new DeleteCommunicationService()
 187         WorkflowException exception = new WorkflowException("11113",7000,"terminate service failure")
 188         when(mockExecution.getVariable("WorkflowException")).thenReturn(exception)
 189         deleteCommunicationService.preFailedOperationStatus(mockExecution)
 190
 191         Mockito.verify(mockExecution,times(1)).setVariable(eq("updateOperationStatus"), captor.capture())
 192         String updateOperationStatus= captor.getValue()
 193         assertNotNull(updateOperationStatus)
 194     }
 195
 196     @Test
 197     void testSendRequest2NSMFWF(){
 198         httpClientMock = mock(HttpClient.class)
 199         httpClientFactoryMock = mock(HttpClientFactory.class)
 200         String url ="http://so.onap:8080/onap/so/infra/e2eServiceInstances/v3/5G-777"
 201         when(mockExecution.getVariable("serviceInstanceId")).thenReturn("5ad89cf9-0569-4a93-9306-d8324321e2be")
 202         when(mockExecution.getVariable("operationId")).thenReturn("998c2081-5a71-4a39-9ae6-d6b7c5bb50c0")
 203         when(mockExecution.getVariable("progress")).thenReturn("20")
 204         when(mockExecution.getVariable("operationContent")).thenReturn("waiting nsmf service delete finished")
 205         when(mockExecution.getVariable("globalSubscriberId")).thenReturn("5GCustomer")
 206         when(mockExecution.getVariable("mso.infra.endpoint.url")).thenReturn("http://so.onap:8080/onap/so/infra")
 207         when(mockExecution.getVariable("e2eSliceServiceInstanceId")).thenReturn("5G-777")
 208         when(mockExecution.getVariable("e2eOperationId")).thenReturn("e151059a-d924-4629-845f-264db19e50b3")
 209         when(httpClientFactoryMock.newJsonClient(new URL(url), ONAPComponents.SO)).thenReturn(httpClientMock)
 210         DeleteCommunicationService obj = spy(DeleteCommunicationService.class)
 211
 212         Response responseMock = mock(Response.class)
 213         when(responseMock.getStatus()).thenReturn(200)
 214         when(responseMock.hasEntity()).thenReturn(true)
 215         when(responseMock.getEntity()).thenReturn(getNSSMFResponse())
 216         when(obj.getHttpClientFactory()).thenReturn(httpClientFactoryMock)
 217         when(httpClientMock.delete(anyString())).thenReturn(responseMock)
 218
 219         obj.sendRequest2NSMFWF(mockExecution)
 220         Mockito.verify(mockExecution,times(1)).setVariable(eq("updateOperationStatus"), captor.capture())
 221         String updateOperationStatus= captor.getValue()
 222         assertNotNull(updateOperationStatus)
 223     }
 224
 225     private String getNSSMFResponse(){
 226         String response = """{
 227             "service":{
 228                 "serviceId":"e151059a-d924-4629-845f-264db19e50b4",
 229                 "operationId":"e151059a-d924-4629-845f-264db19e50b3"
 230             }
 231         }"""
 232         return response
 233     }
 234
 235
 236
 237
 238     private String mockQueryCommunicationServiceReturn()
 239     {
 240         String expect =
 241                 """{
 242                         "service-instance-id": "5G-666",
 243                         "service-instance-name": "eMBB_Slice_Communication_Service_5GCustomer",
 244                         "service-type": "eMBB",
 245                         "service-role": "communication-service",
 246                         "environment-context": "01-010101",
 247                         "workload-context": "12",
 248                         "created-at": "2019-12-11 19:56:00",
 249                         "description": "",
 250                         "model-invariant-id": "e75698d9-925a-4cdd-a6c0-edacbe6a0b51",
 251                         "model-version-id": "8ee5926d-720b-4bb2-86f9-d20e921c143b",
 252                         "service-instance-location-id": "300-01|300-02",
 253                         "resource-version": "1582623470778",
 254                         "orchestration-status": "created",
 255                         "relationship-list": {
 256                             "relationship": [
 257                                 {
 258                                     "related-to": "service-instance",
 259                                     "relationship-label": "org.onap.relationships.inventory.ComposedOf",
 260                                     "related-link": "/aai/v16/business/customers/customer/5GCustomer/service-subscriptions/service-subscription/5G/service-instances/service-instance/5G-777",
 261                                     "relationship-data": [
 262                                         {
 263                                             "relationship-key": "customer.global-customer-id",
 264                                             "relationship-value": "5GCustomer"
 265                                         },
 266                                         {
 267                                             "relationship-key": "service-subscription.service-type",
 268                                             "relationship-value": "5G"
 269                                         },
 270                                         {
 271                                             "relationship-key": "service-instance.service-instance-id",
 272                                             "relationship-value": "5G-777"
 273                                         }
 274                                     ],
 275                                     "related-to-property": [
 276                                         {
 277                                             "property-key": "service-instance.service-instance-name",
 278                                             "property-value": "eMBB_e2e_Slice_Service_5GCustomer"
 279                                         }
 280                                     ]
 281                                 }
 282                             ]
 283                         }
 284                     }"""
 285         return expect
 286     }
 287
 288     private String mockQueryCommunicationServiceProfile()
 289     {
 290         String expect =
 291         """{
 292             "communication-service-profile": [
 293                 {
 294                     "profile-id": "5G-111111",
 295                     "max-number-of-UEs": 50,
 296                     "coverage-area-list": "longgang,futian",
 297                     "latency": 20,
 298                     "exp-data-rate-UL": 300,
 299                     "exp-data-rate-DL": 500,
 300                     "ue-mobility-level": "stationary",
 301                     "resource-sharing-level": "Non-Shared",
 302                     "resource-version": "1577454950460"
 303                 }
 304         ]
 305         }"""
 306         return expect
 307     }
 308 }