src/test/java/org/purl/wf4ever/wfdesc/scufl/TestAllTypes.java

package org.purl.wf4ever.wfdesc.scufl;

import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;

import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.IOException;
import java.net.URI;
import java.net.URL;

import org.codehaus.jackson.JsonNode;
import org.codehaus.jackson.map.ObjectMapper;
import org.junit.Before;
import org.junit.Test;
import org.openrdf.query.QueryLanguage;
import org.openrdf.query.resultio.sparqljson.SPARQLResultsJSONWriter;
import org.openrdf.repository.Repository;
import org.openrdf.repository.RepositoryConnection;
import org.openrdf.repository.sail.SailRepository;
import org.openrdf.rio.RDFFormat;
import org.openrdf.sail.memory.MemoryStore;

import uk.org.taverna.scufl2.api.container.WorkflowBundle;
import uk.org.taverna.scufl2.api.io.WorkflowBundleIO;

public class TestAllTypes {

	private static final String ALLTYPES_T2FLOW = "/allTypes.t2flow";
	private File allTypesWfdesc;

	private URL allTypesT2flow;

	@Before
	public void loadT2flow() throws Exception {
		allTypesT2flow = getClass().getResource(ALLTYPES_T2FLOW);
		assertNotNull("Could not load " + ALLTYPES_T2FLOW, allTypesT2flow);
	}

	@Before
	public void tempFile() throws IOException {
		allTypesWfdesc = File.createTempFile("scufl2-wfdesc", ".ttl");
		allTypesWfdesc.delete();
//		allTypesWfdesc.deleteOnExit();
		 System.out.println(allTypesWfdesc);
	}

	@Test
	public void convert() throws Exception {
		assertFalse(allTypesWfdesc.exists());
		WorkflowBundleIO io = new WorkflowBundleIO();
		WorkflowBundle wfBundle = io.readBundle(allTypesT2flow, null);
		io.writeBundle(wfBundle, allTypesWfdesc,
				"text/vnd.wf4ever.wfdesc+turtle");
		assertTrue(allTypesWfdesc.exists());

		Repository myRepository = new SailRepository(new MemoryStore());
		myRepository.initialize();
		RepositoryConnection con = myRepository.getConnection();
		con.add(allTypesWfdesc, allTypesWfdesc.toURI().toASCIIString(),
				RDFFormat.TURTLE);

		ByteArrayOutputStream out = new ByteArrayOutputStream();

		SPARQLResultsJSONWriter writer = new SPARQLResultsJSONWriter(out);
		con.prepareTupleQuery(
				QueryLanguage.SPARQL,
				"PREFIX wfdesc: <http://purl.org/wf4ever/wfdesc#> "
						+ "PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#> "
						+ "PREFIX owl: <http://www.w3.org/2002/07/owl#> "
						+ "SELECT ?wf ?proc ?procType ?procLabel "
						+ "WHERE {"
						+ "	?wf a wfdesc:Workflow;"
						+ "       wfdesc:hasSubProcess ?proc. "
						+ " ?proc rdfs:label ?procLabel ."
						// Ignore non-specific types
						+ "OPTIONAL { ?proc a ?procType . FILTER (?procType != wfdesc:Description && ?procType != wfdesc:Process && ?procType != owl:Thing) }"
						+ "} " + "ORDER BY ?wf ").evaluate(writer);
		 System.out.println(out.toString());

		ObjectMapper mapper = new ObjectMapper();
		JsonNode jsonNode = mapper.readValue(out.toByteArray(), JsonNode.class);
		String oldWf = null;
		for (JsonNode binding : jsonNode.path("results").path("bindings")) {
			String wf = binding.path("wf").path("value").asText();
			if (!wf.equals(oldWf)) {
				System.out.println(wf);
				oldWf = wf;
			}
			String proc = binding.path("proc").path("value").asText();
			String procType = binding.path("procType").path("value").asText();
			String procTypeShort = URI.create(procType).getFragment();
			String procLabel = binding.path("procLabel").path("value").asText();
			System.out.println(" Processor " + procLabel + " (" + procTypeShort
					+ ")");
			System.out.println("   " + proc + " " + procType);
		}

		out.reset();

		con.prepareTupleQuery(
				QueryLanguage.SPARQL,
				"PREFIX wfdesc: <http://purl.org/wf4ever/wfdesc#> "
						+ " PREFIX rdfs: <http://www.w3.org/2000/01/rdf-schema#> "
						+ " PREFIX owl: <http://www.w3.org/2002/07/owl#> "
						+ " SELECT ?wf ?fromProc ?toProc ?fromProcLabel ?toProcLabel "
						+ " WHERE {" + "	?wf a wfdesc:Workflow;"
						+ "       wfdesc:hasSubProcess ?fromProc,?toProc ;"
						+ "       wfdesc:hasDataLink ?link . "
						+ " ?link wfdesc:hasSource ?fromPort; "
						+ "      wfdesc:hasSink ?toPort ."
						+ " ?fromProc wfdesc:hasOutput ?fromPort ;"
						+ "           rdfs:label ?fromProcLabel ."
						+ " ?toProc wfdesc:hasInput ?toPort ;"
						+ "         rdfs:label ?toProcLabel ." + "} "
						+ "ORDER BY ?wf ").evaluate(writer);
		 System.out.println(out.toString());
		jsonNode = mapper.readValue(out.toByteArray(), JsonNode.class);
		for (JsonNode binding : jsonNode.path("results").path("bindings")) {
			String wf = binding.path("wf").path("value").asText();
			if (!wf.equals(oldWf)) {
				System.out.println(wf);
				oldWf = wf;
			}
			String fromProcLabel = binding.path("fromProcLabel").path("value")
					.asText();
			String toProcLabel = binding.path("toProcLabel").path("value")
					.asText();
			String fromProc = binding.path("fromProc").path("value").asText();
			String toProc = binding.path("toProc").path("value").asText();
			System.out.print(" " + fromProcLabel);
			System.out.println(" -> " + toProcLabel);
			System.out.println("    " + fromProc + " -> " + toProc);
		}

	}

}