Add unit tests for data types and language tags.

smart-connector/src/test/java/eu/knowledge/engine/smartconnector/api/TestPostReactDatatype.java

@@ -0,0 +1,109 @@
+package eu.knowledge.engine.smartconnector.api;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
+
+import java.util.Iterator;
+import java.util.concurrent.ExecutionException;
+
+import org.apache.jena.shared.PrefixMapping;
+import org.apache.jena.sparql.graph.PrefixMappingMem;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import eu.knowledge.engine.smartconnector.util.KnowledgeNetwork;
+import eu.knowledge.engine.smartconnector.api.ExchangeInfo.Status;
+import eu.knowledge.engine.smartconnector.util.KnowledgeBaseImpl;
+
+public class TestPostReactDatatype {
+	private static KnowledgeBaseImpl kb1;
+	private static KnowledgeBaseImpl kb2;
+
+	public boolean kb2Received = false;
+
+	private static final Logger LOG = LoggerFactory.getLogger(TestPostReactDatatype.class);
+
+	@Test
+	public void testPostReact() throws InterruptedException {
+		PrefixMappingMem prefixes = new PrefixMappingMem();
+		prefixes.setNsPrefixes(PrefixMapping.Standard);
+		prefixes.setNsPrefix("ex", "https://www.tno.nl/example/");
+
+		KnowledgeNetwork kn = new KnowledgeNetwork();
+		kb1 = new KnowledgeBaseImpl("kb1");
+		kn.addKB(kb1);
+		kb2 = new KnowledgeBaseImpl("kb2");
+		kn.addKB(kb2);
+
+		GraphPattern gp1 = new GraphPattern(prefixes, "?a ex:b ?c.");
+		PostKnowledgeInteraction pKI = new PostKnowledgeInteraction(new CommunicativeAct(), gp1, null);
+		kb1.register(pKI);
+
+		GraphPattern gp2 = new GraphPattern(prefixes, "?d ex:b ?e.");
+		ReactKnowledgeInteraction rKI = new ReactKnowledgeInteraction(new CommunicativeAct(), gp2, null);
+		kb2.register(rKI, ((anRKI, aReactExchangeInfo) -> {
+			LOG.trace("KB2 reacting...");
+			TestPostReactDatatype.this.kb2Received = true;
+			var argument = aReactExchangeInfo.getArgumentBindings();
+			Iterator<Binding> iter = argument.iterator();
+			assertTrue(iter.hasNext(), "There should be at least a single binding.");
+			Binding b = iter.next();
+
+			assertEquals("<https://www.tno.nl/example/a>", b.get("d"), "Binding of 'd' is incorrect.");
+			assertEquals("\"eek\"^^<http://www.w3.org/2001/XMLSchema#decimal>", b.get("e"),
+					"Binding of 'e' is incorrect.");
+
+			assertFalse(iter.hasNext(), "This BindingSet should only have a single binding.");
+
+			return new BindingSet();
+		}));
+
+		kn.sync();
+		LOG.info("Everyone is up-to-date!");
+
+		BindingSet bindingSet = new BindingSet();
+		Binding binding = new Binding();
+		binding.put("a", "<https://www.tno.nl/example/a>");
+		binding.put("c", "\"eek\"^^<http://www.w3.org/2001/XMLSchema#decimal>");
+		bindingSet.add(binding);
+
+		try {
+			PostResult result = kb1.post(pKI, bindingSet).get();
+
+			assertTrue(this.kb2Received, "KB2 should have received the posted data.");
+
+			assertFalse(
+					result.getExchangeInfoPerKnowledgeBase().stream().anyMatch(ei -> ei.getStatus() == Status.FAILED));
+
+			BindingSet bs = result.getBindings();
+			assertTrue(bs.isEmpty());
+
+			LOG.info("After post!");
+		} catch (ExecutionException e) {
+			LOG.error("Error", e);
+			fail();
+		}
+	}
+
+	@AfterAll
+	public static void cleanup() {
+		LOG.info("Clean up: {}", TestPostReactDatatype.class.getSimpleName());
+		if (kb1 != null) {
+			kb1.stop();
+		} else {
+			fail("KB1 should not be null!");
+		}
+
+		if (kb2 != null) {
+
+			kb2.stop();
+		} else {
+			fail("KB2 should not be null!");
+		}
+	}
+
+}

smart-connector/src/test/java/eu/knowledge/engine/smartconnector/api/TestPostReactLanguageTag.java

@@ -0,0 +1,109 @@
+package eu.knowledge.engine.smartconnector.api;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.fail;
+
+import java.util.Iterator;
+import java.util.concurrent.ExecutionException;
+
+import org.apache.jena.shared.PrefixMapping;
+import org.apache.jena.sparql.graph.PrefixMappingMem;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import eu.knowledge.engine.smartconnector.util.KnowledgeNetwork;
+import eu.knowledge.engine.smartconnector.api.ExchangeInfo.Status;
+import eu.knowledge.engine.smartconnector.util.KnowledgeBaseImpl;
+
+public class TestPostReactLanguageTag {
+	private static KnowledgeBaseImpl kb1;
+	private static KnowledgeBaseImpl kb2;
+
+	public boolean kb2Received = false;
+
+	private static final Logger LOG = LoggerFactory.getLogger(TestPostReactLanguageTag.class);
+
+	@Test
+	public void testPostReact() throws InterruptedException {
+		PrefixMappingMem prefixes = new PrefixMappingMem();
+		prefixes.setNsPrefixes(PrefixMapping.Standard);
+		prefixes.setNsPrefix("ex", "https://www.tno.nl/example/");
+
+		KnowledgeNetwork kn = new KnowledgeNetwork();
+		kb1 = new KnowledgeBaseImpl("kb1");
+		kn.addKB(kb1);
+		kb2 = new KnowledgeBaseImpl("kb2");
+		kn.addKB(kb2);
+
+		GraphPattern gp1 = new GraphPattern(prefixes, "?a ex:b ?c.");
+		PostKnowledgeInteraction pKI = new PostKnowledgeInteraction(new CommunicativeAct(), gp1, null);
+		kb1.register(pKI);
+
+		GraphPattern gp2 = new GraphPattern(prefixes, "?d ex:b ?e.");
+		ReactKnowledgeInteraction rKI = new ReactKnowledgeInteraction(new CommunicativeAct(), gp2, null);
+		kb2.register(rKI, ((anRKI, aReactExchangeInfo) -> {
+			LOG.trace("KB2 reacting...");
+			TestPostReactLanguageTag.this.kb2Received = true;
+			var argument = aReactExchangeInfo.getArgumentBindings();
+			Iterator<Binding> iter = argument.iterator();
+			assertTrue(iter.hasNext(), "There should be at least a single binding.");
+			Binding b = iter.next();
+
+			assertEquals("<https://www.tno.nl/example/a>", b.get("d"), "Binding of 'd' is incorrect.");
+			assertEquals("\"eek\"@en", b.get("e"),
+					"Binding of 'e' is incorrect.");
+
+			assertFalse(iter.hasNext(), "This BindingSet should only have a single binding.");
+
+			return new BindingSet();
+		}));
+
+		kn.sync();
+		LOG.info("Everyone is up-to-date!");
+
+		BindingSet bindingSet = new BindingSet();
+		Binding binding = new Binding();
+		binding.put("a", "<https://www.tno.nl/example/a>");
+		binding.put("c", "\"eek\"@en");
+		bindingSet.add(binding);
+
+		try {
+			PostResult result = kb1.post(pKI, bindingSet).get();
+
+			assertTrue(this.kb2Received, "KB2 should have received the posted data.");
+
+			assertFalse(
+					result.getExchangeInfoPerKnowledgeBase().stream().anyMatch(ei -> ei.getStatus() == Status.FAILED));
+
+			BindingSet bs = result.getBindings();
+			assertTrue(bs.isEmpty());
+
+			LOG.info("After post!");
+		} catch (ExecutionException e) {
+			LOG.error("Error", e);
+			fail();
+		}
+	}
+
+	@AfterAll
+	public static void cleanup() {
+		LOG.info("Clean up: {}", TestPostReactLanguageTag.class.getSimpleName());
+		if (kb1 != null) {
+			kb1.stop();
+		} else {
+			fail("KB1 should not be null!");
+		}
+
+		if (kb2 != null) {
+
+			kb2.stop();
+		} else {
+			fail("KB2 should not be null!");
+		}
+	}
+
+}