add TableReplica field

Author: rushmash91

apis/v1alpha1/ack-generate-metadata.yaml

@@ -1,5 +1,5 @@
 ack_generate_info:
-  build_date: "2025-03-27T16:23:51Z"
+  build_date: "2025-03-28T01:43:12Z"
   build_hash: 980cb1e4734f673d16101cf55206b84ca639ec01
   go_version: go1.24.1
   version: v0.44.0

pkg/resource/table/hooks.go

@@ -15,6 +15,7 @@ package table
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -232,17 +233,17 @@ func (rm *resourceManager) customUpdateTable(
 				}
 				return nil, err
 			}
-			// case delta.DifferentAt("Spec.TableReplicas"):
-			// 	// Enabling replicas required streams enabled and StreamViewType to be NEW_AND_OLD_IMAGES
-			// 	// Version 2019.11.21  TableUpdate API requirement
-			// 	if !hasStreamSpecificationWithNewAndOldImages(desired) {
-			// 		msg := "table must have DynamoDB Streams enabled with StreamViewType set to NEW_AND_OLD_IMAGES for replica updates"
-			// 		rlog.Debug(msg)
-			// 		return nil, ackerr.NewTerminalError(errors.New(msg))
-			// 	}
-			// 	if err := rm.syncReplicas(ctx, latest, desired); err != nil {
-			// 		return nil, err
-			// 	}
+		case delta.DifferentAt("Spec.TableReplicas"):
+			// Enabling replicas required streams enabled and StreamViewType to be NEW_AND_OLD_IMAGES
+			// Version 2019.11.21  TableUpdate API requirement
+			if !hasStreamSpecificationWithNewAndOldImages(desired) {
+				msg := "table must have DynamoDB Streams enabled with StreamViewType set to NEW_AND_OLD_IMAGES for replica updates"
+				rlog.Debug(msg)
+				return nil, ackerr.NewTerminalError(errors.New(msg))
+			}
+			if err := rm.syncReplicas(ctx, latest, desired); err != nil {
+				return nil, err
+			}
 		}
 	}
 
@@ -577,14 +578,14 @@ func customPreCompare(
 		}
 	}
 
-	// // Handle ReplicaUpdates API comparison
-	// if len(a.ko.Spec.TableReplicas) != len(b.ko.Spec.TableReplicas) {
-	// 	delta.Add("Spec.TableReplicas", a.ko.Spec.TableReplicas, b.ko.Spec.TableReplicas)
-	// } else if a.ko.Spec.TableReplicas != nil && b.ko.Spec.TableReplicas != nil {
-	// 	if !equalReplicaArrays(a.ko.Spec.TableReplicas, b.ko.Spec.TableReplicas) {
-	// 		delta.Add("Spec.TableReplicas", a.ko.Spec.TableReplicas, b.ko.Spec.TableReplicas)
-	// 	}
-	// }
+	// Handle ReplicaUpdates API comparison
+	if len(a.ko.Spec.TableReplicas) != len(b.ko.Spec.TableReplicas) {
+		delta.Add("Spec.TableReplicas", a.ko.Spec.TableReplicas, b.ko.Spec.TableReplicas)
+	} else if a.ko.Spec.TableReplicas != nil && b.ko.Spec.TableReplicas != nil {
+		if !equalReplicaArrays(a.ko.Spec.TableReplicas, b.ko.Spec.TableReplicas) {
+			delta.Add("Spec.TableReplicas", a.ko.Spec.TableReplicas, b.ko.Spec.TableReplicas)
+		}
+	}
 
 	if a.ko.Spec.DeletionProtectionEnabled == nil {
 		a.ko.Spec.DeletionProtectionEnabled = aws.Bool(false)