[DBCluster] add missing port in case of RestoreDbClusterToPointInTime…

…Request
aws-cloudformation · Oct 13, 2023 · 6683dfb · 6683dfb
1 parent 8c1d2c2
commit 6683dfb
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/aws-rds-dbcluster/src/main/java/software/amazon/rds/dbcluster/Translator.java b/aws-rds-dbcluster/src/main/java/software/amazon/rds/dbcluster/Translator.java
@@ -111,6 +111,7 @@ static RestoreDbClusterToPointInTimeRequest restoreDbClusterToPointInTimeRequest
                 .iops(model.getIops())
                 .kmsKeyId(model.getKmsKeyId())
                 .networkType(model.getNetworkType())
+                .port(model.getPort())
                 .publiclyAccessible(model.getPubliclyAccessible())
                 .scalingConfiguration(translateScalingConfigurationToSdk(model.getScalingConfiguration()))
                 .serverlessV2ScalingConfiguration(translateServerlessV2ScalingConfiguration(model.getServerlessV2ScalingConfiguration()))

diff --git a/aws-rds-dbcluster/src/test/java/software/amazon/rds/dbcluster/TranslatorTest.java b/aws-rds-dbcluster/src/test/java/software/amazon/rds/dbcluster/TranslatorTest.java
@@ -413,6 +413,19 @@ public void restoreDBClusterFromSnapshotServerlessV2() {
         assertThat(modifyRequest.serverlessV2ScalingConfiguration()).isNull();
     }
 
+    @Test
+    public void restoreDBClusterToPointInTimePort() {
+        final ResourceModel model = ResourceModel.builder()
+                .engineMode(EngineMode.Provisioned.toString())
+                .enableIAMDatabaseAuthentication(true)
+                .useLatestRestorableTime(true)
+                .port(1155)
+                .build();
+        final RestoreDbClusterToPointInTimeRequest request = Translator.restoreDbClusterToPointInTimeRequest(model, Tagging.TagSet.emptySet());
+
+        assertThat(request.port()).isEqualTo(1155);
+    }
+
     @Test
     public void translateDbClusterFromSdk_setDefaultStorageType() {
         final ResourceModel model = Translator.translateDbClusterFromSdk(