Add RSA query reasoner to perform CQ answering over RSA

1 files changed, 8 insertions, 17 deletions

diff --git a/src/main/scala/uk/ac/ox/cs/acqua/Main.scala b/src/main/scala/uk/ac/ox/cs/acqua/Main.scala
index e8cfeb7..221c0e2 100644
--- a/src/main/scala/uk/ac/ox/cs/acqua/Main.scala
+++ b/src/main/scala/uk/ac/ox/cs/acqua/Main.scala
@@ -57,29 +57,20 @@ object Acqua extends App {
   reasoner.loadOntology(ontology.origin)
   reasoner.importData(properties.getDataPath())
   if (reasoner.preprocess()) {
-      Utility.logInfo("The ontology is consistent!");
+      Utility logInfo "The ontology is consistent!"
   }
   else {
-      Utility.logInfo("The ontology is inconsistent!");
+      Utility logInfo "The ontology is inconsistent!"
       reasoner.dispose();
+      // Exit somehow
   }
 
   if (config contains 'queries) {
-    val queries =
-      RDFoxUtil.loadQueriesFromFiles(
-        config('queries).get[List[os.Path]],
-        RSA.Prefixes
-      )
-  //     for(String queryFile : properties.getQueryPath().split(";")) {
-  //         Collection<QueryRecord> queryRecords = pagoda.getQueryManager().collectQueryRecords(queryFile);
-  //         pagoda.evaluate(queryRecords);
+    val queryManager = reasoner.getQueryManager()
+    config('queries).get[List[os.Path]].map(path => {
+      val queries = queryManager collectQueryRecords path.toString
+      reasoner evaluate queries
+    })
   }
 }
 
-
-    // /* Perform query answering */
-    // val answers = rsa ask queries
-
-    // /* Perform logging */
-    // Logger write answers
-    // Logger.generateSimulationScripts(datapath, queries)