Add the feature whitch manage to activites

Author: horike37

lib/activity.js

@@ -18,6 +18,18 @@ module.exports = {
     .then(() => BbPromise.resolve());
   },
 
+  createActivities() {
+    const promises = [];
+    _.forEach(this.deployedActivities, (value, key) => {
+      if (value === 'notDeployed') {
+        promises.push(key);
+      }
+    });
+    return BbPromise
+    .map(promises, (name) => this.createActivity(name))
+    .then(() => BbPromise.resolve());
+  },
+
   deleteActivity(name) {
     const activity = name || this.options.name;
     return this.provider.request('StepFunctions',
@@ -28,6 +40,18 @@ module.exports = {
     .then(() => BbPromise.resolve());
   },
 
+  deleteActivities() {
+    const promises = [];
+    _.forEach(this.deployedActivities, (value, key) => {
+      if (value === 'deployed') {
+        promises.push(key);
+      }
+    });
+    return BbPromise
+    .map(promises, (name) => this.deleteActivity(name))
+    .then(() => BbPromise.resolve());
+  },
+
   describeActivity(name) {
     const activity = name || this.options.name;
     return this.provider.request('StepFunctions',
@@ -44,6 +68,26 @@ module.exports = {
     });
   },
 
+  describeActivities() {
+    const promises = [];
+    _.forEach(this.serverless.service.stepFunctions.activities, (value) => {
+      promises.push(value);
+    });
+    return BbPromise
+    .map(promises, (name) => this.describeActivity(name))
+    .then(() => BbPromise.resolve());
+  },
+
+  checkActivitySettings() {
+    if (!this.serverless.service.stepFunctions.activities) {
+      const errorMessage = [
+        'activities statement does not exists in serverless.yml',
+      ].join('');
+      throw new this.serverless.classes.Error(errorMessage);
+    }
+    return BbPromise.resolve();
+  },
+
   checkActivitySetting(name) {
     const activity = name || this.options.name;
     if (this.serverless.service.stepFunctions.activities.indexOf(activity) < 0) {
@@ -52,6 +96,7 @@ module.exports = {
       ].join('');
       throw new this.serverless.classes.Error(errorMessage);
     }
+    return BbPromise.resolve();
   },
 
   getActivityArn(name) {
@@ -67,4 +112,14 @@ module.exports = {
       return BbPromise.resolve();
     });
   },
+
+  getActivityArns() {
+    const promises = [];
+    _.forEach(this.serverless.service.stepFunctions.activities, (value) => {
+      promises.push(value);
+    });
+    return BbPromise
+    .map(promises, (name) => this.getActivityArn(name))
+    .then(() => BbPromise.resolve());
+  },
 };

lib/index.js

@@ -225,15 +225,36 @@ class ServerlessStepFunctions {
             message += `${chalk.yellow(this.options.name)}${chalk.yellow(':')} `;
             message += `${this.activityArns[this.options.name]}\n`;
             this.serverless.cli.consoleLog(message);
+            return BbPromise.resolve();
           });
-        } else {
-          this.serverless.cli.log(`${this.options.name} activity have already deployed`);
         }
+        this.serverless.cli.log(`${this.options.name} activity have already deployed`);
+        return BbPromise.resolve();
       });
-    } else {
-      
     }
-    return BbPromise.resolve();
+    this.serverless.cli.log('Start to deploy all activities...');
+    return BbPromise.bind(this)
+    .then(this.yamlParse)
+    .then(this.checkActivitySettings)
+    .then(this.getActivityArns)
+    .then(this.describeActivities)
+    .then(this.createActivities)
+    .then(() => {
+      this.serverless.cli.log('Finish to deploy');
+      let message = '';
+      message += `${chalk.yellow.underline('Service Information')}\n`;
+      message += `${chalk.yellow('service:')} ${this.service}\n`;
+      message += `${chalk.yellow('stage:')} ${this.stage}\n`;
+      message += `${chalk.yellow('region:')} ${this.region}\n\n`;
+      message += `${chalk.yellow.underline('Deployed Activity ARNs')}\n`;
+      _.forEach(this.activityArns, (value, key) => {
+        message += `${chalk.yellow(key)}${chalk.yellow(':')} `;
+        message += `${value}\n`;
+      });
+
+      this.serverless.cli.consoleLog(message);
+      return BbPromise.resolve();
+    });
   }
 
   activityRemove() {
@@ -251,14 +272,22 @@ class ServerlessStepFunctions {
           .then(() => {
             this.serverless.cli.log('Finish to remove');
           });
-        } else {
-          this.serverless.cli.log(`${this.options.name} activity is not deployed`);
         }
+        this.serverless.cli.log(`${this.options.name} activity is not deployed`);
+        return BbPromise.resolve();
       });
-    } else {
-      
     }
-    return BbPromise.resolve();
+    this.serverless.cli.log('Start to remove all activities...');
+    return BbPromise.bind(this)
+    .then(this.yamlParse)
+    .then(this.checkActivitySettings)
+    .then(this.getActivityArns)
+    .then(this.describeActivities)
+    .then(this.deleteActivities)
+    .then(() => {
+      this.serverless.cli.log('Finish to remove');
+      return BbPromise.resolve();
+    });
   }
 
   stateMachineDeploy() {