third commit

Author: horike37

lib/index.js

@@ -9,9 +9,28 @@ class AwsStepFunctionsDeploy {
     this.options = options;
     this.provider = this.serverless.getProvider('aws');
     this.awsStateLanguage = {};
+    this.commands = {
+      deploy: {
+        commands: {
+          stepf: {
+            usage: 'Deploy Step functions',
+            lifecycleEvents: [
+              'deploy'
+            ],
+            options: {
+              statemachine: {
+                usage: 'Name of the State Machine',
+                shortcut: 'sm',
+                required: true,
+              }
+            }
+          }
+        }
+      }
+    };
 
     this.hooks = {
-      'before:deploy:deploy': this.action.bind(this),
+      'deploy:stepf:deploy': this.action.bind(this),
     };
   }
 
@@ -48,53 +67,62 @@ class AwsStepFunctionsDeploy {
     if (!this.stepFunctions) {
       return BbPromise.resolve();
     }
-    
-
-    _.forEach(this.stepFunctions, function (stateMachine, stateMachineName) {
-      if (!stateMachine.start) {
-        const errorMessage = [
-          ' Please set `start` in stepFunctions statements in serverless.yml .',
-        ].join('');
-        throw new this.serverless.classes
-        .Error(errorMessage);
-      }
-      
-      //@todo error handling to not stateMachine.states
-
-      const StartAt = stateMachine.start;
-      const Comment = stateMachine.comment;
-      this.awsStateLanguage[stateMachineName] = {
-        Comment: Comment || 'Step Functions Generated by Serverless Step Functions.',
-        StartAt,
-        States: {},
-      };
 
-      _.forEach(stateMachine.states, function (state) {
-        //@todo error handling to not type and resource
-        const Type = state.type;
-        const Resource = state.resource;
-        this.awsStateLanguage[stateMachineName].States = {
-          Type,
-          Resource,
-          End: 'true'
-        }
-      });
-    });
+    if (typeof this.stepFunctions[this.options.statemachine] === 'undefined') {
+      const errorMessage = [
+         `Step function "${this.options.statemachine}" is not exists`,
+       ].join('');
+       throw new this.serverless.classes
+       .Error(errorMessage);
+    }
 
+    //@todo get lambda arn from functionname
+    this.awsStateLanguage[this.options.statemachine] = JSON.stringify(this.stepFunctions[this.options.statemachine]);
     return BbPromise.resolve();
   }
 
   deploy() {
-    return this.provider.request('StepFunctions',
-      'createStateMachine',
-      {
-        definition: 'STRING_VALUE',
-        name: 'STRING_VALUE',
-        roleArn: 'STRING_VALUE'
-      },
+    let stateMachineArn;
+
+    return this.provider.request('STS',
+      'getCallerIdentity',
+      {},
       this.options.stage,
-      this.options.region);
+      this.options.region)
+    .then((result) => {
+      const region = this.options.region || 'us-east-1';
+      stateMachineArn = `arn:aws:states:${region}:${result.Account}:stateMachine:${this.options.statemachine}`;
+    }).then((result) => {
+      return this.provider.request('StepFunctions',
+        'describeStateMachine',
+        {
+          stateMachineArn
+        },
+        this.options.stage,
+        this.options.region);
+    }).then((result) => {
+    console.log(result)
+      return this.provider.request('StepFunctions',
+        'deleteStateMachine',
+        {
+          stateMachineArn
+        },
+        this.options.stage,
+        this.options.region);
 
+    }).then((result) => {
+      return this.provider.request('StepFunctions',
+        'createStateMachine',
+        {
+          definition: this.awsStateLanguage[this.options.statemachine],
+          name: this.options.statemachine,
+          roleArn: ''
+        },
+        this.options.stage,
+        this.options.region)
+    }).catch((error) => {
+      console.log(error);
+    });
   }
 
 }