Implement SCFTimer Event

Author: stevapple

README.md

@@ -335,14 +335,10 @@ 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 Proxy](https://docs.aws.amazon.com/lambda/latest/dg/services-apigateway.html)
-* [COS](https://cloud.tencent.com/document/product/583/9707)
-* [SES Events](https://docs.aws.amazon.com/lambda/latest/dg/services-ses.html)
-* [SNS Events](https://docs.aws.amazon.com/lambda/latest/dg/with-sns.html)
-* [SQS Events](https://docs.aws.amazon.com/lambda/latest/dg/with-sqs.html)
-* [CloudWatch Events](https://docs.aws.amazon.com/lambda/latest/dg/services-cloudwatchevents.html)
-
-**Note**: Each one of the integration points mentioned above includes a set of `Codable` structs that mirror AWS' data model for these APIs.
+* [COS Events](https://cloud.tencent.com/document/product/583/9707)
+* [Timer Events](https://cloud.tencent.com/document/product/583/9708)
+
+**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.
 
 ## Performance
 

Sources/TencentSCFEvents/SCFTimer.swift

@@ -0,0 +1,51 @@
+//===------------------------------------------------------------------------------------===//
+//
+// 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.Date
+
+// https://cloud.tencent.com/document/product/583/9708
+
+public enum SCFTimer {
+    public struct Event: Codable, Equatable {
+        public let trigger: String
+        public var time: Date
+        public let message: String
+
+        enum CodingKeys: String, CodingKey {
+            case type = "Type"
+            case trigger = "TriggerName"
+            case time = "Time"
+            case message = "Message"
+        }
+
+        public func encode(to encoder: Encoder) throws {
+            var container = encoder.container(keyedBy: CodingKeys.self)
+            try container.encode("Timer", forKey: .type)
+            try container.encode(trigger, forKey: .trigger)
+            try container.encode(time, forKey: .time, using: DateCoding.ISO8601.self)
+            try container.encode(message, forKey: .message)
+        }
+
+        public init(from decoder: Decoder) throws {
+            let container = try decoder.container(keyedBy: CodingKeys.self)
+            let type = try container.decode(String.self, forKey: .type)
+            guard type == "Timer" else {
+                throw DecodingError.dataCorruptedError(forKey: CodingKeys.type, in: container, debugDescription: #"Expected type to be "Timer", but `\#(type)` does not match"#)
+            }
+            trigger = try container.decode(String.self, forKey: .trigger)
+            time = try container.decode(Date.self, forKey: .time, using: DateCoding.ISO8601.self)
+            message = try container.decode(String.self, forKey: .message)
+        }
+    }
+}

Tests/TencentSCFEventsTests/COSTests.swift

@@ -73,7 +73,7 @@ class COSTests: XCTestCase {
     """
 
     func testSimpleEventFromJSON() {
-        let data = COSTests.eventBody.data(using: .utf8)!
+        let data = Self.eventBody.data(using: .utf8)!
         var event: COS.Event?
         XCTAssertNoThrow(event = try JSONDecoder().decode(COS.Event.self, from: data))
 
@@ -108,7 +108,7 @@ class COSTests: XCTestCase {
     }
 
     func testEventDecodeAndEncode() {
-        let data = COSTests.eventBody.data(using: .utf8)!
+        let data = Self.eventBody.data(using: .utf8)!
         let decoder = JSONDecoder()
         var event: COS.Event?
         XCTAssertNoThrow(event = try decoder.decode(COS.Event.self, from: data))

Tests/TencentSCFEventsTests/SCFTimerTests.swift

@@ -0,0 +1,72 @@
+//===------------------------------------------------------------------------------------===//
+//
+// 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 SCFTimerTests: XCTestCase {
+    static let eventBody = """
+    {
+        "Type":"Timer",
+        "TriggerName":"EveryDay",
+        "Time":"2019-02-21T11:49:00Z",
+        "Message":"user define msg body"
+    }
+    """
+
+    func testSimpleEventFromJSON() {
+        let data = Self.eventBody.data(using: .utf8)!
+        var event: SCFTimer.Event?
+        XCTAssertNoThrow(event = try JSONDecoder().decode(SCFTimer.Event.self, from: data))
+
+        XCTAssertEqual(event?.message, "user define msg body")
+        XCTAssertEqual(event?.trigger, "EveryDay")
+        XCTAssertEqual(event?.time.description, "2019-02-21 11:49:00 +0000")
+    }
+
+    func testEventTypeNotMatch() {
+        let type = "time"
+        let wrongJson = """
+        {
+            "Type":"\(type)",
+            "TriggerName":"EveryDay",
+            "Time":"2019-02-21T11:49:00Z",
+            "Message":"user define msg body"
+        }
+        """
+        let data = wrongJson.data(using: .utf8)!
+
+        XCTAssertThrowsError(_ = try JSONDecoder().decode(SCFTimer.Event.self, from: data)) { error in
+            guard case DecodingError.dataCorrupted(let context) = error else {
+                XCTFail("Unexpected error: \(error)"); return
+            }
+
+            XCTAssertEqual(context.codingPath.compactMap { $0.stringValue }, ["Type"])
+            XCTAssertEqual(context.debugDescription, #"Expected type to be "Timer", but `\#(type)` does not match"#)
+            XCTAssertNil(context.underlyingError)
+        }
+    }
+
+    func testEventDecodeAndEncode() {
+        let data = Self.eventBody.data(using: .utf8)!
+        let decoder = JSONDecoder()
+        var event: SCFTimer.Event?
+        XCTAssertNoThrow(event = try decoder.decode(SCFTimer.Event.self, from: data))
+
+        var newEvent: SCFTimer.Event?
+        XCTAssertNoThrow(newEvent = try decoder.decode(SCFTimer.Event.self, from: try JSONEncoder().encode(event)))
+
+        XCTAssertEqual(event, newEvent)
+    }
+}