--- a
+++ b/src/net/timbusproject/dpes/alternative/ReasonerClient/SOAP/DependencyReasonerClient.java
@@ -0,0 +1,72 @@
+/**
+ * Copyright (c) 2013/2014 Verein zur Foerderung der IT-Sicherheit in Oesterreich (SBA).
+ * The work has been developed in the TIMBUS Project and the above-mentioned are Members of the TIMBUS Consortium.
+ * TIMBUS is supported by the European Union under the 7th Framework Programme for research and technological
+ * development and demonstration activities (FP7/2007-2013) under grant agreement no. 269940.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at: http://www.apache.org/licenses/LICENSE-2.0
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied, including without
+ * limitation, any warranties or conditions of TITLE, NON-INFRINGEMENT, MERCHANTIBITLY, or FITNESS FOR A PARTICULAR
+ * PURPOSE. In no event and under no legal theory, whether in tort (including negligence), contract, or otherwise,
+ * unless required by applicable law or agreed to in writing, shall any Contributor be liable for damages, including
+ * any direct, indirect, special, incidental, or consequential damages of any character arising as a result of this
+ * License or out of the use or inability to use the Work.
+ * See the License for the specific language governing permissions and limitation under the License.
+ */
+
+package net.timbusproject.dpes.alternative.ReasonerClient.SOAP;
+
+import net.timbusproject.dpes.alternative.ReasonerClient.REST.RequestData;
+import net.timbusproject.dpes.alternative.ReasonerClient.common.ReasonerClientException;
+import net.timbusproject.reasoner.Accept;
+import net.timbusproject.reasoner.ServerService;
+import org.json.JSONObject;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+
+public class DependencyReasonerClient {
+
+ private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(DependencyReasonerClient.class);
+
+ public DependencyReasonerClient() {
+ }
+
+ /***
+ * This might take some minutes because of the synchronous invocation of the reasoner.
+ */
+ public JSONObject request(RequestData requestData) throws IOException, ReasonerClientException {
+ LOG.info("Issuing reasoning request...");
+ String uuid = initiateReasoning(requestData);
+ LOG.info("Got UUID: " + uuid);
+ LOG.info("Waiting for completion...");
+ JSONObject response = retrieveResult(uuid);
+ return response;
+ }
+
+ private JSONObject retrieveResult(String uuid) throws IOException, ReasonerClientException {
+ ServerService serverService = new ServerService();
+ JSONObject response = new JSONObject(serverService.getServerPort().requestStatus(uuid, Accept.JSON).getBody());
+ while (response.getString("status").equalsIgnoreCase("started")) {
+ try {
+ Thread.sleep(5 * 1000);
+ } catch (InterruptedException e) {
+ throw new ReasonerClientException(e);
+ }
+ response = new JSONObject(serverService.getServerPort().requestStatus(uuid, Accept.JSON).getBody());
+ }
+ return response;
+ }
+
+ private String initiateReasoning(RequestData requestData) throws IOException, ReasonerClientException {
+ ServerService serverService = new ServerService();
+ JSONObject response = new JSONObject(serverService.getServerPort().reason(requestData.toString(), Accept.JSON).getBody());
+ String status = response.getString("status");
+ if (!status.equalsIgnoreCase("started")) {
+ throw new ReasonerClientException("Request failed, returned status: " + status);
+ }
+ return response.getString("uuid");
+ }
+}