diff options
Diffstat (limited to 'so-simulator/src/main')
5 files changed, 30 insertions, 48 deletions
diff --git a/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/DeleteVServers.java b/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/DeleteVServers.java index 27d4ce78fd..56b27a1aea 100644 --- a/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/DeleteVServers.java +++ b/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/DeleteVServers.java @@ -1,9 +1,9 @@ package org.onap.so.simulator.actions.aai; -import org.onap.aaiclient.client.aai.AAIObjectType; import org.onap.aaiclient.client.aai.AAIResourcesClient; import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri; import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory; +import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.consol.citrus.actions.AbstractTestAction; @@ -23,8 +23,8 @@ public class DeleteVServers extends AbstractTestAction { String cloudRegion = context.getVariable("cloudRegion"); String cloudOwner = context.getVariable("cloudOwner"); String tenantId = context.getVariable("tenantId"); - AAIResourceUri vserverURI = AAIUriFactory.createResourceUri(AAIObjectType.VSERVER, cloudOwner, cloudRegion, - tenantId, vserverId); + AAIResourceUri vserverURI = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.cloudInfrastructure() + .cloudRegion(cloudOwner, cloudRegion).tenant(tenantId).vserver(vserverId)); aaiResourceClient.delete(vserverURI); logger.error("Delete Vservers in AAI: {}", vserverURI); } catch (Exception e) { diff --git a/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessNetwork.java b/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessNetwork.java index 21f9528f0f..b42441bcae 100644 --- a/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessNetwork.java +++ b/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessNetwork.java @@ -1,10 +1,10 @@ package org.onap.so.simulator.actions.aai; import org.onap.aai.domain.yang.L3Network; -import org.onap.aaiclient.client.aai.AAIObjectType; import org.onap.aaiclient.client.aai.AAIResourcesClient; import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri; import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory; +import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.consol.citrus.actions.AbstractTestAction; @@ -23,7 +23,8 @@ public class ProcessNetwork extends AbstractTestAction { if (context.getVariable("action").equals("assign")) { String networkId = context.getVariable("generatedNetworkId"); - AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, networkId); + AAIResourceUri networkURI = + AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().l3Network(networkId)); L3Network network = new L3Network(); network.setNetworkId(networkId); network.setNetworkName(context.getVariable("networkName")); @@ -33,7 +34,8 @@ public class ProcessNetwork extends AbstractTestAction { aaiResourceClient.create(networkURI, network); } else if (context.getVariable("action").equals("delete")) { String networkId = context.getVariable("networkId"); - AAIResourceUri networkURI = AAIUriFactory.createResourceUri(AAIObjectType.L3_NETWORK, networkId); + AAIResourceUri networkURI = + AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().l3Network(networkId)); aaiResourceClient.delete(networkURI); } } catch (Exception e) { diff --git a/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessVnfc.java b/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessVnfc.java index 954ebdd013..edf212429c 100644 --- a/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessVnfc.java +++ b/so-simulator/src/main/java/org/onap/so/simulator/actions/aai/ProcessVnfc.java @@ -1,18 +1,12 @@ package org.onap.so.simulator.actions.aai; -import java.io.InputStream; -import java.util.List; import org.onap.aai.domain.yang.Vnfc; -import org.onap.aai.domain.yang.Vserver; -import org.onap.aaiclient.client.aai.AAICommonObjectMapperProvider; -import org.onap.aaiclient.client.aai.AAIObjectType; import org.onap.aaiclient.client.aai.AAIResourcesClient; -import org.onap.aaiclient.client.aai.entities.Relationships; import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri; import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory; +import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.core.io.ClassPathResource; import com.consol.citrus.actions.AbstractTestAction; import com.consol.citrus.context.TestContext; @@ -35,11 +29,13 @@ public class ProcessVnfc extends AbstractTestAction { AAIResourcesClient aaiResourceClient = new AAIResourcesClient(); if (context.getVariable("requestAction").equals("CreateVfModuleInstance") - && context.getVariable("serviceAction").equals("assign")) { + && context.getVariable("serviceAction").equals("assign") + && context.getVariable("vfModuleName").equals("nc_dummy_id")) { - AAIResourceUri vnfcURI = AAIUriFactory.createResourceUri(AAIObjectType.VNFC, "zauk51bfrwl09oam001"); + AAIResourceUri vnfcURI = + AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network().vnfc("ssc_server_1")); Vnfc vnfc = new Vnfc(); - vnfc.setVnfcName("zauk51bfrwl09oam001"); + vnfc.setVnfcName("ssc_server_1"); vnfc.setNfcNamingCode("oamfw"); vnfc.setNfcFunction("EPC-OAM-FIREWALL"); vnfc.setProvStatus("PREPROV"); @@ -51,38 +47,20 @@ public class ProcessVnfc extends AbstractTestAction { vnfc.setModelVersionId("9e314c37-2258-4572-a399-c0dd7d5f1aec"); vnfc.setModelCustomizationId("2bd95cd4-d7ff-4af0-985d-2adea0339921"); - if (!aaiResourceClient.exists(vnfcURI)) + if (!aaiResourceClient.exists(vnfcURI)) { + logger.debug("creating VNFC"); aaiResourceClient.create(vnfcURI, vnfc); - AAIResourceUri vfModuleURI = AAIUriFactory.createResourceUri(AAIObjectType.VF_MODULE, - context.getVariable("vnfId"), context.getVariable("vfModuleId")); - AAIResourceUri pserverURI = AAIUriFactory.createResourceUri(AAIObjectType.PSERVER, "test"); - AAIResourceUri vserverURI = AAIUriFactory.createResourceUri(AAIObjectType.VSERVER, - context.getVariable("cloudOwner"), context.getVariable("cloudRegion"), - context.getVariable("tenant"), "d29f3151-592d-4011-9356-ad047794e236"); - aaiResourceClient.connect(vnfcURI, vserverURI); - aaiResourceClient.connect(vserverURI, pserverURI); - aaiResourceClient.connect(vfModuleURI, vnfcURI); - } else if (context.getVariable("requestAction").equals("CreateVfModuleInstance") - && context.getVariable("serviceAction").equals("activate")) { - // For recreate after soft delete - AAIResourceUri vnfcURI = AAIUriFactory.createResourceUri(AAIObjectType.VNFC, "zauk51bfrwl09oam001"); - AAIResourceUri vserverURI = AAIUriFactory.createResourceUri(AAIObjectType.VSERVER, - context.getVariable("cloudOwner"), context.getVariable("cloudRegion"), - context.getVariable("tenant"), "d29f3151-592d-4011-9356-ad047794e236"); - Relationships relationships = aaiResourceClient.get(vnfcURI).getRelationships().get(); - List<AAIResourceUri> uris = relationships.getRelatedUris(AAIObjectType.VSERVER); - if (uris.isEmpty() || uris.size() == 0) { - if (!aaiResourceClient.exists(vserverURI)) { - AAICommonObjectMapperProvider aaiMapper = new AAICommonObjectMapperProvider(); - InputStream vserverFile = - new ClassPathResource("openstack/gr_api/CreateVserver.json").getInputStream(); - Vserver vserver = aaiMapper.getMapper().readValue(vserverFile, Vserver.class); - aaiResourceClient.create(vserverURI, vserver); - } - aaiResourceClient.connect(vnfcURI, vserverURI); + + } else { + aaiResourceClient.get(vnfcURI); } + AAIResourceUri vfModuleURI = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.network() + .genericVnf(context.getVariable("vnfId")).vfModule(context.getVariable("vfModuleId"))); + logger.debug("creating VNFC edge to vf module"); + aaiResourceClient.connect(vfModuleURI, vnfcURI); } + } catch (Exception e) { logger.debug("Exception in ProcessVnfc.doExecute", e); } diff --git a/so-simulator/src/main/java/org/onap/so/simulator/scenarios/openstack/CreateAAInventory.java b/so-simulator/src/main/java/org/onap/so/simulator/scenarios/openstack/CreateAAInventory.java index 371c72dca9..aa54a7a996 100644 --- a/so-simulator/src/main/java/org/onap/so/simulator/scenarios/openstack/CreateAAInventory.java +++ b/so-simulator/src/main/java/org/onap/so/simulator/scenarios/openstack/CreateAAInventory.java @@ -3,10 +3,10 @@ package org.onap.so.simulator.scenarios.openstack; import java.io.InputStream; import org.onap.aai.domain.yang.Vserver; import org.onap.aaiclient.client.aai.AAICommonObjectMapperProvider; -import org.onap.aaiclient.client.aai.AAIObjectType; import org.onap.aaiclient.client.aai.AAIResourcesClient; import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri; import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory; +import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.core.io.ClassPathResource; @@ -29,8 +29,9 @@ public class CreateAAInventory extends AbstractTestAction { InputStream vserverFile = new ClassPathResource("openstack/gr_api/CreateAAIInventory.json").getInputStream(); Vserver vserver = aaiMapper.getMapper().readValue(vserverFile, Vserver.class); - AAIResourceUri vserverURI = AAIUriFactory.createResourceUri(AAIObjectType.VSERVER, "cloudOwner", - "regionOne", "0422ffb57ba042c0800a29dc85ca70f8", vServerId); + AAIResourceUri vserverURI = AAIUriFactory.createResourceUri( + AAIFluentTypeBuilder.cloudInfrastructure().cloudRegion("cloudOwner", "regionOne") + .tenant("0422ffb57ba042c0800a29dc85ca70f8").vserver(vServerId)); aaiResourceClient.create(vserverURI, vserver); } } catch (Exception e) { diff --git a/so-simulator/src/main/resources/openstack/gr_api/GetNeutronNetwork2.json b/so-simulator/src/main/resources/openstack/gr_api/GetNeutronNetwork2.json index 725c896b8d..773400e8f6 100644 --- a/so-simulator/src/main/resources/openstack/gr_api/GetNeutronNetwork2.json +++ b/so-simulator/src/main/resources/openstack/gr_api/GetNeutronNetwork2.json @@ -24,7 +24,8 @@ ], "physical_network": "sriovnet1", "pci_slot": "0000:5e:05.6", - "pci_vendor_info": "8086:154c" + "pci_vendor_info": "8086:154c", + "host_id": "50197c55fc934e7b3947e17db762f0839320f94983df774d84991ad2" }, "fixed_ips": [ { |