Read json file when the statemachine invoke

Author: horike37

index.js

@@ -110,6 +110,10 @@ class ServerlessStepFunctions {
                 usage: 'String data to be passed as an event to your step function',
                 shortcut: 'd',
               },
+              path: {
+                usage: 'The path to a json file with input data to be passed to the invoked step function',
+                shortcut: 'p',
+              },
               stage: {
                 usage: 'Stage of the service',
                 shortcut: 's',
@@ -159,6 +163,7 @@ class ServerlessStepFunctions {
 
   invoke() {
     return BbPromise.bind(this)
+    .then(this.parseInputdate)
     .then(this.getStateMachineArn)
     .then(this.startExecution)
     .then(this.describeExecution);
@@ -332,9 +337,21 @@ class ServerlessStepFunctions {
     });
   }
 
+  parseInputdate() {
+    if (!this.options.data && this.options.path) {
+      const absolutePath = path.isAbsolute(this.options.path) ?
+        this.options.path :
+        path.join(this.serverless.config.servicePath, this.options.path);
+      if (!this.serverless.utils.fileExistsSync(absolutePath)) {
+        throw new this.serverless.classes.Error('The file you provided does not exist.');
+      }
+      this.options.data = JSON.stringify(this.serverless.utils.readFileSync(absolutePath));
+    }
+    return BbPromise.resolve();
+  }
+
   startExecution() {
     this.serverless.cli.log(`Start function ${this.options.state}...`);
-
     return this.provider.request('StepFunctions',
       'startExecution',
       {

index.test.js

@@ -407,6 +407,45 @@ describe('ServerlessStepFunctions', () => {
     );
   });
 
+  describe('#parseInputdate()', () => {
+    let fileExistsSyncStub;
+    let readFileSyncStub;
+    beforeEach(() => {
+      serverlessStepFunctions.serverless.config.servicePath = 'servicePath';
+      fileExistsSyncStub = sinon.stub(serverlessStepFunctions.serverless.utils, 'fileExistsSync')
+      .returns(true);
+      readFileSyncStub = sinon.stub(serverlessStepFunctions.serverless.utils, 'readFileSync')
+      .returns({ foo: 'var' });
+      serverlessStepFunctions.options.data = null;
+      serverlessStepFunctions.options.path = 'data.json';
+    });
+
+    it('should throw error if file does not exists', () => {
+      serverlessStepFunctions.serverless.utils.fileExistsSync.restore();
+      fileExistsSyncStub = sinon.stub(serverlessStepFunctions.serverless.utils, 'fileExistsSync')
+      .returns(false);
+      expect(() => serverlessStepFunctions.parseInputdate()).to.throw(Error);
+      serverlessStepFunctions.serverless.utils.readFileSync.restore();
+    });
+
+    it('should parse file if path param is provided', () => {
+      return serverlessStepFunctions.parseInputdate().then(() => {
+        expect(serverlessStepFunctions.options.data).to.deep.equal('{"foo":"var"}');
+        serverlessStepFunctions.serverless.utils.fileExistsSync.restore();
+        serverlessStepFunctions.serverless.utils.readFileSync.restore();
+      });
+    });
+
+    it('should return resolve if path param is not provided', () => {
+      serverlessStepFunctions.options.path = null;
+      return serverlessStepFunctions.parseInputdate().then(() => {
+        expect(serverlessStepFunctions.options.data).to.deep.equal(null);
+        serverlessStepFunctions.serverless.utils.fileExistsSync.restore();
+        serverlessStepFunctions.serverless.utils.readFileSync.restore();
+      });
+    });
+  });
+
   describe('#startExecution()', () => {
     let startExecutionStub;
     beforeEach(() => {