D-Net

import java.io.IOException;

import java.io.StringWriter;

import java.util.List;

import java.util.Set;

import com.fasterxml.jackson.core.JsonFactory;

import com.fasterxml.jackson.core.JsonGenerator;

import com.google.common.collect.Sets;

import eu.dnetlib.parthenos.CRM;

import eu.dnetlib.parthenos.CRMdig;

import eu.dnetlib.parthenos.CRMpe;

import org.apache.commons.io.IOUtils;

import org.apache.jena.assembler.AssemblerHelp;

import org.apache.jena.assembler.exceptions.AmbiguousSpecificTypeException;

import org.apache.jena.ontology.OntModel;

import org.apache.jena.ontology.OntModelSpec;

import org.apache.jena.rdf.model.*;

import org.apache.jena.vocabulary.RDF;

import org.apache.jena.vocabulary.RDFS;

import org.gcube.informationsystem.model.entity.facet.IdentifierFacet.IdentificationType;

	private OntModel baseModel;

	public GCubeResourceGenerator() {

		final String url = "http://www.w3.org/TR/REC-rdf-syntax/example14.nt";

		baseModel = ModelFactory.createOntologyModel(OntModelSpec.RDFS_MEM_TRANS_INF);

		baseModel.read(CRMpe.RDFS_URL);

		baseModel.read(CRM.RDFS_URL);

		baseModel.read(CRMdig.RDFS_URL);

	}

	protected InfModel loadBaseModel(){

		return ModelFactory.createRDFSModel(baseModel);

	}

	 * Generates the Gcube ER instances (Entity [Resource/Facet] and Relation) as json strings to be registered from a given RDF record serialised in RDF/XML PLAIN format.

	 * @return an Iterable of json strings or an empty Iterable if the record is blank

	public Iterable<String> getGCubeER(final String rdfRecord) throws IOException {

		List<String> jsonResources = Lists.newArrayList();

		InfModel model = loadBaseModel();

		model.read(IOUtils.toInputStream(rdfRecord, "UTF-8"), CRMpe.NS);

		JsonFactory jsonFactory = new JsonFactory();

		Set<String> uriProcessed = Sets.newHashSet();

		//let's start with services

		ResIterator iter = model.listResourcesWithProperty(RDF.type, CRMpe.PE1_Service);

		while (iter.hasNext()) {

			Resource res = iter.nextResource();

			String resourceURI = res.getURI();

			if (!uriProcessed.contains(resourceURI)) {

				log.debug("Processing "+resourceURI);

				Resource specificType = findSpecificType(res, CRMpe.PE1_Service);

				StringWriter sw = new StringWriter();

				JsonGenerator jg = jsonFactory.createGenerator(sw);

				jg.writeStartObject();

				jg.writeStringField("@class", specificType.getURI());

				//******THE FACETS *******//

				jg.writeArrayFieldStart("consistsOf");

				//list of facets

				writeIdentifierFacet(jg, resourceURI);

				writeInfoFacet(jg, getTitleFromRDFResource(res), getDescriptionFromRDFResource(res), getCompetenceFromRDFResource(res),

						getAvailabilityFromRDFResource(res));

				writeEventFacet(jg);

				writeRightsFacet(jg, res);

				writeContactReferenceFacet(jg, res);

				writeDesignatedAccessPointFacet(jg, res);

				jg.writeEndArray();

				// ******* RELATIONSHIPS *****//

				jg.writeEndObject();

				jg.close();

				String json = sw.toString();

				log.debug(json);

				jsonResources.add(json);

				uriProcessed.add(resourceURI);

			} else {

				log.debug(resourceURI+" already processed, now skipping it");

			}

		return jsonResources;

	}

	/**

	 * Finds the most specific type of res.

	 * @param res Resource you want to find the most specific type

	 * @param fallbackType Resource representing the type to return if there is no type or if we get AmbiguousSpecificTypeException

	 * @return Resource: the most specific type, if any. fallbackType otherwise

	 */

	protected Resource findSpecificType(final Resource res, final Resource fallbackType){

		Resource specType = fallbackType;

		try{

			specType = AssemblerHelp.findSpecificType(res, fallbackType);

		}catch(AmbiguousSpecificTypeException e){

			log.warn(res.getURI()+": "+e.getMessage());

		}

		return specType;

	}

	/*

	{"@class": "IsIdentifiedBy",

			"target": {

				"value": "http://pippo",

				"type:'URL",

				"@class": "IdentifierFacet",

			}

	}

	 */

	protected void writeIdentifierFacet(final JsonGenerator jg, final String identifier) throws IOException {

		jg.writeStartObject();

		jg.writeStringField("@class", "P1_is_identified_by");

		jg.writeObjectFieldStart("target");

		jg.writeStringField("@class", "IdentifierFacet");

		jg.writeStringField("value", identifier);

		jg.writeStringField("type", IdentificationType.URI.name());

		jg.writeEndObject();

		jg.writeEndObject();

	}

	protected void writeInfoFacet(final JsonGenerator jg, final String title, final String description, final String competence, final String availability) throws IOException {

		jg.writeStartObject();

		jg.writeStringField("@class", "PE_Info_Facet");

		jg.writeObjectFieldStart("target");

		jg.writeStringField("title", title);

		jg.writeStringField("description", description);

		jg.writeStringField("competence", competence);

		//TODO: uncomment this when George adds the rel to the model, see method getAvailabilityFromRDFResource below

		//jg.writeStringField("availability", availability);

		jg.writeEndObject();

		jg.writeEndObject();

	protected void writeEventFacet(final JsonGenerator jg){

		//TODO: implement me. get begin/end of operation from PP42_has_declarative_time

	}

	protected void writeRightsFacet(final JsonGenerator jg, final Resource res) throws IOException {

		//TODO: implement me. E30_Right facet extends from licenseFacet but it is not correct (textUrl is mandatory, we can't use it in Parthenos)

	}

	protected void writeContactReferenceFacet(final JsonGenerator jg, final Resource resource) throws IOException {

		//PP2_provided_by

		final Statement s = resource.getProperty(CRMpe.PP2_provided_by);

		if(s!=null){

			String appellation = "";

			String description = "";

			String legalAddress  = "";

			String email ="";

			String website = "";

			String address  = "";

			String phoneNumber ="";

			Resource provider = s.getResource();

			if(provider != null){

				//more contact point per provider

				StmtIterator contactPointsStm = provider.listProperties(CRM.P76_has_contact_point);

				while(contactPointsStm.hasNext()){

					Resource cp = contactPointsStm.nextStatement().getResource();

					appellation = getLabelFromRDFResource(cp);

					description = getDescriptionFromRDFResource(cp);

					//TODO: where to find email and legaladdress, address, phoneNumber, website?

					jg.writeStartObject();

					jg.writeStringField("@class", "PE_Contact_Reference_Facet");

					jg.writeObjectFieldStart("target");

					jg.writeStringField("appellation", appellation);

					jg.writeStringField("description", description);

					jg.writeStringField("legalAddress", legalAddress);

					jg.writeStringField("email", email);

					jg.writeStringField("website", website);

					jg.writeStringField("address", address);

					jg.writeStringField("phoneNumber", phoneNumber);

					jg.writeEndObject();

					jg.writeEndObject();

				}

			}

	protected void writeDesignatedAccessPointFacet(final JsonGenerator jg, final Resource resource) throws IOException {

		//PP28_has_designated_access_point

		StmtIterator apStms = resource.listProperties(CRMpe.PP28_has_designated_access_point);

		while(apStms.hasNext()){

			String entryName = getLabelFromRDFResource(resource);

			//(mandatory)

			String endpoint= "";

			String protocol= "";

			String description= getDescriptionFromRDFResource(resource);

			//TODO: authorization is a ValueSchema, I do not understand how to use it and how to map it

			String authorization= "";

			Resource ap = apStms.next().getResource();

			endpoint = ap.getURI();

			//TODO: where to get protocol and authorization?

			jg.writeStartObject();

			jg.writeStringField("@class", "PE29_Access_Point");

			jg.writeObjectFieldStart("target");

			jg.writeStringField("entryName", entryName);

			jg.writeStringField("description", description);

			jg.writeStringField("endpoint", endpoint);

			jg.writeStringField("protocol", protocol);

			//TODO: authorization is a ValueSchema, I do not understand how to use it and how to map it

			//jg.writeStringField("authorization", authorization);

			jg.writeEndObject();

			jg.writeEndObject();

		}

	protected String getTitleFromRDFResource(final Resource resource){

		String title = "";

		final Statement s = resource.getProperty(CRM.P1_is_identified_by);

		if(s != null){

			Resource titleRes = s.getResource();

			if(titleRes != null && (titleRes.hasProperty(RDF.type, CRM.E35_Title) || titleRes.hasProperty(RDF.type, CRM.E41_Appellation) )){

				title = getLabelFromRDFResource(titleRes);

			}

		}

		return title;

	protected String getDescriptionFromRDFResource(final Resource resource){

		if(resource.hasProperty(CRM.P3_has_note)){

			return resource.getProperty(CRM.P3_has_note).getString();

		}

		else return "";

	protected String getLabelFromRDFResource(final Resource resource){

		if(resource.hasProperty(RDFS.label)){

			return resource.getProperty(RDFS.label).getString();

		}

		else return "";

	protected String getCompetenceFromRDFResource(final Resource resource){

		String comp = "";

		if(resource.hasProperty(CRMpe.PP45_has_competency)){

			Resource compRes = resource.getProperty(CRMpe.PP45_has_competency).getResource();

			if(compRes.hasProperty(RDFS.label))

				comp = compRes.getProperty(RDFS.label).getString();

		}

		return comp;

	}

	protected String getAvailabilityFromRDFResource(final Resource resource){

		//TODO: implement this when George adds the rel to the model

		return "";

	}