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

Author: yhamano0312

events/s3.go

@@ -24,6 +24,7 @@ type S3EventRecord struct {
 	RequestParameters    S3RequestParameters     `json:"requestParameters"`
 	ResponseElements     map[string]string       `json:"responseElements"`
 	S3                   S3Entity                `json:"s3"`
+	GlacierEventData     *S3GlacierEventData     `json:"glacierEventData,omitempty"`
 	ReplicationEventData *S3ReplicationEventData `json:"replicationEventData,omitempty"`
 }
 
@@ -71,6 +72,15 @@ func (o *S3Object) UnmarshalJSON(data []byte) error {
 	return nil
 }
 
+type S3GlacierEventData struct {
+	RestoreEventData *S3RestoreEventData `json:"restoreEventData"`
+}
+
+type S3RestoreEventData struct {
+	LifecycleRestorationExpiryTime time.Time `json:"lifecycleRestorationExpiryTime"`
+	LifecycleRestoreStorageClass   string    `json:"lifecycleRestoreStorageClass"`
+}
+
 type S3ReplicationEventData struct {
 	ReplicationRuleID string    `json:"replicationRuleId"`
 	DestinationBucket string    `json:"destinationBucket"`

events/s3_test.go

@@ -57,6 +57,36 @@ func TestS3MarshalingMalformedJSON(t *testing.T) {
 	test.TestMalformedJson(t, S3Event{})
 }
 
+func TestS3GlacierEventMarshaling(t *testing.T) {
+	// 1. read JSON from file
+	inputJSON := test.ReadJSONFromFile(t, "./testdata/s3-glacier-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 glacierEventData is correctly parsed
+	if inputEvent.Records[0].GlacierEventData == nil {
+		t.Error("glacierEventData should not be nil for glacier restore events")
+	}
+
+	// 4. verify restoreEventData is correctly parsed
+	if inputEvent.Records[0].GlacierEventData.RestoreEventData == nil {
+		t.Error("restoreEventData should not be nil")
+	}
+
+	// 5. serialize to JSON
+	outputJSON, err := json.Marshal(inputEvent)
+	if err != nil {
+		t.Errorf("could not marshal event. details: %v", err)
+	}
+
+	// 6. 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-glacier-event.json

@@ -0,0 +1,46 @@
+{
+  "Records": [
+    {
+      "eventVersion": "2.1",
+      "eventSource": "aws:s3",
+      "awsRegion": "us-west-2",
+      "eventTime": "2023-05-10T15:00:00.123Z",
+      "eventName": "s3:ObjectRestore:Completed",
+      "userIdentity": {
+        "principalId": "EXAMPLE"
+      },
+      "requestParameters": {
+        "sourceIPAddress": "127.0.0.1"
+      },
+      "responseElements": {
+        "x-amz-request-id": "EXAMPLE123456789",
+        "x-amz-id-2": "EXAMPLE123/5678abcdefghijklambdaisawesome/mnopqrstuvwxyzABCDEFGH"
+      },
+      "s3": {
+        "s3SchemaVersion": "1.0",
+        "configurationId": "testConfigRule",
+        "bucket": {
+          "name": "example-bucket",
+          "ownerIdentity": {
+            "principalId": "EXAMPLE"
+          },
+          "arn": "arn:aws:s3:::example-bucket"
+        },
+        "object": {
+          "key": "glacier%2Dtest.txt",
+          "urlDecodedKey": "glacier-test.txt",
+          "size": 1024,
+          "versionId": "abcdeH0Xp66ep__QDjR76LK7Gc9X4wKO",
+          "eTag": "0123456789abcdef0123456789abcdef",
+          "sequencer": "0A1B2C3D4E5F678901"
+        }
+      },
+      "glacierEventData": {
+        "restoreEventData": {
+          "lifecycleRestorationExpiryTime": "2023-05-17T15:00:00.456Z",
+          "lifecycleRestoreStorageClass": "STANDARD"
+        }
+      }
+    }
+  ]
+}