Merge pull request #22 from dasmeta/DMVP-5181

fix(DMVP-5181): Add sqs event support

event-notifications.tf

@@ -0,0 +1,41 @@
+data "aws_iam_policy_document" "queue" {
+  count = var.event_notification_config.target_type == "sqs" ? 1 : 0
+
+  statement {
+    effect = "Allow"
+
+    principals {
+      type        = "*"
+      identifiers = ["*"]
+    }
+
+    actions   = ["sqs:SendMessage"]
+    resources = ["arn:aws:sqs:*:*:${var.name}${var.event_notification_config.name_suffix}}"]
+
+    condition {
+      test     = "ArnEquals"
+      variable = "aws:SourceArn"
+      values   = [module.bucket.s3_bucket_arn]
+    }
+  }
+}
+
+resource "aws_sqs_queue" "queue" {
+  count = var.event_notification_config.target_type == "sqs" ? 1 : 0
+
+  name   = replace("${var.name}${var.event_notification_config.name_suffix}", "/\\W+/", "_")
+  policy = data.aws_iam_policy_document.queue[0].json
+}
+
+
+resource "aws_s3_bucket_notification" "bucket_notification" {
+  count = var.event_notification_config.target_type == "sqs" ? 1 : 0
+
+  bucket = module.bucket.s3_bucket_id
+
+  queue {
+    queue_arn     = aws_sqs_queue.queue[0].arn
+    events        = var.event_notification_config.events
+    filter_prefix = var.event_notification_config.filter_prefix
+  }
+}

tests/sqs-event-notifications/1-example.tf

@@ -0,0 +1,13 @@
+module "private" {
+  source = "../.."
+
+  name = "dasmeta-dev-private"
+
+  event_notification_config = {
+    target_type   = "sqs"
+    name_suffix   = "event"
+    filter_prefix = "test/"
+    events        = ["s3:ObjectCreated:CompleteMultipartUpload"]
+  }
+}
+

variables.tf

@@ -118,3 +118,18 @@ variable "cors_rule" {
   type        = any
   default     = []
 }
+
+variable "event_notification_config" {
+  type = object({
+    target_type   = string,                                        // Target type for the S3 event notification, can be "sqs" or "null". Other target types can be implemented in the future.
+    name_suffix   = string,                                        // Suffix to add to the target name.
+    filter_prefix = string,                                        // Prefix to filter object key names for the event notification.
+    events        = optional(list(string), ["s3:ObjectCreated:*"]) // List of S3 events that trigger the notification. Defaults to "s3:ObjectCreated:*".
+  })
+  default = {
+    target_type   = "null"
+    name_suffix   = "event"
+    filter_prefix = "test/"
+    events        = ["s3:ObjectCreated:*"]
+  }
+}