D-Net

package eu.dnetlib.parthenos.catalogue;

import java.io.IOException;

import java.io.InputStream;

import java.util.List;

import eu.dnetlib.parthenos.CRM;

import eu.dnetlib.parthenos.CRMdig;

import eu.dnetlib.parthenos.CRMpe;

import eu.dnetlib.parthenos.rdf.ResourceReader;

import org.apache.jena.ontology.OntModel;

import org.apache.jena.ontology.OntModelSpec;

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

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

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

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

import org.apache.jena.vocabulary.RDF;

import org.assertj.core.util.Lists;

import org.junit.Before;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.junit.runners.JUnit4;

import org.springframework.core.io.ClassPathResource;

import static org.junit.Assert.assertEquals;

import static org.junit.Assert.assertTrue;

/**

 * Created by Alessia Bardi on 11/12/2017.

 *

 * @author Alessia Bardi

 */

@RunWith(JUnit4.class)

public class CatalogueRegistratorTest {

	private CatalogueRegistrator reg;

	private ResourceReader reader = new ResourceReader();

	private String nakalaService = "eu/dnetlib/parthenos/registry/nakala.rdf";

	private String test = "eu/dnetlib/parthenos/registry/test.rdf";

	private String noRiot = "eu/dnetlib/parthenos/registry/sampleNoRiot.rdf";

	private String withproviders = "eu/dnetlib/parthenos/registry/withProviders.rdf";

	private String serviceSample = "eu/dnetlib/parthenos/registry/PE1_Service_sample.rdf";

	private OntModel baseModel;

	@Before

	public void setup() {

		reg = new CatalogueRegistrator();

		reg.setResourceReader(reader);

		baseModel = ModelFactory.createOntologyModel(OntModelSpec.RDFS_MEM_TRANS_INF);

		baseModel.read(CRMpe.RDFS_URL);

		baseModel.read(CRM.RDFS_URL);

		baseModel.read(CRMdig.RDFS_URL);

	}

	@Test

	public void readModel() {

		InfModel model = loadBaseModel();

		model.read(getInputStream(noRiot), CRMpe.NS);

	}

    @Test

	public void testGetJsonForActivity() throws Exception{

		InfModel model = loadBaseModel();

		model.read(getInputStream(nakalaService), CRMpe.NS);

		ResIterator subjects = model.listSubjectsWithProperty(RDF.type, CRM.E7_Activity);

		while (subjects.hasNext()) {

			Resource subject = subjects.nextResource();

			String json = reg.getJsonForActivity(subject, "testCatName", "testGroup");

			System.out.println(json);

		}

	}

	@Test

	public void testGetJsonForMetashare() throws Exception{

		InfModel model = loadBaseModel();

		model.read(getInputStream("eu/dnetlib/parthenos/registry/metashare.rdf"), CRMpe.NS);

		ResIterator subjects = model.listSubjectsWithProperty(RDF.type, CRM.E7_Activity);

		while (subjects.hasNext()) {

			Resource subject = subjects.nextResource();

			String json = reg.getJsonForActivity(subject, "testCatName", "testGroup");

			System.out.println(json);

		}

	}

	@Test

	public void testGetJsonForActor() throws Exception{

		InfModel model = loadBaseModel();

		model.read(getInputStream(test), CRMpe.NS);

		ResIterator subjects = model.listSubjectsWithProperty(RDF.type, CRM.E39_Actor);

		while (subjects.hasNext()) {

			Resource subject = subjects.nextResource();

			String json = reg.getJsonForActor(subject, "testActorName", "testGroup");

			System.out.println(json);

		}

	}

	@Test

	public void testGetJsonForProject() throws Exception{

		InfModel model = loadBaseModel();

		model.read(getInputStream("eu/dnetlib/parthenos/registry/sample1.rdf"), CRMpe.NS);

		ResIterator subjects = model.listSubjectsWithProperty(RDF.type, CRMpe.PE35_Project);

		while (subjects.hasNext()) {

			Resource subject = subjects.nextResource();

			String json = reg.getJsonForActivity(subject, "testProjectName", "testGroup");

			System.out.println(json);

		}

	}

	@Test

	public void testGetJsonForDataset() throws Exception{

		InfModel model = loadBaseModel();

		model.read(getInputStream("eu/dnetlib/parthenos/registry/sample1.rdf"), CRMpe.NS);

		ResIterator subjects = model.listSubjectsWithProperty(RDF.type, CRMpe.PE18_Dataset);

		while (subjects.hasNext()) {

			Resource subject = subjects.nextResource();

			String json = reg.getJsonForThing(subject, "testDatasetName", "testGroup");

			System.out.println(json);

		}

	}

	@Test

	public void testAlphaNumeric(){

			String s = "0039%2002%203232%203325";

			System.out.println(s.replaceAll("[^A-Za-z0-9]","_").toLowerCase());

	}

	@Test

	public void testAlphaNumeric2(){

		String url = "http://parthenos.d4science.org/handle/Humanum/Isidore/Actor/Centre d'Études Supérieures de la Renaissance";

		System.out.println(url.replaceAll("[^A-Za-z0-9]","_").toLowerCase());

	}

	@Test

	public void ensureGroups(){

		InfModel model = loadBaseModel();

		model.read(getInputStream(withproviders), CRMpe.NS);

		Resource subject = model.getResource("http://parthenos.d4science.org/handle/Parthenos/REG/Service/Cendari%20Sparql%20Endpoint");

		List<String> providernames = Lists.newArrayList(reader.getProviderNames(subject));

		assertTrue(providernames.contains("SISMEL"));

		assertTrue(providernames.contains("EHRI Consortium"));

	}

	@Test

	public void ensureGroups2(){

		InfModel model = loadBaseModel();

		model.read(getInputStream(serviceSample), CRMpe.NS);

		Resource subject = model.getResource("http://parthenos.d4science.org/handle/CP/Service/TEST");

		List<String> providernames = Lists.newArrayList(reader.getProviderNames(subject));

		assertTrue(providernames.contains("The Provider of the service (title)"));

		for(String p : providernames){

			System.out.println(p);

		}

	}

	@Test

	public void ensureGroupsMetashare(){

		InfModel model = loadBaseModel();

		model.read(getInputStream("eu/dnetlib/parthenos/registry/metashare.rdf"), CRMpe.NS);

		Resource subject = model.getResource("http://parthenos.d4science.org/handle/Parthenos/REG/Service/Metashare");

		List<String> providernames = Lists.newArrayList(reader.getProviderNames(subject));

		for(String p : providernames){

			System.out.println(p);

		}

	}

	@Test

	public void availibilityTest(){

		InfModel model = loadBaseModel();

		model.read(getInputStream(serviceSample), CRMpe.NS);

		Resource subject = model.getResource("http://parthenos.d4science.org/handle/CP/Service/TEST");

		assertEquals("Yes", reader.getAvailability(subject));

	}

	private InputStream getInputStream(String classpath){

		try {

			final ClassPathResource resource = new ClassPathResource(classpath);

			return resource.getInputStream();

		}catch(IOException e){

			return null;

		}

	}

	protected InfModel loadBaseModel() {

		return ModelFactory.createRDFSModel(baseModel);

	}

}