Renamed LambdaRuntime to Runtime (#26)

Author: fabianfett

Package.swift

@@ -48,6 +48,7 @@ let package = Package(
       "LambdaEvents",
       "LambdaRuntime",
       "LambdaRuntimeTestUtils",
+      "NIO",
       "NIOTestUtils",
       "Logging",
     ])

README.md

@@ -38,7 +38,7 @@ let handler = APIGateway.handler() { (request, ctx) in
   }
 }
 
-let runtime = try LambdaRuntime.createRuntime(eventLoopGroup: group, handler: handler)
+let runtime = try Runtime.createRuntime(eventLoopGroup: group, handler: handler)
 defer { try! runtime.syncShutdown() }
 try runtime.start().wait()
 ```
@@ -130,9 +130,9 @@ let group = MultiThreadedEventLoopGroup(numberOfThreads: 1)
 defer { try! group.syncShutdownGracefully() }
 
 do {
-  let runtime = try LambdaRuntime.createRuntime(
+  let runtime = try Runtime.createRuntime(
     eventLoopGroup: group, 
-    handler: LambdaRuntime.codable(squareNumber))
+    handler: Runtime.codable(squareNumber))
 
   defer { try! runtime.syncShutdown() }
 

Sources/LambdaRuntime/Runtime+Codable.swift

@@ -2,7 +2,7 @@ import Foundation
 import NIO
 import NIOFoundationCompat
 
-extension LambdaRuntime {
+extension Runtime {
 
   /// wrapper to use for the register function that wraps the encoding and decoding
   public static func codable<Event: Decodable, Result: Encodable>(

Sources/LambdaRuntime/Runtime.swift

@@ -8,7 +8,7 @@ public struct InvocationError: Codable {
   let errorMessage: String
 }
 
-final public class LambdaRuntime {
+final public class Runtime {
 
   public typealias Handler = (NIO.ByteBuffer, Context) -> EventLoopFuture<NIO.ByteBuffer?>
 
@@ -29,14 +29,14 @@ final public class LambdaRuntime {
 
   /// the runtime shall be initialised with an EventLoopGroup, that is used throughout the lambda
   public static func createRuntime(eventLoopGroup: EventLoopGroup, environment: Environment? = nil, handler: @escaping Handler)
-    throws -> LambdaRuntime
+    throws -> Runtime
   {
     let env = try environment ?? Environment()
 
     let client  = RuntimeAPIClient(
       eventLoopGroup: eventLoopGroup,
       lambdaRuntimeAPI: env.lambdaRuntimeAPI)
-    let runtime = LambdaRuntime(
+    let runtime = Runtime(
       eventLoopGroup: eventLoopGroup,
       client: client,
       environment: env,

Tests/LambdaRuntimeTests/Runtime+CodableTests.swift

@@ -28,7 +28,7 @@ class RuntimeCodableTests: XCTestCase {
     defer {
         XCTAssertNoThrow(try eventLoopGroup.syncShutdownGracefully())
     }
-    let handler = LambdaRuntime.codable { (req: TestRequest, ctx) -> EventLoopFuture<TestResponse> in
+    let handler = Runtime.codable { (req: TestRequest, ctx) -> EventLoopFuture<TestResponse> in
       return ctx.eventLoop.makeSucceededFuture(TestResponse(greeting: "Hello \(req.name)!"))
     }
 
@@ -52,7 +52,7 @@ class RuntimeCodableTests: XCTestCase {
     defer {
         XCTAssertNoThrow(try eventLoopGroup.syncShutdownGracefully())
     }
-    let handler = LambdaRuntime.codable { (req: TestRequest, ctx) -> EventLoopFuture<TestResponse> in
+    let handler = Runtime.codable { (req: TestRequest, ctx) -> EventLoopFuture<TestResponse> in
       return ctx.eventLoop.makeSucceededFuture(TestResponse(greeting: "Hello \(req.name)!"))
     }
 
@@ -81,7 +81,7 @@ class RuntimeCodableTests: XCTestCase {
     defer {
         XCTAssertNoThrow(try eventLoopGroup.syncShutdownGracefully())
     }
-    let handler = LambdaRuntime.codable { (req: TestRequest, ctx) -> EventLoopFuture<Void> in
+    let handler = Runtime.codable { (req: TestRequest, ctx) -> EventLoopFuture<Void> in
       return ctx.eventLoop.makeSucceededFuture(Void())
     }
 
@@ -101,7 +101,7 @@ class RuntimeCodableTests: XCTestCase {
     defer {
         XCTAssertNoThrow(try eventLoopGroup.syncShutdownGracefully())
     }
-    let handler = LambdaRuntime.codable { (req: TestRequest, ctx) -> EventLoopFuture<Void> in
+    let handler = Runtime.codable { (req: TestRequest, ctx) -> EventLoopFuture<Void> in
       return ctx.eventLoop.makeSucceededFuture(Void())
     }
 
@@ -127,7 +127,7 @@ class RuntimeCodableTests: XCTestCase {
     defer {
         XCTAssertNoThrow(try eventLoopGroup.syncShutdownGracefully())
     }
-    let handler = LambdaRuntime.codable { (req: TestRequest, ctx) -> EventLoopFuture<Void> in
+    let handler = Runtime.codable { (req: TestRequest, ctx) -> EventLoopFuture<Void> in
       return ctx.eventLoop.makeFailedFuture(RuntimeError.unknown)
     }
 

Tests/LambdaRuntimeTests/RuntimeTests.swift

@@ -16,7 +16,7 @@ class RuntimeTests: XCTestCase {
     defer { XCTAssertNoThrow(try group.syncShutdownGracefully()) }
 
     do {
-      let runtime = try LambdaRuntime.createRuntime(eventLoopGroup: group) { (_, ctx) in
+      let runtime = try Runtime.createRuntime(eventLoopGroup: group) { (_, ctx) in
         return ctx.eventLoop.makeSucceededFuture(nil)
       }
       defer { XCTAssertNoThrow(try runtime.syncShutdown()) }
@@ -34,7 +34,7 @@ class RuntimeTests: XCTestCase {
     defer { XCTAssertNoThrow(try group.syncShutdownGracefully()) }
 
     do {
-      let runtime = try LambdaRuntime.createRuntime(eventLoopGroup: group) { (_, ctx) in
+      let runtime = try Runtime.createRuntime(eventLoopGroup: group) { (_, ctx) in
         return ctx.eventLoop.makeSucceededFuture(nil)
       }
       defer { XCTAssertNoThrow(try runtime.syncShutdown()) }

examples/EventSources/Sources/EventSources/main.swift

@@ -106,28 +106,28 @@ func printOriginalPayload(_ handler: @escaping (NIO.ByteBuffer, Context) -> Even
 do {
   logger.info("start runtime")
   let environment = try Environment()
-  let handler: LambdaRuntime.Handler
+  let handler: Runtime.Handler
 
   switch environment.handlerName {
   case "sns":
-    handler = printOriginalPayload(LambdaRuntime.codable(handleSNS))
+    handler = printOriginalPayload(Runtime.codable(handleSNS))
   case "sqs":
-    handler = printOriginalPayload(LambdaRuntime.codable(handleSQS))
+    handler = printOriginalPayload(Runtime.codable(handleSQS))
   case "dynamo":
-    handler = printOriginalPayload(LambdaRuntime.codable(handleDynamoStream))
+    handler = printOriginalPayload(Runtime.codable(handleDynamoStream))
   case "schedule":
-    handler = printOriginalPayload(LambdaRuntime.codable(handleCloudwatchSchedule))
+    handler = printOriginalPayload(Runtime.codable(handleCloudwatchSchedule))
   case "api":
     handler = printOriginalPayload(APIGateway.handler(handleAPIRequest))
   case "s3":
-    handler = printOriginalPayload(LambdaRuntime.codable(handleS3))
+    handler = printOriginalPayload(Runtime.codable(handleS3))
   case "loadbalancer":
     handler = printOriginalPayload(ALB.handler(multiValueHeadersEnabled: true, handleLoadBalancerRequest))
   default:
     handler = printPayload
   }
 
-  let runtime = try LambdaRuntime.createRuntime(eventLoopGroup: group, handler: handler)
+  let runtime = try Runtime.createRuntime(eventLoopGroup: group, handler: handler)
   defer { try! runtime.syncShutdown() }
   logger.info("starting runloop")
 

examples/SquareNumber/Sources/SquareNumber/main.swift

@@ -27,15 +27,15 @@ defer {
 
 do {
 
-  let handler: LambdaRuntime.Handler
+  let handler: Runtime.Handler
   switch ProcessInfo.processInfo.environment["_HANDLER"] {
   case "printNumber":
-    handler = LambdaRuntime.codable(printNumber)
+    handler = Runtime.codable(printNumber)
   default:
-    handler = LambdaRuntime.codable(squareNumber)
+    handler = Runtime.codable(squareNumber)
   }
 
-  let runtime = try LambdaRuntime.createRuntime(eventLoopGroup: group, handler: handler)
+  let runtime = try Runtime.createRuntime(eventLoopGroup: group, handler: handler)
   defer { try! runtime.syncShutdown() }
 
   try runtime.start().wait()

examples/TodoAPIGateway/Package.resolved

@@ -27,7 +27,7 @@ do {
 
   logger.info("register function")
 
-  let handler: LambdaRuntime.Handler
+  let handler: Runtime.Handler
   switch env.handlerName {
   case "list":
     handler = APIGateway.handler(controller.listTodos)
@@ -47,7 +47,7 @@ do {
 
   logger.info("starting runloop")
 
-  let runtime    = try LambdaRuntime.createRuntime(eventLoopGroup: group, environment: env, handler: handler)
+  let runtime    = try Runtime.createRuntime(eventLoopGroup: group, environment: env, handler: handler)
   defer { try! runtime.syncShutdown() }
   try runtime.start().wait()
 }