304 lines
11 KiB
Java
304 lines
11 KiB
Java
package org.gcube.informationsystem.exporter.mapper;
|
|
|
|
import java.net.URI;
|
|
import java.util.List;
|
|
import java.util.UUID;
|
|
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.AccessPoint;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.Profile;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.Property;
|
|
import org.gcube.common.resources.gcore.ServiceEndpoint.Runtime;
|
|
import org.gcube.common.resources.gcore.common.Platform;
|
|
import org.gcube.common.resources.gcore.utils.Group;
|
|
import org.gcube.informationsystem.model.impl.embedded.HeaderImpl;
|
|
import org.gcube.informationsystem.model.impl.relation.ConsistsOfImpl;
|
|
import org.gcube.informationsystem.model.impl.relation.IsIdentifiedByImpl;
|
|
import org.gcube.informationsystem.model.impl.utils.ISMapper;
|
|
import org.gcube.informationsystem.model.reference.embedded.Header;
|
|
import org.gcube.informationsystem.model.reference.entity.Facet;
|
|
import org.gcube.informationsystem.model.reference.entity.Resource;
|
|
import org.gcube.informationsystem.model.reference.relation.ConsistsOf;
|
|
import org.gcube.informationsystem.model.reference.relation.IsIdentifiedBy;
|
|
import org.gcube.informationsystem.resourceregistry.api.exceptions.entity.resource.ResourceAvailableInAnotherContextException;
|
|
import org.gcube.informationsystem.resourceregistry.api.exceptions.entity.resource.ResourceNotFoundException;
|
|
import org.gcube.resourcemanagement.model.impl.entity.facet.AccessPointFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entity.facet.NetworkingFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entity.facet.ServiceStateFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entity.facet.SoftwareFacetImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entity.properties.ValueSchemaImpl;
|
|
import org.gcube.resourcemanagement.model.impl.entity.resource.EServiceImpl;
|
|
import org.gcube.resourcemanagement.model.reference.entity.facet.AccessPointFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entity.facet.NetworkingFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entity.facet.ServiceStateFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entity.facet.SoftwareFacet;
|
|
import org.gcube.resourcemanagement.model.reference.entity.properties.ValueSchema;
|
|
import org.gcube.resourcemanagement.model.reference.entity.resource.EService;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import com.fasterxml.jackson.databind.node.ArrayNode;
|
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
|
|
|
public class ServiceEndpointExporter extends GCoreResourceMapper<ServiceEndpoint, EService> {
|
|
|
|
private static Logger logger = LoggerFactory.getLogger(ServiceEndpointExporter.class);
|
|
|
|
public static final String FIXED_VERSION = "1.0.0";
|
|
|
|
public static final String PLATFORM = "PLATFORM";
|
|
public static final String POSITION = "POSITION";
|
|
|
|
public static final String GHN_ID = "ghnID";
|
|
|
|
public static final String USERNAME = "USERNAME";
|
|
public static final String PASSWORD = "PASSWORD";
|
|
public static final String USERNAME_PASSWORD_SCHEMA_STRING;
|
|
|
|
public static final String NAME = "name";
|
|
public static final String VALUE = "value";
|
|
public static final String ENCRYPTED = "encrypted";
|
|
|
|
public static final String ARRAY = "ARRAY";
|
|
public static final String PROPERTIES = "PROPERTIES";
|
|
|
|
|
|
public static final String NOT_URI_ENDPOINT = "NOT_URI_ENDPOINT";
|
|
|
|
static {
|
|
USERNAME_PASSWORD_SCHEMA_STRING = String.format("%s:%s", USERNAME, PASSWORD);
|
|
}
|
|
|
|
public ServiceEndpointExporter(boolean filteredReport){
|
|
super(ServiceEndpoint.class, EService.class, filteredReport);
|
|
}
|
|
|
|
@Override
|
|
protected EService map(ServiceEndpoint gr) throws Exception {
|
|
Profile profile = gr.profile();
|
|
UUID uuid = UUID.fromString(gr.id());
|
|
boolean readFromIS = false;
|
|
|
|
EService eService = null;
|
|
AccessPointFacet[] accessPointFacets = null;
|
|
SoftwareFacet softwareFacet = null;
|
|
SoftwareFacet platformSoftwareFacet = null;
|
|
ServiceStateFacet serviceStateFacet = null;
|
|
NetworkingFacet networkingFacet = null;
|
|
|
|
try {
|
|
resourceRegistryClient.exists(rClass, uuid);
|
|
readFromIS = true;
|
|
}catch (ResourceNotFoundException e) {
|
|
readFromIS = false;
|
|
}catch (ResourceAvailableInAnotherContextException e) {
|
|
resourceRegistryPublisher.addResourceToCurrentContext(EService.NAME, uuid);
|
|
Thread.sleep(100);
|
|
readFromIS = true;
|
|
}
|
|
|
|
Group<AccessPoint> accessPoints = profile.accessPoints();
|
|
accessPointFacets = new AccessPointFacet[accessPoints.size()];
|
|
|
|
if(readFromIS){
|
|
eService = read(uuid);
|
|
//softwareFacet = (SoftwareFacet) eService.getIdentificationFacets().get(0);
|
|
|
|
List<ConsistsOf<? extends Resource, ? extends Facet>> consistsOfs = eService.getConsistsOf();
|
|
|
|
for(ConsistsOf<? extends Resource, ? extends Facet> c : consistsOfs){
|
|
Facet target = c.getTarget();
|
|
if(c instanceof IsIdentifiedBy){
|
|
if(target instanceof SoftwareFacet) {
|
|
softwareFacet = (SoftwareFacet) target;
|
|
continue;
|
|
}
|
|
} else {
|
|
if(target instanceof AccessPointFacet){
|
|
try {
|
|
Object positionObject = c.getAdditionalProperty(POSITION);
|
|
Integer position = Integer.valueOf(positionObject.toString());
|
|
if(position!=null){
|
|
accessPointFacets[position] = (AccessPointFacet) target;
|
|
}
|
|
}catch (Exception e) {
|
|
// Position is used on relation to match the AccessPoint on ServiceEndpoint
|
|
logger.error("No POSITION found", e);
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if(target instanceof SoftwareFacet){
|
|
SoftwareFacet targetSoftwareFacet = (SoftwareFacet) target;
|
|
if(targetSoftwareFacet.getGroup().compareTo(PLATFORM)==0){
|
|
platformSoftwareFacet = targetSoftwareFacet;
|
|
}
|
|
continue;
|
|
}
|
|
|
|
if(target instanceof ServiceStateFacet){
|
|
serviceStateFacet = (ServiceStateFacet) target;
|
|
continue;
|
|
}
|
|
|
|
if(target instanceof NetworkingFacet){
|
|
networkingFacet = (NetworkingFacet) target;
|
|
continue;
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
}else{
|
|
eService = new EServiceImpl();
|
|
Header header = new HeaderImpl(uuid);
|
|
eService.setHeader(header);
|
|
}
|
|
|
|
/* ----------------------------------------- */
|
|
if(softwareFacet==null){
|
|
softwareFacet = new SoftwareFacetImpl();
|
|
IsIdentifiedBy<EService, SoftwareFacet> identifiedBy =
|
|
new IsIdentifiedByImpl<EService, SoftwareFacet>(eService, softwareFacet, null);
|
|
eService.addFacet(identifiedBy);
|
|
}
|
|
|
|
softwareFacet.setGroup(profile.category());
|
|
softwareFacet.setName(profile.name());
|
|
softwareFacet.setVersion(FIXED_VERSION);
|
|
String description = profile.description();
|
|
if(description!=null && description.compareTo("")!=0){
|
|
softwareFacet.setDescription(getStringAsUTF8(description));
|
|
}
|
|
/* ----------------------------------------- */
|
|
|
|
|
|
/* ----------------------------------------- */
|
|
Platform platform = profile.platform();
|
|
|
|
if(platformSoftwareFacet==null){
|
|
platformSoftwareFacet = new SoftwareFacetImpl();
|
|
eService.addFacet(platformSoftwareFacet);
|
|
}
|
|
|
|
platformSoftwareFacet.setGroup(PLATFORM);
|
|
platformSoftwareFacet.setName(platform.name());
|
|
String platformVersion = String.format("%d.%d.%d-%d",
|
|
platform.version(), platform.minorVersion(),
|
|
platform.revisionVersion(), platform.buildVersion());
|
|
softwareFacet.setVersion(platformVersion);
|
|
/* ----------------------------------------- */
|
|
|
|
|
|
/* ----------------------------------------- */
|
|
Runtime runTime = profile.runtime();
|
|
|
|
if(serviceStateFacet==null){
|
|
serviceStateFacet = new ServiceStateFacetImpl();
|
|
eService.addFacet(serviceStateFacet);
|
|
}
|
|
serviceStateFacet.setValue(runTime.status());
|
|
|
|
if(networkingFacet==null){
|
|
networkingFacet = new NetworkingFacetImpl();
|
|
eService.addFacet(networkingFacet);
|
|
}
|
|
networkingFacet.setHostName(runTime.hostedOn());
|
|
String ghnID = runTime.ghnId();
|
|
if(ghnID!=null && ghnID.compareTo("")!=0){
|
|
networkingFacet.setAdditionalProperty(GHN_ID, ghnID);
|
|
}
|
|
|
|
/* ----------------------------------------- */
|
|
|
|
|
|
/* ----------------------------------------- */
|
|
int i=0;
|
|
for(AccessPoint accessPoint : accessPoints){
|
|
if(accessPointFacets[i] == null){
|
|
accessPointFacets[i] = new AccessPointFacetImpl();
|
|
ConsistsOf<EService, AccessPointFacet> consistsOf = new ConsistsOfImpl<EService, AccessPointFacet>(eService, accessPointFacets[i], null);
|
|
consistsOf.setAdditionalProperty(POSITION, i);
|
|
eService.addFacet(consistsOf);
|
|
}
|
|
|
|
accessPointFacets[i].setEntryName(accessPoint.name());
|
|
String address = accessPoint.address();
|
|
if(address!=null && address.compareTo("")!=0){
|
|
try {
|
|
URI uri = URI.create(address);
|
|
accessPointFacets[i].setEndpoint(uri);
|
|
}catch (IllegalArgumentException e) {
|
|
accessPointFacets[i].setAdditionalProperty(NOT_URI_ENDPOINT, address);
|
|
}
|
|
}
|
|
|
|
String accessPointDescription = accessPoint.description();
|
|
if(accessPointDescription!=null && accessPointDescription.compareTo("")!=0){
|
|
accessPointFacets[i].setDescription(getStringAsUTF8(accessPointDescription));
|
|
}
|
|
|
|
/* ---------- */
|
|
ValueSchema authorization = new ValueSchemaImpl();
|
|
|
|
String value = USERNAME_PASSWORD_SCHEMA_STRING;
|
|
String schema = USERNAME_PASSWORD_SCHEMA_STRING;
|
|
|
|
boolean replaceColon = false;
|
|
|
|
try {
|
|
value = value.replace(USERNAME, accessPoint.username());
|
|
}catch (NullPointerException e) {
|
|
value = value.replace(USERNAME, "");
|
|
schema = schema.replace(USERNAME, "");
|
|
replaceColon = true;
|
|
}
|
|
|
|
try {
|
|
value = value.replace(PASSWORD, accessPoint.password());
|
|
}catch (NullPointerException e) {
|
|
value = value.replace(PASSWORD, "");
|
|
schema = schema.replace(PASSWORD, "");
|
|
replaceColon = true;
|
|
}
|
|
|
|
if(replaceColon){
|
|
value = value.replace(":", "");
|
|
schema = schema.replace(":", "");
|
|
}
|
|
|
|
if(value.compareTo("")!=0){
|
|
authorization.setValue(value);
|
|
authorization.setType(URI.create(schema));
|
|
|
|
accessPointFacets[i].setAuthorization(authorization);
|
|
}
|
|
/* ----- */
|
|
|
|
Group<Property> properties = accessPoint.properties();
|
|
if(properties!=null && properties.size()>0){
|
|
ObjectNode propertiesObjectNode = ISMapper.getObjectMapper().createObjectNode();
|
|
ArrayNode arrayNode = propertiesObjectNode.putArray(ARRAY);
|
|
|
|
for(Property property : properties){
|
|
ObjectNode objectNode = ISMapper.getObjectMapper().createObjectNode();
|
|
objectNode.put(NAME, property.name());
|
|
objectNode.put(VALUE, property.value());
|
|
objectNode.put(ENCRYPTED, Boolean.toString(property.isEncrypted()));
|
|
|
|
arrayNode.add(objectNode);
|
|
}
|
|
|
|
accessPointFacets[i].setAdditionalProperty(PROPERTIES, propertiesObjectNode);
|
|
}
|
|
|
|
i++;
|
|
}
|
|
/* ----------------------------------------- */
|
|
|
|
|
|
return eService;
|
|
}
|
|
|
|
}
|