Use execDir to choose config and data dir when not forked.

[gpl/argeo-slc.git] / runtime / org.argeo.slc.server / src / main / java / org / argeo / slc / server / client / SlcServerHttpClient.java

diff --git a/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/server/client/SlcServerHttpClient.java b/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/server/client/SlcServerHttpClient.java
index 7a77175cf4a6de3a5e236c7f3c3acc8af14070df..59c49b0f6742271af17ed0b6b8aa7b4e89c6e6c8 100644 (file)
--- a/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/server/client/SlcServerHttpClient.java
+++ b/runtime/org.argeo.slc.server/src/main/java/org/argeo/slc/server/client/SlcServerHttpClient.java
@@ -1,54 +1,60 @@
 package org.argeo.slc.server.client;
 
-import java.io.InputStream;
-import java.net.HttpURLConnection;
-import java.net.URL;
+import java.util.List;
 import java.util.Map;
 
-import javax.xml.transform.stream.StreamSource;
-
-import org.apache.commons.io.IOUtils;
-import org.argeo.slc.SlcException;
-import org.springframework.oxm.Unmarshaller;
-
-public class SlcServerHttpClient {
-       private Unmarshaller unmarshaller;
-       private String baseUrl = "http://localhost:7070/org.argeo.slc.webapp/";
-
-       @SuppressWarnings(value = { "unchecked" })
-       public <T> T callService(String path, Map<String, String> parameters) {
-
-               InputStream in = null;
-               try {
-                       URL url = new URL(baseUrl + path);
-                       HttpURLConnection connection = (HttpURLConnection) url
-                                       .openConnection();
-                       if (parameters != null) {
-                               for (String key : parameters.keySet()) {
-                                       connection.addRequestProperty(key, parameters.get(key));
-                               }
-                       }
-
-                       connection.connect();
-
-                       in = connection.getInputStream();
-                       StreamSource source = new StreamSource(in);
-                       Object obj = unmarshaller.unmarshal(source);
-                       return (T) obj;
-               } catch (Exception e) {
-                       throw new SlcException("Cannot call service " + path + " on "
-                                       + baseUrl, e);
-               } finally {
-                       IOUtils.closeQuietly(in);
-               }
-       }
-
-       public void setUnmarshaller(Unmarshaller unmarshaller) {
-               this.unmarshaller = unmarshaller;
-       }
-
-       public void setBaseUrl(String baseUrl) {
-               this.baseUrl = baseUrl;
-       }
+import org.argeo.slc.execution.ExecutionModuleDescriptor;
+import org.argeo.slc.msg.ExecutionAnswer;
+import org.argeo.slc.msg.event.SlcEvent;
+import org.argeo.slc.process.RealizedFlow;
+import org.argeo.slc.process.SlcExecution;
+import org.argeo.slc.runtime.SlcAgentDescriptor;
+
+/** Abstraction of the access to HTTP services of an SLC Server. */
+public interface SlcServerHttpClient extends HttpServicesClient {
+       public final static String LIST_AGENTS = "listAgents.service";
+       public final static String IS_SERVER_READY = "isServerReady.service";
+       public final static String NEW_SLC_EXECUTION = "newSlcExecution.service";
+       public final static String LIST_SLC_EXECUTIONS = "listSlcExecutions.service";
+       public final static String GET_MODULE_DESCRIPTOR = "getExecutionDescriptor.service";
+       public final static String LIST_MODULE_DESCRIPTORS = "listModulesDescriptors.service";
+       public final static String LIST_RESULTS = "listResults.service";
+       public final static String ADD_EVENT_LISTENER = "addEventListener.service";
+       public final static String REMOVE_EVENT_LISTENER = "removeEventListener.service";
+       public final static String POLL_EVENT = "pollEvent.service";
+
+       /** Wait for the provided SlcExecution to be finished. */
+       public void waitForSlcExecutionFinished(SlcExecution slcExecution,
+                       Long timeout);
+
+       /** Block until one of the registered event is finished. */
+       public SlcEvent pollEvent(Long timeout);
+
+       /** Register an event type. */
+       public ExecutionAnswer addEventListener(String eventType, String eventFilter);
+
+       /** Unregister an event type. */
+       public ExecutionAnswer removeEventListener(String eventType,
+                       String eventFilter);
+
+       /** Wait for one agent to be available. */
+       public SlcAgentDescriptor waitForOneAgent();
+
+       /** Wait for the http server to be ready. */
+       public void waitForServerToBeReady();
+
+       /** Start an execution flow on the given agent. */
+       public SlcExecution startFlow(String agentId, RealizedFlow realizedFlow);
+
+       /** Assume one agent and one version per module. */
+       public SlcExecution startFlowDefault(String moduleName, String flowName,
+                       Map<String, Object> args);
+
+       /** List execution modules descriptors. */
+       public List<ExecutionModuleDescriptor> listModuleDescriptors(String agentId);
+
+       /** Retrieve a single execution module descriptor. */
+       public ExecutionModuleDescriptor getModuleDescriptor(String agentId,
+                       String moduleName, String version);
 
 }