diff options
6 files changed, 15 insertions, 81 deletions
diff --git a/adapters/mso-adapter-utils/src/main/java/org/onap/so/openstack/utils/MsoHeatUtils.java b/adapters/mso-adapter-utils/src/main/java/org/onap/so/openstack/utils/MsoHeatUtils.java index bf6374bc2f..7778e53ee3 100644 --- a/adapters/mso-adapter-utils/src/main/java/org/onap/so/openstack/utils/MsoHeatUtils.java +++ b/adapters/mso-adapter-utils/src/main/java/org/onap/so/openstack/utils/MsoHeatUtils.java @@ -326,7 +326,7 @@ public class MsoHeatUtils extends MsoCommonUtils implements VduPlugin { Stack latestStack = null; while (true) { latestStack = queryHeatStack(heatClient, stack.getStackName() + "/" + stack.getId()); - statusHandler.updateStackStatus(stack); + statusHandler.updateStackStatus(latestStack); logger.debug("Polling: {} ({})", latestStack.getStackStatus(), latestStack.getStackName()); if (stackStatus.equals(latestStack.getStackStatus())) { if (numberOfPollingAttempts <= 0) { diff --git a/adapters/mso-adapter-utils/src/test/java/org/onap/so/openstack/utils/MsoHeatUtilsTest.java b/adapters/mso-adapter-utils/src/test/java/org/onap/so/openstack/utils/MsoHeatUtilsTest.java index 5a2515a81e..9f577d8679 100644 --- a/adapters/mso-adapter-utils/src/test/java/org/onap/so/openstack/utils/MsoHeatUtilsTest.java +++ b/adapters/mso-adapter-utils/src/test/java/org/onap/so/openstack/utils/MsoHeatUtilsTest.java @@ -126,7 +126,7 @@ public class MsoHeatUtilsTest extends MsoHeatUtils { doReturn(latestStack).when(heatUtils).queryHeatStack(isA(Heat.class), eq("stackName/id")); doReturn(heatClient).when(heatUtils).getHeatClient(cloudSiteId, tenantId); Stack actual = heatUtils.pollStackForStatus(1, stack, "CREATE_IN_PROGRESS", cloudSiteId, tenantId); - Mockito.verify(stackStatusHandler, times(1)).updateStackStatus(stack); + Mockito.verify(stackStatusHandler, times(1)).updateStackStatus(latestStack); Mockito.verify(heatUtils, times(1)).queryHeatStack(isA(Heat.class), eq("stackName/id")); assertEquals(true, actual != null); } diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasks.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasks.java index df22cfdc26..155455e654 100644 --- a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasks.java +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasks.java @@ -20,7 +20,6 @@ package org.onap.so.bpmn.infrastructure.namingservice.tasks; - import java.util.List; import java.util.Optional; import org.onap.aai.domain.yang.Zone; @@ -89,7 +88,6 @@ public class NamingServiceCreateTasks { namingRequestObject.setPolicyInstanceNameValue(serviceInstance.getModelInfoServiceInstance().getNamingPolicy()); namingRequestObject.setServiceModelNameValue(serviceInstance.getModelInfoServiceInstance().getModelName()); namingRequestObject.setModelVersionValue(serviceInstance.getModelInfoServiceInstance().getModelVersion()); - namingRequestObject.setZoneIdValue(this.getRelatedZoneId(execution)); String generatedWanTransportServiceName = ""; try { @@ -122,44 +120,4 @@ public class NamingServiceCreateTasks { } serviceInstance.setServiceInstanceName(generatedVpnBondingServiceName); } - - protected String getRelatedZoneId(BuildingBlockExecution execution) { - GeneralBuildingBlock gBBInput = execution.getGeneralBuildingBlock(); - String cloudRegionId = gBBInput.getCloudRegion().getLcpCloudRegionId(); - String cloudOwner = gBBInput.getCloudRegion().getCloudOwner(); - AAIResourceUri uri = AAIUriFactory.createResourceUri(AAIObjectType.CLOUD_REGION, cloudOwner, cloudRegionId); - AAIResultWrapper vnfcResultsWrapper = bbInputSetupUtils.getAAIResourceDepthOne(uri); - Optional<Relationships> relationshipsOp = this.getRelationshipsFromWrapper(vnfcResultsWrapper); - Zone aaiZone = getRelatedZone(relationshipsOp); - if (aaiZone == null) { - String errMsg = "No relationships for Cloud Region in AAI to extract zone id"; - exceptionUtil.buildAndThrowWorkflowException(execution, 7000, errMsg); - } - return aaiZone.getZoneId(); - } - - protected Optional<Relationships> getRelationshipsFromWrapper(AAIResultWrapper wrapper) { - Optional<Relationships> relationshipsOp; - relationshipsOp = wrapper.getRelationships(); - if (relationshipsOp.isPresent()) { - return relationshipsOp; - } - return Optional.empty(); - } - - protected org.onap.aai.domain.yang.Zone getRelatedZone(Optional<Relationships> relationshipsOp) { - Zone aaiZone = null; - if (relationshipsOp.isPresent()) { - Relationships relationships = relationshipsOp.get(); - if (!relationships.getAll().isEmpty()) { - List<AAIResultWrapper> zones = relationships.getByType(AAIObjectType.ZONE); - AAIResultWrapper zoneWrapper = zones.get(0); - Optional<Zone> aaiZoneOp = zoneWrapper.asBean(Zone.class); - if (aaiZoneOp.isPresent()) { - aaiZone = aaiZoneOp.get(); - } - } - } - return aaiZone; - } } diff --git a/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasksTest.java b/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasksTest.java index 3f62a61518..44e5e0e707 100644 --- a/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasksTest.java +++ b/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasksTest.java @@ -106,7 +106,7 @@ public class NamingServiceCreateTasksTest extends BaseTaskTest { String generatedName = "generatedWanTransportServiceName"; doReturn(generatedName).when(namingServiceResources).generateServiceInstanceName(any()); NamingServiceCreateTasks spy = Mockito.spy(namingServiceCreateTasks); - doReturn("testZoneId").when(spy).getRelatedZoneId(any()); + spy.createWanTransportServiceName(execution); verify(namingServiceResources, times(1)).generateServiceInstanceName(any()); assertEquals(generatedName, serviceInstance.getServiceInstanceName()); @@ -124,37 +124,4 @@ public class NamingServiceCreateTasksTest extends BaseTaskTest { verify(namingServiceResources, times(1)).generateServiceInstanceName(any()); assertEquals(generatedName, serviceInstance.getServiceInstanceName()); } - - @Test - public void getRelatedZoneIdTest() throws Exception { - - String zoneId = "zoneId"; - Zone zone = new Zone(); - zone.setZoneId(zoneId); - - CloudRegion cloudRegion = new CloudRegion(); - cloudRegion.setCloudOwner("testCloudOwner"); - cloudRegion.setLcpCloudRegionId("testLcpCloudRegionId"); - GeneralBuildingBlock gBBInput = execution.getGeneralBuildingBlock(); - gBBInput.setCloudRegion(cloudRegion); - - AAIResultWrapper cloudRegionWrapper = - new AAIResultWrapper(new AAICommonObjectMapperProvider().getMapper().writeValueAsString(cloudRegion)); - - Relationships relationships = Mockito.mock(Relationships.class); - relationships.getAll().add(cloudRegionWrapper); - Optional<Relationships> relationshipsOp = Optional.of(relationships); - - doReturn(cloudRegionWrapper).when(MOCK_bbInputSetupUtils).getAAIResourceDepthOne(any()); - - NamingServiceCreateTasks spy = Mockito.spy(namingServiceCreateTasks); - - doReturn(relationshipsOp).when(spy).getRelationshipsFromWrapper(isA(AAIResultWrapper.class)); - doReturn(zone).when(spy).getRelatedZone(any()); - spy.setBbInputSetupUtils(MOCK_bbInputSetupUtils); - - String returnedZoneId = spy.getRelatedZoneId(execution); - - assertEquals(zoneId, returnedZoneId); - } } diff --git a/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/namingservice/NamingRequestObjectTest.java b/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/namingservice/NamingRequestObjectTest.java index 49f858d2ce..7c50b2031d 100644 --- a/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/namingservice/NamingRequestObjectTest.java +++ b/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/namingservice/NamingRequestObjectTest.java @@ -35,7 +35,6 @@ public class NamingRequestObjectTest { private String resourceName = "resourceName"; private String serviceModelName = "serviceModelName"; private String modelVersion = "modelVersion"; - private String zoneId = "zoneId"; @Test public void namingRequestObjectTest() { @@ -68,7 +67,6 @@ public class NamingRequestObjectTest { expected.put(NamingServiceConstants.NS_RESOURCE_NAME, resourceName); expected.put(NamingServiceConstants.NS_SERVICE_MODEL_NAME, serviceModelName); expected.put(NamingServiceConstants.NS_MODEL_VERSION, modelVersion); - expected.put(NamingServiceConstants.NS_ZONE_ID, zoneId); NamingRequestObject namingRequestObject = new NamingRequestObject(); namingRequestObject.setExternalKeyValue(externalKey); @@ -77,7 +75,6 @@ public class NamingRequestObjectTest { namingRequestObject.setResourceNameValue(resourceName); namingRequestObject.setModelVersionValue(modelVersion); namingRequestObject.setServiceModelNameValue(serviceModelName); - namingRequestObject.setZoneIdValue(zoneId); HashMap<String, String> actual = namingRequestObject.getNamingRequestObjectMap(); assertThat(actual, sameBeanAs(expected)); diff --git a/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/orchestration/NamingServiceResourcesTest.java b/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/orchestration/NamingServiceResourcesTest.java index 1f5b42b94e..c60e749a29 100644 --- a/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/orchestration/NamingServiceResourcesTest.java +++ b/bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/orchestration/NamingServiceResourcesTest.java @@ -123,4 +123,16 @@ public class NamingServiceResourcesTest extends TestDataSetup { verify(MOCK_namingClient, times(1)).postNameGenRequest(any(NameGenRequest.class)); assertEquals("generatedServiceInstanceName", generatedName); } + + @Test + public void deleteServiceInstanceNameTest() throws Exception { + NameGenDeleteRequest req = new NameGenDeleteRequest(); + doReturn(req).when(MOCK_namingRequestObjectBuilder).nameGenDeleteRequestMapper(isA(List.class)); + + NamingRequestObject nrObject = new NamingRequestObject(); + nrObject.setExternalKeyValue("testExternalKey"); + nrObject.setNamingTypeValue(NamingServiceConstants.NAMING_TYPE_SERVICE); + namingServiceResources.deleteServiceInstanceName(nrObject); + verify(MOCK_namingClient, times(1)).deleteNameGenRequest(any(NameGenDeleteRequest.class)); + } } |