Improvements to HTTP client SCL API

[simantics/platform.git] / bundles / org.simantics.scl.rest / src / org / simantics / scl / rest / HttpClientUtils.java

diff --git a/bundles/org.simantics.scl.rest/src/org/simantics/scl/rest/HttpClientUtils.java b/bundles/org.simantics.scl.rest/src/org/simantics/scl/rest/HttpClientUtils.java
new file mode 100644 (file)
index 0000000..dfdbf5b
--- /dev/null
+++ b/bundles/org.simantics.scl.rest/src/org/simantics/scl/rest/HttpClientUtils.java
@@ -0,0 +1,57 @@
+package org.simantics.scl.rest;
+
+import java.util.concurrent.Future;
+
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.Invocation;
+import javax.ws.rs.client.InvocationCallback;
+import javax.ws.rs.core.Configuration;
+import javax.ws.rs.core.Response;
+
+import org.glassfish.jersey.client.ClientConfig;
+import org.glassfish.jersey.media.multipart.MultiPartFeature;
+import org.simantics.scl.runtime.SCLContext;
+import org.simantics.scl.runtime.function.Function1;
+import org.simantics.scl.runtime.tuple.Tuple0;
+
+public class HttpClientUtils {
+    
+    public static Client buildClient(ClientBuilder clientBuilder) {
+        final ClientConfig clientConfig = new ClientConfig();
+        clientConfig.register(MultiPartFeature.class);
+        return ClientBuilder.newBuilder().withConfig((Configuration) clientConfig).build();
+    }
+    
+    public static String statusMessageOf(Response response) {
+        return response.getStatusInfo().getReasonPhrase();
+    }
+    
+    public static Future<Response> asyncInvoke(Invocation invocation, Function1<Response, Tuple0> responseCallback, Function1<Throwable, Tuple0> failureCallback) {
+        SCLContext context = SCLContext.createDerivedContext();
+        
+        return invocation.submit(new InvocationCallback<Response>() {
+
+            @Override
+            public void completed(Response response) {
+                SCLContext.push(context);
+                try {
+                    responseCallback.apply(response);
+                } finally {
+                    SCLContext.pop();
+                }
+            }
+            
+            @Override
+            public void failed(Throwable throwable) {
+                SCLContext.push(context);
+                try {
+                    failureCallback.apply(throwable);
+                } finally {
+                    SCLContext.pop();
+                }
+                
+            }
+        });
+    }
+}