gerrit.onap Code Review - so.git/blob

   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 org.junit.Assert.assertEquals;
  23 import static org.junit.Assert.assertNotNull;
  24 import static org.junit.Assert.assertNull;
  25 import static org.junit.Assert.assertTrue;
  26 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockDeleteAllottedResource;
  27 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetAllottedResource;
  28 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockPatchAllottedResource;
  29 import static org.openecomp.mso.bpmn.mock.StubResponseDatabase.mockUpdateRequestDB;
  30 import static org.openecomp.mso.bpmn.mock.StubResponseSDNCAdapter.mockSDNCAdapter;
  31
  32 import java.io.IOException;
  33 import java.util.HashMap;
  34 import java.util.Map;
  35 import java.util.UUID;
  36
  37 import org.camunda.bpm.engine.test.Deployment;
  38 import org.junit.Test;
  39 import org.openecomp.mso.bpmn.common.BPMNUtil;
  40 import org.openecomp.mso.bpmn.core.RollbackData;
  41 import org.openecomp.mso.bpmn.mock.FileUtil;
  42
  43
  44 public class DoCreateAllottedResourceBRGRollbackTest extends AbstractTestBase {
  45
  46     private static final String PROCNAME = "DoCreateAllottedResourceBRGRollback";
  47     private static final String RbType = "DCARBRG_";
  48     private final CallbackSet callbacks = new CallbackSet();
  49
  50     public DoCreateAllottedResourceBRGRollbackTest() throws IOException {
  51         callbacks.put("deactivate", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyDeactivateCallback.xml"));
  52         callbacks.put("delete", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyDeleteCallback.xml"));
  53         callbacks.put("unassign", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyUnassignCallback.xml"));
  54     }
  55
  56     @Test
  57     @Deployment(resources = {
  58             "subprocess/SDNCAdapterV1.bpmn",
  59             "subprocess/FalloutHandler.bpmn",
  60             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
  61     public void testDoCreateAllottedResourceBRGRollback_Success() throws Exception {
  62
  63         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
  64         MockPatchAllottedResource(CUST, SVC, INST, ARID);
  65         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
  66         mockSDNCAdapter(200);
  67         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
  68
  69         String businessKey = UUID.randomUUID().toString();
  70         Map<String, Object> variables = new HashMap<>();
  71         setVariablesSuccess(variables, "testRequestId1");
  72
  73         invokeSubProcess(PROCNAME, businessKey, variables);
  74
  75         injectSDNCCallbacks(callbacks, "deactivate");
  76         injectSDNCCallbacks(callbacks, "delete");
  77         injectSDNCCallbacks(callbacks, "unassign");
  78
  79         waitForProcessEnd(businessKey, 10000);
  80
  81         assertTrue(isProcessEnded(businessKey));
  82         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
  83         System.out.println("workflowException:\n" + workflowException);
  84         assertEquals(null, workflowException);
  85         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
  86         assertNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
  87     }
  88
  89     @Test
  90     @Deployment(resources = {
  91             "subprocess/SDNCAdapterV1.bpmn",
  92             "subprocess/FalloutHandler.bpmn",
  93             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
  94     public void testDoCreateAllottedResourceBRGRollback_skipRollback() throws Exception {
  95
  96         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
  97         MockPatchAllottedResource(CUST, SVC, INST, ARID);
  98         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
  99         mockSDNCAdapter(200);
 100         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 101
 102         String businessKey = UUID.randomUUID().toString();
 103         Map<String, Object> variables = new HashMap<>();
 104         RollbackData rollbackData = setVariablesSuccess(variables, "testRequestId1");
 105
 106         rollbackData.put(RbType, "rollbackAAI", "false");
 107         rollbackData.put(RbType, "rollbackSDNCassign", "false");
 108
 109         invokeSubProcess(PROCNAME, businessKey, variables);
 110
 111         waitForProcessEnd(businessKey, 10000);
 112
 113         assertTrue(isProcessEnded(businessKey));
 114         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 115         System.out.println("workflowException:\n" + workflowException);
 116         assertEquals(null, workflowException);
 117         assertEquals(null, BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 118         assertNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 119     }
 120
 121     @Test
 122     @Deployment(resources = {
 123             "subprocess/SDNCAdapterV1.bpmn",
 124             "subprocess/FalloutHandler.bpmn",
 125             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 126     public void testDoCreateAllottedResourceBRGRollback_DoNotRollBack() throws Exception {
 127
 128         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 129
 130         String businessKey = UUID.randomUUID().toString();
 131         Map<String, Object> variables = new HashMap<>();
 132         RollbackData rollbackData = setVariablesSuccess(variables, "testRequestId1");
 133
 134         // this will cause "rollbackSDNC" to be set to false
 135         rollbackData.put(RbType, "rollbackSDNCassign", "false");
 136
 137         invokeSubProcess(PROCNAME, businessKey, variables);
 138
 139         waitForProcessEnd(businessKey, 10000);
 140
 141         assertTrue(isProcessEnded(businessKey));
 142         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 143         System.out.println("workflowException:\n" + workflowException);
 144         assertEquals(null, workflowException);
 145         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 146         assertNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 147     }
 148
 149     @Test
 150     @Deployment(resources = {
 151             "subprocess/SDNCAdapterV1.bpmn",
 152             "subprocess/FalloutHandler.bpmn",
 153             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 154     public void testDoCreateAllottedResourceBRGRollback_NoDeactivate() throws Exception {
 155
 156         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
 157         MockPatchAllottedResource(CUST, SVC, INST, ARID);
 158         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
 159         mockSDNCAdapter(200);
 160         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 161
 162         String businessKey = UUID.randomUUID().toString();
 163         Map<String, Object> variables = new HashMap<>();
 164         RollbackData rollbackData = setVariablesSuccess(variables, "testRequestId1");
 165
 166         rollbackData.put(RbType, "rollbackSDNCactivate", "false");
 167
 168         invokeSubProcess(PROCNAME, businessKey, variables);
 169
 170         injectSDNCCallbacks(callbacks, "delete");
 171         injectSDNCCallbacks(callbacks, "unassign");
 172
 173         waitForProcessEnd(businessKey, 10000);
 174
 175         assertTrue(isProcessEnded(businessKey));
 176         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 177         System.out.println("workflowException:\n" + workflowException);
 178         assertEquals(null, workflowException);
 179         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 180         assertNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 181     }
 182
 183     @Test
 184     @Deployment(resources = {
 185             "subprocess/SDNCAdapterV1.bpmn",
 186             "subprocess/FalloutHandler.bpmn",
 187             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 188     public void testDoCreateAllottedResourceBRGRollback_NoDelete() throws Exception {
 189
 190         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
 191         MockPatchAllottedResource(CUST, SVC, INST, ARID);
 192         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
 193         mockSDNCAdapter(200);
 194         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 195
 196         String businessKey = UUID.randomUUID().toString();
 197         Map<String, Object> variables = new HashMap<>();
 198         RollbackData rollbackData = setVariablesSuccess(variables, "testRequestId1");
 199
 200         rollbackData.put(RbType, "rollbackSDNCcreate", "false");
 201
 202         invokeSubProcess(PROCNAME, businessKey, variables);
 203
 204         injectSDNCCallbacks(callbacks, "deactivate");
 205         injectSDNCCallbacks(callbacks, "unassign");
 206
 207         waitForProcessEnd(businessKey, 10000);
 208
 209         assertTrue(isProcessEnded(businessKey));
 210         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 211         System.out.println("workflowException:\n" + workflowException);
 212         assertEquals(null, workflowException);
 213         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 214         assertNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 215     }
 216
 217     @Test
 218     @Deployment(resources = {
 219             "subprocess/SDNCAdapterV1.bpmn",
 220             "subprocess/FalloutHandler.bpmn",
 221             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 222     public void testDoCreateAllottedResourceBRGRollback_NoUnassign() throws Exception {
 223
 224         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
 225         MockPatchAllottedResource(CUST, SVC, INST, ARID);
 226         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
 227         mockSDNCAdapter(200);
 228         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 229
 230         String businessKey = UUID.randomUUID().toString();
 231         Map<String, Object> variables = new HashMap<>();
 232         RollbackData rollbackData = setVariablesSuccess(variables, "testRequestId1");
 233
 234         rollbackData.put(RbType, "rollbackSDNCassign", "false");
 235
 236                 /*
 237                  * Note: if assign == false then the flow/script will set
 238                  * "skipRollback" to false, which will cause ALL of the SDNC steps
 239                  * to be skipped, not just the unassign step.
 240                  */
 241
 242         invokeSubProcess(PROCNAME, businessKey, variables);
 243
 244         waitForProcessEnd(businessKey, 10000);
 245
 246         assertTrue(isProcessEnded(businessKey));
 247         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 248         System.out.println("workflowException:\n" + workflowException);
 249         assertEquals(null, workflowException);
 250         assertEquals("true", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 251         assertNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 252     }
 253
 254     @Test
 255     @Deployment(resources = {
 256             "subprocess/SDNCAdapterV1.bpmn",
 257             "subprocess/FalloutHandler.bpmn",
 258             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 259     public void testDoCreateAllottedResourceBRGRollback_SubProcessError() throws Exception {
 260
 261         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
 262         MockPatchAllottedResource(CUST, SVC, INST, ARID);
 263         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
 264         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 265
 266         mockSDNCAdapter(404);
 267
 268         String businessKey = UUID.randomUUID().toString();
 269         Map<String, Object> variables = new HashMap<>();
 270         setVariablesSuccess(variables, "testRequestId1");
 271
 272         invokeSubProcess(PROCNAME, businessKey, variables);
 273
 274         waitForProcessEnd(businessKey, 10000);
 275
 276         assertTrue(isProcessEnded(businessKey));
 277         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 278         System.out.println("workflowException:\n" + workflowException);
 279         assertEquals(null, workflowException);
 280         assertEquals("false", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 281         assertNotNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 282     }
 283
 284     @Test
 285     @Deployment(resources = {
 286             "subprocess/SDNCAdapterV1.bpmn",
 287             "subprocess/FalloutHandler.bpmn",
 288             "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 289     public void testDoCreateAllottedResourceBRGRollback_JavaException() throws Exception {
 290
 291         MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRGRollback/arGetById.xml");
 292         MockPatchAllottedResource(CUST, SVC, INST, ARID);
 293         MockDeleteAllottedResource(CUST, SVC, INST, ARID, ARVERS);
 294         mockSDNCAdapter(200);
 295         mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 296
 297         String businessKey = UUID.randomUUID().toString();
 298         Map<String, Object> variables = new HashMap<>();
 299         setVariablesSuccess(variables, "testRequestId1");
 300
 301         variables.put("rollbackData", "string instead of rollback data");
 302
 303         invokeSubProcess(PROCNAME, businessKey, variables);
 304
 305         waitForProcessEnd(businessKey, 10000);
 306
 307         assertTrue(isProcessEnded(businessKey));
 308         String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 309         System.out.println("workflowException:\n" + workflowException);
 310         assertEquals(null, workflowException);
 311         assertEquals("false", BPMNUtil.getVariable(processEngineRule, PROCNAME, "rolledBack"));
 312         assertNotNull(BPMNUtil.getVariable(processEngineRule, PROCNAME, "rollbackError"));
 313     }
 314
 315     private RollbackData setVariablesSuccess(Map<String, Object> variables, String requestId) {
 316         variables.put("isDebugLogEnabled", "true");
 317         variables.put("failNotFound", "true");
 318         variables.put("msoRequestId", requestId);
 319         variables.put("mso-request-id", "requestId");
 320         variables.put("allottedResourceId", ARID);
 321
 322         variables.put("serviceInstanceId", DEC_INST);
 323         variables.put("parentServiceInstanceId", DEC_PARENT_INST);
 324
 325         RollbackData rollbackData = new RollbackData();
 326
 327         rollbackData.put(RbType, "serviceInstanceId", DEC_INST);
 328         rollbackData.put(RbType, "serviceSubscriptionType", SVC);
 329         rollbackData.put(RbType, "disablerollback", "false");
 330         rollbackData.put(RbType, "rollbackAAI", "true");
 331         rollbackData.put(RbType, "rollbackSDNCassign", "true");
 332         rollbackData.put(RbType, "rollbackSDNCactivate", "true");
 333         rollbackData.put(RbType, "rollbackSDNCcreate", "true");
 334         rollbackData.put(RbType, "aaiARPath", "http://localhost:28090/aai/v9/business/customers/customer/" + CUST + "/service-subscriptions/service-subscription/" + SVC + "/service-instances/service-instance/" + INST + "/allotted-resources/allotted-resource/" + ARID);
 335
 336         rollbackData.put(RbType, "sdncActivateRollbackReq", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceBRGRollback/sdncActivateRollbackReq.xml"));
 337         rollbackData.put(RbType, "sdncCreateRollbackReq", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceBRGRollback/sdncCreateRollbackReq.xml"));
 338         rollbackData.put(RbType, "sdncAssignRollbackReq", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceBRGRollback/sdncAssignRollbackReq.xml"));
 339
 340         variables.put("rollbackData", rollbackData);
 341
 342         return rollbackData;
 343     }
 344
 345 }