Implement APIGateway Events

Author: stevapple

Examples/CloudFunctions/Sources/APIGateway/main.swift

@@ -37,11 +37,11 @@ Lambda.run(APIGatewayProxyLambda())
 
 // FIXME: Use proper Event abstractions once added to AWSLambdaRuntime
 struct APIGatewayProxyLambda: EventLoopLambdaHandler {
-    public typealias In = APIGateway.V2.Request
-    public typealias Out = APIGateway.V2.Response
+    public typealias In = APIGateway.Request
+    public typealias Out = APIGateway.Response
 
-    public func handle(context: Lambda.Context, event: APIGateway.V2.Request) -> EventLoopFuture<APIGateway.V2.Response> {
+    public func handle(context: Lambda.Context, event: APIGateway.Request) -> EventLoopFuture<APIGateway.Response> {
         context.logger.debug("hello, api gateway!")
-        return context.eventLoop.makeSucceededFuture(APIGateway.V2.Response(statusCode: .ok, body: "hello, world!"))
+        return context.eventLoop.makeSucceededFuture(APIGateway.Response(statusCode: .ok, body: "hello, world!"))
     }
 }

README.md

@@ -335,6 +335,7 @@ By default, the library also registers a Signal handler that traps `INT` and `TE
 
 Tencent SCFs can be invoked directly from the Tencent SCF console, Tencent SCF API, TCCLI and Tencent Cloud toolkit. More commonly, they are invoked as a reaction to an events coming from the Tencent Cloud platform. To make it easier to integrate with Tencent Cloud platform events, the library includes an `TencentSCFEvents` target which provides abstractions for many commonly used events. Additional events can be easily modeled when needed following the same patterns set by `TencentSCFEvents`. Integration points with the Tencent Cloud Platform include:
 
+* [APIGateway Request](https://cloud.tencent.com/document/product/583/12513)
 * [COS Events](https://cloud.tencent.com/document/product/583/9707)
 * [Timer Events](https://cloud.tencent.com/document/product/583/9708)
 * [CMQ Topic Messages](https://cloud.tencent.com/document/product/583/11517)

Sources/TencentSCFEvents/APIGateway.swift

@@ -0,0 +1,96 @@
+//===------------------------------------------------------------------------------------===//
+//
+// This source file is part of the SwiftTencentSCFRuntime open source project
+//
+// Copyright (c) 2020 stevapple and the SwiftTencentSCFRuntime project authors
+// Licensed under Apache License v2.0
+//
+// See LICENSE.txt for license information
+// See CONTRIBUTORS.txt for the list of SwiftTencentSCFRuntime project authors
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+//===------------------------------------------------------------------------------------===//
+
+import struct Foundation.Data
+import class Foundation.JSONEncoder
+
+// https://cloud.tencent.com/document/product/583/12513
+
+public enum APIGateway {
+    /// APIGatewayRequest contains data coming from the API Gateway
+    public struct Request: Codable {
+        public struct Context: Codable {
+            public let identity: [String: String]
+            public let serviceId: String
+            public let requestId: String
+            public let path: String
+            public let sourceIp: String
+            public let stage: Stage
+            public let httpMethod: HTTPMethod
+        }
+
+        public let path: String
+        public let httpMethod: HTTPMethod
+        public let headers: HTTPHeaders
+        public let query: [String: String]
+
+        public let pathParameters: [String: String]
+        public let queryStringParameters: [String: String]
+        public let headerParameters: [String: String]
+        public let stageVariables: [String: String]
+
+        public let context: Context
+        public let body: String
+
+        enum CodingKeys: String, CodingKey {
+            case context = "requestContext"
+            case body
+            case headers
+            case query = "queryString"
+            case path
+            case httpMethod
+
+            case pathParameters
+            case queryStringParameters
+            case headerParameters
+            case stageVariables
+        }
+    }
+
+    public enum Stage: String, Codable {
+        case test
+        case prepub
+        case release
+    }
+
+    public struct Response: Codable {
+        public let statusCode: HTTPResponseStatus
+        public let headers: HTTPHeaders?
+        public let body: String?
+        public let isBase64Encoded: Bool
+
+        public init(
+            statusCode: HTTPResponseStatus,
+            headers: HTTPHeaders? = nil,
+            body: String? = nil,
+            isBase64Encoded: Bool = false
+        ) {
+            self.statusCode = statusCode
+            self.headers = headers
+            self.body = body
+            self.isBase64Encoded = isBase64Encoded
+        }
+
+        public init(
+            statusCode: HTTPResponseStatus,
+            headers: HTTPHeaders? = nil,
+            body: Data? = nil
+        ) {
+            self.statusCode = statusCode
+            self.headers = headers
+            self.body = body?.base64EncodedString()
+            self.isBase64Encoded = true
+        }
+    }
+}