multiple publish/unpublish on environment available

Author: iyerrama29

lib/publish.js

@@ -186,7 +186,6 @@ function Publish(_event, options) {
 Publish.prototype.init = function() {
   try {
     var self = this;
-    inputs.environment_ids = [];
     async.waterfall([
       function(cb) {
         //proceed after confirmation
@@ -212,21 +211,46 @@ Publish.prototype.init = function() {
       },
       function(authtoken, cb) {
         headers.authtoken = authtoken;
+        var body = {
+          _method: 'GET'
+        };
+        if (typeof inputs.environment === 'object' && Array.isArray(inputs.environment)) {
+          body.query = {
+            $or: []
+          };
+          inputs.environment.forEach(function (envName) {
+            body['query']['$or'].push({
+              name: envName
+            });
+          });
+        } else if (typeof inputs.environment === 'string') {
+          inputs.environment = [inputs.environment];
+        }
         // get environment names from Contentstack
         return request({
-          uri: `${api.host}/${api.version}${api.urls.environments}${inputs.environment}`,
+          uri: `${api.host}/${api.version}${api.urls.environments}`,
           headers: headers,
-          method: 'GET',
-          json: true
-        }, function(err, body) {
+          method: 'POST',
+          json: body
+        }, function(err, response) {
           if (err) {
             return cb(err);
-          } else if (body.environments && body.environments.length) {
-            log(info(JSON.stringify(body)));
-            inputs.environment_ids = _.map(body.environments, 'uid');
+          } else if (response && response.environments && response.environments.length) {
+            // set environment details
+            var envNames = _.map(response.environments, 'name');
+            var envNotPresent = [];
+            inputs.environment.forEach(function (envName) {
+              if (envNames.indexOf(envName) === -1) {
+                log(error(`${envName} was not found!`));
+                envNotPresent.push(envName);
+              }
+            });
+            if (envNotPresent.length > 0) {
+              return cb(`The following environments were not found in the stack!\n${envNotPresent}`);
+            }
             return cb(null);
           }
-          return cb(body);
+          return cb(`No environments were found in the stack! Query made on environment was:\n${JSON.stringify(body)}`);
         });
       },
       function(cb) {
@@ -251,10 +275,10 @@ Publish.prototype.init = function() {
       }
     ], function(err) {
       if (err) {
-        log(error(`Errorred in bulk ${inputs.event}ing on ${inputs.environment} environment due to\n${err.message || JSON.stringify(err)}`));
+        log(error(`Errorred in bulk ${inputs.event}ing on ${JSON.stringify(inputs.environment)} environment due to\n${err.message || JSON.stringify(err)}`));
         process.exit(1);
       }
-      log(success(`Bulk ${inputs.event}ing finished on ${inputs.environment} environment.`));
+      log(success(`Bulk ${inputs.event}ing finished on ${JSON.stringify(inputs.environment)} environment.`));
       process.exit(0);
       return;
     });
@@ -425,7 +449,7 @@ Publish.prototype.publishAssets = function(assets, finalCallback) {
       json: {
         asset: {
           locales: (Array.isArray(inputs.languages)) ? inputs.languages : [inputs.languages],
-          environments: (Array.isArray(inputs.environment)) ? inputs.environment : [inputs.environment]
+          environments: inputs.environment
         }
       }
     }, function(error) {