252 lines
11 KiB
Java
252 lines
11 KiB
Java
/**
|
|
*
|
|
*/
|
|
package org.gcube.informationsystem.resourceregistry.publisher.old;
|
|
|
|
import java.util.List;
|
|
import java.util.UUID;
|
|
|
|
import org.gcube.informationsystem.model.reference.entities.Facet;
|
|
import org.gcube.informationsystem.model.reference.entities.Resource;
|
|
import org.gcube.informationsystem.model.reference.relations.ConsistsOf;
|
|
import org.gcube.informationsystem.resourceregistry.publisher.ContextTest;
|
|
import org.gcube.informationsystem.resourceregistry.publisher.ResourceRegistryPublisher;
|
|
import org.gcube.informationsystem.resourceregistry.publisher.ResourceRegistryPublisherFactory;
|
|
import org.gcube.informationsystem.resourceregistry.publisher.ResourceRegistryPublisherImpl;
|
|
import org.gcube.informationsystem.serialization.ElementMapper;
|
|
import org.gcube.resourcemanagement.model.impl.entities.facets.CPUFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entities.facets.NetworkingFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entities.facets.SoftwareFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entities.resources.EServiceImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entities.resources.HostingNodeImpl;
|
|
import org.gcube.resourcemanagement.model.impl.relations.consistsof.IsIdentifiedByImpl;
|
|
import org.gcube.resourcemanagement.model.impl.relations.isrelatedto.ActivatesImpl;
|
|
import org.gcube.resourcemanagement.model.reference.entities.facets.CPUFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entities.facets.NetworkingFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entities.facets.SoftwareFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entities.resources.EService;
|
|
import org.gcube.resourcemanagement.model.reference.entities.resources.HostingNode;
|
|
import org.gcube.resourcemanagement.model.reference.relations.consistsof.IsIdentifiedBy;
|
|
import org.gcube.resourcemanagement.model.reference.relations.isrelatedto.Activates;
|
|
import org.junit.Assert;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
/**
|
|
* @author Luca Frosini (ISTI - CNR)
|
|
*/
|
|
public class EntityManagementTest extends ContextTest {
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(EntityManagementTest.class);
|
|
|
|
protected ResourceRegistryPublisher resourceRegistryPublisher;
|
|
|
|
public EntityManagementTest(){
|
|
Object rrURLOBj = ContextTest.properties.get(RESOURCE_REGISTRY_URL_PROPERTY);
|
|
if(rrURLOBj!=null && !rrURLOBj.toString().isEmpty()) {
|
|
resourceRegistryPublisher = new ResourceRegistryPublisherImpl(rrURLOBj.toString());
|
|
}else {
|
|
resourceRegistryPublisher = ResourceRegistryPublisherFactory.create();
|
|
}
|
|
}
|
|
|
|
//@Test
|
|
public void testCreateUpdateDeleteFacet() throws Exception {
|
|
CPUFacet cpuFacet = new CPUFacetImpl();
|
|
cpuFacet.setClockSpeed("1 GHz");
|
|
cpuFacet.setModel("Opteron");
|
|
cpuFacet.setVendor("AMD");
|
|
|
|
CPUFacet createdCpuFacet = resourceRegistryPublisher.createFacet(cpuFacet);
|
|
|
|
Assert.assertTrue(cpuFacet.getClockSpeed().compareTo(createdCpuFacet.getClockSpeed())==0);
|
|
Assert.assertTrue(cpuFacet.getModel().compareTo(createdCpuFacet.getModel())==0);
|
|
Assert.assertTrue(cpuFacet.getVendor().compareTo(createdCpuFacet.getVendor())==0);
|
|
|
|
UUID uuid = createdCpuFacet.getID();
|
|
|
|
String newVendor = "Intel";
|
|
String newClockSpeed = "2 GHz";
|
|
createdCpuFacet.setVendor(newVendor);
|
|
createdCpuFacet.setClockSpeed(newClockSpeed);
|
|
|
|
String additionPropertyKey = "My";
|
|
String additionPropertyValue = "Test";
|
|
createdCpuFacet.setAdditionalProperty(additionPropertyKey, additionPropertyValue);
|
|
|
|
CPUFacet updatedCpuFacet = resourceRegistryPublisher.updateFacet(createdCpuFacet);
|
|
Assert.assertTrue(createdCpuFacet.getClockSpeed().compareTo(updatedCpuFacet.getClockSpeed())==0);
|
|
Assert.assertTrue(createdCpuFacet.getModel().compareTo(updatedCpuFacet.getModel())==0);
|
|
Assert.assertTrue(createdCpuFacet.getVendor().compareTo(updatedCpuFacet.getVendor())==0);
|
|
Assert.assertTrue(((String) updatedCpuFacet.getAdditionalProperty(additionPropertyKey)).compareTo((String) createdCpuFacet.getAdditionalProperty(additionPropertyKey))==0);
|
|
Assert.assertTrue(uuid.compareTo(updatedCpuFacet.getID())==0);
|
|
|
|
boolean deleted = resourceRegistryPublisher.deleteFacet(updatedCpuFacet);
|
|
Assert.assertTrue(deleted);
|
|
}
|
|
|
|
//@Test
|
|
public void testCreateUpdateDeleteFacetStringAPI() throws Exception {
|
|
CPUFacet cpuFacet = new CPUFacetImpl();
|
|
cpuFacet.setClockSpeed("1 GHz");
|
|
cpuFacet.setModel("Opteron");
|
|
cpuFacet.setVendor("AMD");
|
|
|
|
String createdCpuFacetString = resourceRegistryPublisher.createFacet(ElementMapper.marshal(cpuFacet));
|
|
|
|
CPUFacet createdCpuFacet = ElementMapper.unmarshal(CPUFacet.class, createdCpuFacetString);
|
|
|
|
Assert.assertTrue(cpuFacet.getClockSpeed().compareTo(createdCpuFacet.getClockSpeed())==0);
|
|
Assert.assertTrue(cpuFacet.getModel().compareTo(createdCpuFacet.getModel())==0);
|
|
Assert.assertTrue(cpuFacet.getVendor().compareTo(createdCpuFacet.getVendor())==0);
|
|
|
|
UUID uuid = createdCpuFacet.getID();
|
|
|
|
String newVendor = "Intel";
|
|
String newClockSpeed = "2 GHz";
|
|
createdCpuFacet.setVendor(newVendor);
|
|
createdCpuFacet.setClockSpeed(newClockSpeed);
|
|
|
|
String additionPropertyKey = "My";
|
|
String additionPropertyValue = "Test";
|
|
createdCpuFacet.setAdditionalProperty(additionPropertyKey, additionPropertyValue);
|
|
|
|
String updatedCpuFacetString = resourceRegistryPublisher.updateFacet(ElementMapper.marshal(createdCpuFacet));
|
|
|
|
CPUFacet updatedCpuFacet = ElementMapper.unmarshal(CPUFacet.class, updatedCpuFacetString);
|
|
Assert.assertTrue(createdCpuFacet.getClockSpeed().compareTo(updatedCpuFacet.getClockSpeed())==0);
|
|
Assert.assertTrue(createdCpuFacet.getModel().compareTo(updatedCpuFacet.getModel())==0);
|
|
Assert.assertTrue(createdCpuFacet.getVendor().compareTo(updatedCpuFacet.getVendor())==0);
|
|
Assert.assertTrue(((String) updatedCpuFacet.getAdditionalProperty(additionPropertyKey)).compareTo((String) createdCpuFacet.getAdditionalProperty(additionPropertyKey))==0);
|
|
Assert.assertTrue(uuid.compareTo(updatedCpuFacet.getID())==0);
|
|
|
|
boolean deleted = resourceRegistryPublisher.deleteFacet(updatedCpuFacet);
|
|
Assert.assertTrue(deleted);
|
|
}
|
|
|
|
//@Test
|
|
public void testCreateDeleteResources() throws Exception {
|
|
|
|
EService eService = new EServiceImpl();
|
|
|
|
SoftwareFacet softwareFacet = new SoftwareFacetImpl();
|
|
softwareFacet.setGroup("InformationSystem");
|
|
softwareFacet.setName("resource-registry");
|
|
softwareFacet.setVersion("1.1.0");
|
|
|
|
IsIdentifiedBy<EService, SoftwareFacet> isIdentifiedByESSF = new IsIdentifiedByImpl<>(eService, softwareFacet, null);
|
|
eService.addFacet(isIdentifiedByESSF);
|
|
|
|
EService createdEService = resourceRegistryPublisher.createResource(eService);
|
|
|
|
List<? extends Facet> idenficationFacets = createdEService.getIdentificationFacets();
|
|
Assert.assertTrue(idenficationFacets!=null);
|
|
Assert.assertTrue(idenficationFacets.size()==1);
|
|
Facet f = idenficationFacets.get(0);
|
|
Assert.assertTrue(f!=null);
|
|
Assert.assertTrue(SoftwareFacet.class.isAssignableFrom(f.getClass()));
|
|
SoftwareFacet createdSoftwareFacet = (SoftwareFacet) f;
|
|
logger.debug("Created : {}", softwareFacet);
|
|
Assert.assertTrue(createdSoftwareFacet.getGroup().compareTo(softwareFacet.getGroup())==0);
|
|
Assert.assertTrue(createdSoftwareFacet.getName().compareTo(softwareFacet.getName())==0);
|
|
Assert.assertTrue(createdSoftwareFacet.getVersion().compareTo(softwareFacet.getVersion())==0);
|
|
|
|
|
|
NetworkingFacet networkingFacet = new NetworkingFacetImpl();
|
|
networkingFacet.setIPAddress("146.48.87.183");
|
|
networkingFacet.setHostName("pc-frosini.isti.cnr.it");
|
|
networkingFacet.setDomainName("isti.cnr.it");
|
|
networkingFacet.setMask("255.255.248.0");
|
|
networkingFacet.setBroadcastAddress("146.48.87.255");
|
|
|
|
NetworkingFacet createdNetworkingFacet = resourceRegistryPublisher.createFacet(networkingFacet);
|
|
|
|
HostingNode hostingNode = new HostingNodeImpl();
|
|
|
|
CPUFacet cpuFacet = new CPUFacetImpl();
|
|
cpuFacet.setClockSpeed("1 GHz");
|
|
cpuFacet.setModel("Opteron");
|
|
cpuFacet.setVendor("AMD");
|
|
|
|
hostingNode.addFacet(cpuFacet);
|
|
|
|
IsIdentifiedBy<HostingNode, NetworkingFacet> isIdentifiedByHNNF = new IsIdentifiedByImpl<>(hostingNode, createdNetworkingFacet, null);
|
|
hostingNode.addFacet(isIdentifiedByHNNF);
|
|
|
|
Activates<HostingNode, EService> activates = new ActivatesImpl<HostingNode, EService>(hostingNode, createdEService, null);
|
|
|
|
hostingNode.attachResource(activates);
|
|
|
|
HostingNode createdHostingNode = resourceRegistryPublisher.createResource(hostingNode);
|
|
|
|
List<ConsistsOf<? extends Resource, ? extends Facet>> consistsOfList = createdHostingNode.getConsistsOf();
|
|
CPUFacet createdCPUFacet = null;
|
|
for(ConsistsOf<? extends Resource, ? extends Facet> consistsOf : consistsOfList){
|
|
if (CPUFacet.class.isAssignableFrom(consistsOf.getTarget().getClass())) {
|
|
createdCPUFacet = (CPUFacet) consistsOf.getTarget();
|
|
}
|
|
|
|
}
|
|
Assert.assertTrue(createdCPUFacet!=null);
|
|
logger.info("Created : {}", createdCPUFacet);
|
|
|
|
|
|
boolean deleted = resourceRegistryPublisher.deleteResource(createdHostingNode);
|
|
Assert.assertTrue(deleted);
|
|
|
|
deleted = resourceRegistryPublisher.deleteResource(createdEService);
|
|
Assert.assertTrue(deleted);
|
|
|
|
}
|
|
|
|
//@Test
|
|
public void testCreateAndDeleteEntitiesAndRelations() throws Exception {
|
|
EService eService = new EServiceImpl();
|
|
|
|
SoftwareFacet softwareFacet = new SoftwareFacetImpl();
|
|
softwareFacet.setGroup("InformationSystem");
|
|
softwareFacet.setName("resource-registry");
|
|
softwareFacet.setVersion("1.1.0");
|
|
|
|
IsIdentifiedBy<Resource, Facet> isIdentifiedBy = new IsIdentifiedByImpl<Resource, Facet>(eService, softwareFacet, null);
|
|
eService.addFacet(isIdentifiedBy);
|
|
|
|
EService createdEService = resourceRegistryPublisher.createResource(eService);
|
|
|
|
HostingNode hostingNode = new HostingNodeImpl();
|
|
HostingNode createdHostingNode = resourceRegistryPublisher.createResource(hostingNode);
|
|
|
|
|
|
CPUFacet cpuFacet = new CPUFacetImpl();
|
|
cpuFacet.setClockSpeed("1 GHz");
|
|
cpuFacet.setModel("Opteron");
|
|
cpuFacet.setVendor("AMD");
|
|
|
|
CPUFacet createdCpuFacet = resourceRegistryPublisher.createFacet(cpuFacet);
|
|
|
|
|
|
IsIdentifiedBy<HostingNode, CPUFacet> isIdentifiedByCPUFacet = new IsIdentifiedByImpl<>(createdHostingNode, createdCpuFacet, null);
|
|
IsIdentifiedBy<HostingNode, CPUFacet> createdIsIdentifiedByCPUFacet = resourceRegistryPublisher.createConsistsOf(isIdentifiedByCPUFacet);
|
|
|
|
Activates<HostingNode, EService> activates = new ActivatesImpl<>(createdHostingNode, createdEService, null);
|
|
Activates<HostingNode, EService> createdActivates = resourceRegistryPublisher.createIsRelatedTo(activates);
|
|
|
|
|
|
boolean deleted = resourceRegistryPublisher.deleteConsistsOf(createdIsIdentifiedByCPUFacet);
|
|
Assert.assertTrue(deleted);
|
|
|
|
|
|
deleted = resourceRegistryPublisher.deleteIsRelatedTo(createdActivates);
|
|
Assert.assertTrue(deleted);
|
|
|
|
|
|
deleted = resourceRegistryPublisher.deleteResource(createdHostingNode);
|
|
Assert.assertTrue(deleted);
|
|
|
|
deleted = resourceRegistryPublisher.deleteResource(createdEService);
|
|
Assert.assertTrue(deleted);
|
|
}
|
|
|
|
|
|
}
|