Implement CKafka Event

Author: stevapple

README.md

@@ -337,6 +337,7 @@ Tencent SCFs can be invoked directly from the Tencent SCF console, Tencent SCF A
 
 * [COS Events](https://cloud.tencent.com/document/product/583/9707)
 * [Timer Events](https://cloud.tencent.com/document/product/583/9708)
+* [CKafka Messages](https://cloud.tencent.com/document/product/583/17530)
 
 **Note**: Each one of the integration points mentioned above includes a set of `Codable` structs that transform Tencent Cloud's data model for these APIs.
 

Sources/TencentSCFEvents/CKafka.swift

@@ -0,0 +1,66 @@
+//===------------------------------------------------------------------------------------===//
+//
+// 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
+//
+//===------------------------------------------------------------------------------------===//
+
+// https://cloud.tencent.com/document/product/583/17530
+
+public enum CKafka {
+    public struct Event: Codable, Equatable {
+        public typealias Record = Message
+        public let records: [Record]
+
+        public enum CodingKeys: String, CodingKey {
+            case records = "Records"
+        }
+    }
+
+    public struct Message: Codable, Equatable {
+        public let topic: String
+        public let partition: UInt64
+        public let offset: UInt64
+        public let key: String
+        public let body: String
+        
+        enum WrappingCodingKeys: String, CodingKey {
+            case ckafka = "Ckafka"
+        }
+
+        enum CodingKeys: String, CodingKey {
+            case topic
+            case partition
+            case offset
+            case key = "msgKey"
+            case body = "msgBody"
+        }
+        
+        public func encode(to encoder: Encoder) throws {
+            var wrapperContainer = encoder.container(keyedBy: WrappingCodingKeys.self)
+            var container = wrapperContainer.nestedContainer(keyedBy: CodingKeys.self, forKey: .ckafka)
+            try container.encode(topic, forKey: .topic)
+            try container.encode(partition, forKey: .partition)
+            try container.encode(offset, forKey: .offset)
+            try container.encode(key, forKey: .key)
+            try container.encode(body, forKey: .body)
+        }
+        
+        public init(from decoder: Decoder) throws {
+            let wrapperContainer = try decoder.container(keyedBy: WrappingCodingKeys.self)
+            let container = try wrapperContainer.nestedContainer(keyedBy: CodingKeys.self, forKey: .ckafka)
+            topic = try container.decode(String.self, forKey: .topic)
+            partition = try container.decode(UInt64.self, forKey: .partition)
+            offset = try container.decode(UInt64.self, forKey: .offset)
+            key = try container.decode(String.self, forKey: .key)
+            body = try container.decode(String.self, forKey: .body)
+        }
+    }
+}

Tests/TencentSCFEventsTests/CKafkaTests.swift

@@ -0,0 +1,88 @@
+//===------------------------------------------------------------------------------------===//
+//
+// 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
+//
+//===------------------------------------------------------------------------------------===//
+
+@testable import TencentSCFEvents
+import XCTest
+
+class CKafkaTests: XCTestCase {
+    static let eventBody = """
+    {
+      "Records": [
+        {
+          "Ckafka": {
+            "topic": "test-topic",
+            "partition":1,
+            "offset":36,
+            "msgKey": "None",
+            "msgBody": "Hello from Ckafka!"
+          }
+        },
+        {
+          "Ckafka": {
+            "topic": "test-topic",
+            "partition":1,
+            "offset":37,
+            "msgKey": "None",
+            "msgBody": "Hello from Ckafka again!"
+          }
+        }
+      ]
+    }
+    """
+
+    func testSimpleEventFromJSON() {
+        let data = Self.eventBody.data(using: .utf8)!
+        var event: CKafka.Event?
+        XCTAssertNoThrow(event = try JSONDecoder().decode(CKafka.Event.self, from: data))
+
+        guard event?.records.count == 2 else {
+            XCTFail("Expected to have two records")
+            return
+        }
+        
+        if let record = event?.records.first {
+            XCTAssertEqual(record.topic, "test-topic")
+            XCTAssertEqual(record.partition, 1)
+            XCTAssertEqual(record.offset, 36)
+            XCTAssertEqual(record.key, "None")
+            XCTAssertEqual(record.body, "Hello from Ckafka!")
+        } else {
+            XCTFail("Unexpected error")
+            return
+        }
+        
+        if let record = event?.records.last {
+            XCTAssertEqual(record.topic, "test-topic")
+            XCTAssertEqual(record.partition, 1)
+            XCTAssertEqual(record.offset, 37)
+            XCTAssertEqual(record.key, "None")
+            XCTAssertEqual(record.body, "Hello from Ckafka again!")
+        } else {
+            XCTFail("Unexpected error")
+            return
+        }
+    }
+
+    func testEventDecodeAndEncode() {
+        let data = Self.eventBody.data(using: .utf8)!
+        let decoder = JSONDecoder()
+        var event: CKafka.Event?
+        XCTAssertNoThrow(event = try decoder.decode(CKafka.Event.self, from: data))
+
+        var newEvent: CKafka.Event?
+        XCTAssertNoThrow(newEvent = try decoder.decode(CKafka.Event.self, from: try JSONEncoder().encode(event)))
+
+        XCTAssertEqual(event, newEvent)
+    }
+}