Added min size validation on bucket name

Signed-off-by: Asif Sohail Mohammed <[email protected]>
opensearch-project · Aug 14, 2023 · 9a45736 · 9a45736
1 parent fc943b0
commit 9a45736
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/...res-common/src/main/java/org/opensearch/dataprepper/plugins/dlq/s3/S3DlqWriterConfig.java b/...res-common/src/main/java/org/opensearch/dataprepper/plugins/dlq/s3/S3DlqWriterConfig.java
@@ -37,6 +37,7 @@ public class S3DlqWriterConfig {
 
     @JsonProperty("bucket")
     @NotEmpty
+    @Size(min = 3, max = 500, message = "bucket length should be at least 3 characters")
     private String bucket;
 
     @JsonProperty("key_path_prefix")

diff --git a/...lugins/s3-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/s3/S3SinkConfig.java b/...lugins/s3-sink/src/main/java/org/opensearch/dataprepper/plugins/sink/s3/S3SinkConfig.java
@@ -9,6 +9,7 @@
 import jakarta.validation.Valid;
 import jakarta.validation.constraints.NotEmpty;
 import jakarta.validation.constraints.NotNull;
+import jakarta.validation.constraints.Size;
 import org.opensearch.dataprepper.model.configuration.PluginModel;
 import org.opensearch.dataprepper.plugins.sink.s3.accumulator.BufferTypeOptions;
 import org.opensearch.dataprepper.plugins.sink.s3.compression.CompressionOption;
@@ -32,6 +33,7 @@ public class S3SinkConfig {
 
     @JsonProperty("bucket")
     @NotEmpty
+    @Size(min = 3, max = 500, message = "bucket length should be at least 3 characters")
     private String bucketName;
 
     @JsonProperty("object_key")

diff --git a/...main/java/org/opensearch/dataprepper/plugins/source/configuration/S3ScanBucketOption.java b/...main/java/org/opensearch/dataprepper/plugins/source/configuration/S3ScanBucketOption.java
@@ -8,6 +8,7 @@
 import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
 import jakarta.validation.constraints.AssertTrue;
 import jakarta.validation.constraints.NotEmpty;
+import jakarta.validation.constraints.Size;
 import org.opensearch.dataprepper.plugins.source.CustomLocalDateTimeDeserializer;
 
 import java.time.Duration;
@@ -23,6 +24,7 @@ public class S3ScanBucketOption {
 
     @JsonProperty("name")
     @NotEmpty
+    @Size(min = 3, max = 500, message = "bucket length should be at least 3 characters")
     private String name;
 
     @JsonDeserialize(using = CustomLocalDateTimeDeserializer.class)