Merge pull request #3 from Y2JChamp/master

X-CSRF-Token FETCH

Author: 0xMelkor

smp3.0connectionlib/src/main/java/stacksmashers/smp30connectionlib/delegate/ODataHttpPostClientCallback.java

@@ -0,0 +1,20 @@
+package stacksmashers.smp30connectionlib.delegate;
+
+import com.google.gson.JsonObject;
+import com.koushikdutta.ion.Response;
+
+/**
+ * Created by Y2J on 03/05/17.
+ */
+
+public interface ODataHttpPostClientCallback<T> {
+    /**
+     * Invoked on network or HTTP service error
+     **/
+    void onErrorCallback(Exception ex, Response<JsonObject> response);
+
+    /**
+     * Invoked on success
+     */
+    void onPostSuccessCallback();
+}

smp3.0connectionlib/src/main/java/stacksmashers/smp30connectionlib/delegate/ODataHttpTokenClientCallback.java

@@ -0,0 +1,20 @@
+package stacksmashers.smp30connectionlib.delegate;
+
+import com.google.gson.JsonObject;
+import com.koushikdutta.ion.Response;
+
+/**
+ * Created by Y2J on 03/05/17.
+ */
+
+public interface ODataHttpTokenClientCallback<T> {
+    /**
+     * Invoked on network or HTTP service error
+     **/
+    void onErrorCallback(Exception ex, Response<JsonObject> response);
+
+    /**
+     * Invoked on success of token fetch
+     */
+    void onFetchXCSRFTokenSuccessCallback(String token);
+}

smp3.0connectionlib/src/main/java/stacksmashers/smp30connectionlib/smp/Header.java

@@ -0,0 +1,28 @@
+package stacksmashers.smp30connectionlib.smp;
+
+import com.koushikdutta.async.http.NameValuePair;
+
+/**
+ * Created by Y2J on 03/05/17.
+ */
+
+public class Header implements NameValuePair {
+
+    private String name;
+    private String value;
+
+    public Header(String name, String value){
+        this.name = name;
+        this.value =value;
+    }
+
+    @Override
+    public String getName() {
+        return name;
+    }
+
+    @Override
+    public String getValue() {
+        return value;
+    }
+}

smp3.0connectionlib/src/main/java/stacksmashers/smp30connectionlib/smp/ODataHttpClient.java

@@ -9,13 +9,20 @@
 import com.google.gson.JsonDeserializer;
 import com.google.gson.JsonObject;
 import com.koushikdutta.async.future.FutureCallback;
+import com.koushikdutta.async.http.Headers;
+import com.koushikdutta.async.http.NameValuePair;
 import com.koushikdutta.ion.Ion;
 import com.koushikdutta.ion.Response;
 
 import java.lang.reflect.Type;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 import stacksmashers.smp30connectionlib.delegate.ODataHttpClientCallback;
+import stacksmashers.smp30connectionlib.delegate.ODataHttpPostClientCallback;
+import stacksmashers.smp30connectionlib.delegate.ODataHttpTokenClientCallback;
 import stacksmashers.smp30connectionlib.enums.TypeHttpProtocol;
 import stacksmashers.smp30connectionlib.exception.SmpExceptionInvalidInput;
 import stacksmashers.smp30connectionlib.netutil.IonFactory;
@@ -54,6 +61,8 @@ public class ODataHttpClient {
      * Handle events from the OData service
      **/
     private ODataHttpClientCallback delegate;
+    private ODataHttpTokenClientCallback tokenDelegate;
+    private ODataHttpPostClientCallback postDelegate;
 
     /**
      * Class used to inject json raw data
@@ -83,6 +92,16 @@ public void setDelegate(ODataHttpClientCallback delegate) throws SmpExceptionInv
         this.delegate = delegate;
     }
 
+    public void setTokenDelegate(ODataHttpTokenClientCallback tokenDelegate) throws SmpExceptionInvalidInput {
+        InputValidator.validateNotNull(tokenDelegate);
+        this.tokenDelegate = tokenDelegate;
+    }
+
+    public void setPostDelegate(ODataHttpPostClientCallback postDelegate) throws SmpExceptionInvalidInput {
+        InputValidator.validateNotNull(postDelegate);
+        this.postDelegate = postDelegate;
+    }
+
     public void setDeserializer(Class clazz, JsonDeserializer deserializer) throws SmpExceptionInvalidInput {
         InputValidator.validateNotNull(clazz);
         InputValidator.validateNotNull(deserializer);
@@ -149,4 +168,75 @@ private List buildResult(JsonObject raw, Type type) {
         return result;
     }
 
+    public void getXCSRFToken(String url) throws SmpExceptionInvalidInput {
+        TypeHttpProtocol protocol = InputValidator.getURLProtocol(url);
+
+        try {
+            IonFactory ionFactory = new IonFactory(this.context, protocol);
+            Ion ion = ionFactory.build();
+            ion.with(ionFactory.getContext())
+                    .load(url)
+                    .addHeader("X-SMP-APPCID", xsmpappcid)
+                    .addHeader("Accept", "application/json")
+                    .addHeader("X-CSRF-Token","Fetch")
+                    .basicAuthentication(username, password)
+                    .asJsonObject()
+                    .withResponse()
+                    .setCallback(new FutureCallback<Response<JsonObject>>() {
+                        @Override
+                        public void onCompleted(Exception e, Response<JsonObject> result) {
+                            try {
+                                new IonResponseManager(e, result);
+                                Headers response = result.getHeaders().getHeaders();
+                                String token = response.get("x-csrf-token");
+
+                                if (tokenDelegate != null) {
+                                    tokenDelegate.onFetchXCSRFTokenSuccessCallback(token);
+                                }
+                            } catch (Exception e1) {
+                                if (tokenDelegate != null) {
+                                    tokenDelegate.onErrorCallback(e, result);
+                                }
+                            }
+                        }
+                    });
+        } catch (Exception e) {
+            throw new SmpExceptionInvalidInput(e.getMessage());
+        }
+    }
+
+    public void sendODataEntitySet(String url, JsonObject jsonObject, Header... params) throws SmpExceptionInvalidInput {
+        TypeHttpProtocol protocol = InputValidator.getURLProtocol(url);
+
+        try {
+            IonFactory ionFactory = new IonFactory(this.context, protocol);
+            Ion ion = ionFactory.build();
+            ion.with(ionFactory.getContext())
+                    .load(url)
+                    .setHeader(params)
+                    .basicAuthentication(username, password)
+                    .setJsonObjectBody(jsonObject)
+                    .asJsonObject()
+                    .withResponse()
+                    .setCallback(new FutureCallback<Response<JsonObject>>() {
+                        @Override
+                        public void onCompleted(Exception e, Response<JsonObject> result) {
+                            try {
+                                new IonResponseManager(e, result);
+                                if (postDelegate != null) {
+                                    postDelegate.onPostSuccessCallback();
+                                }
+                            } catch (Exception e1) {
+                                if (postDelegate != null) {
+                                    postDelegate.onErrorCallback(e, result);
+                                }
+                            }
+                        }
+                    });
+        } catch (Exception e) {
+            throw new SmpExceptionInvalidInput(e.getMessage());
+        }
+    }
+
+
 }