SDK plugin support added

Author: nadeem-cs

index.d.ts

@@ -100,7 +100,7 @@ export class Stack {
     /**
      * @deprecated since version 3.15.0
      */
-    constructor(api_key: string, delivery_token: string, environment_name: string, region?: Region, fetchOptions?: FetchOptions, live_preview?: LivePreview);
+    constructor(api_key: string, delivery_token: string, environment_name: string, region?: Region, fetchOptions?: FetchOptions, live_preview?: LivePreview, plugins?: Plugins[]);
 
     environment: string;
     cachePolicy: CachePolicy;

src/core/lib/request.js

@@ -5,7 +5,8 @@ import fetch from "runtime/http.js";
 let version = '{{VERSION}}';
 let environment,
     api_key;
-export default function Request(options, fetchOptions) {
+export default function Request(stack, fetchOptions) {
+    let requestParams = stack.requestParams;
     return new Promise(function(resolve, reject) {
         let queryParams;
         let serialize = function(obj, prefix) {
@@ -28,21 +29,19 @@ export default function Request(options, fetchOptions) {
             return str.join("&");
         };
 
-        let url = options.url,
-            headers = options.headers;
+        
 
         // setting headers
-        headers['Content-Type'] = 'application/json; charset=UTF-8';
-        headers['X-User-Agent'] = 'contentstack-{{PLATFORM}}/' + version;
+        requestParams.headers['Content-Type'] = 'application/json; charset=UTF-8';
+        requestParams.headers['X-User-Agent'] = 'contentstack-{{PLATFORM}}/' + version;
 
-        if (options.body && typeof options.body === 'object') {
-            delete options.body._method;
-            if (typeof options.body.query === "object" && Object.keys(options.body.query).length === 0) delete options.body.query;
-            queryParams = serialize(options.body);
+        if (requestParams.body && typeof requestParams.body === 'object') {
+            delete requestParams.body._method;
+            if (typeof requestParams.body.query === "object" && Object.keys(requestParams.body.query).length === 0) delete requestParams.body.query;
+            queryParams = serialize(requestParams.body);
         }
 
-        return fetchRetry(url + '?' + queryParams, 
-                            headers, 
+        return fetchRetry(stack, queryParams, 
                             fetchOptions, 
                             resolve, 
                             reject, 
@@ -58,7 +57,10 @@ function wait(retryDelay) {
     });
 }
 
-function fetchRetry(url, headers, fetchOptions, resolve, reject, retryDelay = 300, retryLimit = 5) {
+function fetchRetry(stack, queryParams, fetchOptions, resolve, reject, retryDelay = 300, retryLimit = 5) {
+    let requestParams = stack.requestParams,
+        url = requestParams.url + '?' + queryParams,
+        headers = requestParams.headers
     var option = Utils.mergeDeep({ 
         method: 'GET',
         headers: headers,
@@ -83,20 +85,38 @@ function fetchRetry(url, headers, fetchOptions, resolve, reject, retryDelay = 30
             }
             wait(msDelay)
                 .then(() => {
-                    return fetchRetry(url, headers, fetchOptions, resolve, reject, retryDelay, retryLimit)
+                    return fetchRetry(stack, queryParams, fetchOptions, resolve, reject, retryDelay, retryLimit)
                 })
                 .catch(() => {
-                    return fetchRetry(url, headers, fetchOptions, resolve, reject, retryDelay, retryLimit)
+                    return fetchRetry(stack, queryParams, fetchOptions, resolve, reject, retryDelay, retryLimit)
                 })
         }
     }
+
     if (fetchOptions.debug)  fetchOptions.logHandler('info', { url: url, option: option});
+
+    var plugins = stack.plugins;
+    if (plugins && plugins != undefined)
+    plugins.forEach(pluginObj => {
+        pluginObj.onRequest(stack, {url, option})
+    });
+    
     fetch(url, option)
-        .then(function(response) {    
+        .then( function(response) {    
+
+            
             if (fetchOptions.debug)  fetchOptions.logHandler('info', response);
-            let data = response.json();      
+            let data = response.json();
+
             if (response.ok && response.status === 200) {
-                resolve(data);
+                data.then(json => {
+                    if (plugins) json.plugins = [];
+                    for (let index = 0; index < plugins.length; index++) {
+                        json =  plugins[index].onResponse(stack, {url, option}, response, json)
+                    }
+                    resolve(json);
+                })
+
             } else {
                 data.then((json) => {
                     if (fetchOptions.retryCondition && fetchOptions.retryCondition(response)) {

src/core/lib/utils.js

@@ -265,7 +265,7 @@ export function sendRequest(queryObject, options) {
 
     let callback = function(continueFlag, resolve, reject) {
         if (continueFlag) {
-            Request(queryObject.requestParams, options)
+            Request(queryObject, options)
                 .then(function(data) {
                     try {
                         self.entry_uid = self.asset_uid = self.tojson = self.queryCachePolicy = undefined;

src/core/stack.js

@@ -18,6 +18,7 @@ let errorRetry = [408, 429]
      * @param param.region - DB region for Stack.
      * @param param.branch - Name of the branch you want to fetch data from
      * @param param.live_preview - Live preview configuration.
+     * @param param.plugins - List of plugins objects.
      * @param param.fetchOptions - Custom setting for the request.
      * @param param.fetchOptions.debug - This will enable debug log. Default is false
      * @param param.fetchOptions.timeout - Set timeout for the request.
@@ -65,7 +66,7 @@ export default class Stack {
                     return
                 }
             }
-         };
+        };
         this.config = Utils.mergeDeep({}, config)
 
         if(stack_arguments[0].region && stack_arguments[0].region !== undefined && stack_arguments[0].region !== "us") {
@@ -75,6 +76,13 @@ export default class Stack {
         if (stack_arguments[0].fetchOptions && stack_arguments[0].fetchOptions !== undefined) {
             this.fetchOptions =  Utils.mergeDeep(this.fetchOptions, stack_arguments[0].fetchOptions);
         }
+
+        if (stack_arguments[0].plugins && stack_arguments[0].plugins !== undefined) {
+            this.plugins = []
+            stack_arguments[0].plugins.forEach(pluginObj => {
+                this.plugins.push(pluginObj)
+            });
+        }
 
         this.cachePolicy = CacheProvider.policies.IGNORE_CACHE;
         this.provider = CacheProvider.providers('localstorage');
@@ -371,17 +379,18 @@ export default class Stack {
      * @instance 
      */
     fetch(fetchOptions) {
-        let result = {
+        this.requestParams = {
             method: 'POST',
             headers: this.headers,
+            plugins: this.plugins,
             url: this.config.protocol + "://" + this.config.host + ':' + this.config.port + '/' + this.config.version + this.config.urls.content_types + this.content_type_uid,
             body: {
                 _method: 'GET',
                 environment: this.environment
             }
         };
         var options = Utils.mergeDeep(this.fetchOptions, fetchOptions);
-        return Request(result, options);
+        return Request(this, options);
     }
 
   /**