Enhance naming service support 39/89539/1
authorMnushkin, Dmitry <dmitry.mnushkin@att.com>
Thu, 6 Jun 2019 19:34:19 +0000 (15:34 -0400)
committerBenjamin, Max (mb388a) <mb388a@us.att.com>
Thu, 6 Jun 2019 19:44:00 +0000 (15:44 -0400)
correct sourcing for service-model-name in NamingMS
remove zone ID from NamingMS input for service name
follow up removal of autowired on NamingRequestObject

Change-Id: Icba2e32c07ee0c7d7739ce21bd547e3030c1e271
Issue-ID: SO-1976
Signed-off-by: Benjamin, Max (mb388a) <mb388a@us.att.com>
bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasks.java
bpmn/so-bpmn-tasks/src/test/java/org/onap/so/bpmn/infrastructure/namingservice/tasks/NamingServiceCreateTasksTest.java
bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/namingservice/NamingRequestObjectTest.java
bpmn/so-bpmn-tasks/src/test/java/org/onap/so/client/orchestration/NamingServiceResourcesTest.java

index df22cfd..155455e 100644 (file)
@@ -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;
-    }
 }
index 3f62a61..44e5e0e 100644 (file)
@@ -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);
-    }
 }
index 49f858d..7c50b20 100644 (file)
@@ -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));
index 1f5b42b..c60e749 100644 (file)
@@ -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));
+    }
 }