feat: add lifecycle event data structure and corresponding test for S3 events

Author: yhamano0312

events/s3.go

@@ -28,6 +28,7 @@ type S3EventRecord struct {
 	RestoreEventData            *S3RestoreEventData            `json:"restoreEventData,omitempty"`
 	ReplicationEventData        *S3ReplicationEventData        `json:"replicationEventData,omitempty"`
 	IntelligentTieringEventData *S3IntelligentTieringEventData `json:"intelligentTieringEventData,omitempty"`
+	LifecycleEventData          *S3LifecycleEventData          `json:"lifecycleEventData,omitempty"`
 }
 
 type S3UserIdentity struct {
@@ -95,6 +96,14 @@ type S3IntelligentTieringEventData struct {
 	DestinationAccessTier string `json:"destinationAccessTier"`
 }
 
+type S3LifecycleEventData struct {
+	TransitionEventData *S3TransitionEventData `json:"transitionEventData"`
+}
+
+type S3TransitionEventData struct {
+	DestinationStorageClass string `json:"destinationStorageClass"`
+}
+
 type S3TestEvent struct {
 	Service   string    `json:"Service"`
 	Bucket    string    `json:"Bucket"`

events/s3_test.go

@@ -142,6 +142,41 @@ func TestS3IntelligentTieringEventMarshaling(t *testing.T) {
 	assert.JSONEq(t, string(inputJSON), string(outputJSON))
 }
 
+func TestS3LifecycleEventMarshaling(t *testing.T) {
+	// 1. read JSON from file
+	inputJSON := test.ReadJSONFromFile(t, "./testdata/s3-lifecycle-event.json")
+
+	// 2. de-serialize into Go object
+	var inputEvent S3Event
+	if err := json.Unmarshal(inputJSON, &inputEvent); err != nil {
+		t.Errorf("could not unmarshal event. details: %v", err)
+	}
+
+	// 3. verify lifecycleEventData is correctly parsed
+	if inputEvent.Records[0].LifecycleEventData == nil {
+		t.Error("lifecycleEventData should not be nil for lifecycle events")
+	}
+
+	// 4. verify transitionEventData is correctly parsed
+	if inputEvent.Records[0].LifecycleEventData.TransitionEventData == nil {
+		t.Error("transitionEventData should not be nil")
+	}
+
+	// 5. verify destinationStorageClass is correctly parsed
+	if inputEvent.Records[0].LifecycleEventData.TransitionEventData.DestinationStorageClass == "" {
+		t.Error("destinationStorageClass should not be empty")
+	}
+
+	// 6. serialize to JSON
+	outputJSON, err := json.Marshal(inputEvent)
+	if err != nil {
+		t.Errorf("could not marshal event. details: %v", err)
+	}
+
+	// 7. check result
+	assert.JSONEq(t, string(inputJSON), string(outputJSON))
+}
+
 func TestS3ReplicationEventMarshaling(t *testing.T) {
 	// 1. read JSON from file
 	inputJSON := test.ReadJSONFromFile(t, "./testdata/s3-replication-event.json")

events/testdata/s3-lifecycle-event.json

@@ -0,0 +1,45 @@
+{
+  "Records": [
+    {
+      "eventVersion": "2.3",
+      "eventSource": "aws:s3",
+      "awsRegion": "us-west-2",
+      "eventTime": "2023-08-20T14:25:00.321Z",
+      "eventName": "s3:LifecycleTransition",
+      "userIdentity": {
+        "principalId": "s3.amazonaws.com"
+      },
+      "requestParameters": {
+        "sourceIPAddress": "s3.amazonaws.com"
+      },
+      "responseElements": {
+        "x-amz-request-id": "LIFECYCLE123456789",
+        "x-amz-id-2": "LIFECYCLEabcdefghijklmnopqrstuvwxyz"
+      },
+      "s3": {
+        "s3SchemaVersion": "1.0",
+        "configurationId": "LifecycleTransitionRule",
+        "bucket": {
+          "name": "example-bucket",
+          "ownerIdentity": {
+            "principalId": "EXAMPLE"
+          },
+          "arn": "arn:aws:s3:::example-bucket"
+        },
+        "object": {
+          "key": "lifecycle%2Dtest.dat",
+          "urlDecodedKey": "lifecycle-test.dat",
+          "size": 10485760,
+          "versionId": "lifecycleVersion123",
+          "eTag": "abcd1234ef5678901234567890abcdef",
+          "sequencer": "0066LIFECYCLE890"
+        }
+      },
+      "lifecycleEventData": {
+        "transitionEventData": {
+          "destinationStorageClass": "GLACIER"
+        }
+      }
+    }
+  ]
+}