added AWS S3 Event Source (#632)

* added AWS S3 Event Source

* Update s3.js

---------

Co-authored-by: Jon Greenwood <[email protected]>
Co-authored-by: Brett Andrews <[email protected]>

src/configure.d.ts

@@ -3,7 +3,7 @@ import { Handler } from 'aws-lambda';
 import { Logger } from './logger';
 import Framework from './frameworks';
 
-type EventSources = 'AWS_SNS' | 'AWS_DYNAMODB' | 'AWS_EVENTBRIDGE' | 'AWS_SQS' | 'AWS_KINESIS_DATA_STREAM';
+type EventSources = 'AWS_SNS' | 'AWS_DYNAMODB' | 'AWS_EVENTBRIDGE' | 'AWS_SQS' | 'AWS_KINESIS_DATA_STREAM' | 'AWS_S3';
 
 interface EventSource {
   getRequest?: any; // TODO:

src/event-sources/aws/s3.js

@@ -0,0 +1,28 @@
+const getRequestValuesFromS3 = ({ event }) => {
+  const method = 'POST'
+  const headers = { host: 's3.amazonaws.com' }
+  const body = event
+
+  return {
+    method,
+    headers,
+    body
+  }
+}
+
+const getResponseToS3 = ({
+  statusCode,
+  body,
+  headers,
+  isBase64Encoded
+}) => ({
+  statusCode,
+  headers,
+  body,
+  isBase64Encoded
+})
+
+module.exports = {
+  getRequest: getRequestValuesFromS3,
+  getResponse: getResponseToS3
+}

src/event-sources/index.js

@@ -9,6 +9,7 @@ const azureHttpFunctionV3EventSource = require('./azure/http-function-runtime-v3
 const azureHttpFunctionV4EventSource = require('./azure/http-function-runtime-v4')
 const awsEventBridgeEventSource = require('./aws/eventbridge')
 const awsKinesisEventSource = require('./aws/kinesis')
+const awsS3 = require('./aws/s3')
 
 function getEventSource ({ eventSourceName }) {
   switch (eventSourceName) {
@@ -34,6 +35,8 @@ function getEventSource ({ eventSourceName }) {
       return awsEventBridgeEventSource
     case 'AWS_KINESIS_DATA_STREAM':
       return awsKinesisEventSource
+    case 'AWS_S3':
+      return awsS3
     default:
       throw new Error('Couldn\'t detect valid event source.')
   }