bpmn/MSOCommonBPMN/src/test/java/org/openecomp/mso/bpmn/common/HomingTest.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
  21 /*
  22  * © 2014 AT&T Intellectual Property. All rights reserved. Used under license from AT&T Intellectual Property.
  23  */
  24 package org.openecomp.mso.bpmn.common;
  25
  26 import static org.openecomp.mso.bpmn.mock.StubResponseDatabase.MockGetServiceResourcesCatalogDataByModelUuid;
  27 import static org.openecomp.mso.bpmn.mock.StubResponseSNIRO.*;
  28 import static org.junit.Assert.*;
  29
  30 import java.io.IOException;
  31 import java.util.ArrayList;
  32 import java.util.HashMap;
  33 import java.util.List;
  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
  40 import org.openecomp.mso.bpmn.core.WorkflowException;
  41 import org.openecomp.mso.bpmn.core.domain.*;
  42
  43 import org.openecomp.mso.bpmn.mock.FileUtil;
  44 import org.openecomp.mso.bpmn.common.WorkflowTest;
  45
  46
  47 /**
  48  * Test the Homing subflow building block.
  49  *
  50  * @author cb645j
  51  */
  52 public class HomingTest extends WorkflowTest {
  53
  54         ServiceDecomposition serviceDecomposition = new ServiceDecomposition();
  55         String subscriber = "";
  56         String subscriber2 = "";
  57
  58         private final CallbackSet callbacks = new CallbackSet();
  59
  60         public HomingTest() throws IOException {
  61                 String sniroCallback = FileUtil.readResourceFile("__files/BuildingBlocks/sniroCallback2AR1Vnf");
  62                 String sniroCallback2 = FileUtil.readResourceFile("__files/BuildingBlocks/sniroCallback2AR1Vnf2Net");
  63                 String sniroCallback3 = FileUtil.readResourceFile("__files/BuildingBlocks/sniroCallbackInfraVnf");
  64                 String sniroCallbackNoSolution = FileUtil.readResourceFile("__files/BuildingBlocks/sniroCallbackNoSolutionFound");
  65                 String sniroCallbackPolicyException = FileUtil.readResourceFile("__files/BuildingBlocks/sniroCallbackPolicyException");
  66                 String sniroCallbackServiceException = FileUtil.readResourceFile("__files/BuildingBlocks/sniroCallbackServiceException");
  67                 callbacks.put("sniro", JSON, "SNIROResponse", sniroCallback);
  68                 callbacks.put("sniro2", JSON, "SNIROResponse", sniroCallback2);
  69                 callbacks.put("sniro3", JSON, "SNIROResponse", sniroCallback3);
  70                 callbacks.put("sniroNoSol", JSON, "SNIROResponse", sniroCallbackNoSolution);
  71                 callbacks.put("sniroPolicyEx", JSON, "SNIROResponse", sniroCallbackPolicyException);
  72                 callbacks.put("sniroServiceEx", JSON, "SNIROResponse", sniroCallbackServiceException);
  73
  74                 // Service Model
  75                 ModelInfo sModel = new ModelInfo();
  76                 sModel.setModelCustomizationUuid("testModelCustomizationUuid");
  77                 sModel.setModelInstanceName("testModelInstanceName");
  78                 sModel.setModelInvariantUuid("testModelInvariantId");
  79                 sModel.setModelName("testModelName");
  80                 sModel.setModelUuid("testModelUuid");
  81                 sModel.setModelVersion("testModelVersion");
  82                 // Service Instance
  83                 ServiceInstance si = new ServiceInstance();
  84                 si.setInstanceId("testServiceInstanceId123");
  85                 // Allotted Resources
  86                 List<AllottedResource> arList = new ArrayList<AllottedResource>();
  87                 AllottedResource ar = new AllottedResource();
  88                 ar.setResourceId("testResourceIdAR");
  89                 ar.setResourceInstanceName("testARInstanceName");
  90                 ModelInfo arModel = new ModelInfo();
  91                 arModel.setModelCustomizationUuid("testModelCustomizationUuidAR");
  92                 arModel.setModelInvariantUuid("testModelInvariantIdAR");
  93                 arModel.setModelName("testModelNameAR");
  94                 arModel.setModelVersion("testModelVersionAR");
  95                 arModel.setModelUuid("testARModelUuid");
  96                 arModel.setModelType("testModelTypeAR");
  97                 ar.setModelInfo(arModel);
  98                 AllottedResource ar2 = new AllottedResource();
  99                 ar2.setResourceId("testResourceIdAR2");
 100                 ar2.setResourceInstanceName("testAR2InstanceName");
 101                 ModelInfo arModel2 = new ModelInfo();
 102                 arModel2.setModelCustomizationUuid("testModelCustomizationUuidAR2");
 103                 arModel2.setModelInvariantUuid("testModelInvariantIdAR2");
 104                 arModel2.setModelName("testModelNameAR2");
 105                 arModel2.setModelVersion("testModelVersionAR2");
 106                 arModel2.setModelUuid("testAr2ModelUuid");
 107                 arModel2.setModelType("testModelTypeAR2");
 108                 ar2.setModelInfo(arModel2);
 109                 arList.add(ar);
 110                 arList.add(ar2);
 111                 // Vnfs
 112                 List<VnfResource> vnfList = new ArrayList<VnfResource>();
 113                 VnfResource vnf = new VnfResource();
 114                 vnf.setResourceId("testResourceIdVNF");
 115                 vnf.setResourceInstanceName("testVnfInstanceName");
 116                 ModelInfo vnfModel = new ModelInfo();
 117                 vnfModel.setModelCustomizationUuid("testModelCustomizationUuidVNF");
 118                 vnfModel.setModelInvariantUuid("testModelInvariantIdVNF");
 119                 vnfModel.setModelName("testModelNameVNF");
 120                 vnfModel.setModelVersion("testModelVersionVNF");
 121                 vnfModel.setModelUuid("testVnfModelUuid");
 122                 vnfModel.setModelType("testModelTypeVNF");
 123                 vnf.setModelInfo(vnfModel);
 124                 vnfList.add(vnf);
 125                 System.out.println("SERVICE DECOMP: " + serviceDecomposition.getServiceResourcesJsonString());
 126                 serviceDecomposition.setModelInfo(sModel);
 127                 serviceDecomposition.setServiceAllottedResources(arList);
 128                 serviceDecomposition.setServiceVnfs(vnfList);
 129                 serviceDecomposition.setServiceInstance(si);
 130
 131                 // Subscriber
 132                 subscriber = "{\"globalSubscriberId\": \"SUB12_0322_DS_1201\",\"subscriberCommonSiteId\": \"DALTX0101\",\"subscriberName\": \"SUB_12_0322_DS_1201\"}";
 133                 subscriber2 = "{\"globalSubscriberId\": \"SUB12_0322_DS_1201\",\"subscriberName\": \"SUB_12_0322_DS_1201\"}";
 134         }
 135
 136         @Test
 137         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 138         public void testHoming_success_2AR1Vnf() throws Exception {
 139
 140                 mockSNIRO();
 141
 142                 String businessKey = UUID.randomUUID().toString();
 143                 Map<String, Object> variables = new HashMap<>();
 144                 setVariables(variables);
 145
 146                 invokeSubProcess("Homing", businessKey, variables);
 147
 148                 injectWorkflowMessages(callbacks, "sniro");
 149
 150                 waitForProcessEnd(businessKey, 10000);
 151
 152                 //Get Variables
 153                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 154                 ServiceDecomposition serviceDecompositionExp = (ServiceDecomposition) getVariableFromHistory(businessKey, "serviceDecomposition");
 155                 String expectedSniroRequest = (String) getVariableFromHistory(businessKey, "sniroRequest");
 156
 157                 Resource resourceAR = serviceDecompositionExp.getServiceResource("testResourceIdAR");
 158                 HomingSolution resourceARHoming = resourceAR.getHomingSolution();
 159                 Resource resourceAR2 = serviceDecompositionExp.getServiceResource("testResourceIdAR2");
 160                 HomingSolution resourceARHoming2 = resourceAR2.getHomingSolution();
 161                 Resource resourceVNF = serviceDecompositionExp.getServiceResource("testResourceIdVNF");
 162                 HomingSolution resourceVNFHoming = resourceVNF.getHomingSolution();
 163                 String resourceARHomingString = resourceARHoming.toString();
 164                 resourceARHomingString = resourceARHomingString.replaceAll("\\s+", " ");
 165                 String resourceARHoming2String = resourceARHoming2.toString();
 166                 resourceARHoming2String = resourceARHoming2String.replaceAll("\\s+", " ");
 167                 String resourceVNFHomingString = resourceVNFHoming.toString();
 168                 resourceVNFHomingString = resourceVNFHomingString.replaceAll("\\s+", " ");
 169                 expectedSniroRequest = expectedSniroRequest.replaceAll("\\s+", "");
 170
 171                 assertNull(workflowException);
 172                 assertEquals(homingSolutionService("service", "testSIID1", "MDTNJ01", "aic", "dfwtx", "KDTNJ01", "3.0", "\"f1d563e8-e714-4393-8f99-cc480144a05e\", \"j1d563e8-e714-4393-8f99-cc480144a05e\"", "\"s1d563e8-e714-4393-8f99-cc480144a05e\", \"b1d563e8-e714-4393-8f99-cc480144a05e\""), resourceARHomingString);
 173                 assertEquals(homingSolutionService("service", "testSIID2", "testVnfHostname2", "aic", "testCloudRegionId2", "testAicClli2", "3.0", null, null), resourceARHoming2String);
 174                 assertEquals(homingSolutionCloud("cloud", "", "", "aic", "testCloudRegionId3", "testAicClli3", "3.0", "\"91d563e8-e714-4393-8f99-cc480144a05e\", \"21d563e8-e714-4393-8f99-cc480144a05e\"", "\"31d563e8-e714-4393-8f99-cc480144a05e\", \"71d563e8-e714-4393-8f99-cc480144a05e\""), resourceVNFHomingString);
 175                 assertEquals(verifySniroRequest(), expectedSniroRequest);
 176
 177         }
 178
 179         @Test
 180         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 181         public void testHoming_success_2AR1Vnf2Net() throws Exception {
 182
 183                 mockSNIRO();
 184
 185                 String businessKey = UUID.randomUUID().toString();
 186                 Map<String, Object> variables = new HashMap<>();
 187                 setVariables2(variables);
 188
 189                 invokeSubProcess("Homing", businessKey, variables);
 190
 191                 injectWorkflowMessages(callbacks, "sniro2");
 192
 193                 waitForProcessEnd(businessKey, 10000);
 194
 195                 //Get Variables
 196                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 197                 ServiceDecomposition serviceDecompositionExp = (ServiceDecomposition) getVariableFromHistory(businessKey, "serviceDecomposition");
 198                 String expectedSniroRequest = (String) getVariableFromHistory(businessKey, "sniroRequest");
 199
 200                 Resource resourceAR = serviceDecompositionExp.getServiceResource("testResourceIdAR");
 201                 HomingSolution resourceARHoming = resourceAR.getHomingSolution();
 202                 Resource resourceAR2 = serviceDecompositionExp.getServiceResource("testResourceIdAR2");
 203                 HomingSolution resourceARHoming2 = resourceAR2.getHomingSolution();
 204                 Resource resourceVNF = serviceDecompositionExp.getServiceResource("testResourceIdVNF");
 205                 HomingSolution resourceVNFHoming = resourceVNF.getHomingSolution();
 206                 Resource resourceNet = serviceDecompositionExp.getServiceResource("testResourceIdNet");
 207                 HomingSolution resourceNetHoming = resourceNet.getHomingSolution();
 208                 Resource resourceNet2 = serviceDecompositionExp.getServiceResource("testResourceIdNet2");
 209                 HomingSolution resourceNetHoming2 = resourceNet2.getHomingSolution();
 210
 211                 String resourceARHomingString = resourceARHoming.toString();
 212                 resourceARHomingString = resourceARHomingString.replaceAll("\\s+", " ");
 213                 String resourceARHoming2String = resourceARHoming2.toString();
 214                 resourceARHoming2String = resourceARHoming2String.replaceAll("\\s+", " ");
 215                 String resourceVNFHomingString = resourceVNFHoming.toString();
 216                 resourceVNFHomingString = resourceVNFHomingString.replaceAll("\\s+", " ");
 217                 String resourceNetHomingString = resourceNetHoming.toString();
 218                 resourceNetHomingString = resourceNetHomingString.replaceAll("\\s+", " ");
 219                 String resourceNetHoming2String = resourceNetHoming2.toString();
 220                 resourceNetHoming2String = resourceNetHoming2String.replaceAll("\\s+", " ");
 221                 expectedSniroRequest = expectedSniroRequest.replaceAll("\\s+", "");
 222
 223                 assertNull(workflowException);
 224                 assertEquals(homingSolutionService("service", "testSIID1", "MDTNJ01", "aic", "dfwtx", "KDTNJ01", "3.0", "\"f1d563e8-e714-4393-8f99-cc480144a05e\", \"j1d563e8-e714-4393-8f99-cc480144a05e\"", "\"s1d563e8-e714-4393-8f99-cc480144a05e\", \"b1d563e8-e714-4393-8f99-cc480144a05e\""), resourceARHomingString);
 225                 assertEquals(homingSolutionService("service", "testSIID2", "testVnfHostname2", "aic", "testCloudRegionId2", "testAicClli2", "3.0", null, null), resourceARHoming2String);
 226                 assertEquals(homingSolutionCloud("cloud", "", "", "aic", "testCloudRegionId3", "testAicClli3", "3.0", "\"91d563e8-e714-4393-8f99-cc480144a05e\", \"21d563e8-e714-4393-8f99-cc480144a05e\"", "\"31d563e8-e714-4393-8f99-cc480144a05e\", \"71d563e8-e714-4393-8f99-cc480144a05e\""), resourceVNFHomingString);
 227                 assertEquals(homingSolutionService("service", "testServiceInstanceIdNet", "testVnfHostNameNet", "aic", "testCloudRegionIdNet", "testAicClliNet", "3.0", null, null), resourceNetHomingString);
 228                 assertEquals(homingSolutionCloud("cloud", "", "", "aic", "testCloudRegionIdNet2", "testAicClliNet2", "3.0", "\"f1d563e8-e714-4393-8f99-cc480144a05n\", \"j1d563e8-e714-4393-8f99-cc480144a05n\"", "\"s1d563e8-e714-4393-8f99-cc480144a05n\", \"b1d563e8-e714-4393-8f99-cc480144a05n\""), resourceNetHoming2String);
 229                 assertEquals(verifySniroRequest(), expectedSniroRequest);
 230         }
 231
 232         @Test
 233         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/BuildingBlock/DecomposeService.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 234         public void testHoming_success_vnfResourceList() throws Exception {
 235
 236                 // Create a Service Decomposition
 237 //System.out.println("At start of testHoming_success_vnfResourceList");
 238             MockGetServiceResourcesCatalogDataByModelUuid("2f7f309d-c842-4644-a2e4-34167be5eeb4", "/BuildingBlocks/catalogResp.json");
 239                 //MockGetServiceResourcesCatalogData("1cc4e2e4-eb6e-404d-a66f-c8733cedcce8", "5.0", "/BuildingBlocks/catalogResp.json");
 240                 String busKey = UUID.randomUUID().toString();
 241                 Map<String, Object> vars = new HashMap<>();
 242                 setVariablesForServiceDecomposition(vars, "testRequestId123", "ff5256d2-5a33-55df-13ab-12abad84e7ff");
 243                 invokeSubProcess("DecomposeService", busKey, vars);
 244
 245                 ServiceDecomposition sd = (ServiceDecomposition) getVariableFromHistory(busKey, "serviceDecomposition");
 246 //System.out.println("In testHoming_success_vnfResourceList, ServiceDecomposition = " + sd);
 247                 List<VnfResource> vnfResourceList = sd.getServiceVnfs();
 248 //System.out.println(" vnfResourceList = " + vnfResourceList);
 249                 vnfResourceList.get(0).setResourceId("test-resource-id-000");
 250
 251                 // Invoke Homing
 252
 253                 mockSNIRO();
 254
 255                 String businessKey = UUID.randomUUID().toString();
 256                 Map<String, Object> variables = new HashMap<>();
 257                 variables.put("isDebugLogEnabled", "true");
 258                 variables.put("msoRequestId", "testRequestId");
 259                 variables.put("serviceInstanceId", "testServiceInstanceId");
 260                 variables.put("serviceDecomposition", sd);
 261                 variables.put("subscriberInfo", subscriber2);
 262
 263                 invokeSubProcess("Homing", businessKey, variables);
 264                 injectWorkflowMessages(callbacks, "sniro3");
 265                 waitForProcessEnd(businessKey, 10000);
 266
 267                 //Get Variables
 268
 269                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 270                 ServiceDecomposition serviceDecompositionExp = (ServiceDecomposition) getVariableFromHistory(businessKey, "serviceDecomposition");
 271
 272                 Resource resourceVnf = serviceDecompositionExp.getServiceResource("test-resource-id-000");
 273                 HomingSolution resourceVnfHoming = resourceVnf.getHomingSolution();
 274
 275                 String resourceVnfHomingString = resourceVnfHoming.toString();
 276                 resourceVnfHomingString = resourceVnfHomingString.replaceAll("\\s+", " ");
 277
 278                 assertNull(workflowException);
 279
 280                 //Verify request
 281                 String sniroRequest = (String) getVariableFromHistory(businessKey, "sniroRequest");
 282                 assertEquals(FileUtil.readResourceFile("__files/BuildingBlocks/sniroRequest_infravnf").replaceAll("\n", "").replaceAll("\r", "").replaceAll("\t", ""), sniroRequest.replaceAll("\n", "").replaceAll("\r", "").replaceAll("\t", ""));
 283
 284                 assertEquals(homingSolutionService("service", "service-instance-01234", "MDTNJ01", "att-aic", "mtmnj1a", "KDTNJ01", "3.0", "\"f1d563e8-e714-4393-8f99-cc480144a05e\", \"j1d563e8-e714-4393-8f99-cc480144a05e\"", "\"s1d563e8-e714-4393-8f99-cc480144a05e\", \"b1d563e8-e714-4393-8f99-cc480144a05e\""), resourceVnfHomingString);
 285         }
 286
 287         @Test
 288         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 289         public void testHoming_error_inputVariable() throws Exception {
 290
 291                 String businessKey = UUID.randomUUID().toString();
 292                 Map<String, Object> variables = new HashMap<>();
 293                 setVariables3(variables);
 294
 295                 invokeSubProcess("Homing", businessKey, variables);
 296
 297                 waitForProcessEnd(businessKey, 10000);
 298
 299                 //Get Variables
 300                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 301
 302                 assertEquals("WorkflowException[processKey=Homing,errorCode=4000,errorMessage=A required input variable is missing or null]", workflowException.toString());
 303         }
 304
 305         @Test
 306         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 307         public void testHoming_error_badResponse() throws Exception {
 308                 mockSNIRO_500();
 309
 310                 String businessKey = UUID.randomUUID().toString();
 311                 Map<String, Object> variables = new HashMap<>();
 312                 setVariables(variables);
 313
 314                 invokeSubProcess("Homing", businessKey, variables);
 315
 316                 waitForProcessEnd(businessKey, 10000);
 317
 318                 //Get Variables
 319                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 320
 321                 assertEquals("WorkflowException[processKey=Homing,errorCode=500,errorMessage=Received a Bad Sync Response from Sniro.]", workflowException.toString());
 322         }
 323
 324         @Test
 325         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 326         public void testHoming_error_sniroNoSolution() throws Exception {
 327                 mockSNIRO();
 328
 329                 String businessKey = UUID.randomUUID().toString();
 330                 Map<String, Object> variables = new HashMap<>();
 331                 setVariables(variables);
 332
 333                 invokeSubProcess("Homing", businessKey, variables);
 334
 335                 injectWorkflowMessages(callbacks, "sniroNoSol");
 336
 337                 waitForProcessEnd(businessKey, 10000);
 338
 339                 //Get Variables
 340                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 341
 342                 assertEquals("WorkflowException[processKey=Homing,errorCode=400,errorMessage=No solution found for plan 08e1b8cf-144a-4bac-b293-d5e2eedc97e8]", workflowException.toString());
 343         }
 344
 345         @Test
 346         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 347         public void testHoming_error_sniroPolicyException() throws Exception {
 348                 mockSNIRO();
 349
 350                 String businessKey = UUID.randomUUID().toString();
 351                 Map<String, Object> variables = new HashMap<>();
 352                 setVariables(variables);
 353
 354                 invokeSubProcess("Homing", businessKey, variables);
 355
 356                 injectWorkflowMessages(callbacks, "sniroPolicyEx");
 357
 358                 waitForProcessEnd(businessKey, 10000);
 359
 360                 //Get Variables
 361                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 362
 363                 assertEquals("WorkflowException[processKey=Homing,errorCode=400,errorMessage=Sniro Async Callback Response contains a Request Error Policy Exception: Message content size exceeds the allowable limit]", workflowException.toString());
 364         }
 365
 366         @Test
 367         @Deployment(resources = {"subprocess/BuildingBlock/Homing.bpmn", "subprocess/ReceiveWorkflowMessage.bpmn"})
 368         public void testHoming_error_sniroServiceException() throws Exception {
 369                 mockSNIRO();
 370
 371                 String businessKey = UUID.randomUUID().toString();
 372                 Map<String, Object> variables = new HashMap<>();
 373                 setVariables(variables);
 374
 375                 invokeSubProcess("Homing", businessKey, variables);
 376
 377                 injectWorkflowMessages(callbacks, "sniroServiceEx");
 378
 379                 waitForProcessEnd(businessKey, 10000);
 380
 381                 //Get Variables
 382                 WorkflowException workflowException = (WorkflowException) getVariableFromHistory(businessKey, "WorkflowException");
 383
 384                 assertEquals("WorkflowException[processKey=Homing,errorCode=400,errorMessage=Sniro Async Callback Response contains a Request Error Service Exception: SNIROPlacementError: requests.exceptions.HTTPError: 404 Client Error: Not Found for url: http://135.21.171.200:8091/v1/plans/97b4e303-5f75-492c-8fb2-21098281c8b8]", workflowException.toString());
 385         }
 386
 387
 388
 389         private void setVariables(Map<String, Object> variables) {
 390                 variables.put("isDebugLogEnabled", "true");
 391         //      variables.put("mso-request-id", "testRequestId");
 392                 variables.put("msoRequestId", "testRequestId");
 393                 variables.put("serviceInstanceId", "testServiceInstanceId");
 394                 variables.put("serviceDecomposition", serviceDecomposition);
 395                 variables.put("subscriberInfo", subscriber2);
 396
 397         }
 398
 399         private void setVariables2(Map<String, Object> variables) {
 400                 List<NetworkResource> netList = new ArrayList<NetworkResource>();
 401                 NetworkResource net = new NetworkResource();
 402                 net.setResourceId("testResourceIdNet");
 403                 ModelInfo netModel = new ModelInfo();
 404                 netModel.setModelCustomizationUuid("testModelCustomizationUuidNet");
 405                 netModel.setModelInvariantUuid("testModelInvariantIdNet");
 406                 netModel.setModelName("testModelNameNet");
 407                 netModel.setModelVersion("testModelVersionNet");
 408                 net.setModelInfo(netModel);
 409                 netList.add(net);
 410                 NetworkResource net2 = new NetworkResource();
 411                 net2.setResourceId("testResourceIdNet2");
 412                 ModelInfo netModel2 = new ModelInfo();
 413                 netModel2.setModelCustomizationUuid("testModelCustomizationUuidNet2");
 414                 netModel2.setModelInvariantUuid("testModelInvariantIdNet2");
 415                 netModel2.setModelName("testModelNameNet2");
 416                 netModel2.setModelVersion("testModelVersionNet2");
 417                 net2.setModelInfo(netModel2);
 418                 netList.add(net2);
 419                 serviceDecomposition.setServiceNetworks(netList);
 420
 421                 variables.put("isDebugLogEnabled", "true");
 422                 variables.put("msoRequestId", "testRequestId");
 423                 variables.put("serviceInstanceId", "testServiceInstanceId");
 424                 variables.put("serviceDecomposition", serviceDecomposition);
 425                 variables.put("subscriberInfo", subscriber2);
 426         }
 427
 428         private void setVariables3(Map<String, Object> variables) {
 429                 variables.put("isDebugLogEnabled", "true");
 430         //      variables.put("mso-request-id", "testRequestId");
 431                 variables.put("msoRequestId", "testRequestId");
 432                 variables.put("serviceInstanceId", "testServiceInstanceId");
 433                 variables.put("serviceDecomposition", null);
 434                 variables.put("subscriberInfo", subscriber2);
 435
 436         }
 437
 438         private String homingSolutionService(String type, String serviceInstanceId, String vnfHostname, String cloudOwner, String cloudRegionId, String aicClli, String aicVersion, String enList, String licenseList){
 439                 String solution = "";
 440                 if(enList == null){
 441                         solution = "{ \"homingSolution\" : { \"inventoryType\" : \"" + type + "\", \"serviceInstanceId\" : \"" + serviceInstanceId + "\", \"vnfHostname\" : \"" + vnfHostname + "\", \"cloudOwner\" : \"" + cloudOwner + "\", \"cloudRegionId\" : \"" + cloudRegionId + "\", \"aicClli\" : \"" + aicClli + "\", \"aicVersion\" : \"" + aicVersion + "\" } }";
 442                 }else{
 443                         solution = "{ \"homingSolution\" : { \"inventoryType\" : \"" + type + "\", \"serviceInstanceId\" : \"" + serviceInstanceId + "\", \"vnfHostname\" : \"" + vnfHostname + "\", \"cloudOwner\" : \"" + cloudOwner + "\", \"cloudRegionId\" : \"" + cloudRegionId + "\", \"aicClli\" : \"" + aicClli + "\", \"aicVersion\" : \"" + aicVersion + "\", \"entitlementPoolList\" : [ " + enList +  " ], \"licenseKeyGroupList\" : [ " + licenseList +  " ] } }";
 444                 }
 445                 return solution;
 446         }
 447
 448         private String homingSolutionCloud(String type, String serviceInstanceId, String vnfHostname, String cloudOwner, String cloudRegionId, String aicClli, String aicVersion, String enList, String licenseList){
 449                 String solution = "";
 450                 if(enList == null){
 451                         solution = "{ \"homingSolution\" : { \"inventoryType\" : \"" + type + "\", \"cloudOwner\" : \"" + cloudOwner + "\", \"cloudRegionId\" : \"" + cloudRegionId + "\", \"aicClli\" : \"" + aicClli + "\", \"aicVersion\" : \"" + aicVersion + "\" } }";
 452                 }else{
 453                         solution = "{ \"homingSolution\" : { \"inventoryType\" : \"" + type + "\", \"cloudOwner\" : \"" + cloudOwner + "\", \"cloudRegionId\" : \"" + cloudRegionId + "\", \"aicClli\" : \"" + aicClli + "\", \"aicVersion\" : \"" + aicVersion + "\", \"entitlementPoolList\" : [ " + enList +  " ], \"licenseKeyGroupList\" : [ " + licenseList +  " ] } }";
 454                 }
 455                 return solution;
 456         }
 457
 458         private void setVariablesForServiceDecomposition(Map<String, Object> variables, String requestId, String siId) {
 459                 variables.put("isDebugLogEnabled", "true");
 460                 variables.put("mso-request-id", requestId);
 461                 variables.put("msoRequestId", requestId);
 462                 variables.put("serviceInstanceId",siId);
 463
 464                 String serviceModelInfo = "{ "+ "\"modelType\": \"service\"," +
 465                                 "\"modelInvariantUuid\": \"1cc4e2e4-eb6e-404d-a66f-c8733cedcce8\"," +
 466                                 "\"modelUuid\": \"2f7f309d-c842-4644-a2e4-34167be5eeb4\"," +
 467                                 "\"modelName\": \"ADIOD vRouter vCE 011017 Service\"," +
 468                                 "\"modelVersion\": \"5.0\"," +
 469                                 "}";
 470                 variables.put("serviceModelInfo", serviceModelInfo);
 471         }
 472
 473         private String verifySniroRequest(){
 474                 String request = "{\"requestInfo\":{\"transactionId\":\"testRequestId\",\"requestId\":\"testRequestId\",\"callbackUrl\":\"http://localhost:28090/workflows/messages/message/SNIROResponse/testRequestId\",\"sourceId\":\"mso\",\"optimizer\":[\"placement\",\"license\"],\"numSolutions\":1,\"timeout\":600},\"placementInfo\":{\"serviceModelInfo\":{\"modelType\":\"\",\"modelInvariantId\":\"testModelInvariantId\",\"modelVersionId\":\"testModelUuid\",\"modelName\":\"testModelName\",\"modelVersion\":\"testModelVersion\"},\"subscriberInfo\":{\"globalSubscriberId\":\"SUB12_0322_DS_1201\",\"subscriberName\":\"SUB_12_0322_DS_1201\",\"subscriberCommonSiteId\":\"\"},\"demandInfo\":{\"placementDemand\":[{\"resourceInstanceType\":\"ALLOTTED_RESOURCE\",\"serviceResourceId\":\"testResourceIdAR\",\"resourceModuleName\":\"\",\"resourceModelInfo\":{\"modelCustomizationId\":\"testModelCustomizationUuidAR\",\"modelInvariantId\":\"testModelInvariantIdAR\",\"modelName\":\"testModelNameAR\",\"modelVersion\":\"testModelVersionAR\",\"modelVersionId\":\"testARModelUuid\",\"modelType\":\"testModelTypeAR\"},\"tenantId\":\"\",\"tenantName\":\"\"},{\"resourceInstanceType\":\"ALLOTTED_RESOURCE\",\"serviceResourceId\":\"testResourceIdAR2\",\"resourceModuleName\":\"\",\"resourceModelInfo\":{\"modelCustomizationId\":\"testModelCustomizationUuidAR2\",\"modelInvariantId\":\"testModelInvariantIdAR2\",\"modelName\":\"testModelNameAR2\",\"modelVersion\":\"testModelVersionAR2\",\"modelVersionId\":\"testAr2ModelUuid\",\"modelType\":\"testModelTypeAR2\"},\"tenantId\":\"\",\"tenantName\":\"\"}],\"licenseDemand\":[{\"resourceInstanceType\":\"VNF\",\"serviceResourceId\":\"testResourceIdVNF\",\"resourceModuleName\":\"\",\"resourceModelInfo\":{\"modelCustomizationId\":\"testModelCustomizationUuidVNF\",\"modelInvariantId\":\"testModelInvariantIdVNF\",\"modelName\":\"testModelNameVNF\",\"modelVersion\":\"testModelVersionVNF\",\"modelVersionId\":\"testVnfModelUuid\",\"modelType\":\"testModelTypeVNF\"}}]},\"policyId\":[],\"serviceInstanceId\":\"testServiceInstanceId123\",\"orderInfo\":\"{\\\"requestParameters\\\":null}\"}}";
 475                 return request;
 476         }
 477
 478 }