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

Author: yhamano0312

events/s3.go

@@ -25,6 +25,7 @@ type S3EventRecord struct {
 	ResponseElements     map[string]string       `json:"responseElements"`
 	S3                   S3Entity                `json:"s3"`
 	GlacierEventData     *S3GlacierEventData     `json:"glacierEventData,omitempty"`
+	RestoreEventData     *S3RestoreEventData     `json:"restoreEventData,omitempty"`
 	ReplicationEventData *S3ReplicationEventData `json:"replicationEventData,omitempty"`
 }
 

events/s3_test.go

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

@@ -0,0 +1,44 @@
+{
+  "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"
+        }
+      },
+      "restoreEventData": {
+        "lifecycleRestorationExpiryTime": "2023-05-17T15:00:00.456Z",
+        "lifecycleRestoreStorageClass": "STANDARD"
+      }
+    }
+  ]
+}