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.commons.lang3.StringUtils;

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.After;

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

	}

	@After

	public void tearDown() throws URISyntaxException, IOException {

		//purge the item from the catalogue

		if(doPurge) reg.purge(resourceCatName);

	}

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

		System.out.println(uuid);

		if(StringUtils.isNotBlank(uuid)) doPurge = true;

	}

	@Test

	public void testPurge() throws IOException, URISyntaxException {

		reg.purge(resourceCatName);

		doPurge = false;

	}

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

		}

		doPurge = false;

	}

	@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 static InputStream getStream(final String classpath) throws IOException {

		return new ClassPathResource(classpath).getInputStream();

	}

	protected InfModel loadBaseModel() {

		return ModelFactory.createRDFSModel(baseModel);

	}

}