Added SNS & SQS Events

Sources/AWSLambdaEvents/SNS.swift

@@ -0,0 +1,107 @@
+//===----------------------------------------------------------------------===//
+//
+// This source file is part of the SwiftAWSLambdaRuntime open source project
+//
+// Copyright (c) 2017-2020 Apple Inc. and the SwiftAWSLambdaRuntime project authors
+// Licensed under Apache License v2.0
+//
+// See LICENSE.txt for license information
+// See CONTRIBUTORS.txt for the list of SwiftAWSLambdaRuntime project authors
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+//===----------------------------------------------------------------------===//
+
+import struct Foundation.Date
+
+/// https://github.com/aws/aws-lambda-go/blob/master/events/sns.go
+public enum SNS {
+    public struct Event: Decodable {
+        public struct Record: Decodable {
+            public let eventVersion: String
+            public let eventSubscriptionArn: String
+            public let eventSource: String
+            public let sns: Message
+
+            public enum CodingKeys: String, CodingKey {
+                case eventVersion = "EventVersion"
+                case eventSubscriptionArn = "EventSubscriptionArn"
+                case eventSource = "EventSource"
+                case sns = "Sns"
+            }
+        }
+
+        public let records: [Record]
+
+        public enum CodingKeys: String, CodingKey {
+            case records = "Records"
+        }
+    }
+
+    public struct Message {
+        public enum Attribute {
+            case string(String)
+            case binary([UInt8])
+        }
+
+        public let signature: String
+        public let messageId: String
+        public let type: String
+        public let topicArn: String
+        public let messageAttributes: [String: Attribute]
+        public let signatureVersion: String
+
+        @ISO8601WithFractionalSecondsCoding
+        public var timestamp: Date
+        public let signingCertURL: String
+        public let message: String
+        public let unsubscribeUrl: String
+        public let subject: String?
+    }
+}
+
+extension SNS.Message: Decodable {
+    enum CodingKeys: String, CodingKey {
+        case signature = "Signature"
+        case messageId = "MessageId"
+        case type = "Type"
+        case topicArn = "TopicArn"
+        case messageAttributes = "MessageAttributes"
+        case signatureVersion = "SignatureVersion"
+        case timestamp = "Timestamp"
+        case signingCertURL = "SigningCertUrl"
+        case message = "Message"
+        case unsubscribeUrl = "UnsubscribeUrl"
+        case subject = "Subject"
+    }
+}
+
+extension SNS.Message.Attribute: Equatable {}
+
+extension SNS.Message.Attribute: Decodable {
+    enum CodingKeys: String, CodingKey {
+        case dataType = "Type"
+        case dataValue = "Value"
+    }
+
+    public init(from decoder: Decoder) throws {
+        let container = try decoder.container(keyedBy: CodingKeys.self)
+
+        let dataType = try container.decode(String.self, forKey: .dataType)
+        // https://docs.aws.amazon.com/sns/latest/dg/sns-message-attributes.html#SNSMessageAttributes.DataTypes
+        switch dataType {
+        case "String":
+            let value = try container.decode(String.self, forKey: .dataValue)
+            self = .string(value)
+        case "Binary":
+            let base64encoded = try container.decode(String.self, forKey: .dataValue)
+            let bytes = try base64encoded.base64decoded()
+            self = .binary(bytes)
+        default:
+            throw DecodingError.dataCorruptedError(forKey: .dataType, in: container, debugDescription: """
+            Unexpected value \"\(dataType)\" for key \(CodingKeys.dataType).
+            Expected `String` or `Binary`.
+            """)
+        }
+    }
+}

Sources/AWSLambdaEvents/SQS.swift

@@ -0,0 +1,96 @@
+//===----------------------------------------------------------------------===//
+//
+// This source file is part of the SwiftAWSLambdaRuntime open source project
+//
+// Copyright (c) 2017-2020 Apple Inc. and the SwiftAWSLambdaRuntime project authors
+// Licensed under Apache License v2.0
+//
+// See LICENSE.txt for license information
+// See CONTRIBUTORS.txt for the list of SwiftAWSLambdaRuntime project authors
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+//===----------------------------------------------------------------------===//
+
+/// https://github.com/aws/aws-lambda-go/blob/master/events/sqs.go
+public enum SQS {
+    public struct Event: Decodable {
+        public let records: [Message]
+
+        enum CodingKeys: String, CodingKey {
+            case records = "Records"
+        }
+    }
+
+    public struct Message {
+        /// https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_MessageAttributeValue.html
+        public enum Attribute {
+            case string(String)
+            case binary([UInt8])
+            case number(String)
+        }
+
+        public let messageId: String
+        public let receiptHandle: String
+        public var body: String
+        public let md5OfBody: String
+        public let md5OfMessageAttributes: String?
+        public let attributes: [String: String]
+        public let messageAttributes: [String: Attribute]
+        public let eventSourceArn: String
+        public let eventSource: String
+        public let awsRegion: AWSRegion
+    }
+}
+
+extension SQS.Message: Decodable {
+    enum CodingKeys: String, CodingKey {
+        case messageId
+        case receiptHandle
+        case body
+        case md5OfBody
+        case md5OfMessageAttributes
+        case attributes
+        case messageAttributes
+        case eventSourceArn = "eventSourceARN"
+        case eventSource
+        case awsRegion
+    }
+}
+
+extension SQS.Message.Attribute: Equatable {}
+
+extension SQS.Message.Attribute: Decodable {
+    enum CodingKeys: String, CodingKey {
+        case dataType
+        case stringValue
+        case binaryValue
+
+        // BinaryListValue and StringListValue are unimplemented since
+        // they are not implemented as discussed here:
+        // https://docs.aws.amazon.com/AWSSimpleQueueService/latest/APIReference/API_MessageAttributeValue.html
+    }
+
+    public init(from decoder: Decoder) throws {
+        let container = try decoder.container(keyedBy: CodingKeys.self)
+
+        let dataType = try container.decode(String.self, forKey: .dataType)
+        switch dataType {
+        case "String":
+            let value = try container.decode(String.self, forKey: .stringValue)
+            self = .string(value)
+        case "Number":
+            let value = try container.decode(String.self, forKey: .stringValue)
+            self = .number(value)
+        case "Binary":
+            let base64encoded = try container.decode(String.self, forKey: .binaryValue)
+            let bytes = try base64encoded.base64decoded()
+            self = .binary(bytes)
+        default:
+            throw DecodingError.dataCorruptedError(forKey: .dataType, in: container, debugDescription: """
+            Unexpected value \"\(dataType)\" for key \(CodingKeys.dataType).
+            Expected `String`, `Binary` or `Number`.
+            """)
+        }
+    }
+}