/selectQuery endpoint added

broker-core/src/main/java/de/fraunhofer/iais/eis/ids/broker/main/AppConfig.java

@@ -14,6 +14,7 @@
 import de.fraunhofer.iais.eis.ids.component.interaction.multipart.MultipartComponentInteractor;
 import de.fraunhofer.iais.eis.ids.component.interaction.validation.ShaclValidator;
 import de.fraunhofer.iais.eis.ids.connector.commons.broker.QueryHandler;
+import de.fraunhofer.iais.eis.ids.index.common.endpoint.FrontendEndpoints;
 import de.fraunhofer.iais.eis.ids.index.common.main.AppConfigTemplate;
 import de.fraunhofer.iais.eis.ids.index.common.persistence.ConstructQueryResultHandler;
 import de.fraunhofer.iais.eis.ids.index.common.persistence.DescriptionProvider;
@@ -58,6 +59,7 @@ public MultipartComponentInteractor build() {
         //Repository facade is our bridge to the triple store backend
         RepositoryFacade repositoryFacade = new RepositoryFacade(sparqlEndpointUrl);
 
+        FrontendEndpoints.repositoryFacade = repositoryFacade;
         //Object taking care of storing connectors and their resources in a triple store with optional indexing
         SelfDescriptionPersistenceAndIndexing selfDescriptionPersistence = new SelfDescriptionPersistenceAndIndexing(
                 repositoryFacade, catalogUri, indexing, maxNumberOfIndexedConnectorResources);

broker-core/src/main/java/de/fraunhofer/iais/eis/ids/broker/main/Main.java

@@ -31,7 +31,7 @@
  */
 @Configuration
 @EnableAutoConfiguration(exclude = SolrAutoConfiguration.class)
-@ComponentScan(basePackages = { "de.fraunhofer.iais.eis.ids.component.protocol.http.server"} )
+@ComponentScan(basePackages = { "de.fraunhofer.iais.eis.ids.component.protocol.http.server","de.fraunhofer.iais.eis.ids.index.common.endpoint"} )
 public class Main extends MainTemplate implements ComponentInteractorProvider {
 
     Logger logger = LoggerFactory.getLogger(Main.class);

open-index-common/src/main/java/de/fraunhofer/iais/eis/ids/index/common/endpoint/FrontendEndpoints.java

@@ -0,0 +1,38 @@
+package de.fraunhofer.iais.eis.ids.index.common.endpoint;
+
+
+import de.fraunhofer.iais.eis.ids.index.common.persistence.RepositoryFacade;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.core.env.Environment;
+
+
+/**
+ * This class adds endpoints to send SPARQL (update) queries to the triplestore
+ */
+@RestController
+public class FrontendEndpoints {
+
+    public static RepositoryFacade repositoryFacade;
+    //private String sparqlUrl = "http://broker-core:3030/connectorData";
+
+    @PostMapping("/updateQuery")
+    public String updateQuery(@RequestBody String queryMessage) {
+        repositoryFacade.getNewWritableConnection().update(queryMessage);
+        return "Query ran successfully";
+    }
+
+    /**
+     * This function provides read access to the triplestore by executing a SPARQL SELECT query
+     * @param queryMessage The SELECT query to be executed
+     * @return Query binding in TSV format
+     */
+    @PostMapping("/selectQuery")
+    public String readQuery(@RequestBody String queryMessage) {
+        return repositoryFacade.selectQueryReturnTSV(queryMessage);
+    }
+}