Plugins implemented

Author: ishaileshmishra

src/main/java/com/contentstack/sdk/Asset.java

@@ -87,10 +87,10 @@ public Asset configure(JSONObject jsonObject) {
      *         <b>Example :</b><br>
      *
      *         <pre class="prettyprint">
-     *         Stack stack = Contentstack.stack("apiKey", "deliveryToken", "environment");
-     *         Asset asset = stack.asset(asset_uid);
-     *         asset.setHeader();
-     *         </pre>
+     *                         Stack stack = Contentstack.stack("apiKey", "deliveryToken", "environment");
+     *                         Asset asset = stack.asset(asset_uid);
+     *                         asset.setHeader();
+     *                 </pre>
      */
     public void setHeader(@NotNull String headerKey, @NotNull String headerValue) {
         headers.put(headerKey, headerValue);
@@ -108,10 +108,10 @@ public void setHeader(@NotNull String headerKey, @NotNull String headerValue) {
      *         <b>Example :</b><br>
      *
      *         <pre class="prettyprint">
-     *         Stack stack = Contentstack.stack("apiKey", "deliveryToken", "environment");
-     *         Asset asset = stack.asset(asset_uid);
-     *         asset.removeHeader();
-     *        </pre>
+     *                         Stack stack = Contentstack.stack("apiKey", "deliveryToken", "environment");
+     *                         Asset asset = stack.asset(asset_uid);
+     *                         asset.removeHeader();
+     *                        </pre>
      */
     public void removeHeader(@NotNull String headerKey) {
         headers.remove(headerKey);

src/main/java/com/contentstack/sdk/CSHttpConnection.java

@@ -191,20 +191,21 @@ private void getService(String requestUrl) throws IOException {
         this.headers.put(CONTENT_TYPE, APPLICATION_JSON);
 
         Request request = null;
-        if (this.config.plugins!=null){
+        if (this.config.plugins != null) {
             request = pluginRequestImp(requestUrl);
-            //this.headers = request.headers();
-            //requestUrl = request.url();
+            this.headers.clear();
+            Request finalRequest = request;
+            request.headers().names().forEach(key -> {
+                this.headers.put(key, finalRequest.headers().get(key));
+            });
+            requestUrl = request.url().toString();
         }
 
-        //Call call = client.newCall(request);
         Response<ResponseBody> response = this.service.getRequest(requestUrl, this.headers).execute();
         if (response.isSuccessful()) {
             assert response.body() != null;
-
-            // TODO: On Response result
-            if (request!=null){
-                response = pluginResponseImp( request, response);
+            if (request != null) {
+                response = pluginResponseImp(request, response);
             }
             responseJSON = new JSONObject(response.body().string());
             if (this.config.livePreviewEntry != null && !this.config.livePreviewEntry.isEmpty()) {

src/main/java/com/contentstack/sdk/ContentstackPlugin.java

@@ -1,11 +1,12 @@
 package com.contentstack.sdk;
 
 import okhttp3.Request;
+import okhttp3.ResponseBody;
 import retrofit2.Response;
 
 public interface ContentstackPlugin {
 
     void onRequest(Stack stack, Request request);
 
-    Response onResponse(Stack stack, Request request, Response response);
+    Response<ResponseBody> onResponse(Stack stack, Request request, Response response);
 }

src/test/java/com/contentstack/sdk/TestContentstackPlugin.java

@@ -65,14 +65,19 @@ void testContentstackPlugin() {
             plugins.add(plugin1);
             plugins.add(plugin2);
 
-
             // Create a config instance:
             Config config = new Config();
             config.setPlugins(plugins);
 
             Stack stack = Contentstack.stack(API_KEY, DELIVERY_TOKEN, ENV, config);
             ContentType contentType = stack.contentType("fakeCT");
-            Entry entry = contentType.entry();
+            Entry entry = contentType.entry("something_demo");
+            entry.fetch(new EntryResultCallBack() {
+                @Override
+                public void onCompletion(ResponseType responseType, Error error) {
+
+                }
+            });
 
         } catch (IllegalAccessException e) {
             throw new RuntimeException(e);