D-Net

package eu.dnetlib.parthenos.catalogue;

import java.io.IOException;

import java.io.InputStream;

import java.net.URISyntaxException;

import eu.dnetlib.parthenos.CRM;

import eu.dnetlib.parthenos.CRMdig;

import eu.dnetlib.parthenos.CRMpe;

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.junit.Before;

import org.junit.Ignore;

import org.junit.Test;

import org.junit.runner.RunWith;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.core.io.ClassPathResource;

import org.springframework.test.context.TestPropertySource;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/**

 * Created by Alessia Bardi on 15/03/2018.

 *

 * @author Alessia Bardi

 */

@Ignore

@RunWith(SpringJUnit4ClassRunner.class)

@SpringBootTest

@TestPropertySource(

		locations = "classpath:application-integrationtest.properties")

public class CatalogueRegistratorIntegrationTest {

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

	private String resourceCatName = "nakalatest";

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

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

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

	@Autowired

	private CatalogueRegistrator reg;

	private OntModel baseModel;

	@Before

	public void setup() {

		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 testRegistration() throws Exception{

		InfModel model = loadBaseModel();

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

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

		Resource nakala = subjects.nextResource();

		String uuid = reg.register(nakala, CRM.E7_Activity, CKANUtils.nakala_org);

		System.out.println(uuid);

		purge(uuid);

	}

	@Test

	public void testError500_1() throws Exception{

		InfModel model = loadBaseModel();

		model.read(getStream(error500_1), CRMpe.NS);

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

		Resource r = subjects.nextResource();

		String uuid = reg.register(r, CRM.E29_Design_or_Procedure, CKANUtils.Parthenos_org);

		System.out.println(uuid);

		purge(uuid);

	}

	@Test

	public void testPurge() throws IOException, URISyntaxException {

		reg.purge(resourceCatName);

	}

	private void purge(final String uuid) throws IOException, URISyntaxException {

		reg.purge(uuid);

	}

	private static InputStream getStream(final String classpath) throws IOException {

		return new ClassPathResource(classpath).getInputStream();

	}

	protected InfModel loadBaseModel() {

		return ModelFactory.createRDFSModel(baseModel);

	}

}