Updated S3.Event (#195)

motivation: support s3:ObjectRemoved:* event

changes:
* Changed the S3.Event object size field to an optional due to the missing field on a s3:ObjectRemoved:* event
* Added one additional test to check propper json decoding

Author: mufumade

Sources/AWSLambdaEvents/S3.swift

@@ -69,7 +69,10 @@ public enum S3 {
 
     public struct Object: Codable {
         public let key: String
-        public let size: UInt64
+        /// The object's size in bytes.
+        ///
+        /// Note: This property is available for all event types except "ObjectRemoved:*"
+        public let size: UInt64?
         public let urlDecodedKey: String?
         public let versionId: String?
         public let eTag: String

Tests/AWSLambdaEventsTests/S3Tests.swift

@@ -16,7 +16,7 @@
 import XCTest
 
 class S3Tests: XCTestCase {
-    static let eventBody = """
+    static let eventBodyObjectCreated = """
     {
       "Records": [
         {
@@ -57,8 +57,49 @@ class S3Tests: XCTestCase {
     }
     """
 
-    func testSimpleEventFromJSON() {
-        let data = S3Tests.eventBody.data(using: .utf8)!
+    // A S3 ObjectRemoved:* event does not contain the object size
+    static let eventBodyObjectRemoved = """
+    {
+      "Records": [
+        {
+          "eventVersion":"2.1",
+          "eventSource":"aws:s3",
+          "awsRegion":"eu-central-1",
+          "eventTime":"2020-01-13T09:25:40.621Z",
+          "eventName":"ObjectRemoved:DeleteMarkerCreated",
+          "userIdentity":{
+            "principalId":"AWS:AAAAAAAJ2MQ4YFQZ7AULJ"
+          },
+          "requestParameters":{
+            "sourceIPAddress":"123.123.123.123"
+          },
+          "responseElements":{
+            "x-amz-request-id":"01AFA1430E18C358",
+            "x-amz-id-2":"JsbNw6sHGFwgzguQjbYcew//bfAeZITyTYLfjuu1U4QYqCq5CPlSyYLtvWQS+gw0RxcroItGwm8="
+          },
+          "s3":{
+            "s3SchemaVersion":"1.0",
+            "configurationId":"98b55bc4-3c0c-4007-b727-c6b77a259dde",
+            "bucket":{
+              "name":"eventsources",
+              "ownerIdentity":{
+                "principalId":"AAAAAAAAAAAAAA"
+              },
+              "arn":"arn:aws:s3:::eventsources"
+            },
+            "object":{
+              "key":"Hi.md",
+              "eTag":"91a7f2c3ae81bcc6afef83979b463f0e",
+              "sequencer":"005E1C37948E783A6E"
+            }
+          }
+        }
+      ]
+    }
+    """
+
+    func testObjectCreatedEvent() {
+        let data = S3Tests.eventBodyObjectCreated.data(using: .utf8)!
         var event: S3.Event?
         XCTAssertNoThrow(event = try JSONDecoder().decode(S3.Event.self, from: data))
 
@@ -85,4 +126,33 @@ class S3Tests: XCTestCase {
         XCTAssertEqual(record.s3.object.eTag, "91a7f2c3ae81bcc6afef83979b463f0e")
         XCTAssertEqual(record.s3.object.sequencer, "005E1C37948E783A6E")
     }
+
+    func testObjectRemovedEvent() {
+        let data = S3Tests.eventBodyObjectRemoved.data(using: .utf8)!
+        var event: S3.Event?
+        XCTAssertNoThrow(event = try JSONDecoder().decode(S3.Event.self, from: data))
+
+        guard let record = event?.records.first else {
+            XCTFail("Expected to have one record")
+            return
+        }
+
+        XCTAssertEqual(record.eventVersion, "2.1")
+        XCTAssertEqual(record.eventSource, "aws:s3")
+        XCTAssertEqual(record.awsRegion, .eu_central_1)
+        XCTAssertEqual(record.eventName, "ObjectRemoved:DeleteMarkerCreated")
+        XCTAssertEqual(record.eventTime, Date(timeIntervalSince1970: 1_578_907_540.621))
+        XCTAssertEqual(record.userIdentity, S3.UserIdentity(principalId: "AWS:AAAAAAAJ2MQ4YFQZ7AULJ"))
+        XCTAssertEqual(record.requestParameters, S3.RequestParameters(sourceIPAddress: "123.123.123.123"))
+        XCTAssertEqual(record.responseElements.count, 2)
+        XCTAssertEqual(record.s3.schemaVersion, "1.0")
+        XCTAssertEqual(record.s3.configurationId, "98b55bc4-3c0c-4007-b727-c6b77a259dde")
+        XCTAssertEqual(record.s3.bucket.name, "eventsources")
+        XCTAssertEqual(record.s3.bucket.ownerIdentity, S3.UserIdentity(principalId: "AAAAAAAAAAAAAA"))
+        XCTAssertEqual(record.s3.bucket.arn, "arn:aws:s3:::eventsources")
+        XCTAssertEqual(record.s3.object.key, "Hi.md")
+        XCTAssertNil(record.s3.object.size)
+        XCTAssertEqual(record.s3.object.eTag, "91a7f2c3ae81bcc6afef83979b463f0e")
+        XCTAssertEqual(record.s3.object.sequencer, "005E1C37948E783A6E")
+    }
 }