bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DoCreateAllottedResourceTXCRollbackTest.java

   1 /*
   2  * © 2014 AT&T Intellectual Property. All rights reserved. Used under license from AT&T Intellectual Property.
   3  */
   4 package org.openecomp.mso.bpmn.vcpe;
   5
   6 import static org.junit.Assert.assertEquals;
   7 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockDeleteAllottedResource;
   8 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetAllottedResource;
   9 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockPatchAllottedResource;
  10 import static org.openecomp.mso.bpmn.mock.StubResponseDatabase.mockUpdateRequestDB;
  11 import static org.openecomp.mso.bpmn.mock.StubResponseSDNCAdapter.mockSDNCAdapter;
  12
  13 import java.io.IOException;
  14 import java.util.HashMap;
  15 import java.util.Map;
  16 import java.util.UUID;
  17
  18 import org.camunda.bpm.engine.test.Deployment;
  19 import org.junit.Assert;
  20 import org.junit.Test;
  21 import org.openecomp.mso.bpmn.common.BPMNUtil;
  22 import org.openecomp.mso.bpmn.common.WorkflowTest;
  23 import org.openecomp.mso.bpmn.core.RollbackData;
  24 import org.openecomp.mso.bpmn.mock.FileUtil;
  25
  26
  27 public class DoCreateAllottedResourceTXCRollbackTest extends WorkflowTest {
  28
  29         private static final String RbType = "DCARTXC_";
  30         private final CallbackSet callbacks = new CallbackSet();
  31
  32         public DoCreateAllottedResourceTXCRollbackTest() throws IOException {
  33                 callbacks.put("deactivate", FileUtil.readResourceFile("__files/VCPE/VfModularity/SDNCTopologyDeactivateCallback.xml"));
  34                 callbacks.put("delete", FileUtil.readResourceFile("__files/VCPE/VfModularity/SDNCTopologyDeleteCallback.xml"));
  35                 callbacks.put("unassign", FileUtil.readResourceFile("__files/VCPE/VfModularity/SDNCTopologyUnassignCallback.xml"));
  36         }
  37
  38         @Test
  39         @Deployment(resources = {
  40                         "subprocess/SDNCAdapterV1.bpmn",
  41                         "subprocess/FalloutHandler.bpmn",
  42                         "subprocess/DoCreateAllottedResourceTXCRollback.bpmn"})
  43         public void testDoCreateAllottedResourceTXCRollback_success() throws Exception{
  44
  45                 MockGetAllottedResource("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "arId-1", "VCPE/DoCreateAllottedResourceTXCRollback/arGetById.xml");
  46                 MockPatchAllottedResource("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "arId-1");
  47                 MockDeleteAllottedResource("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "arId-1", "1490627351232");
  48                 mockSDNCAdapter(200);
  49                 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
  50
  51                 String businessKey = UUID.randomUUID().toString();
  52                 Map<String, Object> variables = new HashMap<>();
  53                 setVariablesSuccess(variables, "testRequestId1");
  54
  55                 invokeSubProcess("DoCreateAllottedResourceTXCRollback", businessKey, variables);
  56
  57                 injectSDNCCallbacks(callbacks, "deactivate");
  58                 injectSDNCCallbacks(callbacks, "delete");
  59                 injectSDNCCallbacks(callbacks, "unassign");
  60
  61                 waitForProcessEnd(businessKey, 10000);
  62
  63                 Assert.assertTrue(isProcessEnded(businessKey));
  64                 String workflowException = BPMNUtil.getVariable(processEngineRule, "DoCreateAllottedResourceTXCRollback", "WorkflowException");
  65                 System.out.println("workflowException:\n" + workflowException);
  66                 assertEquals(null, workflowException);
  67         }
  68
  69         private void setVariablesSuccess(Map<String, Object> variables, String requestId) {
  70                 variables.put("isDebugLogEnabled", "true");
  71                 variables.put("failNotFound", "true");
  72                 variables.put("msoRequestId", requestId);
  73                 variables.put("mso-request-id", "requestId");
  74                 variables.put("allottedResourceId", "arId-1");
  75
  76                 variables.put("serviceInstanceId", "MIS%252F1604%252F0026%252FSW_INTERNET");
  77                 variables.put("parentServiceInstanceId","MIS%252F1604%252F0026%252FSW_INTERNET");
  78                 RollbackData rollbackData = new RollbackData();
  79
  80                 rollbackData.put(RbType, "serviceInstanceId", "MIS%252F1604%252F0026%252FSW_INTERNET");
  81                 rollbackData.put(RbType, "serviceSubscriptionType", "123456789");
  82                 rollbackData.put(RbType, "disablerollback", "false");
  83                 rollbackData.put(RbType, "rollbackAAI", "true");
  84                 rollbackData.put(RbType, "rollbackSDNCassign", "true");
  85                 rollbackData.put(RbType, "rollbackSDNCactivate", "true");
  86                 rollbackData.put(RbType, "rollbackSDNCcreate", "true");
  87                 rollbackData.put(RbType, "aaiARPath", "http://localhost:28090/aai/v9/business/customers/customer/SDN-ETHERNET-INTERNET/service-subscriptions/service-subscription/123456789/service-instances/service-instance/MIS%252F1604%252F0026%252FSW_INTERNET/allotted-resources/allotted-resource/arId-1");
  88
  89                 rollbackData.put(RbType, "sdncActivateRollbackReq", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceTXCRollback/sdncActivateRollbackReq.xml"));
  90                 rollbackData.put(RbType, "sdncCreateRollbackReq", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceTXCRollback/sdncCreateRollbackReq.xml"));
  91                 rollbackData.put(RbType, "sdncAssignRollbackReq", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceTXCRollback/sdncAssignRollbackReq.xml"));
  92
  93                 variables.put("rollbackData",rollbackData);
  94         }
  95
  96 }