bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/vcpe/scripts/DoCreateAllottedResourceBRGTest.groovy

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Modifications Copyright (c) 2019 Samsung
   8  * ================================================================================
   9  * Licensed under the Apache License, Version 2.0 (the "License");
  10  * you may not use this file except in compliance with the License.
  11  * You may obtain a copy of the License at
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  15  * Unless required by applicable law or agreed to in writing, software
  16  * distributed under the License is distributed on an "AS IS" BASIS,
  17  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  18  * See the License for the specific language governing permissions and
  19  * limitations under the License.
  20  * ============LICENSE_END=========================================================
  21  */
  22
  23 package org.onap.so.bpmn.vcpe.scripts
  24
  25 import com.github.tomakehurst.wiremock.junit.WireMockRule
  26 import org.camunda.bpm.engine.delegate.BpmnError
  27 import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
  28 import org.junit.*
  29 import org.mockito.MockitoAnnotations
  30 import org.onap.so.bpmn.core.RollbackData
  31 import org.onap.so.bpmn.core.UrnPropertiesReader
  32 import org.onap.so.bpmn.core.WorkflowException
  33 import org.onap.so.bpmn.mock.FileUtil
  34 import org.onap.so.client.aai.AAIObjectType
  35 import org.onap.so.client.aai.AAIResourcesClient
  36 import org.onap.so.client.aai.entities.uri.AAIUriFactory
  37
  38 import javax.ws.rs.core.UriBuilder
  39
  40 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse
  41 import static com.github.tomakehurst.wiremock.client.WireMock.put
  42 import static com.github.tomakehurst.wiremock.client.WireMock.urlMatching
  43 import static org.junit.Assert.*
  44 import static org.mockito.Mockito.*
  45 import static org.onap.so.bpmn.mock.StubResponseAAI.*
  46
  47 class DoCreateAllottedResourceBRGTest extends GroovyTestBase {
  48
  49     @Rule
  50     public WireMockRule wireMockRule = new WireMockRule(PORT)
  51
  52     String Prefix = "DCARBRG_"
  53
  54     @BeforeClass
  55     public static void setUpBeforeClass() {
  56         aaiUriPfx = UrnPropertiesReader.getVariable("aai.endpoint")
  57     }
  58
  59     @Before
  60     public void init() {
  61         MockitoAnnotations.initMocks(this)
  62     }
  63
  64     public DoCreateAllottedResourceBRGTest() {
  65         super("DoCreateAllottedResourceBRG")
  66     }
  67
  68     // ***** preProcessRequest *****
  69
  70     @Test
  71     public void preProcessRequest() {
  72         ExecutionEntity mex = setupMock()
  73         initPreProcess(mex)
  74
  75         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
  76         DoCreateAllottedResourceBRG.preProcessRequest(mex)
  77
  78         verify(mex).setVariable("prefix", Prefix)
  79
  80         assertTrue(checkMissingPreProcessRequest("mso.workflow.sdncadapter.callback"))
  81         assertTrue(checkMissingPreProcessRequest("mso.workflow.sdnc.replication.delay"))
  82         assertTrue(checkMissingPreProcessRequest("serviceInstanceId"))
  83         assertTrue(checkMissingPreProcessRequest("parentServiceInstanceId"))
  84         assertTrue(checkMissingPreProcessRequest("allottedResourceModelInfo"))
  85         assertTrue(checkMissingPreProcessRequest("vni"))
  86         assertTrue(checkMissingPreProcessRequest("vgmuxBearerIP"))
  87         assertTrue(checkMissingPreProcessRequest("brgWanMacAddress"))
  88         assertTrue(checkMissingPreProcessRequest("allottedResourceRole"))
  89         assertTrue(checkMissingPreProcessRequest("allottedResourceType"))
  90     }
  91
  92     // ***** getAaiAR *****
  93
  94     @Test
  95     @Ignore
  96     public void getAaiAR() {
  97         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRG/getArBrg.xml")
  98
  99         ExecutionEntity mex = setupMock()
 100         initGetAaiAR(mex)
 101
 102         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 103         DoCreateAllottedResourceBRG.getAaiAR(mex)
 104
 105         verify(mex).setVariable("foundActiveAR", true)
 106     }
 107
 108     @Test
 109     public void getAaiAR_Duplicate() {
 110         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRG/getArBrg.xml")
 111
 112         ExecutionEntity mex = setupMock()
 113         initGetAaiAR(mex)
 114
 115         // fail if duplicate
 116         when(mex.getVariable("failExists")).thenReturn("true")
 117
 118         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 119
 120         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.getAaiAR(mex) }))
 121     }
 122
 123     @Test
 124     public void getAaiAR_NotActive() {
 125         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRG/getArBrg.xml")
 126
 127         ExecutionEntity mex = setupMock()
 128         initGetAaiAR(mex)
 129
 130         // not active
 131         when(mex.getVariable("aaiAROrchStatus")).thenReturn("not-active")
 132
 133         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 134
 135         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.getAaiAR(mex) }))
 136     }
 137
 138     @Test
 139     @Ignore
 140     public void getAaiAR_NoStatus() {
 141         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRG/getArBrg.xml")
 142
 143         ExecutionEntity mex = setupMock()
 144         initGetAaiAR(mex)
 145
 146         when(mex.getVariable("aaiAROrchStatus")).thenReturn(null)
 147
 148         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 149         DoCreateAllottedResourceBRG.getAaiAR(mex)
 150
 151         verify(mex, never()).setVariable("foundActiveAR", true)
 152     }
 153
 154     // ***** createAaiAR *****
 155
 156     @Test
 157     public void createAaiAR() {
 158         ExecutionEntity mockExecution = setupMock()
 159         AAIResourcesClient client = mock(AAIResourcesClient.class)
 160         when(mockExecution.getVariable("PSI_resourceLink")).thenReturn(AAIUriFactory.createResourceFromExistingURI(AAIObjectType.SERVICE_INSTANCE, UriBuilder.fromPath("/aai/v9/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST).build()))
 161         when(mockExecution.getVariable("CSI_resourceLink")).thenReturn("/aai/v9/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST)
 162         when(mockExecution.getVariable("allottedResourceModelInfo")).thenReturn("{\n" +
 163                 "  \"modelInvariantUuid\":\"modelInvariantUuid\",\n" +
 164                 "  \"modelUuid\" : \"modelUuid\"\n" +
 165                 "}")
 166         DoCreateAllottedResourceBRG doCreateAllottedResourceBRG = spy(DoCreateAllottedResourceBRG.class)
 167         when(doCreateAllottedResourceBRG.getAAIClient()).thenReturn(client)
 168         doCreateAllottedResourceBRG.createAaiAR(mockExecution)
 169     }
 170
 171     @Test
 172     @Ignore
 173     public void createAaiAR_NoArid_NoModelUuids() {
 174         ExecutionEntity mex = setupMock()
 175         def map = setupMap(mex)
 176         initCreateAaiAr(mex)
 177
 178         // no allottedResourceId - will be generated
 179
 180         when(mex.getVariable("allottedResourceId")).thenReturn(null)
 181
 182         wireMockRule
 183                 .stubFor(put(urlMatching("/aai/.*/allotted-resource/.*"))
 184                 .willReturn(aResponse()
 185                 .withStatus(200)))
 186
 187         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 188         DoCreateAllottedResourceBRG.createAaiAR(mex)
 189
 190         def arid = map.get("allottedResourceId")
 191         assertNotNull(arid)
 192         assertFalse(arid.isEmpty())
 193
 194         def data = map.get("rollbackData")
 195         assertNotNull(data)
 196         assertTrue(data instanceof RollbackData)
 197
 198         assertEquals(arid, data.get(Prefix, "allottedResourceId"))
 199     }
 200
 201     @Test
 202     public void createAaiAR_MissingPsiLink() {
 203         ExecutionEntity mex = setupMock()
 204         initCreateAaiAr(mex)
 205
 206         when(mex.getVariable("PSI_resourceLink")).thenReturn(null)
 207
 208         MockPutAllottedResource(CUST, SVC, INST, ARID)
 209
 210         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 211
 212         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.createAaiAR(mex) }))
 213     }
 214
 215     @Test
 216     public void createAaiAR_HttpFailed() {
 217         ExecutionEntity mex = setupMock()
 218         initCreateAaiAr(mex)
 219
 220         MockPutAllottedResource_500(CUST, SVC, INST, ARID)
 221
 222         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 223
 224         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.createAaiAR(mex) }))
 225     }
 226
 227     @Test
 228     public void createAaiAR_BpmnError() {
 229         ExecutionEntity mex = setupMock()
 230         initCreateAaiAr(mex)
 231
 232         when(mex.getVariable("aai.endpoint")).thenThrow(new BpmnError("expected exception"))
 233
 234         MockPutAllottedResource(CUST, SVC, INST, ARID)
 235
 236         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 237
 238         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.createAaiAR(mex) }))
 239     }
 240
 241     @Test
 242     public void createAaiAR_Ex() {
 243         ExecutionEntity mex = setupMock()
 244         initCreateAaiAr(mex)
 245
 246         when(mex.getVariable("aai.endpoint")).thenThrow(new RuntimeException("expected exception"))
 247
 248         MockPutAllottedResource(CUST, SVC, INST, ARID)
 249
 250         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 251
 252         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.createAaiAR(mex) }))
 253     }
 254
 255     // ***** buildSDNCRequest *****
 256
 257     @Test
 258     public void buildSDNCRequest() {
 259         ExecutionEntity mex = setupMock()
 260         initBuildSDNCRequest(mex)
 261
 262         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 263
 264         String result = DoCreateAllottedResourceBRG.buildSDNCRequest(mex, "myact", "myreq")
 265
 266         assertTrue(result.indexOf("<sdncadapter:RequestId>myreq</") >= 0)
 267         assertTrue(result.indexOf("<sdncadapter:SvcAction>myact</") >= 0)
 268         assertTrue(result.indexOf("<allotted-resource-id>ari</") >= 0)
 269         assertTrue(result.indexOf("<sdncadapter:SvcInstanceId>sii</") >= 0)
 270         assertTrue(result.indexOf("<service-instance-id>sii</") >= 0)
 271         assertTrue(result.indexOf("<parent-service-instance-id>psii</") >= 0)
 272         assertTrue(result.indexOf("<subscription-service-type>sst</") >= 0)
 273         assertTrue(result.indexOf("<global-customer-id>gci</") >= 0)
 274         assertTrue(result.indexOf("<sdncadapter:CallbackUrl>scu</") >= 0)
 275         assertTrue(result.indexOf("<request-id>mri</") >= 0)
 276         assertTrue(result.indexOf("<brg-wan-mac-address>bwma</") >= 0)
 277         assertTrue(result.indexOf("<vni>myvni</") >= 0)
 278         assertTrue(result.indexOf("<vgmux-bearer-ip>vbi</") >= 0)
 279         assertTrue(result.indexOf("<model-invariant-uuid>miu</") >= 0)
 280         assertTrue(result.indexOf("<model-uuid>mu</") >= 0)
 281         assertTrue(result.indexOf("<model-customization-uuid>mcu</") >= 0)
 282         assertTrue(result.indexOf("<model-version>mv</") >= 0)
 283         assertTrue(result.indexOf("<model-name>mn</") >= 0)
 284     }
 285
 286     @Test
 287     public void buildSDNCRequest_EmptyModelInfo() {
 288         ExecutionEntity mex = setupMock()
 289         initBuildSDNCRequest(mex)
 290
 291         when(mex.getVariable("allottedResourceModelInfo")).thenReturn("{}")
 292
 293         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 294
 295         String result = DoCreateAllottedResourceBRG.buildSDNCRequest(mex, "myact", "myreq")
 296
 297         assertTrue(result.indexOf("<sdncadapter:RequestId>myreq</") >= 0)
 298         assertTrue(result.indexOf("<sdncadapter:SvcAction>myact</") >= 0)
 299         assertTrue(result.indexOf("<allotted-resource-id>ari</") >= 0)
 300         assertTrue(result.indexOf("<sdncadapter:SvcInstanceId>sii</") >= 0)
 301         assertTrue(result.indexOf("<service-instance-id>sii</") >= 0)
 302         assertTrue(result.indexOf("<parent-service-instance-id>psii</") >= 0)
 303         assertTrue(result.indexOf("<subscription-service-type>sst</") >= 0)
 304         assertTrue(result.indexOf("<global-customer-id>gci</") >= 0)
 305         assertTrue(result.indexOf("<sdncadapter:CallbackUrl>scu</") >= 0)
 306         assertTrue(result.indexOf("<request-id>mri</") >= 0)
 307         assertTrue(result.indexOf("<brg-wan-mac-address>bwma</") >= 0)
 308         assertTrue(result.indexOf("<vni>myvni</") >= 0)
 309         assertTrue(result.indexOf("<vgmux-bearer-ip>vbi</") >= 0)
 310         assertTrue(result.indexOf("<model-invariant-uuid/>") >= 0)
 311         assertTrue(result.indexOf("<model-uuid/>") >= 0)
 312         assertTrue(result.indexOf("<model-customization-uuid/>") >= 0)
 313         assertTrue(result.indexOf("<model-version/>") >= 0)
 314         assertTrue(result.indexOf("<model-name/>") >= 0)
 315     }
 316
 317     @Test
 318     public void buildSDNCRequest_Ex() {
 319         ExecutionEntity mex = setupMock()
 320         initBuildSDNCRequest(mex)
 321
 322         when(mex.getVariable("allottedResourceId")).thenThrow(new RuntimeException("expected exception"))
 323
 324         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 325
 326         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.buildSDNCRequest(mex, "myact", "myreq") }))
 327     }
 328
 329     // ***** preProcessSDNCAssign *****
 330
 331     @Test
 332     public void preProcessSDNCAssign() {
 333         ExecutionEntity mex = setupMock()
 334         def map = setupMap(mex)
 335         def data = initPreProcessSDNC(mex)
 336
 337         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 338         DoCreateAllottedResourceBRG.preProcessSDNCAssign(mex)
 339
 340         def req = map.get("sdncAssignRequest")
 341         assertNotNull(req)
 342
 343         assertEquals(data, map.get("rollbackData"))
 344
 345         def rbreq = data.get(Prefix, "sdncAssignRollbackReq")
 346
 347         assertTrue(req.indexOf("<sdncadapter:SvcAction>assign</") >= 0)
 348         assertTrue(req.indexOf("<request-action>CreateBRGInstance</") >= 0)
 349         assertTrue(req.indexOf("<sdncadapter:RequestId>") >= 0)
 350
 351         assertTrue(rbreq.indexOf("<sdncadapter:SvcAction>unassign</") >= 0)
 352         assertTrue(rbreq.indexOf("<request-action>DeleteBRGInstance</") >= 0)
 353         assertTrue(rbreq.indexOf("<sdncadapter:RequestId>") >= 0)
 354     }
 355
 356     @Test
 357     public void preProcessSDNCAssign_BpmnError() {
 358         ExecutionEntity mex = setupMock()
 359         initPreProcessSDNC(mex)
 360
 361         when(mex.getVariable("rollbackData")).thenThrow(new BpmnError("expected exception"))
 362
 363         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 364
 365         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCAssign(mex) }))
 366     }
 367
 368     @Test
 369     public void preProcessSDNCAssign_Ex() {
 370         ExecutionEntity mex = setupMock()
 371         initPreProcessSDNC(mex)
 372
 373         when(mex.getVariable("rollbackData")).thenThrow(new RuntimeException("expected exception"))
 374
 375         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 376
 377         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCAssign(mex) }))
 378     }
 379
 380     // ***** preProcessSDNCCreate *****
 381
 382     @Test
 383     public void preProcessSDNCCreate() {
 384         ExecutionEntity mex = setupMock()
 385         def map = setupMap(mex)
 386         def data = initPreProcessSDNC(mex)
 387
 388         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 389         DoCreateAllottedResourceBRG.preProcessSDNCCreate(mex)
 390
 391         def req = map.get("sdncCreateRequest")
 392         assertNotNull(req)
 393
 394         assertEquals(data, map.get("rollbackData"))
 395
 396         def rbreq = data.get(Prefix, "sdncCreateRollbackReq")
 397
 398         assertTrue(req.indexOf("<sdncadapter:SvcAction>create</") >= 0)
 399         assertTrue(req.indexOf("<request-action>CreateBRGInstance</") >= 0)
 400         assertTrue(req.indexOf("<sdncadapter:RequestId>") >= 0)
 401
 402         assertTrue(rbreq.indexOf("<sdncadapter:SvcAction>delete</") >= 0)
 403         assertTrue(rbreq.indexOf("<request-action>DeleteBRGInstance</") >= 0)
 404         assertTrue(rbreq.indexOf("<sdncadapter:RequestId>") >= 0)
 405
 406     }
 407
 408     @Test
 409     public void preProcessSDNCCreate_BpmnError() {
 410         ExecutionEntity mex = setupMock()
 411         initPreProcessSDNC(mex)
 412
 413         when(mex.getVariable("rollbackData")).thenThrow(new BpmnError("expected exception"))
 414
 415         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 416
 417         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCCreate(mex) }))
 418     }
 419
 420     @Test
 421     public void preProcessSDNCCreate_Ex() {
 422         ExecutionEntity mex = setupMock()
 423         initPreProcessSDNC(mex)
 424
 425         when(mex.getVariable("rollbackData")).thenThrow(new RuntimeException("expected exception"))
 426
 427         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 428
 429         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCCreate(mex) }))
 430     }
 431
 432     // ***** preProcessSDNCActivate *****
 433
 434     @Test
 435     public void preProcessSDNCActivate() {
 436         ExecutionEntity mex = setupMock()
 437         def map = setupMap(mex)
 438         def data = initPreProcessSDNC(mex)
 439
 440         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 441         DoCreateAllottedResourceBRG.preProcessSDNCActivate(mex)
 442
 443         def req = map.get("sdncActivateRequest")
 444         assertNotNull(req)
 445
 446         assertEquals(data, map.get("rollbackData"))
 447
 448         def rbreq = data.get(Prefix, "sdncActivateRollbackReq")
 449
 450         assertTrue(req.indexOf("<sdncadapter:SvcAction>activate</") >= 0)
 451         assertTrue(req.indexOf("<request-action>CreateBRGInstance</") >= 0)
 452         assertTrue(req.indexOf("<sdncadapter:RequestId>") >= 0)
 453
 454         assertTrue(rbreq.indexOf("<sdncadapter:SvcAction>deactivate</") >= 0)
 455         assertTrue(rbreq.indexOf("<request-action>DeleteBRGInstance</") >= 0)
 456         assertTrue(rbreq.indexOf("<sdncadapter:RequestId>") >= 0)
 457
 458     }
 459
 460     @Test
 461     public void preProcessSDNCActivate_BpmnError() {
 462         ExecutionEntity mex = setupMock()
 463         initPreProcessSDNC(mex)
 464
 465         when(mex.getVariable("rollbackData")).thenThrow(new BpmnError("expected exception"))
 466
 467         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 468
 469         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCActivate(mex) }))
 470     }
 471
 472     @Test
 473     public void preProcessSDNCActivate_Ex() {
 474         ExecutionEntity mex = setupMock()
 475         initPreProcessSDNC(mex)
 476
 477         when(mex.getVariable("rollbackData")).thenThrow(new RuntimeException("expected exception"))
 478
 479         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 480
 481         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCActivate(mex) }))
 482     }
 483
 484     // ***** validateSDNCResp *****
 485
 486     @Test
 487     public void validateSDNCResp() {
 488         ExecutionEntity mex = setupMock()
 489         def map = setupMap(mex)
 490         def data = initValidateSDNCResp(mex)
 491         def resp = initValidateSDNCResp_Resp()
 492
 493         when(mex.getVariable(Prefix + "sdncResponseSuccess")).thenReturn(true)
 494
 495         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 496
 497         DoCreateAllottedResourceBRG.validateSDNCResp(mex, resp, "create")
 498
 499         verify(mex).getVariable("WorkflowException")
 500         verify(mex).getVariable("SDNCA_SuccessIndicator")
 501         verify(mex).getVariable("rollbackData")
 502
 503         assertEquals(data, map.get("rollbackData"))
 504
 505         assertEquals("true", data.get(Prefix, "rollback" + "SDNCcreate"))
 506
 507     }
 508
 509     @Test
 510     public void validateSDNCResp_Get() {
 511         ExecutionEntity mex = setupMock()
 512         def data = initValidateSDNCResp(mex)
 513         def resp = initValidateSDNCResp_Resp()
 514
 515         when(mex.getVariable(Prefix + "sdncResponseSuccess")).thenReturn(true)
 516
 517         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 518
 519         DoCreateAllottedResourceBRG.validateSDNCResp(mex, resp, "get")
 520
 521         verify(mex).getVariable("WorkflowException")
 522         verify(mex).getVariable("SDNCA_SuccessIndicator")
 523
 524         verify(mex, never()).getVariable("rollbackData")
 525     }
 526
 527     @Test
 528     public void validateSDNCResp_Unsuccessful() {
 529         ExecutionEntity mex = setupMock()
 530         initValidateSDNCResp(mex)
 531         def resp = initValidateSDNCResp_Resp()
 532
 533         // unsuccessful
 534         when(mex.getVariable(Prefix + "sdncResponseSuccess")).thenReturn(false)
 535
 536         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 537
 538         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.validateSDNCResp(mex, resp, "create") }))
 539     }
 540
 541     @Test
 542     public void validateSDNCResp_BpmnError() {
 543         ExecutionEntity mex = setupMock()
 544         initValidateSDNCResp(mex)
 545         def resp = initValidateSDNCResp_Resp()
 546
 547         when(mex.getVariable("WorkflowException")).thenThrow(new BpmnError("expected exception"))
 548
 549         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 550
 551         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.validateSDNCResp(mex, resp, "create") }))
 552     }
 553
 554     @Test
 555     public void validateSDNCResp_Ex() {
 556         ExecutionEntity mex = setupMock()
 557         initValidateSDNCResp(mex)
 558         def resp = initValidateSDNCResp_Resp()
 559
 560         when(mex.getVariable("WorkflowException")).thenThrow(new RuntimeException("expected exception"))
 561
 562         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 563
 564         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.validateSDNCResp(mex, resp, "create") }))
 565     }
 566
 567     // ***** preProcessSDNCGet *****
 568
 569     @Test
 570     public void preProcessSDNCGet_FoundAR() {
 571         ExecutionEntity mex = setupMock()
 572         def map = setupMap(mex)
 573         initPreProcessSDNCGet(mex)
 574
 575         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 576         DoCreateAllottedResourceBRG.preProcessSDNCGet(mex)
 577
 578         String req = map.get("sdncGetRequest")
 579
 580         assertTrue(req.indexOf("<sdncadapter:RequestId>") >= 0)
 581         assertTrue(req.indexOf("<sdncadapter:SvcInstanceId>sii</") >= 0)
 582         assertTrue(req.indexOf("<sdncadapter:SvcOperation>arlink</") >= 0)
 583         assertTrue(req.indexOf("<sdncadapter:CallbackUrl>myurl</") >= 0)
 584
 585     }
 586
 587     @Test
 588     public void preProcessSDNCGet_NotFoundAR() {
 589         ExecutionEntity mex = setupMock()
 590         def map = setupMap(mex)
 591         initPreProcessSDNCGet(mex)
 592
 593         when(mex.getVariable("foundActiveAR")).thenReturn(false)
 594
 595         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 596         DoCreateAllottedResourceBRG.preProcessSDNCGet(mex)
 597
 598         String req = map.get("sdncGetRequest")
 599
 600         assertTrue(req.indexOf("<sdncadapter:RequestId>") >= 0)
 601         assertTrue(req.indexOf("<sdncadapter:SvcInstanceId>sii</") >= 0)
 602         assertTrue(req.indexOf("<sdncadapter:SvcOperation>assignlink</") >= 0)
 603         assertTrue(req.indexOf("<sdncadapter:CallbackUrl>myurl</") >= 0)
 604
 605     }
 606
 607     @Test
 608     public void preProcessSDNCGet_Ex() {
 609         ExecutionEntity mex = setupMock()
 610         initPreProcessSDNCGet(mex)
 611
 612         when(mex.getVariable("foundActiveAR")).thenThrow(new RuntimeException("expected exception"))
 613
 614         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 615
 616         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessSDNCGet(mex) }))
 617     }
 618
 619     // ***** updateAaiAROrchStatus *****
 620
 621     @Test
 622     @Ignore
 623     public void updateAaiAROrchStatus() {
 624         MockPatchAllottedResource(CUST, SVC, INST, ARID)
 625
 626         ExecutionEntity mex = setupMock()
 627         initUpdateAaiAROrchStatus(mex)
 628
 629         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 630         DoCreateAllottedResourceBRG.updateAaiAROrchStatus(mex, "success")
 631     }
 632
 633     // ***** generateOutputs *****
 634
 635     @Test
 636     public void generateOutputs() {
 637         ExecutionEntity mex = setupMock()
 638         def brgtop = FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceBRG/SDNCTopologyQueryCallback.xml")
 639
 640         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 641         when(mex.getVariable("enhancedCallbackRequestData")).thenReturn(brgtop)
 642
 643         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 644         DoCreateAllottedResourceBRG.generateOutputs(mex)
 645
 646         verify(mex).setVariable("allotedResourceName", "namefromrequest")
 647
 648     }
 649
 650     @Test
 651     public void generateOutputs_BadXml() {
 652         ExecutionEntity mex = setupMock()
 653
 654         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 655         when(mex.getVariable("enhancedCallbackRequestData")).thenReturn("invalid xml")
 656
 657         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 658         DoCreateAllottedResourceBRG.generateOutputs(mex)
 659
 660         verify(mex, never()).setVariable(anyString(), anyString())
 661
 662     }
 663
 664     @Test
 665     public void generateOutputs_BpmnError() {
 666         ExecutionEntity mex = setupMock()
 667
 668         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 669         when(mex.getVariable("enhancedCallbackRequestData")).thenThrow(new BpmnError("expected exception"))
 670
 671         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 672
 673         DoCreateAllottedResourceBRG.generateOutputs(mex)
 674         verify(mex, never()).setVariable(anyString(), anyString())
 675
 676     }
 677
 678     @Test
 679     public void generateOutputs_Ex() {
 680         ExecutionEntity mex = setupMock()
 681
 682         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 683         when(mex.getVariable("enhancedCallbackRequestData")).thenThrow(new RuntimeException("expected exception"))
 684
 685         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 686
 687         DoCreateAllottedResourceBRG.generateOutputs(mex)
 688         verify(mex, never()).setVariable(anyString(), anyString())
 689
 690     }
 691
 692     // ***** preProcessRollback *****
 693
 694     @Test
 695     public void preProcessRollback() {
 696         ExecutionEntity mex = setupMock()
 697         WorkflowException wfe = mock(WorkflowException.class)
 698
 699         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 700         when(mex.getVariable("WorkflowException")).thenReturn(wfe)
 701
 702         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 703         DoCreateAllottedResourceBRG.preProcessRollback(mex)
 704
 705         verify(mex).setVariable("prevWorkflowException", wfe)
 706     }
 707
 708     @Test
 709     public void preProcessRollback_NotWFE() {
 710         ExecutionEntity mex = setupMock()
 711
 712         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 713         when(mex.getVariable("WorkflowException")).thenReturn("I'm not a WFE")
 714
 715         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 716         DoCreateAllottedResourceBRG.preProcessRollback(mex)
 717     }
 718
 719     @Test
 720     public void preProcessRollback_BpmnError() {
 721         ExecutionEntity mex = setupMock()
 722
 723         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 724         when(mex.getVariable("WorkflowException")).thenThrow(new BpmnError("expected exception"))
 725
 726         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 727
 728         DoCreateAllottedResourceBRG.preProcessRollback(mex)
 729     }
 730
 731     @Test
 732     public void preProcessRollback_Ex() {
 733         ExecutionEntity mex = setupMock()
 734
 735         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 736         when(mex.getVariable("WorkflowException")).thenThrow(new RuntimeException("expected exception"))
 737
 738         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 739
 740         DoCreateAllottedResourceBRG.preProcessRollback(mex)
 741
 742     }
 743
 744     // ***** postProcessRollback *****
 745
 746     @Test
 747     public void postProcessRollback() {
 748         ExecutionEntity mex = setupMock()
 749         WorkflowException wfe = mock(WorkflowException.class)
 750
 751         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 752         when(mex.getVariable("prevWorkflowException")).thenReturn(wfe)
 753
 754         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 755         DoCreateAllottedResourceBRG.postProcessRollback(mex)
 756
 757         verify(mex).setVariable("WorkflowException", wfe)
 758         verify(mex).setVariable("rollbackData", null)
 759
 760     }
 761
 762     @Test
 763     public void postProcessRollback_NotWFE() {
 764         ExecutionEntity mex = setupMock()
 765
 766         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 767         when(mex.getVariable("prevWorkflowException")).thenReturn("I'm not a WFE")
 768
 769         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 770         DoCreateAllottedResourceBRG.postProcessRollback(mex)
 771
 772         verify(mex).setVariable("rollbackData", null)
 773
 774     }
 775
 776     @Test
 777     public void postProcessRollback_BpmnError() {
 778         ExecutionEntity mex = setupMock()
 779
 780         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 781         when(mex.getVariable("prevWorkflowException")).thenThrow(new BpmnError("expected exception"))
 782
 783         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 784
 785         assertTrue(doBpmnError({ _ -> DoCreateAllottedResourceBRG.postProcessRollback(mex) }))
 786         verify(mex, never()).setVariable("rollbackData", null)
 787
 788     }
 789
 790     @Test
 791     public void postProcessRollback_Ex() {
 792         ExecutionEntity mex = setupMock()
 793
 794         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 795         when(mex.getVariable("prevWorkflowException")).thenThrow(new RuntimeException("expected exception"))
 796
 797         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 798
 799         DoCreateAllottedResourceBRG.postProcessRollback(mex)
 800         verify(mex, never()).setVariable("rollbackData", null)
 801
 802     }
 803
 804     private boolean checkMissingPreProcessRequest(String fieldnm) {
 805         ExecutionEntity mex = setupMock()
 806         initPreProcess(mex)
 807
 808         DoCreateAllottedResourceBRG DoCreateAllottedResourceBRG = new DoCreateAllottedResourceBRG()
 809
 810         when(mex.getVariable(fieldnm)).thenReturn("")
 811
 812         return doBpmnError({ _ -> DoCreateAllottedResourceBRG.preProcessRequest(mex) })
 813     }
 814
 815     private void initPreProcess(ExecutionEntity mex) {
 816         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 817         when(mex.getVariable("mso.workflow.sdncadapter.callback")).thenReturn("sdncurn")
 818         when(mex.getVariable("mso.workflow.sdnc.replication.delay")).thenReturn("sdncdelay")
 819         when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
 820         when(mex.getVariable("parentServiceInstanceId")).thenReturn("psii")
 821         when(mex.getVariable("allottedResourceModelInfo")).thenReturn("armi")
 822         when(mex.getVariable("vni")).thenReturn("myvni")
 823         when(mex.getVariable("vgmuxBearerIP")).thenReturn("vbi")
 824         when(mex.getVariable("brgWanMacAddress")).thenReturn("bwma")
 825         when(mex.getVariable("allottedResourceRole")).thenReturn("arr")
 826         when(mex.getVariable("allottedResourceType")).thenReturn("art")
 827     }
 828
 829     private void initGetAaiAR(ExecutionEntity mex) {
 830         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 831         when(mex.getVariable("allottedResourceType")).thenReturn("BRGt")
 832         when(mex.getVariable("allottedResourceRole")).thenReturn("BRGr")
 833         when(mex.getVariable("CSI_service")).thenReturn(FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceBRG/getAR.xml"))
 834         when(mex.getVariable("aai.endpoint")).thenReturn(aaiUriPfx)
 835         when(mex.getVariable("aaiAROrchStatus")).thenReturn("Active")
 836     }
 837
 838     private initCreateAaiAr(ExecutionEntity mex) {
 839         when(mex.getVariable("disableRollback")).thenReturn(45)
 840         when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
 841         when(mex.getVariable("parentServiceInstanceId")).thenReturn("psii")
 842         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 843         when(mex.getVariable("allottedResourceId")).thenReturn(ARID)
 844         when(mex.getVariable("aai.endpoint")).thenReturn(aaiUriPfx)
 845         when(mex.getVariable("mso.workflow.global.default.aai.namespace")).thenReturn(UrnPropertiesReader.getVariable("mso.workflow.global.default.aai.namespace"))
 846         when(mex.getVariable("PSI_resourceLink")).thenReturn(AAIUriFactory.createResourceFromExistingURI(AAIObjectType.SERVICE_INSTANCE, UriBuilder.fromPath("/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST).build()))
 847         when(mex.getVariable("allottedResourceType")).thenReturn("BRGt")
 848         when(mex.getVariable("allottedResourceRole")).thenReturn("BRGr")
 849         when(mex.getVariable("CSI_resourceLink")).thenReturn(aaiUriPfx + "/aai/v9/mycsi")
 850         when(mex.getVariable("allottedResourceModelInfo")).thenReturn("""
 851                 {
 852                     "modelInvariantUuid":"modelinvuuid",
 853                     "modelUuid":"modeluuid",
 854                     "modelCustomizationUuid":"modelcustuuid"
 855                 }
 856             """)
 857     }
 858
 859     private initBuildSDNCRequest(ExecutionEntity mex) {
 860         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 861         when(mex.getVariable("allottedResourceId")).thenReturn("ari")
 862         when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
 863         when(mex.getVariable("parentServiceInstanceId")).thenReturn("psii")
 864         when(mex.getVariable("subscriptionServiceType")).thenReturn("sst")
 865         when(mex.getVariable("globalCustomerId")).thenReturn("gci")
 866         when(mex.getVariable("sdncCallbackUrl")).thenReturn("scu")
 867         when(mex.getVariable("msoRequestId")).thenReturn("mri")
 868         when(mex.getVariable("brgWanMacAddress")).thenReturn("bwma")
 869         when(mex.getVariable("vni")).thenReturn("myvni")
 870         when(mex.getVariable("vgmuxBearerIP")).thenReturn("vbi")
 871         when(mex.getVariable("allottedResourceModelInfo")).thenReturn("""
 872                 {
 873                     "modelInvariantUuid":"miu",
 874                     "modelUuid":"mu",
 875                     "modelCustomizationUuid":"mcu",
 876                     "modelVersion":"mv",
 877                     "modelName":"mn"
 878                 }
 879             """)
 880     }
 881
 882     private RollbackData initPreProcessSDNC(ExecutionEntity mex) {
 883         def data = new RollbackData()
 884
 885         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 886         when(mex.getVariable("rollbackData")).thenReturn(data)
 887
 888         return data
 889     }
 890
 891     private initPreProcessSDNCGet(ExecutionEntity mex) {
 892         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 893         when(mex.getVariable("sdncCallbackUrl")).thenReturn("myurl")
 894         when(mex.getVariable("foundActiveAR")).thenReturn(true)
 895         when(mex.getVariable("aaiARGetResponse")).thenReturn("<selflink>arlink</selflink>")
 896         when(mex.getVariable("sdncAssignResponse")).thenReturn("<response-data>&lt;object-path&gt;assignlink&lt;/object-path&gt;</response-data>")
 897         when(mex.getVariable("serviceInstanceId")).thenReturn("sii")
 898         when(mex.getVariable("sdncCallbackUrl")).thenReturn("myurl")
 899     }
 900
 901     private RollbackData initValidateSDNCResp(ExecutionEntity mex) {
 902         def data = new RollbackData()
 903
 904         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 905         when(mex.getVariable("prefix")).thenReturn(Prefix)
 906         when(mex.getVariable("SDNCA_SuccessIndicator")).thenReturn(true)
 907         when(mex.getVariable("rollbackData")).thenReturn(data)
 908
 909         return data
 910     }
 911
 912     private String initValidateSDNCResp_Resp() {
 913         return "<response-data>&lt;response-code&gt;200&lt;/response-code&gt;</response-data>"
 914     }
 915
 916     private initUpdateAaiAROrchStatus(ExecutionEntity mex) {
 917         when(mex.getVariable(DBGFLAG)).thenReturn("true")
 918         when(mex.getVariable("aaiARPath")).thenReturn("/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST + "/allotted-resources/allotted-resource/" + ARID)
 919     }
 920
 921 }