D-Net

package eu.dnetlib.parthenos.registry;

import java.io.IOException;

import java.io.InputStream;

import java.io.StringWriter;

import com.fasterxml.jackson.core.JsonFactory;

import com.fasterxml.jackson.core.JsonGenerator;

import eu.dnetlib.parthenos.CRMpe;

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

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

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

import org.apache.jena.vocabulary.RDF;

import org.junit.Assert;

import org.junit.Test;

import org.springframework.core.io.ClassPathResource;

/**

 * Created by Alessia Bardi on 02/10/2017.

 *

 * @author Alessia Bardi

 */

public class FacetWriterTest {

	private FacetWriter facetWriter = new FacetWriter();

	private static String baseURI = "http://parthenos.d4science.org/CRMext/CRMpe.rdfs/";

	/**

	 *

	 * Method: writeIdentifierFacet(final JsonGenerator jg, final String identifier)

	 *

	 */

	@Test

	public void testWriteIdentifierFacet() throws Exception {

		JsonFactory jsonFactory = new JsonFactory();

		StringWriter sw = new StringWriter();

		JsonGenerator jg = jsonFactory.createGenerator(sw);

		facetWriter.writeIdentifierFacet(jg, "thisIsAnIDentifier");

		jg.close();

		System.out.println(sw.toString());

		Assert.assertEquals("{\"@class\":\"P1_is_identified_by\",\"target\":{\"@class\":\"IdentifierFacet\",\"value\":\"thisIsAnIDentifier\",\"type\":\"URI\"}}", sw.toString());

	}

	/**

	 *

	 * Method: writeContactReferenceFacet(final JsonGenerator jg, final Resource resource)

	 *

	 */

	@Test

	public void testWriteContactReferenceFacet() throws Exception {

		GCubeResourceGenerator generator = new GCubeResourceGenerator();

		JsonFactory jsonFactory = new JsonFactory();

		StringWriter sw = new StringWriter();

		JsonGenerator jg = jsonFactory.createGenerator(sw);

		Model model = generator.loadBaseModel();

		model.read(getStream("eu/dnetlib/parthenos/registry/test.rdf"), baseURI);

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

		if(iter.hasNext()){

			Resource r = iter.nextResource();

			System.out.println("Found service "+r.getURI());

			facetWriter.writeContactReferenceFacet(jg, r);

			jg.close();

			System.out.println(sw.toString());

		}

		else {

			System.out.println("Could not find any service");

			throw new Exception("I was expecting some PE1_Service or subclass instances!");

		}

	}

	private InputStream getStream(final String classpath) throws IOException {

		return new ClassPathResource(classpath).getInputStream();

	}

}