bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DeleteVcpeResCustServiceTest.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 package org.openecomp.mso.bpmn.vcpe;
  21
  22 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
  23 import static com.github.tomakehurst.wiremock.client.WireMock.get;
  24 import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
  25 import static com.github.tomakehurst.wiremock.client.WireMock.urlMatching;
  26 import static org.junit.Assert.assertEquals;
  27 import static org.junit.Assert.assertNotNull;
  28 import static org.junit.Assert.assertTrue;
  29 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockDeleteAllottedResource;
  30 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetAllottedResource;
  31 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetServiceInstance;
  32 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockNodeQueryServiceInstanceById;
  33 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockPatchAllottedResource;
  34 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockQueryAllottedResourceById;
  35 import static org.openecomp.mso.bpmn.mock.StubResponseDatabase.mockUpdateRequestDB;
  36 import static org.openecomp.mso.bpmn.mock.StubResponseSDNCAdapter.mockSDNCAdapter;
  37
  38 import java.io.IOException;
  39 import java.io.UnsupportedEncodingException;
  40 import java.util.HashMap;
  41 import java.util.Map;
  42 import java.util.UUID;
  43
  44 import org.camunda.bpm.engine.test.Deployment;
  45 import org.junit.Test;
  46 import org.openecomp.mso.bpmn.common.BPMNUtil;
  47 import org.openecomp.mso.bpmn.mock.FileUtil;
  48
  49 import com.github.tomakehurst.wiremock.stubbing.Scenario;
  50
  51 public class DeleteVcpeResCustServiceTest extends AbstractTestBase {
  52
  53     private static final String PROCNAME = "DeleteVcpeResCustService";
  54     private static final String Prefix = "DVRCS_";
  55     private static final String AR_BRG_ID = "ar-brgB";
  56     private static final String AR_TXC_ID = "ar-txcA";
  57
  58     private final CallbackSet callbacks = new CallbackSet();
  59     private final String request;
  60
  61     public DeleteVcpeResCustServiceTest() throws IOException {
  62         callbacks.put("deactivate", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyDeactivateCallback.xml"));
  63         callbacks.put("delete", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyDeleteCallback.xml"));
  64         callbacks.put("unassign", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyUnassignCallback.xml"));
  65
  66         request = FileUtil.readResourceFile("__files/VCPE/DeleteVcpeResCustService/request.json");
  67     }
  68
  69     @Test
  70     @Deployment(resources = {
  71             "process/DeleteVcpeResCustService.bpmn",
  72             "subprocess/GenericGetService.bpmn",
  73             "subprocess/GenericDeleteService.bpmn",
  74             "subprocess/SDNCAdapterV1.bpmn",
  75             "subprocess/FalloutHandler.bpmn",
  76             "subprocess/DoDeleteServiceInstance.bpmn",
  77             "subprocess/DoDeleteAllottedResourceBRG.bpmn",
  78             "subprocess/DoDeleteAllottedResourceTXC.bpmn",
  79             "subprocess/CompleteMsoProcess.bpmn",
  80
  81             // stubs
  82             "VCPE/stubprocess/DoDeleteVnfAndModules.bpmn"})
  83
  84     public void testDeleteVcpeResCustService_Success() throws Exception {
  85
  86         MockNodeQueryServiceInstanceById(INST, "GenericFlows/getSIUrlById.xml");
  87
  88         // TODO: use INST instead of DEC_INST
  89         /*
  90                  * Seems to be a bug in GenericDeleteService (or its subflows) as they
  91                  * fail to URL-encode the SI id before performing the query so we'll
  92                  * add a stub for that case, too.
  93                  */
  94         MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
  95
  96                 /*
  97                  * cannot use MockGetServiceInstance(), because we need to return
  98                  * different responses as we traverse through the flow
  99                  */
 100
 101         // initially, the SI includes the ARs
 102         stubFor(get(urlMatching("/aai/v[0-9]+/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST))
 103                 .inScenario("SI retrieval")
 104                 .whenScenarioStateIs(Scenario.STARTED)
 105                 .willReturn(aResponse()
 106                         .withStatus(200)
 107                         .withHeader("Content-Type", "text/xml")
 108                         .withBodyFile("VCPE/DeleteVcpeResCustService/getSI.xml"))
 109                 .willSetStateTo("ARs Deleted"));
 110
 111         // once the ARs have been deleted, the SI should be empty
 112         stubFor(get(urlMatching("/aai/v[0-9]+/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST))
 113                 .inScenario("SI retrieval")
 114                 .whenScenarioStateIs("ARs Deleted")
 115                 .willReturn(aResponse()
 116                         .withStatus(200)
 117                         .withHeader("Content-Type", "text/xml")
 118                         .withBodyFile("VCPE/DeleteVcpeResCustService/getSIAfterDelArs.xml")));
 119
 120         // for BRG
 121         MockQueryAllottedResourceById(AR_BRG_ID, "VCPE/DeleteVcpeResCustService/getBRGArUrlById.xml");
 122         MockGetAllottedResource(CUST, SVC, INST, AR_BRG_ID, "VCPE/DeleteVcpeResCustService/arGetBRGById.xml");
 123         MockPatchAllottedResource(CUST, SVC, INST, AR_BRG_ID);
 124         MockDeleteAllottedResource(CUST, SVC, INST, AR_BRG_ID, ARVERS);
 125
 126         // for TXC
 127         MockQueryAllottedResourceById(AR_TXC_ID, "VCPE/DeleteVcpeResCustService/getTXCArUrlById.xml");
 128         MockGetAllottedResource(CUST, SVC, INST, AR_TXC_ID, "VCPE/DeleteVcpeResCustService/arGetTXCById.xml");
 129         MockPatchAllottedResource(CUST, SVC, INST, AR_TXC_ID);
 130         MockDeleteAllottedResource(CUST, SVC, INST, AR_TXC_ID, ARVERS);
 131
 132         mockSDNCAdapter(200);
 133         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 134
 135         Map<String, Object> variables = setupVariables();
 136
 137         String businessKey = UUID.randomUUID().toString();
 138         invokeAsyncProcess(PROCNAME, "v1", businessKey, request, variables);
 139
 140         // for BRG
 141         injectSDNCCallbacks(callbacks, "deactivate");
 142         injectSDNCCallbacks(callbacks, "delete");
 143         injectSDNCCallbacks(callbacks, "unassign");
 144
 145         // for TXC
 146         injectSDNCCallbacks(callbacks, "deactivate");
 147         injectSDNCCallbacks(callbacks, "delete");
 148         injectSDNCCallbacks(callbacks, "unassign");
 149
 150         // for SI
 151         injectSDNCCallbacks(callbacks, "deactivate");
 152         injectSDNCCallbacks(callbacks, "delete");
 153
 154         waitForProcessEnd(businessKey, 10000);
 155
 156         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 157         System.out.println("workflowException:\n" + workflowException);
 158
 159         String completionReq = BPMNUtil.getVariable(processEngineRule, PROCNAME, Prefix + VAR_COMP_REQ);
 160         System.out.println("completionReq:\n" + completionReq);
 161
 162         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, PROCNAME + VAR_SUCCESS_IND));
 163         assertEquals("200", BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_RESP_CODE));
 164         assertEquals(null, workflowException);
 165         assertTrue(completionReq.contains("<request-id>testRequestId<"));
 166         assertTrue(completionReq.contains("<action>DELETE<"));
 167         assertTrue(completionReq.contains("<source>VID<"));
 168
 169         assertEquals("2", BPMNUtil.getVariable(processEngineRule, PROCNAME, Prefix + "vnfsDeletedCount"));
 170
 171         BPMNUtil.assertAnyProcessInstanceFinished(processEngineRule, "DoDeleteVnfAndModules");
 172     }
 173
 174     @Test
 175     @Deployment(resources = {
 176             "process/DeleteVcpeResCustService.bpmn",
 177             "subprocess/GenericGetService.bpmn",
 178             "subprocess/GenericDeleteService.bpmn",
 179             "subprocess/SDNCAdapterV1.bpmn",
 180             "subprocess/FalloutHandler.bpmn",
 181             "subprocess/DoDeleteServiceInstance.bpmn",
 182             "subprocess/DoDeleteAllottedResourceBRG.bpmn",
 183             "subprocess/DoDeleteAllottedResourceTXC.bpmn",
 184             "subprocess/CompleteMsoProcess.bpmn",
 185
 186             // stubs
 187             "VCPE/stubprocess/DoDeleteVnfAndModules.bpmn"})
 188
 189     public void testDeleteVcpeResCustService_NoBRG_NoTXC_NoVNF() throws Exception {
 190
 191         MockNodeQueryServiceInstanceById(INST, "GenericFlows/getSIUrlById.xml");
 192
 193         // TODO: use INST instead of DEC_INST
 194                 /*
 195                  * Seems to be a bug in GenericDeleteService (or its subflows) as they
 196                  * fail to URL-encode the SI id before performing the query so we'll
 197                  * add a stub for that case, too.
 198                  */
 199         MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
 200
 201         MockGetServiceInstance(CUST, SVC, INST, "VCPE/DeleteVcpeResCustService/getSIAfterDelArs.xml");
 202
 203         mockSDNCAdapter(200);
 204         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 205
 206         Map<String, Object> variables = setupVariables();
 207
 208         String businessKey = UUID.randomUUID().toString();
 209         invokeAsyncProcess(PROCNAME, "v1", businessKey, request, variables);
 210
 211         // for SI
 212         injectSDNCCallbacks(callbacks, "deactivate");
 213         injectSDNCCallbacks(callbacks, "delete");
 214
 215         waitForProcessEnd(businessKey, 10000);
 216
 217         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 218         System.out.println("workflowException:\n" + workflowException);
 219
 220         String completionReq = BPMNUtil.getVariable(processEngineRule, PROCNAME, Prefix + VAR_COMP_REQ);
 221         System.out.println("completionReq:\n" + completionReq);
 222
 223         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, PROCNAME + VAR_SUCCESS_IND));
 224         assertEquals("200", BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_RESP_CODE));
 225         assertEquals(null, workflowException);
 226         assertTrue(completionReq.contains("<request-id>testRequestId<"));
 227         assertTrue(completionReq.contains("<action>DELETE<"));
 228         assertTrue(completionReq.contains("<source>VID<"));
 229
 230         assertEquals("0", BPMNUtil.getVariable(processEngineRule, PROCNAME, Prefix + "vnfsDeletedCount"));
 231
 232         BPMNUtil.assertNoProcessInstance(processEngineRule, "DoDeleteVnfAndModules");
 233     }
 234
 235     @Test
 236     @Deployment(resources = {
 237             "process/DeleteVcpeResCustService.bpmn",
 238             "subprocess/GenericGetService.bpmn",
 239             "subprocess/GenericDeleteService.bpmn",
 240             "subprocess/SDNCAdapterV1.bpmn",
 241             "subprocess/FalloutHandler.bpmn",
 242             "subprocess/DoDeleteServiceInstance.bpmn",
 243             "subprocess/DoDeleteAllottedResourceBRG.bpmn",
 244             "subprocess/DoDeleteAllottedResourceTXC.bpmn",
 245             "subprocess/CompleteMsoProcess.bpmn",
 246
 247             // stubs
 248             "VCPE/stubprocess/DoDeleteVnfAndModules.bpmn"})
 249
 250     public void testDeleteVcpeResCustService_Fault() throws Exception {
 251
 252         MockNodeQueryServiceInstanceById(INST, "GenericFlows/getSIUrlById.xml");
 253
 254         // TODO: use INST instead of DEC_INST
 255                 /*
 256                  * Seems to be a bug in GenericDeleteService (or its subflows) as they
 257                  * fail to URL-encode the SI id before performing the query so we'll
 258                  * add a stub for that case, too.
 259                  */
 260         MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
 261
 262         MockGetServiceInstance(CUST, SVC, INST, "VCPE/DeleteVcpeResCustService/getSIAfterDelArs.xml");
 263
 264         // generate failure
 265         mockSDNCAdapter(404);
 266
 267         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 268
 269         Map<String, Object> variables = setupVariables();
 270
 271         String businessKey = UUID.randomUUID().toString();
 272         invokeAsyncProcess(PROCNAME, "v1", businessKey, request, variables);
 273
 274         waitForProcessEnd(businessKey, 10000);
 275
 276         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 277         System.out.println("workflowException:\n" + workflowException);
 278
 279         String completionReq = BPMNUtil.getVariable(processEngineRule, PROCNAME, Prefix + VAR_COMP_REQ);
 280         System.out.println("completionReq:\n" + completionReq);
 281
 282         assertEquals(null, BPMNUtil.getVariable(processEngineRule, PROCNAME, PROCNAME + VAR_SUCCESS_IND));
 283         assertEquals(null, BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_RESP_CODE));
 284         assertNotNull(workflowException);
 285     }
 286
 287     private Map<String, Object> setupVariables() throws UnsupportedEncodingException {
 288         Map<String, Object> variables = new HashMap<>();
 289         variables.put("isDebugLogEnabled", "true");
 290         variables.put("requestId", "testRequestId");
 291         variables.put("serviceInstanceId", DEC_INST);
 292         variables.put("sdncVersion", "1802");
 293         variables.put("serviceInstanceName", "some-junk-name");
 294         return variables;
 295     }
 296
 297 }