More Events.

Added the following Event types:
- ALB Event
- Cloudwatch Event
- SQS Event
- SNS Event
- DynamoDB Event

Improvements to:
- APIGateway

Added multi purpose type:
- Added AWSNumber (Thanks for the idea @Ro-M.)

Author: fabianfett

.gitignore

@@ -4,4 +4,5 @@
 xcuserdata
 Layer
 Examples/**/lambda.zip
-packaged.yaml
+packaged.yaml
+bootstrap

.swiftpm/xcode/xcshareddata/xcschemes/AWSLambda.xcscheme

@@ -0,0 +1,18 @@
+// swift-tools-version:5.1
+// The swift-tools-version declares the minimum version of Swift required to build this package.
+
+import PackageDescription
+
+let package = Package(
+  name: "EventSources",
+  dependencies: [
+    .package(path: "../.."),
+    .package(url: "https://github.com/apple/swift-nio.git", .upToNextMajor(from: "2.9.0")),
+    .package(url: "https://github.com/apple/swift-log.git", .upToNextMajor(from: "1.1.1")),
+  ],
+  targets: [
+    .target(
+      name: "EventSources",
+      dependencies: ["LambdaRuntime", "Logging", "NIO", "NIOFoundationCompat", "NIOHTTP1"]),
+  ]
+)

Examples/EventSources/Package.resolved

@@ -0,0 +1,3 @@
+# EventSources
+
+This package/executable can be used to test the different Event types. This especially usefull during development of new Event types. We use the sam `template.yaml` to deploy the external resources needed for testing. Please be aware, if you deploy the given `template.yaml` costs may occur (especially when using the LoadBalancer). 

Examples/EventSources/Package.swift

@@ -0,0 +1,119 @@
+import LambdaRuntime
+import NIO
+import Logging
+import Foundation
+
+LoggingSystem.bootstrap(StreamLogHandler.standardError)
+
+
+let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
+defer { try! group.syncShutdownGracefully() }
+let logger = Logger(label: "AWSLambda.EventSources")
+
+func handleSNS(event: SNS.Event, ctx: Context) -> EventLoopFuture<Void> {
+  ctx.logger.info("Payload: \(String(describing: event))")
+  
+  return ctx.eventLoop.makeSucceededFuture(Void())
+}
+
+func handleSQS(event: SQS.Event, ctx: Context) -> EventLoopFuture<Void> {
+  ctx.logger.info("Payload: \(String(describing: event))")
+  
+  return ctx.eventLoop.makeSucceededFuture(Void())
+}
+
+func handleDynamoStream(event: DynamoDB.Event, ctx: Context) -> EventLoopFuture<Void> {
+  ctx.logger.info("Payload: \(String(describing: event))")
+  
+  return ctx.eventLoop.makeSucceededFuture(Void())
+}
+
+func handleCloudwatchSchedule(event: Cloudwatch.Event<Cloudwatch.ScheduledEvent>, ctx: Context)
+  -> EventLoopFuture<Void>
+{
+  ctx.logger.info("Payload: \(String(describing: event))")
+  
+  return ctx.eventLoop.makeSucceededFuture(Void())
+}
+
+func handleAPIRequest(req: APIGateway.Request, ctx: Context) -> EventLoopFuture<APIGateway.Response> {
+  ctx.logger.info("Payload: \(String(describing: req))")
+  
+  struct Payload: Encodable {
+    let path: String
+    let method: String
+  }
+  
+  let payload = Payload(path: req.path, method: req.httpMethod.rawValue)
+  let response = try! APIGateway.Response(statusCode: .ok, payload: payload)
+  
+  return ctx.eventLoop.makeSucceededFuture(response)
+}
+
+func handleLoadBalancerRequest(req: ALB.TargetGroupRequest, ctx: Context) ->
+  EventLoopFuture<ALB.TargetGroupResponse>
+{
+  ctx.logger.info("Payload: \(String(describing: req))")
+  
+  struct Payload: Encodable {
+    let path: String
+    let method: String
+  }
+  
+  let payload = Payload(path: req.path, method: req.httpMethod.rawValue)
+  let response = try! ALB.TargetGroupResponse(statusCode: .ok, payload: payload)
+  
+  return ctx.eventLoop.makeSucceededFuture(response)
+}
+
+func printPayload(buffer: NIO.ByteBuffer, ctx: Context) -> EventLoopFuture<ByteBuffer?> {
+  let payload = buffer.getString(at: 0, length: buffer.readableBytes)
+  ctx.logger.error("Payload: \(String(describing: payload))")
+
+  return ctx.eventLoop.makeSucceededFuture(nil)
+}
+
+func printOriginalPayload(_ handler: @escaping (NIO.ByteBuffer, Context) -> EventLoopFuture<ByteBuffer?>)
+  -> ((NIO.ByteBuffer, Context) -> EventLoopFuture<ByteBuffer?>)
+{
+  return { (buffer, ctx) in
+    let payload = buffer.getString(at: 0, length: buffer.readableBytes)
+    ctx.logger.info("Payload: \(String(describing: payload))")
+
+    return handler(buffer, ctx)
+  }
+}
+
+do {
+  logger.info("start runtime")
+  let environment = try Environment()
+  let handler: LambdaRuntime.Handler
+  
+  switch environment.handlerName {
+  case "sns":
+    handler = printOriginalPayload(LambdaRuntime.codable(handleSNS))
+  case "sqs":
+    handler = printOriginalPayload(LambdaRuntime.codable(handleSQS))
+  case "dynamo":
+    handler = printOriginalPayload(LambdaRuntime.codable(handleDynamoStream))
+  case "schedule":
+    handler = printOriginalPayload(LambdaRuntime.codable(handleCloudwatchSchedule))
+  case "api":
+    handler = printOriginalPayload(APIGateway.handler(handleAPIRequest))
+  case "loadbalancer":
+    handler = printOriginalPayload(ALB.handler(multiValueHeadersEnabled: true, handleLoadBalancerRequest))
+  default:
+    handler = printPayload
+  }
+  
+  let runtime = try LambdaRuntime.createRuntime(eventLoopGroup: group, handler: handler)
+  defer { try! runtime.syncShutdown() }
+  logger.info("starting runloop")
+
+  try runtime.start().wait()
+}
+catch {
+  logger.error("error: \(String(describing: error))")
+}
+
+