fix: parser S3Model not compatible with ObjectRemoved events

Author: Ran Isenberg

Diff for: examples/event_sources/src/kinesis_firehose_delivery_stream.py

@@ -1,7 +1,10 @@
 import base64
 import json
 
-from aws_lambda_powertools.utilities.data_classes import KinesisFirehoseEvent, event_source
+from aws_lambda_powertools.utilities.data_classes import (
+    KinesisFirehoseEvent,
+    event_source,
+)
 from aws_lambda_powertools.utilities.typing import LambdaContext
 
 

Diff for: tests/events/s3EventDeleteObject.json

@@ -0,0 +1,36 @@
+{
+  "Records": [
+    {
+      "eventVersion": "2.1",
+      "eventSource": "aws:s3",
+      "awsRegion": "us-east-2",
+      "eventTime": "2019-09-03T19:37:27.192Z",
+      "eventName": "ObjectRemoved:Delete",
+      "userIdentity": {
+        "principalId": "AWS:AIDAINPONIXQXHT3IKHL2"
+      },
+      "requestParameters": {
+        "sourceIPAddress": "205.255.255.255"
+      },
+      "responseElements": {
+        "x-amz-request-id": "D82B88E5F771F645",
+        "x-amz-id-2": "vlR7PnpV2Ce81l0PRw6jlUpck7Jo5ZsQjryTjKlc5aLWGVHPZLj5NeC6qMa0emYBDXOo6QBU0Wo="
+      },
+      "s3": {
+        "s3SchemaVersion": "1.0",
+        "configurationId": "828aa6fc-f7b5-4305-8584-487c791949c1",
+        "bucket": {
+          "name": "lambda-artifacts-deafc19498e3f2df",
+          "ownerIdentity": {
+            "principalId": "A3I5XTEXAMAI3E"
+          },
+          "arn": "arn:aws:s3:::lambda-artifacts-deafc19498e3f2df"
+        },
+        "object": {
+          "key": "b21b84d653bb07b05b1e6b33684dc11b",
+          "sequencer": "0C0F6F405D6ED209E1"
+        }
+      }
+    }
+  ]
+}

Diff for: tests/functional/parser/test_s3.py

@@ -1,4 +1,6 @@
-from aws_lambda_powertools.utilities.parser import event_parser, parse
+import pytest
+
+from aws_lambda_powertools.utilities.parser import ValidationError, event_parser, parse
 from aws_lambda_powertools.utilities.parser.models import S3Model, S3RecordModel
 from aws_lambda_powertools.utilities.typing import LambdaContext
 from tests.functional.utils import load_event
@@ -93,3 +95,57 @@ def test_s3_empty_object():
     event_dict = load_event("s3Event.json")
     event_dict["Records"][0]["s3"]["object"]["size"] = 0
     parse(event=event_dict, model=S3Model)
+
+
+def test_s3_none_object_size_failed_validation():
+    event_dict = load_event("s3Event.json")
+    event_dict["Records"][0]["s3"]["object"]["size"] = None
+    with pytest.raises(ValidationError):
+        parse(event=event_dict, model=S3Model)
+
+
+def test_s3_none_etag_value_failed_validation():
+    event_dict = load_event("s3Event.json")
+    event_dict["Records"][0]["s3"]["object"]["eTag"] = None
+    with pytest.raises(ValidationError):
+        parse(event=event_dict, model=S3Model)
+
+
+@event_parser(model=S3Model)
+def handle_s3_delete_object(event: S3Model, _: LambdaContext):
+    records = list(event.Records)
+    assert len(records) == 1
+    record: S3RecordModel = records[0]
+    assert record.eventVersion == "2.1"
+    assert record.eventSource == "aws:s3"
+    assert record.awsRegion == "us-east-2"
+    convert_time = int(round(record.eventTime.timestamp() * 1000))
+    assert convert_time == 1567539447192
+    assert record.eventName == "ObjectRemoved:Delete"
+    user_identity = record.userIdentity
+    assert user_identity.principalId == "AWS:AIDAINPONIXQXHT3IKHL2"
+    request_parameters = record.requestParameters
+    assert str(request_parameters.sourceIPAddress) == "205.255.255.255/32"
+    assert record.responseElements.x_amz_request_id == "D82B88E5F771F645"
+    assert (
+        record.responseElements.x_amz_id_2
+        == "vlR7PnpV2Ce81l0PRw6jlUpck7Jo5ZsQjryTjKlc5aLWGVHPZLj5NeC6qMa0emYBDXOo6QBU0Wo="
+    )
+    s3 = record.s3
+    assert s3.s3SchemaVersion == "1.0"
+    assert s3.configurationId == "828aa6fc-f7b5-4305-8584-487c791949c1"
+    bucket = s3.bucket
+    assert bucket.name == "lambda-artifacts-deafc19498e3f2df"
+    assert bucket.ownerIdentity.principalId == "A3I5XTEXAMAI3E"
+    assert bucket.arn == "arn:aws:s3:::lambda-artifacts-deafc19498e3f2df"
+    assert s3.object.key == "b21b84d653bb07b05b1e6b33684dc11b"
+    assert s3.object.size is None
+    assert s3.object.eTag is None
+    assert s3.object.versionId is None
+    assert s3.object.sequencer == "0C0F6F405D6ED209E1"
+    assert record.glacierEventData is None
+
+
+def test_s3_trigger_event_delete_object():
+    event_dict = load_event("s3EventDeleteObject.json")
+    handle_s3_delete_object(event_dict, LambdaContext())