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

Author: yhamano0312

events/s3.go

@@ -15,18 +15,19 @@ type S3Event struct {
 
 // S3EventRecord which wrap record data
 type S3EventRecord struct {
-	EventVersion         string                  `json:"eventVersion"`
-	EventSource          string                  `json:"eventSource"`
-	AWSRegion            string                  `json:"awsRegion"`
-	EventTime            time.Time               `json:"eventTime"`
-	EventName            string                  `json:"eventName"`
-	PrincipalID          S3UserIdentity          `json:"userIdentity"`
-	RequestParameters    S3RequestParameters     `json:"requestParameters"`
-	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"`
+	EventVersion                string                         `json:"eventVersion"`
+	EventSource                 string                         `json:"eventSource"`
+	AWSRegion                   string                         `json:"awsRegion"`
+	EventTime                   time.Time                      `json:"eventTime"`
+	EventName                   string                         `json:"eventName"`
+	PrincipalID                 S3UserIdentity                 `json:"userIdentity"`
+	RequestParameters           S3RequestParameters            `json:"requestParameters"`
+	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"`
+	IntelligentTieringEventData *S3IntelligentTieringEventData `json:"intelligentTieringEventData,omitempty"`
 }
 
 type S3UserIdentity struct {
@@ -90,6 +91,10 @@ type S3ReplicationEventData struct {
 	FailureReason     string    `json:"failureReason"`
 }
 
+type S3IntelligentTieringEventData struct {
+	DestinationAccessTier string `json:"destinationAccessTier"`
+}
+
 type S3TestEvent struct {
 	Service   string    `json:"Service"`
 	Bucket    string    `json:"Bucket"`

events/s3_test.go

@@ -112,6 +112,36 @@ func TestS3RestoreEventMarshaling(t *testing.T) {
 	assert.JSONEq(t, string(inputJSON), string(outputJSON))
 }
 
+func TestS3IntelligentTieringEventMarshaling(t *testing.T) {
+	// 1. read JSON from file
+	inputJSON := test.ReadJSONFromFile(t, "./testdata/s3-intelligenttier-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 intelligentTieringEventData is correctly parsed
+	if inputEvent.Records[0].IntelligentTieringEventData == nil {
+		t.Error("intelligentTieringEventData should not be nil for intelligent tiering events")
+	}
+
+	// 4. verify destinationAccessTier is correctly parsed
+	if inputEvent.Records[0].IntelligentTieringEventData.DestinationAccessTier == "" {
+		t.Error("destinationAccessTier should not be empty")
+	}
+
+	// 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-intelligenttier-event.json

@@ -0,0 +1,43 @@
+{
+  "Records": [
+    {
+      "eventVersion": "2.3",
+      "eventSource": "aws:s3",
+      "awsRegion": "us-east-1",
+      "eventTime": "2023-11-15T10:30:00.789Z",
+      "eventName": "s3:IntelligentTiering:TransitionAccess",
+      "userIdentity": {
+        "principalId": "s3.amazonaws.com"
+      },
+      "requestParameters": {
+        "sourceIPAddress": "s3.amazonaws.com"
+      },
+      "responseElements": {
+        "x-amz-request-id": "EXAMPLE123456789",
+        "x-amz-id-2": "EXAMPLEabcdefghijklmnopqrstuvwxyz"
+      },
+      "s3": {
+        "s3SchemaVersion": "1.0",
+        "configurationId": "IntelligentTieringConfig",
+        "bucket": {
+          "name": "example-bucket",
+          "ownerIdentity": {
+            "principalId": "EXAMPLE"
+          },
+          "arn": "arn:aws:s3:::example-bucket"
+        },
+        "object": {
+          "key": "intelligent%2Dtier%2Dtest.dat",
+          "urlDecodedKey": "intelligent-tier-test.dat",
+          "size": 5242880,
+          "versionId": "versionExample123",
+          "eTag": "d41d8cd98f00b204e9800998ecf8427e",
+          "sequencer": "0066ABC1234567890"
+        }
+      },
+      "intelligentTieringEventData": {
+        "destinationAccessTier": "ARCHIVE_ACCESS"
+      }
+    }
+  ]
+}