vid-automation/src/test/java/org/onap/vid/api/AsyncInstantiationALaCarteApiTest3.java

   1 package org.onap.vid.api;
   2
   3 import static org.apache.commons.lang3.RandomStringUtils.randomAlphabetic;
   4 import static org.hamcrest.CoreMatchers.is;
   5 import static org.hamcrest.CoreMatchers.nullValue;
   6 import static org.hamcrest.MatcherAssert.assertThat;
   7 import static org.hamcrest.Matchers.allOf;
   8 import static org.hamcrest.Matchers.not;
   9 import static org.hamcrest.collection.IsCollectionWithSize.hasSize;
  10 import static org.onap.simulator.presetGenerator.presets.mso.PresetMSOBaseCreateInstancePost.DEFAULT_REQUEST_ID;
  11 import static org.onap.simulator.presetGenerator.presets.mso.PresetMSOOrchestrationRequestGet.COMPLETE;
  12 import static org.onap.simulator.presetGenerator.presets.mso.PresetMSOServiceInstanceGen2WithNames.Keys.RELATED_VNF1_ACTION;
  13 import static org.onap.simulator.presetGenerator.presets.mso.PresetMSOServiceInstanceGen2WithNames.Keys.RELATED_VNF2_ACTION;
  14 import static org.onap.simulator.presetGenerator.presets.mso.PresetMSOServiceInstanceGen2WithNames.Keys.SERVICE_NAME;
  15 import static org.onap.simulator.presetGenerator.presets.mso.PresetMSOServiceInstanceGen2WithNames.Keys.VNF_GROUP1_ACTION;
  16 import static vid.automation.test.services.SimulatorApi.registerExpectationFromPreset;
  17 import static vid.automation.test.services.SimulatorApi.registerExpectationFromPresets;
  18
  19 import com.google.common.collect.ImmutableList;
  20 import com.google.common.collect.ImmutableMap;
  21 import java.util.List;
  22 import java.util.Map;
  23 import java.util.UUID;
  24 import java.util.function.Function;
  25 import org.onap.simulator.presetGenerator.presets.BasePresets.BaseMSOPreset;
  26 import org.onap.simulator.presetGenerator.presets.BasePresets.BasePreset;
  27 import org.onap.simulator.presetGenerator.presets.aai.PresetAAIGetCloudOwnersByCloudRegionId;
  28 import org.onap.simulator.presetGenerator.presets.aai.PresetAAIGetSubscribersGet;
  29 import org.onap.simulator.presetGenerator.presets.aai.PresetAAISearchNodeQueryNonEmptyResult;
  30 import org.onap.simulator.presetGenerator.presets.ecompportal_att.PresetGetSessionSlotCheckIntervalGet;
  31 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOAddOrRemoveOneInstanceGroupMember;
  32 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOAddOrRemoveOneInstanceGroupMember.InstanceGroupMemberAction;
  33 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOBaseCreateInstancePost;
  34 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateNetworkALaCarteServiceCypress2;
  35 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateServiceInstanceGen2WithNamesAlacarteGroupingService;
  36 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateServiceInstanceGen2WithNamesAlacarteService;
  37 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateServiceInstanceMultipleVnfsServiceCypress;
  38 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateVnfALaCarteServiceCypress;
  39 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateVnfALaCarteServiceCypress2;
  40 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOCreateVnfGroup;
  41 import org.onap.simulator.presetGenerator.presets.mso.PresetMSODeleteBaseVfModuleCypress;
  42 import org.onap.simulator.presetGenerator.presets.mso.PresetMSODeleteNetworkAlaCarteCypress;
  43 import org.onap.simulator.presetGenerator.presets.mso.PresetMSODeleteService;
  44 import org.onap.simulator.presetGenerator.presets.mso.PresetMSODeleteVfModuleCypress;
  45 import org.onap.simulator.presetGenerator.presets.mso.PresetMSODeleteVnfAlaCarteCypress;
  46 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOOrchestrationRequestGet;
  47 import org.onap.simulator.presetGenerator.presets.mso.PresetMSOServiceInstanceGen2WithNames;
  48 import org.onap.simulator.presetGenerator.presets.sdc.PresetSDCGetServiceMetadataGet;
  49 import org.onap.simulator.presetGenerator.presets.sdc.PresetSDCGetServiceToscaModelGet;
  50 import org.onap.vid.model.asyncInstantiation.JobAuditStatus;
  51 import org.onap.vid.model.asyncInstantiation.JobAuditStatus.SourceStatus;
  52 import org.onap.vid.model.asyncInstantiation.ServiceInfo;
  53 import org.testng.annotations.AfterMethod;
  54 import org.testng.annotations.DataProvider;
  55 import org.testng.annotations.Test;
  56 import vid.automation.test.infra.FeatureTogglingTest;
  57 import vid.automation.test.infra.Features;
  58 import vid.automation.test.model.JobStatus;
  59 import vid.automation.test.model.ServiceAction;
  60 import vid.automation.test.services.AsyncJobsService;
  61 import vid.automation.test.services.SimulatorApi;
  62 import vid.automation.test.services.SimulatorApi.RegistrationStrategy;
  63
  64 @FeatureTogglingTest({Features.FLAG_ASYNC_JOBS, Features.FLAG_ASYNC_INSTANTIATION, Features.FLAG_ASYNC_ALACARTE_VNF})
  65 public class AsyncInstantiationALaCarteApiTest3 extends AsyncInstantiationBase {
  66
  67     private static final String CREATE_BULK_OF_ALACARTE_REQUEST = "asyncInstantiation/vidRequestCreateALaCarte.json";
  68     private static final String CREATE_BULK_OF_ALACARTE_MULTIPLE_VNF_NETWORK_REQUEST_CYPRESS = "a-la-carte/redux-multiple-vnf-network.json";
  69     private static final String CREATE_BULK_OF_ALACARTE_REQUEST_WITH_VNF_GROUP = "VnfGroup/serviceWithVnfGroupCreateRequest.json";
  70     private static final String PAYLOAD_TEMPLATE_1_VNF_GROUP_WITH_3_MEMBERS_REQUEST = "VnfGroup/payloadTemplate1VnfGroupWith3MembersRequest.json";
  71     private static final String DELETE_AND_CREATE_NETWORK_FROM_SERVICE = "asyncInstantiation/vidRequestDelete1Create1Network.json";
  72     private static final String DELETE_SERVICE_WITH_NETWORK = "asyncInstantiation/vidRequestDeleteServiceWithNetwork.json";
  73     private static final String DELETE_AND_CREATE_VNF_FROM_SERVICE = "asyncInstantiation/vidRequestDelete1Create1Vnf.json";
  74     private static final String DELETE_SERVICE_WITH_VNF = "asyncInstantiation/vidRequestDeleteServiceWithVnf.json";
  75
  76
  77     private static final String FIRST_REQUEST_ID = "d1011670-0e1a-4b74-945d-8bf5aede1d9c";
  78     private static final String SECOND_REQUEST_ID = "e2011670-0e1a-4b74-945d-8bf5aede1d9c";
  79     private static final String THIRD_REQUEST_ID = "f3011670-0e1a-4b74-945d-8bf5aede1d9c";
  80     private static final String SERVICE_INSTANCE_ID = BaseMSOPreset.DEFAULT_INSTANCE_ID;
  81     private static final String MSO_COMPLETE_STATUS = "COMPLETE";
  82     private static final String MSO_FAILED_STATUS = "FAILED";
  83
  84
  85     @DataProvider
  86     public static Object[][] scenarios() {
  87         return new Object[][]{
  88                 {Scenario.PARALLEL},
  89                 {Scenario.COMPLETED},
  90 //                {Scenario.NAME_TAKEN}, Not relevant because the name uniqueness is supported only for bulk in Macro
  91 //                {Scenario.DUPLICATE_NAME}, Not relevant because name duplication is not handled in A La Carte
  92                 {Scenario.IN_PROGRESS},
  93                 {Scenario.MSO_FAIL}
  94         };
  95     }
  96
  97     @AfterMethod
  98     protected void dropAllFromNameCounter() {
  99         AsyncJobsService asyncJobsService = new AsyncJobsService();
 100         asyncJobsService.dropAllFromNameCounter();
 101     }
 102
 103     @Test(dataProvider = "multipleVnfDataProvider")
 104     public void deployServiceFromCypress__multipleVnfsAndNetwork(String expectedStatus, JobStatus expectedJobStatus) {
 105         dropAllFromNameCounter();// needed because each data provider info not going to after method
 106         final ImmutableMap<PresetMSOServiceInstanceGen2WithNames.Keys, String> names = ImmutableMap.of(SERVICE_NAME, "serviceInstanceName");
 107
 108         List<PresetMSOBaseCreateInstancePost> createPresets =   ImmutableList.of(
 109                 new PresetMSOCreateServiceInstanceMultipleVnfsServiceCypress(names, 0, DEFAULT_REQUEST_ID),
 110                 new PresetMSOCreateVnfALaCarteServiceCypress(FIRST_REQUEST_ID, SERVICE_INSTANCE_ID,"VFvGeraldine00001", "zzz1"),
 111                 new PresetMSOCreateVnfALaCarteServiceCypress(SECOND_REQUEST_ID, SERVICE_INSTANCE_ID,"VFvGeraldine00001_001", "ONAP"),
 112                 new PresetMSOCreateNetworkALaCarteServiceCypress2(THIRD_REQUEST_ID, SERVICE_INSTANCE_ID, "ExtVL")
 113         );
 114         List<PresetMSOOrchestrationRequestGet> inProgressPresets =  ImmutableList.of(
 115                 new PresetMSOOrchestrationRequestGet(expectedStatus.equals("SERVICE_FAILED") ? MSO_FAILED_STATUS : MSO_COMPLETE_STATUS, DEFAULT_REQUEST_ID),
 116                 new PresetMSOOrchestrationRequestGet( MSO_COMPLETE_STATUS, FIRST_REQUEST_ID, "First VNF instance was created successfully." ),
 117                 new PresetMSOOrchestrationRequestGet(expectedStatus, SECOND_REQUEST_ID, expectedStatus.equals(MSO_COMPLETE_STATUS)?"Second VNF instance was created successfully.": MSO_BASE_ERROR),
 118                 new PresetMSOOrchestrationRequestGet(MSO_COMPLETE_STATUS, THIRD_REQUEST_ID,"Network was created successfully.")
 119         );
 120         List<BasePreset> presets = getPresets( createPresets, inProgressPresets);
 121
 122         registerExpectationFromPresets(presets, RegistrationStrategy.CLEAR_THEN_SET);
 123         registerExpectationFromPreset(PresetAAIGetCloudOwnersByCloudRegionId.PRESET_MTN6_TO_ATT_AIC, RegistrationStrategy.APPEND);
 124
 125         final List<String> uuids = createBulkOfInstances(false, 1, names, CREATE_BULK_OF_ALACARTE_MULTIPLE_VNF_NETWORK_REQUEST_CYPRESS);
 126
 127         assertThat(uuids, hasSize(1));
 128         final String jobId = uuids.get(0);
 129
 130         //expected vid statuses
 131         ImmutableList<JobAuditStatus> vidAuditStatuses;
 132
 133         if (expectedStatus.equals(MSO_COMPLETE_STATUS)){
 134             vidAuditStatuses = vidAuditStatusesCompleted(jobId);
 135         } else if (expectedStatus.equals("SERVICE_FAILED")){
 136             vidAuditStatuses = vidAuditStatusesFailed(jobId);
 137         } else {
 138             vidAuditStatuses = vidAuditStatusesCompletedWithErrors(jobId);
 139         }
 140
 141         assertServiceInfoSpecific3(jobId, expectedJobStatus , names.get(SERVICE_NAME));
 142         assertAuditStatuses(jobId, vidAuditStatuses, null);
 143     }
 144
 145
 146     @DataProvider
 147     Object[][] multipleVnfDataProvider() {
 148         return new Object[][]{{MSO_FAILED_STATUS, JobStatus.COMPLETED_WITH_ERRORS},{MSO_COMPLETE_STATUS, JobStatus.COMPLETED}, {"SERVICE_FAILED", JobStatus.FAILED}};
 149     }
 150
 151     @Test
 152     @FeatureTogglingTest(Features.FLAG_1902_VNF_GROUPING)
 153     public void deploy1ServiceWith1VnfGroup() {
 154         final ImmutableMap<PresetMSOServiceInstanceGen2WithNames.Keys, String> names = ImmutableMap.of(SERVICE_NAME, "Grouping_Service_Instance");
 155         String serviceReqId = "3cf5ea96-6b34-4945-b5b1-4a7798b1caf2";
 156         String serviceInstanceId = BaseMSOPreset.DEFAULT_INSTANCE_ID;
 157         String instanceGroupReqId = "715a5106-cdcc-44ee-8923-83d68a896908";
 158
 159         List<PresetMSOBaseCreateInstancePost> createPresets = ImmutableList.of(
 160                 new PresetMSOCreateServiceInstanceGen2WithNamesAlacarteGroupingService(names, 0, serviceReqId),
 161                 new PresetMSOCreateVnfGroup("ABC", instanceGroupReqId, PresetMSOCreateVnfGroup.MODEL_INFO_1, serviceInstanceId, false));
 162         List<PresetMSOOrchestrationRequestGet> inProgressPresets = ImmutableList.of(
 163                 new PresetMSOOrchestrationRequestGet("COMPLETE", serviceReqId),
 164                 new PresetMSOOrchestrationRequestGet("COMPLETE", instanceGroupReqId, "Instance group was created successfully."));
 165         List<BasePreset> presets = getPresets(createPresets, inProgressPresets);
 166
 167         registerExpectationFromPresets(presets, RegistrationStrategy.CLEAR_THEN_SET);
 168
 169         final List<String> uuids = createBulkOfInstances(false, 1, names, CREATE_BULK_OF_ALACARTE_REQUEST_WITH_VNF_GROUP);
 170
 171         assertThat(uuids, hasSize(1));
 172         final String jobId = uuids.get(0);
 173
 174         assertExpectedStatusAndServiceInfo(JobStatus.COMPLETED, jobId, new ServiceInfo(
 175                 "us16807000", JobStatus.COMPLETED, false,
 176                 "d61e6f2d-12fa-4cc2-91df-7c244011d6fc", "WayneHolland", "WATKINS",
 177                 null, null,
 178                 null, null,
 179                 null, null,
 180                 "TYLER SILVIA", "SILVIA ROBBINS",
 181                 null, names.get(SERVICE_NAME),
 182                 "4117a0b6-e234-467d-b5b9-fe2f68c8b0fc", "Grouping Service for Test", "1.0",
 183                 jobId, null, ServiceAction.INSTANTIATE, false));
 184
 185
 186         assertAuditStatuses(jobId, vidAuditStatusesCompleted(jobId),null);
 187
 188         assertThat(SimulatorApi.retrieveRecordedRequestsPathCounter(), allOf(
 189                 TestUtils.hasOrLacksOfEntry(createPresets.get(0).getReqPath(), 1L),
 190                 TestUtils.hasOrLacksOfEntry(createPresets.get(1).getReqPath(), 1L),
 191                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(0).getReqPath(), 1L),
 192                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(1).getReqPath(), 1L)));
 193     }
 194
 195     @DataProvider
 196     public static Object[][] addAndDeleteMembersMsoStatus() {
 197         return new Object[][]{
 198                 {MSO_COMPLETE_STATUS, MSO_COMPLETE_STATUS, JobStatus.COMPLETED},
 199                 {MSO_FAILED_STATUS, MSO_FAILED_STATUS, JobStatus.FAILED},
 200                 {MSO_COMPLETE_STATUS, MSO_FAILED_STATUS, JobStatus.COMPLETED_WITH_ERRORS}
 201         };
 202     }
 203
 204     @Test(dataProvider = "addAndDeleteMembersMsoStatus")
 205     @FeatureTogglingTest(Features.FLAG_1902_VNF_GROUPING)
 206     public void add1delete1GroupMembers_withGoodResponseFromMso_verifyStatusAndRequests(String firstMemberStatus, String secondMemberStatus, JobStatus expectedJobStatus) {
 207
 208         String firstMemberRequestId = UUID.randomUUID().toString();
 209         String secondMemberRequestId = UUID.randomUUID().toString();
 210
 211         List<PresetMSOAddOrRemoveOneInstanceGroupMember> instanceGroupMemberPreset = ImmutableList.of(
 212                 new PresetMSOAddOrRemoveOneInstanceGroupMember("VNF_GROUP1_INSTANCE_ID", "RELATED_VNF1_INSTANCE_ID", getUserCredentials().getUserId(), firstMemberRequestId, InstanceGroupMemberAction.Add),
 213                 new PresetMSOAddOrRemoveOneInstanceGroupMember("VNF_GROUP1_INSTANCE_ID", "RELATED_VNF2_INSTANCE_ID", getUserCredentials().getUserId(), secondMemberRequestId, InstanceGroupMemberAction.Remove)
 214         );
 215         List<PresetMSOOrchestrationRequestGet> inProgressPresets = ImmutableList.of(
 216                 new PresetMSOOrchestrationRequestGet(firstMemberStatus, firstMemberRequestId),
 217                 new PresetMSOOrchestrationRequestGet(secondMemberStatus, secondMemberRequestId)
 218         );
 219
 220         List<BasePreset> presets = getGroupMembersPresets(instanceGroupMemberPreset,inProgressPresets);
 221         registerExpectationFromPresets(presets, RegistrationStrategy.CLEAR_THEN_SET);
 222         final List<String> uuids = createBulkOfInstances(false, 1, ImmutableMap.of(
 223                 VNF_GROUP1_ACTION, "None",
 224                 RELATED_VNF1_ACTION, "Create",
 225                 RELATED_VNF2_ACTION, "None_Delete"
 226         ), PAYLOAD_TEMPLATE_1_VNF_GROUP_WITH_3_MEMBERS_REQUEST);
 227
 228         assertThat(uuids, hasSize(1));
 229         final String jobId = uuids.get(0);
 230
 231         assertAuditStatuses(jobId, vidAuditStatuses(jobId, expectedJobStatus), null, 60);
 232         assertThat(SimulatorApi.retrieveRecordedRequestsPathCounter(), allOf(
 233                 TestUtils.hasOrLacksOfEntry(instanceGroupMemberPreset.get(0).getReqPath(), 1L),
 234                 TestUtils.hasOrLacksOfEntry(instanceGroupMemberPreset.get(1).getReqPath(), 1L),
 235                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(0).getReqPath(), 1L),
 236                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(1).getReqPath(), 1L)
 237         ));
 238     }
 239
 240     @Test
 241     @FeatureTogglingTest(Features.FLAG_1902_VNF_GROUPING)
 242     public void addVnfGroupWith2GroupMembers_withGoodResponseFromMso_verifyStatusAndRequests() {
 243
 244         String vnfGroupRequestId = UUID.randomUUID().toString();
 245         String firstMemberRequestId = UUID.randomUUID().toString();
 246         String secondMemberRequestId = UUID.randomUUID().toString();
 247
 248         List <PresetMSOCreateVnfGroup> vnfGroupPreset = ImmutableList.of(
 249                 new PresetMSOCreateVnfGroup("VNF_GROUP1_INSTANCE_NAME",vnfGroupRequestId,PresetMSOCreateVnfGroup.MODEL_INFO_0,"service-instance-id", true));
 250         List<PresetMSOAddOrRemoveOneInstanceGroupMember> instanceGroupMemberPreset = ImmutableList.of(
 251                 new PresetMSOAddOrRemoveOneInstanceGroupMember("VNF_GROUP1_INSTANCE_ID", "RELATED_VNF1_INSTANCE_ID", getUserCredentials().getUserId(), firstMemberRequestId, InstanceGroupMemberAction.Add),
 252                 new PresetMSOAddOrRemoveOneInstanceGroupMember("VNF_GROUP1_INSTANCE_ID", "RELATED_VNF2_INSTANCE_ID", getUserCredentials().getUserId(), secondMemberRequestId, InstanceGroupMemberAction.Add)
 253         );
 254         List<PresetMSOOrchestrationRequestGet> inProgressPresets = ImmutableList.of(
 255                 new PresetMSOOrchestrationRequestGet(MSO_COMPLETE_STATUS, vnfGroupRequestId),
 256                 new PresetMSOOrchestrationRequestGet(MSO_COMPLETE_STATUS, firstMemberRequestId),
 257                 new PresetMSOOrchestrationRequestGet(MSO_COMPLETE_STATUS, secondMemberRequestId)
 258         );
 259
 260         final ImmutableList.Builder<BasePreset> basePresetBuilder = new ImmutableList.Builder<>();
 261         basePresetBuilder
 262                 .add(new PresetGetSessionSlotCheckIntervalGet())
 263                 .add(new PresetAAIGetSubscribersGet())
 264                 .addAll(instanceGroupMemberPreset)
 265                 .addAll(inProgressPresets)
 266                 .addAll(vnfGroupPreset);
 267         List<BasePreset> presets = basePresetBuilder.build();
 268
 269         registerExpectationFromPresets(presets, RegistrationStrategy.CLEAR_THEN_SET);
 270         final List<String> uuids = createBulkOfInstances(false, 1, ImmutableMap.of(
 271                 VNF_GROUP1_ACTION, "Create",
 272                 RELATED_VNF1_ACTION, "Create",
 273                 RELATED_VNF2_ACTION, "Create"
 274         ), PAYLOAD_TEMPLATE_1_VNF_GROUP_WITH_3_MEMBERS_REQUEST);
 275
 276         assertThat(uuids, hasSize(1));
 277         final String jobId = uuids.get(0);
 278
 279         assertAuditStatuses(jobId, vidAuditStatusesCompleted(jobId), null, 60);
 280         assertThat(SimulatorApi.retrieveRecordedRequestsPathCounter(), allOf(
 281                 TestUtils.hasOrLacksOfEntry(vnfGroupPreset.get(0).getReqPath(), 1L),
 282                 TestUtils.hasOrLacksOfEntry(instanceGroupMemberPreset.get(0).getReqPath(), 2L),
 283                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(0).getReqPath(), 1L),
 284                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(1).getReqPath(), 1L),
 285                 TestUtils.hasOrLacksOfEntry(inProgressPresets.get(2).getReqPath(), 1L)
 286         ));
 287     }
 288
 289     @Test(dataProvider = "scenarios")
 290     public void aLaCarteServiceScenarioRunner(Scenario scenario) {
 291         /*
 292         This tests creates one or more a-la-carte requests, following one of the these scenarios:
 293
 294         MSO_FAIL:        Submits to MSO, but while getting Orchestration status -> MSO
 295                          reports failure
 296         COMPLETED:       Clean legit flow.
 297         NAME_TAKEN:      Sends request for instance, where AAI reports the name is
 298                          already taken. Therefore, MSO expects added postfix _001.
 299         IN_PROGRESS:     Submits to MSO, but while getting Orchestration status -> MSO
 300                          reports IN_PROGRESS endlessly
 301         DUPLICATE_NAME:  Sends two requests for instances with the same name.
 302         PARALLEL:        Submits 3 requests, that must not interfere with each other.
 303          */
 304
 305         registerExpectationFromPresets(ImmutableList.of(
 306                 new PresetGetSessionSlotCheckIntervalGet(),
 307                 new PresetAAIGetSubscribersGet()
 308         ), RegistrationStrategy.CLEAR_THEN_SET);
 309
 310
 311         final String name0 = randomAlphabetic(18);
 312
 313         OneServiceActor inProgressCase = new OneServiceActor(
 314                 scenario == Scenario.PARALLEL || scenario == Scenario.IN_PROGRESS || scenario == Scenario.DUPLICATE_NAME,
 315                 "IN_PROGRESS", "status #1",
 316                 ImmutableMap.of(SERVICE_NAME, name0), 0,
 317                 JobStatus.IN_PROGRESS, this::vidAuditStatusesInProgress
 318         );
 319
 320         OneServiceActor completedCase = new OneServiceActor(
 321                 scenario == Scenario.PARALLEL || scenario == Scenario.COMPLETED,
 322                 MSO_COMPLETE_STATUS, "status #2",
 323                 ImmutableMap.of(SERVICE_NAME, randomAlphabetic(5)), 0,
 324                 JobStatus.COMPLETED, this::vidAuditStatusesCompleted
 325         );
 326
 327         final String name1 = randomAlphabetic(5);
 328         OneServiceActor occupiedNameCase = new OneServiceActor(
 329                 scenario == Scenario.NAME_TAKEN,
 330                 MSO_COMPLETE_STATUS, "status #6",
 331                 ImmutableMap.of(SERVICE_NAME, name1), 1,
 332                 JobStatus.COMPLETED, this::vidAuditStatusesCompleted,
 333                 ImmutableList.of(new PresetAAISearchNodeQueryNonEmptyResult("service-instance", name1))
 334         );
 335
 336         OneServiceActor failedCase = new OneServiceActor(
 337                 scenario == Scenario.PARALLEL || scenario == Scenario.MSO_FAIL,
 338                 "FAILED", "status #3",
 339                 ImmutableMap.of(SERVICE_NAME, randomAlphabetic(10)), 0,
 340                 JobStatus.FAILED, this::vidAuditStatusesFailed
 341         );
 342
 343         OneServiceActor duplicateNameCase = new OneServiceActor(
 344                 scenario == Scenario.DUPLICATE_NAME,
 345                 MSO_COMPLETE_STATUS, "status #4",
 346                 ImmutableMap.of(SERVICE_NAME, name0), 1,
 347                 JobStatus.COMPLETED, this::vidAuditStatusesCompleted
 348         );
 349
 350         OneServiceActor inProgressTooLongCase = new OneServiceActor(
 351                 scenario == Scenario.IN_PROGRESS,
 352                 "IN_PROGRESS", "status #5",
 353                 ImmutableMap.of(SERVICE_NAME, randomAlphabetic(10)), 0,
 354                 JobStatus.FAILED, this::vidAuditStatusesFailed, 24
 355         );
 356
 357         final List<OneServiceActor> servicesActors =
 358                 ImmutableList.of(inProgressCase, completedCase, occupiedNameCase, failedCase, duplicateNameCase, inProgressTooLongCase);
 359
 360         servicesActors.forEach(actor -> registerExpectationFromPresets(actor.getPresets(),
 361                 RegistrationStrategy.APPEND));
 362
 363         servicesActors.forEach(OneServiceActor::createInstances);
 364
 365         servicesActors.forEach(OneServiceActor::assertServiceInfo);
 366         servicesActors.forEach(OneServiceActor::assertAuditStatuses2);
 367     }
 368
 369     @Test
 370     public void delete1Create1NetworkFromService() {
 371         String deleteRequestId = UUID.randomUUID().toString();
 372         String createRequestId = UUID.randomUUID().toString();
 373         String serviceInstanceId = BaseMSOPreset.DEFAULT_INSTANCE_ID;
 374         String networkInstanceId = "NETWORK_INSTANCE_ID";
 375
 376         registerExpectationFromPresets(ImmutableList.of(
 377                 new PresetMSODeleteNetworkAlaCarteCypress(deleteRequestId, serviceInstanceId, networkInstanceId, "us16807000"),
 378                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteRequestId),
 379                 new PresetMSOCreateNetworkALaCarteServiceCypress2(createRequestId, serviceInstanceId, "ExtVL", "action-data", "6b528779-44a3-4472-bdff-9cd15ec93450"),
 380                 new PresetMSOOrchestrationRequestGet(COMPLETE, createRequestId),
 381                 PresetAAIGetCloudOwnersByCloudRegionId.PRESET_MTN6_TO_ATT_AIC
 382         ), RegistrationStrategy.CLEAR_THEN_SET);
 383
 384         List<String> uuids = createBulkOfInstances(false, 1, ImmutableMap.of(), DELETE_AND_CREATE_NETWORK_FROM_SERVICE);
 385         assertThat(uuids, hasSize(1));
 386         String jobId = uuids.get(0);
 387
 388         assertExpectedStatusAndServiceInfo(JobStatus.COMPLETED, jobId, true, new ServiceInfo(
 389                 "us16807000", JobStatus.COMPLETED, false,
 390                 "d61e6f2d-12fa-4cc2-91df-7c244011d6fc", "WayneHolland", "WATKINS",
 391                 "JAG1", "YUDFJULP-JAG1",
 392                 "092eb9e8e4b7412e8787dd091bc58e86", "USP-SIP-IC-24335-T-01",
 393                 "JANET25", null,
 394                 "TYLER SILVIA", null,
 395                 null, "InstanceName",
 396                 "6b528779-44a3-4472-bdff-9cd15ec93450", "action-data", "1.0",
 397                 jobId, null, ServiceAction.UPDATE, false)
 398         );
 399     }
 400
 401     @Test
 402     public void deleteServiceWithNetwork() {
 403         String deleteNetworkRequestId = UUID.randomUUID().toString();
 404         String deleteServiceRequestId = UUID.randomUUID().toString();
 405         String serviceInstanceId = BaseMSOPreset.DEFAULT_INSTANCE_ID;
 406         String networkInstanceId = "NETWORK_INSTANCE_ID";
 407
 408         registerExpectationFromPresets(ImmutableList.of(
 409                 new PresetMSODeleteNetworkAlaCarteCypress(deleteNetworkRequestId, serviceInstanceId, networkInstanceId, "us16807000"),
 410                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteNetworkRequestId),
 411                 new PresetMSODeleteService(deleteServiceRequestId, serviceInstanceId),
 412                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteServiceRequestId),
 413                 PresetAAIGetCloudOwnersByCloudRegionId.PRESET_MTN6_TO_ATT_AIC
 414         ), RegistrationStrategy.CLEAR_THEN_SET);
 415
 416         List<String> uuids = createBulkOfInstances(false, 1, ImmutableMap.of(), DELETE_SERVICE_WITH_NETWORK);
 417         assertThat(uuids, hasSize(1));
 418         String jobId = uuids.get(0);
 419
 420         assertExpectedStatusAndServiceInfo(JobStatus.COMPLETED, jobId, true, new ServiceInfo(
 421                 "us16807000", JobStatus.COMPLETED, false,
 422                 "d61e6f2d-12fa-4cc2-91df-7c244011d6fc", "WayneHolland", "WATKINS",
 423                 "JAG1", "YUDFJULP-JAG1",
 424                 "092eb9e8e4b7412e8787dd091bc58e86", "USP-SIP-IC-24335-T-01",
 425                 "JANET25", null,
 426                 "TYLER SILVIA", null,
 427                 null, "InstanceName",
 428                 "6b528779-44a3-4472-bdff-9cd15ec93450", "action-data", "1.0",
 429                 jobId, null, ServiceAction.DELETE, false)
 430         );
 431     }
 432
 433     @Test
 434     public void delete1VnfWithVfModulesAndCreate1VnfFromService() {
 435         String deleteVnfRequestId = UUID.randomUUID().toString();
 436         String createVnfRequestId = UUID.randomUUID().toString();
 437         String deleteVfModuleRequestId = UUID.randomUUID().toString();
 438         String deleteBaseVfModuleRequestId = UUID.randomUUID().toString();
 439         String serviceInstanceId = BaseMSOPreset.DEFAULT_INSTANCE_ID;
 440         String vnfInstanceId = "VNF_INSTANCE_ID";
 441
 442         registerExpectationFromPresets(ImmutableList.of(
 443                 new PresetAAIGetSubscribersGet(),
 444                 new PresetMSODeleteVnfAlaCarteCypress(deleteVnfRequestId, serviceInstanceId, vnfInstanceId, "us16807000"),
 445                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteVnfRequestId),
 446                 new PresetSDCGetServiceToscaModelGet("6b528779-44a3-4472-bdff-9cd15ec93450", "csar-withDynamicFields-ecompNamingFalse-partialModelDetails-vnfEcompNamingFalse.zip"),
 447                 new PresetSDCGetServiceMetadataGet("6b528779-44a3-4472-bdff-9cd15ec93450", "e49fbd11-e60c-4a8e-b4bf-30fbe8f4fcc0" , "csar-withDynamicFields-ecompNamingFalse-partialModelDetails-vnfEcompNamingFalse.zip"),
 448                 new PresetMSODeleteVfModuleCypress(deleteVfModuleRequestId, serviceInstanceId, vnfInstanceId, "VF_MODULE_INSTANCE_ID"),
 449                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteVfModuleRequestId),
 450                 new PresetMSODeleteBaseVfModuleCypress(deleteBaseVfModuleRequestId, serviceInstanceId, vnfInstanceId, "VF_MODULE_BASE_INSTANCE_ID"),
 451                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteBaseVfModuleRequestId),
 452                 new PresetMSOCreateVnfALaCarteServiceCypress2(createVnfRequestId, serviceInstanceId, "2017388_PASQUALEvPEmCaNkinstanceName", "zzz1"),
 453                 new PresetMSOOrchestrationRequestGet(COMPLETE, createVnfRequestId),
 454                 PresetAAIGetCloudOwnersByCloudRegionId.PRESET_SOME_LEGACY_REGION_TO_ATT_AIC,
 455                 PresetAAIGetCloudOwnersByCloudRegionId.PRESET_MTN6_TO_ATT_AIC,
 456                 PresetAAIGetCloudOwnersByCloudRegionId.PRESET_AAIAIC25_TO_ATT_AIC
 457         ), RegistrationStrategy.CLEAR_THEN_SET);
 458
 459         List<String> uuids = createBulkOfInstances(false, 1, ImmutableMap.of(), DELETE_AND_CREATE_VNF_FROM_SERVICE);
 460         assertThat(uuids, hasSize(1));
 461         String jobId = uuids.get(0);
 462
 463         assertExpectedStatusAndServiceInfo(JobStatus.COMPLETED, jobId, true, new ServiceInfo(
 464                 "us16807000", JobStatus.COMPLETED, false,
 465                 "d61e6f2d-12fa-4cc2-91df-7c244011d6fc", "WayneHolland", "WATKINS",
 466                 "NFT1", "NFTJSSSS-NFT1",
 467                 "bae71557c5bb4d5aac6743a4e5f1d054", "AIN Web Tool-15-D-testalexandria",
 468                 "hvf6", null,
 469                 "TYLER SILVIA", null,
 470                 "f8791436-8d55-4fde-b4d5-72dd2cf13cfb", "mCaNkinstancename",
 471                 "6b528779-44a3-4472-bdff-9cd15ec93450", "action-data", "1.0",
 472                 jobId, null, ServiceAction.UPDATE, false)
 473         );
 474     }
 475
 476     @Test
 477     public void deleteServiceWithVnf() {
 478         String deleteVnfRequestId = UUID.randomUUID().toString();
 479         String deleteServiceRequestId = UUID.randomUUID().toString();
 480         String serviceInstanceId = BaseMSOPreset.DEFAULT_INSTANCE_ID;
 481         String vnfInstanceId = "VNF_INSTANCE_ID";
 482
 483         registerExpectationFromPresets(ImmutableList.of(
 484                 new PresetMSODeleteVnfAlaCarteCypress(deleteVnfRequestId, serviceInstanceId, vnfInstanceId, "us16807000"),
 485                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteVnfRequestId),
 486                 new PresetMSODeleteService(deleteServiceRequestId, serviceInstanceId),
 487                 new PresetMSOOrchestrationRequestGet(COMPLETE, deleteServiceRequestId),
 488                 PresetAAIGetCloudOwnersByCloudRegionId.PRESET_SOME_LEGACY_REGION_TO_ATT_AIC
 489         ), RegistrationStrategy.CLEAR_THEN_SET);
 490
 491         List<String> uuids = createBulkOfInstances(false, 1, ImmutableMap.of(), DELETE_SERVICE_WITH_VNF);
 492         assertThat(uuids, hasSize(1));
 493         String jobId = uuids.get(0);
 494
 495         assertExpectedStatusAndServiceInfo(JobStatus.COMPLETED, jobId, true, new ServiceInfo(
 496                 "us16807000", JobStatus.COMPLETED, false,
 497                 "d61e6f2d-12fa-4cc2-91df-7c244011d6fc", "WayneHolland", "WATKINS",
 498                 "NFT1", "NFTJSSSS-NFT1",
 499                 "bae71557c5bb4d5aac6743a4e5f1d054", "AIN Web Tool-15-D-testalexandria",
 500                 "hvf6", null,
 501                 "TYLER SILVIA", null,
 502                 "f8791436-8d55-4fde-b4d5-72dd2cf13cfb", "mCaNkinstancename",
 503                 "6b528779-44a3-4472-bdff-9cd15ec93450", "action-data", "1.0",
 504                 jobId, null, ServiceAction.DELETE, false)
 505         );
 506     }
 507
 508     private ImmutableList<JobAuditStatus> vidAuditStatusesInProgress(String jobId) {
 509         return ImmutableList.of(
 510                 vidAuditStatus(jobId, "PENDING", false),
 511                 vidAuditStatus(jobId, "IN_PROGRESS", false)
 512         );
 513     }
 514
 515     private ImmutableList<JobAuditStatus> vidAuditStatusesCompleted(String jobId) {
 516         return ImmutableList.of(
 517                 vidAuditStatus(jobId, "PENDING", false),
 518                 vidAuditStatus(jobId, "IN_PROGRESS", false),
 519                 vidAuditStatus(jobId, "COMPLETED", true)
 520         );
 521     }
 522
 523     private ImmutableList<JobAuditStatus> vidAuditStatuses(String jobId, JobStatus jobStatus) {
 524         switch(jobStatus) {
 525             case COMPLETED:
 526                 return vidAuditStatusesCompleted(jobId);
 527             case COMPLETED_WITH_ERRORS:
 528                 return vidAuditStatusesCompletedWithErrors(jobId);
 529             case FAILED:
 530                 return vidAuditStatusesFailed(jobId);
 531             case IN_PROGRESS:
 532                 return vidAuditStatusesInProgress(jobId);
 533         }
 534
 535         return null;
 536     }
 537
 538     private ImmutableList<JobAuditStatus> msoAuditStatuses(String jobId , String lastStatus, String lastAdditionalInfo) {
 539         final List<JobAuditStatus> auditMsoStatuses = getAuditStatuses(jobId, SourceStatus.MSO.name());
 540         final UUID actualRequestId = auditMsoStatuses.get(0).getRequestId();
 541         return ImmutableList.of(
 542                 msoAuditStatus(jobId, "REQUESTED", null, actualRequestId),
 543                 msoAuditStatus(jobId, lastStatus, lastAdditionalInfo, actualRequestId)
 544         );
 545     }
 546
 547     private JobAuditStatus msoAuditStatus(String jobId, String jobStatus, String additionalInfo, UUID requestId) {
 548         return new JobAuditStatus(UUID.fromString(jobId), jobStatus, SourceStatus.MSO, requestId, additionalInfo, false);
 549     }
 550
 551     private void assertServiceInfoSpecific3(String jobId, JobStatus jobStatus, String serviceInstanceName) {
 552         assertExpectedStatusAndServiceInfo(jobStatus, jobId, true, new ServiceInfo(
 553                 "us16807000", jobStatus, false,
 554                 "aaa1", "aaa1", "yyy1",
 555                 "YYY1", "UUUAIAAI-YYY1",
 556                 "1178612d2b394be4834ad77f567c0af2", "AIN Web Tool-15-D-SSPtestcustome",
 557                 "hvf6", null,
 558                 "TYLER SILVIA", null,
 559                 null, serviceInstanceName,
 560                 "6e59c5de-f052-46fa-aa7e-2fca9d674c44", "ComplexService", "1.0",
 561                 jobId, null, ServiceAction.INSTANTIATE, false)
 562         );
 563     }
 564
 565     private List<BasePreset> getGroupMembersPresets(List<PresetMSOAddOrRemoveOneInstanceGroupMember> deleteMembersPreset, List<PresetMSOOrchestrationRequestGet> inProgressPresets) {
 566         final ImmutableList.Builder<BasePreset> basePresetBuilder = new ImmutableList.Builder<>();
 567         basePresetBuilder
 568                 .add(new PresetGetSessionSlotCheckIntervalGet())
 569                 .add(new PresetAAIGetSubscribersGet())
 570                 .addAll(deleteMembersPreset)
 571                 .addAll(inProgressPresets);
 572         return basePresetBuilder.build();
 573     }
 574
 575
 576     enum Scenario {
 577         PARALLEL, COMPLETED, NAME_TAKEN, DUPLICATE_NAME, IN_PROGRESS, MSO_FAIL
 578     }
 579
 580     class OneServiceActor {
 581         private final boolean isRelevant;
 582         private final String requestId;
 583         private final String msoInfo;
 584         private final Map<PresetMSOServiceInstanceGen2WithNames.Keys, String> serviceNames;
 585         private final int suffix;
 586         private final String expectedMsoLastStatus;
 587         private final JobStatus jobStatus;
 588         private final Function<String, List<JobAuditStatus>> jobAuditStatusesProvider;
 589         private String jobId;
 590         private int startedHoursAgo = 1;
 591         private List<BasePreset> morePresets = ImmutableList.of();
 592
 593         private OneServiceActor(boolean isRelevant, String msoLastStatus, String msoInfo, Map<PresetMSOServiceInstanceGen2WithNames.Keys, String> serviceNames, int suffix, JobStatus jobStatus, Function<String, List<JobAuditStatus>> jobAuditStatusesProvider) {
 594             this.isRelevant = isRelevant;
 595             this.requestId = UUID.randomUUID().toString();
 596             this.msoInfo = msoInfo;
 597             this.serviceNames = serviceNames;
 598             this.suffix = suffix;
 599             this.expectedMsoLastStatus = msoLastStatus;
 600             this.jobStatus = jobStatus;
 601             this.jobAuditStatusesProvider = jobAuditStatusesProvider;
 602         }
 603
 604         private OneServiceActor(boolean isRelevant, String msoLastStatus, String msoInfo, Map<PresetMSOServiceInstanceGen2WithNames.Keys, String> serviceNames, int suffix, JobStatus jobStatus, Function<String, List<JobAuditStatus>> jobAuditStatusesProvider, int startedHoursAgo) {
 605             this(isRelevant, msoLastStatus, msoInfo, serviceNames, suffix, jobStatus,  jobAuditStatusesProvider);
 606             this.startedHoursAgo = startedHoursAgo;
 607         }
 608
 609         private OneServiceActor(boolean isRelevant, String msoLastStatus, String msoInfo, Map<PresetMSOServiceInstanceGen2WithNames.Keys, String> serviceNames, int suffix, JobStatus jobStatus, Function<String, List<JobAuditStatus>> jobAuditStatusesProvider, List<BasePreset> morePresets) {
 610             this(isRelevant, msoLastStatus, msoInfo, serviceNames, suffix, jobStatus,  jobAuditStatusesProvider);
 611             this.morePresets = morePresets;
 612         }
 613
 614         public List<BasePreset> getPresets() {
 615             // if not relevant -> return empty list
 616             return isRelevant ?
 617                     ImmutableList.<BasePreset>builder().add(
 618                             new PresetMSOCreateServiceInstanceGen2WithNamesAlacarteService(serviceNames, suffix, requestId),
 619                             new PresetMSOOrchestrationRequestGet(expectedMsoLastStatus, requestId, msoInfo, startedHoursAgo)
 620                     ).addAll(morePresets).build()
 621                     : ImmutableList.of();
 622         }
 623
 624         private void createInstances() {
 625             // call VID with 1 request, keep the job id
 626             if (!isRelevant) return;
 627             final List<String> jobIds = createBulkOfInstances(false, 1, serviceNames, CREATE_BULK_OF_ALACARTE_REQUEST);
 628             assertThat(jobIds, hasSize(1));
 629             jobId = jobIds.get(0);
 630         }
 631
 632         private void assertServiceInfo() {
 633             if (!isRelevant) return;
 634             assertThat(jobId, is(not(nullValue())));
 635             assertServiceInfoSpecific1(jobId, jobStatus, serviceNames.get(SERVICE_NAME));
 636         }
 637
 638         private void assertAuditStatuses2() {
 639             if (!isRelevant) return;
 640             assertThat(jobId, is(not(nullValue())));
 641             assertAuditStatuses(jobId, jobAuditStatusesProvider.apply(jobId), msoAuditStatuses(jobId, expectedMsoLastStatus, msoInfo));
 642         }
 643     }
 644
 645 }