bpmn/MSOInfrastructureBPMN/src/test/java/org/openecomp/mso/bpmn/vcpe/DoCreateAllottedResourceBRGTest.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 org.junit.Assert.assertEquals;
  23 import static org.junit.Assert.assertNotNull;
  24 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetAllottedResource;
  25 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetServiceInstance;
  26 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockNodeQueryServiceInstanceById;
  27 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockPatchAllottedResource;
  28 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockPutAllottedResource;
  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.Assert;
  39 import org.junit.Test;
  40 import org.openecomp.mso.bpmn.common.BPMNUtil;
  41 import org.openecomp.mso.bpmn.mock.FileUtil;
  42
  43
  44 public class DoCreateAllottedResourceBRGTest extends AbstractTestBase {
  45
  46         private static final String PROCNAME = "DoCreateAllottedResourceBRG";
  47         private final CallbackSet callbacks = new CallbackSet();
  48
  49         public DoCreateAllottedResourceBRGTest() throws IOException {
  50                 callbacks.put("assign", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyAssignCallback.xml"));
  51                 callbacks.put("create", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyCreateCallback.xml"));
  52                 callbacks.put("activate", FileUtil.readResourceFile("__files/VfModularity/SDNCTopologyActivateCallback.xml"));
  53                 callbacks.put("query", FileUtil.readResourceFile("__files/VCPE/DoCreateAllottedResourceBRG/SDNCTopologyQueryCallback.xml"));
  54         }
  55
  56         @Test
  57         @Deployment(resources = {
  58                         "subprocess/GenericGetService.bpmn",
  59                         "subprocess/SDNCAdapterV1.bpmn",
  60                         "subprocess/FalloutHandler.bpmn",
  61                         "subprocess/DoCreateAllottedResourceBRG.bpmn",
  62                         "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
  63         public void testDoCreateAllottedResourceBRG_Success() throws Exception{
  64
  65                 // TODO: use INST instead of DEC_INST
  66                 /*
  67                  * should be INST instead of DEC_INST, but AAI utilities appear to
  68                  * have a bug in that they don't URL-encode the SI id before using
  69                  * it in the query
  70                  */
  71                 MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
  72                 MockNodeQueryServiceInstanceById(DEC_PARENT_INST, "GenericFlows/getParentSIUrlById.xml");
  73
  74                 MockGetServiceInstance(CUST, SVC, INST, "GenericFlows/getServiceInstance.xml");
  75                 MockGetServiceInstance(CUST, SVC, PARENT_INST, "GenericFlows/getParentServiceInstance.xml");
  76                 MockPutAllottedResource(CUST, SVC, PARENT_INST, ARID);
  77                 MockPatchAllottedResource(CUST, SVC, PARENT_INST, ARID);
  78                 mockSDNCAdapter(200);
  79                 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
  80
  81                 String businessKey = UUID.randomUUID().toString();
  82                 Map<String, Object> variables = new HashMap<>();
  83                 setVariablesSuccess(variables, "testRequestId123");
  84
  85                 invokeSubProcess(PROCNAME, businessKey, variables);
  86
  87                 injectSDNCCallbacks(callbacks, "assign");
  88                 injectSDNCCallbacks(callbacks, "create");
  89                 injectSDNCCallbacks(callbacks, "activate");
  90                 injectSDNCCallbacks(callbacks, "query");
  91
  92                 waitForProcessEnd(businessKey, 10000);
  93
  94                 Assert.assertTrue(isProcessEnded(businessKey));
  95                 String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
  96                 assertEquals(null, workflowException);
  97
  98                 assertEquals("namefromrequest", BPMNUtil.getVariable(processEngineRule, PROCNAME, "allotedResourceName"));
  99         }
 100
 101         @Test
 102         @Deployment(resources = {
 103                         "subprocess/GenericGetService.bpmn",
 104                         "subprocess/SDNCAdapterV1.bpmn",
 105                         "subprocess/FalloutHandler.bpmn",
 106                         "subprocess/DoCreateAllottedResourceBRG.bpmn",
 107                         "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 108         public void testDoCreateAllottedResourceBRG_NoSI() throws Exception{
 109
 110                 // TODO: use INST instead of DEC_INST
 111                 /*
 112                  * should be INST instead of DEC_INST, but AAI utilities appear to
 113                  * have a bug in that they don't URL-encode the SI id before using
 114                  * it in the query
 115                  */
 116                 MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getNotFound.xml");
 117                 MockNodeQueryServiceInstanceById(DEC_PARENT_INST, "GenericFlows/getParentSIUrlById.xml");
 118
 119                 MockGetServiceInstance(CUST, SVC, INST, "GenericFlows/getServiceInstance.xml");
 120                 MockGetServiceInstance(CUST, SVC, PARENT_INST, "GenericFlows/getParentServiceInstance.xml");
 121                 MockPutAllottedResource(CUST, SVC, PARENT_INST, ARID);
 122                 MockPatchAllottedResource(CUST, SVC, PARENT_INST, ARID);
 123                 mockSDNCAdapter(200);
 124                 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 125
 126                 String businessKey = UUID.randomUUID().toString();
 127                 Map<String, Object> variables = new HashMap<>();
 128                 setVariablesSuccess(variables, "testRequestId123");
 129
 130                 invokeSubProcess(PROCNAME, businessKey, variables);
 131
 132                 waitForProcessEnd(businessKey, 10000);
 133
 134                 Assert.assertTrue(isProcessEnded(businessKey));
 135                 String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 136                 assertNotNull(workflowException);
 137
 138                 assertEquals(null, BPMNUtil.getVariable(processEngineRule, PROCNAME, "allotedResourceName"));
 139         }
 140
 141         @Test
 142         @Deployment(resources = {
 143                         "subprocess/GenericGetService.bpmn",
 144                         "subprocess/SDNCAdapterV1.bpmn",
 145                         "subprocess/FalloutHandler.bpmn",
 146                         "subprocess/DoCreateAllottedResourceBRG.bpmn",
 147                         "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 148         public void testDoCreateAllottedResourceBRG_ActiveAr() throws Exception{
 149
 150                 // TODO: use INST instead of DEC_INST
 151                 /*
 152                  * should be INST instead of DEC_INST, but AAI utilities appear to
 153                  * have a bug in that they don't URL-encode the SI id before using
 154                  * it in the query
 155                  */
 156                 MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
 157                 MockNodeQueryServiceInstanceById(DEC_PARENT_INST, "GenericFlows/getParentSIUrlById.xml");
 158
 159                 MockGetServiceInstance(CUST, SVC, INST, "VCPE/DoCreateAllottedResourceBRG/getSIandAR.xml");
 160                 MockGetAllottedResource(CUST, SVC, INST, ARID, "VCPE/DoCreateAllottedResourceBRG/getArBrg2.xml");
 161                 MockGetServiceInstance(CUST, SVC, PARENT_INST, "GenericFlows/getParentServiceInstance.xml");
 162                 MockPutAllottedResource(CUST, SVC, PARENT_INST, ARID);
 163                 MockPatchAllottedResource(CUST, SVC, PARENT_INST, ARID);
 164                 mockSDNCAdapter(200);
 165                 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 166
 167                 String businessKey = UUID.randomUUID().toString();
 168                 Map<String, Object> variables = new HashMap<>();
 169                 setVariablesSuccess(variables, "testRequestId123");
 170
 171                 variables.put("failExists", "false");
 172
 173                 invokeSubProcess(PROCNAME, businessKey, variables);
 174
 175                 injectSDNCCallbacks(callbacks, "query");
 176
 177                 waitForProcessEnd(businessKey, 10000);
 178
 179                 Assert.assertTrue(isProcessEnded(businessKey));
 180                 String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 181                 assertEquals(null, workflowException);
 182
 183                 assertEquals("namefromrequest", BPMNUtil.getVariable(processEngineRule, PROCNAME, "allotedResourceName"));
 184         }
 185
 186         @Test
 187         @Deployment(resources = {
 188                         "subprocess/GenericGetService.bpmn",
 189                         "subprocess/SDNCAdapterV1.bpmn",
 190                         "subprocess/FalloutHandler.bpmn",
 191                         "subprocess/DoCreateAllottedResourceBRG.bpmn",
 192                         "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 193         public void testDoCreateAllottedResourceBRG_NoParentSI() throws Exception{
 194
 195                 // TODO: use INST instead of DEC_INST
 196                 /*
 197                  * should be INST instead of DEC_INST, but AAI utilities appear to
 198                  * have a bug in that they don't URL-encode the SI id before using
 199                  * it in the query
 200                  */
 201                 MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
 202                 MockNodeQueryServiceInstanceById(DEC_PARENT_INST, "GenericFlows/getNotFound.xml");
 203
 204                 MockGetServiceInstance(CUST, SVC, INST, "GenericFlows/getServiceInstance.xml");
 205                 MockGetServiceInstance(CUST, SVC, PARENT_INST, "GenericFlows/getParentServiceInstance.xml");
 206                 MockPutAllottedResource(CUST, SVC, PARENT_INST, ARID);
 207                 MockPatchAllottedResource(CUST, SVC, PARENT_INST, ARID);
 208                 mockSDNCAdapter(200);
 209                 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 210
 211                 String businessKey = UUID.randomUUID().toString();
 212                 Map<String, Object> variables = new HashMap<>();
 213                 setVariablesSuccess(variables, "testRequestId123");
 214
 215                 invokeSubProcess(PROCNAME, businessKey, variables);
 216
 217                 waitForProcessEnd(businessKey, 10000);
 218
 219                 Assert.assertTrue(isProcessEnded(businessKey));
 220                 String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 221                 assertNotNull(workflowException);
 222
 223                 assertEquals(null, BPMNUtil.getVariable(processEngineRule, PROCNAME, "allotedResourceName"));
 224         }
 225
 226         @Test
 227         @Deployment(resources = {
 228                         "subprocess/GenericGetService.bpmn",
 229                         "subprocess/SDNCAdapterV1.bpmn",
 230                         "subprocess/FalloutHandler.bpmn",
 231                         "subprocess/DoCreateAllottedResourceBRG.bpmn",
 232                         "subprocess/DoCreateAllottedResourceBRGRollback.bpmn"})
 233         public void testDoCreateAllottedResourceBRG_SubProcessError() throws Exception{
 234
 235                 // TODO: use INST instead of DEC_INST
 236                 /*
 237                  * should be INST instead of DEC_INST, but AAI utilities appear to
 238                  * have a bug in that they don't URL-encode the SI id before using
 239                  * it in the query
 240                  */
 241                 MockNodeQueryServiceInstanceById(DEC_INST, "GenericFlows/getSIUrlById.xml");
 242                 MockNodeQueryServiceInstanceById(DEC_PARENT_INST, "GenericFlows/getParentSIUrlById.xml");
 243
 244                 MockGetServiceInstance(CUST, SVC, INST, "GenericFlows/getServiceInstance.xml");
 245                 MockGetServiceInstance(CUST, SVC, PARENT_INST, "GenericFlows/getParentServiceInstance.xml");
 246                 MockPutAllottedResource(CUST, SVC, PARENT_INST, ARID);
 247                 MockPatchAllottedResource(CUST, SVC, PARENT_INST, ARID);
 248                 mockSDNCAdapter(404);
 249                 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
 250
 251                 String businessKey = UUID.randomUUID().toString();
 252                 Map<String, Object> variables = new HashMap<>();
 253                 setVariablesSuccess(variables, "testRequestId123");
 254
 255                 invokeSubProcess(PROCNAME, businessKey, variables);
 256
 257                 waitForProcessEnd(businessKey, 10000);
 258
 259                 Assert.assertTrue(isProcessEnded(businessKey));
 260                 String workflowException = BPMNUtil.getVariable(processEngineRule, PROCNAME, VAR_WFEX);
 261                 assertNotNull(workflowException);
 262
 263                 assertEquals(null, BPMNUtil.getVariable(processEngineRule, PROCNAME, "allotedResourceName"));
 264         }
 265
 266         private void setVariablesSuccess(Map<String, Object> variables, String requestId) {
 267                 variables.put("isDebugLogEnabled", "true");
 268                 variables.put("failExists", "true");
 269                 variables.put("disableRollback", "true");
 270                 variables.put("msoRequestId", requestId);
 271                 variables.put("mso-request-id", "requestId");
 272                 variables.put("sourceNetworkId", "snId");
 273                 variables.put("sourceNetworkRole", "snRole");
 274                 variables.put("allottedResourceRole", "txc");
 275                 variables.put("allottedResourceType", "BRG");
 276                 variables.put("allottedResourceId", ARID);
 277                 variables.put("vni", "BRG");
 278                 variables.put("vgmuxBearerIP", "bearerip");
 279                 variables.put("brgWanMacAddress", "wanmac");
 280
 281                 variables.put("serviceInstanceId", DEC_INST);
 282                 variables.put("parentServiceInstanceId", DEC_PARENT_INST);
 283
 284                 variables.put("serviceChainServiceInstanceId", "scsiId");
 285
 286                 String arModelInfo = "{ "+ "\"modelType\": \"allotted-resource\"," +
 287                                 "\"modelInvariantUuid\": \"ff5256d2-5a33-55df-13ab-12abad84e7ff\"," +
 288                                 "\"modelUuid\": \"fe6478e5-ea33-3346-ac12-ab121484a3fe\"," +
 289                                 "\"modelName\": \"vSAMP12\"," +
 290                                 "\"modelVersion\": \"1.0\"," +
 291                                 "\"modelCustomizationUuid\": \"MODEL-ID-1234\"," +
 292                                 "}";
 293                 variables.put("allottedResourceModelInfo", arModelInfo);
 294         }
 295
 296 }