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 eu.dnetlib.parthenos.publisher.ParthenosPublisherException;

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;

import static org.junit.Assert.assertFalse;

import static org.junit.Assert.assertTrue;

/**

 * 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";

	private boolean doPurge=false;

	@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, "testGroup");

		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, "testGroup");

		System.out.println(uuid);

		purge(uuid);

	}

	@Test

	public void testPurge() throws IOException, URISyntaxException {

		reg.purge(resourceCatName);

	}

//	@Test

//	public void testAddGroup() throws IOException, URISyntaxException, ParthenosPublisherException {

//		InfModel model = loadBaseModel();

//		model.read(getStream(rdfWithProviders), CRMpe.NS);

//		ResIterator it = model.listSubjectsWithProperty(CRMpe.PP2_provided_by);

//		while(it.hasNext()){

//			Resource withProvider = it.nextResource();

//			reg.ensureGroups(withProvider);

//		}

//		reg.getCatalogueAPIClient().purgeGroup("SISMEL");

//		reg.getCatalogueAPIClient().purgeGroup("EHRI Consortium");

//	}

//

//	@Test

//	public void testAddGroup2() throws IOException, URISyntaxException, ParthenosPublisherException {

//		InfModel model = loadBaseModel();

//		model.read(getStream(serviceSample), CRMpe.NS);

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

//		Iterator<String> providers = reg.getResourceReader().getProviderNames(subject);

//		reg.ensureGroups(subject);

//		while(providers.hasNext()){

//			String p = providers.next();

//			System.out.println("purging group "+p);

//			reg.getCatalogueAPIClient().purgeGroup(p);

//		}

//	}

	@Test

	public void testGroup() throws ParthenosPublisherException, IOException, URISyntaxException {

		assertFalse(reg.getCatalogueAPIClient().groupExist("sismeltest"));

		String sismelJson = "{"

				+ "  \"name\":\"sismeltest\","

				+ "  \"id\":\"sismeltest\","

				+ "  \"title\": \"SISMEL TEST GROUP TITLE\""

				//+ "  \"description\": \"%s\""

				+ "}";

		reg.getCatalogueAPIClient().registerGroup(sismelJson, "sismeltest");

		assertTrue(reg.getCatalogueAPIClient().groupExist("sismeltest"));

		reg.getCatalogueAPIClient().purgeGroup("sismeltest");

		assertFalse(reg.getCatalogueAPIClient().groupExist("sismeltest"));

	}

	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);

	}

}