Implement a simple API Gateway event (#530)

Only 'body'.

Author: abetomo

bin/node-lambda

@@ -146,6 +146,7 @@ program
   .option('-M, --enableRunMultipleEvents [ENABLE_RUN_MULTIPLE_EVENTS]', 'Enable run multiple events',
     ENABLE_RUN_MULTIPLE_EVENTS)
   .option('-y, --proxy [PROXY]', 'Proxy server', PROXY)
+  .option('--apiGateway', 'Convert to API Gateway events', false)
   .action((prg) => lambda.run(prg))
 
 program

lib/main.js

@@ -80,7 +80,13 @@ event_sources.json and ${program.eventFile} files as needed.`)
       return this._runMultipleHandlers(event)
     }
     context.local = true
-    this._runHandler(handler, event, program, context)
+    const eventObject = (() => {
+      if (program.apiGateway) {
+        return this._convertToApiGatewayEvents(event)
+      }
+      return event
+    })()
+    this._runHandler(handler, eventObject, program, context)
   }
 
   _runHandler (handler, event, program, context) {
@@ -176,6 +182,16 @@ so you can easily test run multiple events.
     })
   }
 
+  _convertToApiGatewayEvents (event) {
+    console.log(`!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+Emulate only the body of the API Gateway event.
+!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+`)
+    return {
+      body: JSON.stringify(event)
+    }
+  }
+
   _isUseS3 (program) {
     if (typeof program.deployUseS3 === 'boolean') {
       return program.deployUseS3

test/node-lambda.js

@@ -244,6 +244,38 @@ describe('bin/node-lambda', () => {
         })
       })
     })
+
+    describe('node-lambda run (API Gateway events))', () => {
+      const eventObj = {
+        asyncTest: false,
+        callbackWaitsForEmptyEventLoop: true,
+        callbackCode: 'callback(null);'
+      }
+
+      it('`node-lambda run` exitCode is `0`', function (done) {
+        _generateEventFile(eventObj)
+        const run = spawn('node', [
+          nodeLambdaPath, 'run',
+          '--handler', 'index.handler',
+          '--eventFile', 'event.json',
+          '--apiGateway'
+        ])
+        let stdoutString = ''
+        run.stdout.on('data', (data) => {
+          stdoutString += data.toString().replace(/\r|\n|\s/g, '')
+        })
+
+        run.on('exit', (code) => {
+          const expected = '!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!EmulateonlythebodyoftheAPIGatewayevent.' +
+            '!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!Runningindex.handler==================================event' +
+            '{body:\'{"asyncTest":false,"callbackWaitsForEmptyEventLoop":true,"callbackCode":"callback(null);"}\'}' +
+            '==================================Stoppingindex.handlerSuccess:'
+          assert.equal(stdoutString, expected)
+          assert.equal(code, 0)
+          done()
+        })
+      })
+    })
   })
 
   describe('node-lambda duplicate check of short option', () => {