Merge pull request #76 from FlowzPlatform/pause-subscription-in-cb-subscription

Pause subscription in cb subscription

Author: chiragob

service/package.json

@@ -51,7 +51,7 @@
     "feathers-socketio": "^2.0.1",
     "fibers": "^2.0.0",
     "flowz-error-handler": "0.0.1",
-    "flowz-subscription": "^0.2.1",
+    "flowz-subscription": "^0.2.2",
     "helmet": "^3.9.0",
     "lodash": "^4.17.4",
     "moment": "^2.20.1",

service/src/services/cb-subscription/cb-subscription.class.js

@@ -36,7 +36,13 @@ class Service {
   }
 
   get (id, params) {
-    let result = retrieveSubscription(id, params);
+    let result;
+    if (params.query.pause) {
+      // console.log('pauseSubscription ::', params.query); /* eslint-disable-line no-console */
+      result = pauseSubscription(id, params);
+    } else {
+      result = retrieveSubscription(id, params);
+    }
 
     return Promise.resolve(result).then(res => {
       return res;
@@ -114,6 +120,28 @@ let retrieveSubscription = function (id, params) {
   });
 };
 
+let pauseSubscription = function (id, params) {
+  if (params.query.pause == 'true') {
+    // console.log('Pause'); /* eslint-disable-line no-console*/
+    return config.chargebee.subscription.pause(id).request(function (error, result) {
+      if (error) {
+        return error;
+      } else {
+        return result;
+      }
+    });
+  } else if (params.query.pause == 'false') {
+    // console.log('Play'); /* eslint-disable-line no-console*/
+    return config.chargebee.subscription.resume(id).request(function (error, result) {
+      if (error) {
+        return error;
+      } else {
+        return result;
+      }
+    });
+  }
+};
+
 let createSubscription = async(function (data, params) {
   //INITIATE NEW TRANSACTION 
   transaction_id = await (initiateTransaction(data, params));