enha: added option to define table stream

Author: kfc-manager

main.tf

@@ -10,12 +10,14 @@ locals {
 }
 
 resource "aws_dynamodb_table" "main" {
-  billing_mode   = var.provisioned != null ? "PROVISIONED" : "PAY_PER_REQUEST"
-  hash_key       = var.hash_key["name"]
-  range_key      = try(var.sort_key["name"], null)
-  name           = var.identifier
-  read_capacity  = try(var.provisioned["read_capacity"], null)
-  write_capacity = try(var.provisioned["write_capacity"], null)
+  billing_mode     = var.provisioned != null ? "PROVISIONED" : "PAY_PER_REQUEST"
+  hash_key         = var.hash_key["name"]
+  range_key        = try(var.sort_key["name"], null)
+  name             = var.identifier
+  read_capacity    = try(var.provisioned["read_capacity"], null)
+  write_capacity   = try(var.provisioned["write_capacity"], null)
+  stream_enabled   = var.stream_view != null
+  stream_view_type = var.stream_view
 
   dynamic "attribute" {
     for_each = local.attributes

outputs.tf

@@ -7,3 +7,8 @@ output "arn" {
   description = "ARN of the DynamoDB table."
   value       = try(aws_dynamodb_table.main.arn, null)
 }
+
+output "stream_arn" {
+  description = "ARN of the stream of the DynamoDB table."
+  value       = try(aws_dynamodb_table.main.stream_arn, null)
+}

tests/table.tftest.hcl

@@ -33,4 +33,30 @@ run "valid_identifier" {
   }
 }
 
+run "invalid_stream_view" {
+  command = plan
+
+  variables {
+    identifier = "abc"
+    hash_key = {
+      name = "TestPKey"
+      type = "S"
+    }
+    stream_view = "TEST_ONLY"
+  }
+
+  expect_failures = [var.stream_view]
+}
 
+run "valid_stream_view" {
+  command = plan
+
+  variables {
+    identifier = "abc"
+    hash_key = {
+      name = "TestPKey"
+      type = "S"
+    }
+    stream_view = "KEYS_ONLY"
+  }
+}

variables.tf

@@ -53,6 +53,18 @@ variable "gsi_keys" {
   default = []
 }
 
+variable "stream_view" {
+  description = "View type of streams from the DynamoDB table. Valid values are: 'KEYS_ONLY', 'NEW_IMAGE', 'OLD_IMAGE', 'NEW_AND_OLD_IMAGES' and null. If null streams will be disabled."
+  type        = string
+  default     = null
+  validation {
+    condition = var.stream_view == null || var.stream_view == "KEYS_ONLY" || (
+      var.stream_view == "NEW_IMAGE") || var.stream_view == "OLD_IMAGE" || (
+    var.stream_view == "NEW_AND_OLD_IMAGES")
+    error_message = "Stream view must be 'KEYS_ONLY', 'NEW_IMAGE', 'OLD_IMAGE', 'NEW_AND_OLD_IMAGES' or null"
+  }
+}
+
 variable "tags" {
   description = "A map of tags to add to all resources."
   type        = map(string)