fix(dynamodb): Update Input with external-name for isUpToDate and pos…

…tUpdate functions Signed-off-by: kelvinwijaya <[email protected]>
crossplane-contrib · Aug 1, 2023 · a479ff9 · a479ff9
1 parent d4de19b
commit a479ff9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/controller/dynamodb/table/hooks.go b/pkg/controller/dynamodb/table/hooks.go
@@ -87,7 +87,7 @@ func SetupTable(mgr ctrl.Manager, o controller.Options) error {
 
 func (e *updateClient) postUpdate(_ context.Context, cr *svcapitypes.Table, obj *svcsdk.UpdateTableOutput, _ managed.ExternalUpdate, _ error) (managed.ExternalUpdate, error) {
 	cbresult, err := e.client.DescribeContinuousBackups(&svcsdk.DescribeContinuousBackupsInput{
-		TableName: aws.String(cr.Name),
+		TableName: aws.String(meta.GetExternalName(cr)),
 	})
 	if err != nil {
 		return managed.ExternalUpdate{}, err
@@ -99,7 +99,7 @@ func (e *updateClient) postUpdate(_ context.Context, cr *svcapitypes.Table, obj
 		pitrSpecEnabled := pointer.BoolDeref(cr.Spec.ForProvider.PointInTimeRecoveryEnabled, false)
 
 		pitrInput := &svcsdk.UpdateContinuousBackupsInput{
-			TableName: aws.String(cr.Name),
+			TableName: aws.String(meta.GetExternalName(cr)),
 			PointInTimeRecoverySpecification: (&svcsdk.PointInTimeRecoverySpecification{
 				PointInTimeRecoveryEnabled: &pitrSpecEnabled,
 			}),
@@ -425,7 +425,7 @@ func (e *updateClient) isUpToDate(cr *svcapitypes.Table, resp *svcsdk.DescribeTa
 
 	// point in time recovery status
 	cbresult, err := e.client.DescribeContinuousBackups(&svcsdk.DescribeContinuousBackupsInput{
-		TableName: aws.String(cr.Name),
+		TableName: aws.String(meta.GetExternalName(cr)),
 	})
 	if err != nil {
 		return false, err