Created an extra package for the lambda events. (#22)

- LambdaEvents can be imported by other runtimes for handling Events.

Author: fabianfett

Package.swift

@@ -10,10 +10,14 @@ let package = Package(
       name: "LambdaRuntime",
       targets: ["LambdaRuntime"]
     ),
-  .library(
-    name: "LambdaRuntimeTestUtils",
-    targets: ["LambdaRuntimeTestUtils"]
-  ),
+    .library(
+      name: "LambdaEvents",
+      targets: ["LambdaEvents"]
+    ),
+    .library(
+      name: "LambdaRuntimeTestUtils",
+      targets: ["LambdaRuntimeTestUtils"]
+    ),
   ],
   dependencies: [
     .package(url: "https://github.com/apple/swift-nio.git", .upToNextMajor(from: "2.9.0")),
@@ -22,25 +26,30 @@ let package = Package(
     .package(url: "https://github.com/fabianfett/swift-base64-kit.git", .upToNextMajor(from: "0.2.0")),
   ],
   targets: [
-    .target(
-      name: "LambdaRuntime", dependencies: [
-        "AsyncHTTPClient",
-        "NIO",
-        "NIOHTTP1",
-        "NIOFoundationCompat",
-        "Logging",
-        "Base64Kit"
+    .target(name: "LambdaEvents", dependencies: [
+      "NIO",
+      "NIOHTTP1",
+      "NIOFoundationCompat",
+      "Base64Kit"
+    ]),
+    .target(name: "LambdaRuntime", dependencies: [
+      "LambdaEvents",
+      "AsyncHTTPClient",
+      "NIO",
+      "NIOHTTP1",
+      "NIOFoundationCompat",
+      "Logging"
+    ]),
+    .target(name: "LambdaRuntimeTestUtils", dependencies: [
+      "NIOHTTP1",
+      "LambdaRuntime"
     ]),
-    .target(
-      name: "LambdaRuntimeTestUtils",
-      dependencies: ["NIOHTTP1", "LambdaRuntime"]
-    ),
     .testTarget(name: "LambdaRuntimeTests", dependencies: [
-        "LambdaRuntime",
-        "LambdaRuntimeTestUtils",
-        "Base64Kit",
-        "NIOTestUtils",
-        "Logging",
+      "LambdaEvents",
+      "LambdaRuntime",
+      "LambdaRuntimeTestUtils",
+      "NIOTestUtils",
+      "Logging",
     ])
   ]
 )

Sources/LambdaRuntime/Events/ALB.swift renamed to Sources/LambdaEvents/ALB.swift

@@ -2,9 +2,7 @@ import Foundation
 import NIO
 import NIOHTTP1
 
-
 // https://github.com/aws/aws-lambda-go/blob/master/events/alb.go
-
 public struct ALB {
 
   /// ALBTargetGroupRequest contains data originating from the ALB Lambda target group integration
@@ -53,42 +51,6 @@ public struct ALB {
   }
 }
 
-// MARK: - Handler -
-
-extension ALB {
-  
-  public static func handler(
-    multiValueHeadersEnabled: Bool = false,
-    _ handler: @escaping (ALB.TargetGroupRequest, Context) -> EventLoopFuture<ALB.TargetGroupResponse>)
-    -> ((NIO.ByteBuffer, Context) -> EventLoopFuture<ByteBuffer?>)
-  {
-    // reuse as much as possible
-    let encoder = JSONEncoder()
-    let decoder = JSONDecoder()
-    encoder.userInfo[ALB.TargetGroupResponse.MultiValueHeadersEnabledKey] = multiValueHeadersEnabled
-    
-    return { (inputBytes: NIO.ByteBuffer, ctx: Context) -> EventLoopFuture<ByteBuffer?> in
-      
-      let req: ALB.TargetGroupRequest
-      do {
-        req = try decoder.decode(ALB.TargetGroupRequest.self, from: inputBytes)
-      }
-      catch {
-        return ctx.eventLoop.makeFailedFuture(error)
-      }
-            
-      return handler(req, ctx)
-        .flatMapErrorThrowing() { (error) -> ALB.TargetGroupResponse in
-          ctx.logger.error("Unhandled error. Responding with HTTP 500: \(error).")
-          return ALB.TargetGroupResponse(statusCode: .internalServerError)
-        }
-        .flatMapThrowing { (result: ALB.TargetGroupResponse) -> NIO.ByteBuffer in
-          return try encoder.encodeAsByteBuffer(result, allocator: ByteBufferAllocator())
-        }
-    }
-  }
-}
-
 // MARK: - Request -
 
 extension ALB.TargetGroupRequest: Decodable {
@@ -154,7 +116,7 @@ extension ALB.TargetGroupRequest: Decodable {
 
 extension ALB.TargetGroupResponse: Encodable {
 
-  internal static let MultiValueHeadersEnabledKey =
+  public static let MultiValueHeadersEnabledKey =
     CodingUserInfoKey(rawValue: "ALB.TargetGroupResponse.MultiValueHeadersEnabledKey")!
 
   enum CodingKeys: String, CodingKey {

Sources/LambdaRuntime/Events/APIGateway.swift renamed to Sources/LambdaEvents/APIGateway.swift

@@ -1,7 +1,7 @@
 import Foundation
-import NIOFoundationCompat
 import NIO
 import NIOHTTP1
+import NIOFoundationCompat
 import Base64Kit
 
 // https://github.com/aws/aws-lambda-go/blob/master/events/apigw.go
@@ -77,40 +77,6 @@ public struct APIGateway {
   }
 }
 
-// MARK: - Handler -
-
-extension APIGateway {
-  
-  public static func handler(
-    _ handler: @escaping (APIGateway.Request, Context) -> EventLoopFuture<APIGateway.Response>)
-    -> ((NIO.ByteBuffer, Context) -> EventLoopFuture<ByteBuffer?>)
-  {
-    // reuse as much as possible
-    let encoder = JSONEncoder()
-    let decoder = JSONDecoder()
-    
-    return { (inputBytes: NIO.ByteBuffer, ctx: Context) -> EventLoopFuture<ByteBuffer?> in
-      
-      let req: APIGateway.Request
-      do {
-        req = try decoder.decode(APIGateway.Request.self, from: inputBytes)
-      }
-      catch {
-        return ctx.eventLoop.makeFailedFuture(error)
-      }
-            
-      return handler(req, ctx)
-        .flatMapErrorThrowing() { (error) -> APIGateway.Response in
-          ctx.logger.error("Unhandled error. Responding with HTTP 500: \(error).")
-          return APIGateway.Response(statusCode: .internalServerError)
-        }
-        .flatMapThrowing { (result: Response) -> NIO.ByteBuffer in
-          return try encoder.encodeAsByteBuffer(result, allocator: ByteBufferAllocator())
-        }
-    }
-  }
-}
-
 // MARK: - Request -
 
 extension APIGateway.Request: Decodable {

Sources/LambdaRuntime/AWSNumber.swift renamed to Sources/LambdaEvents/AWSNumber.swift

@@ -5,7 +5,7 @@ import NIO
 public struct DynamoDB {
 
   public struct Event: Decodable {
-    let records: [EventRecord]
+    public let records: [EventRecord]
 
     public enum CodingKeys: String, CodingKey {
       case records = "Records"