add serverless message

Author: horike37

index.js

@@ -65,6 +65,10 @@ class ServerlessStepFunctions {
                 shortcut: 's',
                 required: true,
               },
+              data: {
+                usage: 'String data to be passed as an event to your step function',
+                shortcut: 'd',
+              }
             },
           },
         },

lib/deploy.js

@@ -21,6 +21,8 @@ module.exports = {
       ]
     }
     `;
+
+    this.serverless.cli.log(`Start to deploy ${this.options.state} step function...`);
     BbPromise.bind(this)
     .then(this.yamlParse)
     .then(this.getStateMachineArn)
@@ -163,10 +165,13 @@ module.exports = {
       },
       this.options.stage,
       this.options.region)
-    .then(() => BbPromise.resolve())
-    .catch((error) => {
-    console.log(error)
+    .then(() => {
+      this.serverless.cli.consoleLog('');
+      this.serverless.cli.log(`Finish to deploy ${this.options.state} step function`);
+      return BbPromise.resolve()
+    }).catch((error) => {
       if (error.message.match(/State Machine is being deleted/)) {
+        this.serverless.cli.printDot();
         setTimeout(this.createStateMachine.bind(this), 5000);
       } else {
         throw new this.serverless.classes.Error(error.message);

lib/invoke.js

@@ -12,10 +12,13 @@ module.exports = {
   },
 
   startExecution() {
+    this.serverless.cli.log(`Start function ${this.options.state}...`);
+
     return this.provider.request('StepFunctions',
       'startExecution',
       {
         stateMachineArn: this.stateMachineArn,
+        input: this.options.data
       },
       this.options.stage,
       this.options.region)
@@ -36,11 +39,12 @@ module.exports = {
       this.options.stage,
       this.options.region)
     .then((result) => {
-
       if (result.status === 'RUNNING') {
+        this.serverless.cli.printDot();
         setTimeout(this.describeExecution.bind(this), 5000);
       } else {
-        
+        this.serverless.cli.consoleLog('');
+        this.serverless.cli.consoleLog(result);
       }
       return BbPromise.resolve();
     }).catch((error) => {

lib/remove.js

@@ -5,7 +5,11 @@ module.exports = {
   remove() {
     BbPromise.bind(this)
     .then(this.getStateMachineArn)
-    .then(this.deleteStateMachine);
+    .then(this.deleteStateMachine)
+    .then(() => {
+      this.serverless.cli.log(`Remove ${this.options.state}`);
+      return BbPromise.resolve();
+    });
 
     return BbPromise.resolve();
   },