fix(s3): missing NotNull for bucket and key

kestra-io · Aug 16, 2024 · 6b500a4 · 6b500a4
1 parent ac0b919
commit 6b500a4
Show file tree

Hide file tree

Showing 6 changed files with 14 additions and 0 deletions.
diff --git a/src/main/java/io/kestra/plugin/aws/s3/AbstractS3ObjectInterface.java b/src/main/java/io/kestra/plugin/aws/s3/AbstractS3ObjectInterface.java
@@ -2,12 +2,14 @@
 
 import io.kestra.core.models.annotations.PluginProperty;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
 
 public interface AbstractS3ObjectInterface extends AbstractS3 {
     @Schema(
         title = "The S3 bucket name."
     )
     @PluginProperty(dynamic = true)
+    @NotNull
     String getBucket();
 
     @Schema(

diff --git a/src/main/java/io/kestra/plugin/aws/s3/Copy.java b/src/main/java/io/kestra/plugin/aws/s3/Copy.java
@@ -7,6 +7,7 @@
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.aws.AbstractConnection;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import software.amazon.awssdk.services.s3.S3Client;
@@ -105,12 +106,14 @@ public static class CopyObject {
             title = "The bucket name"
         )
         @PluginProperty(dynamic = true)
+        @NotNull
         String bucket;
 
         @Schema(
             title = "The bucket key"
         )
         @PluginProperty(dynamic = true)
+        @NotNull
         String key;
     }
 

diff --git a/src/main/java/io/kestra/plugin/aws/s3/CreateBucket.java b/src/main/java/io/kestra/plugin/aws/s3/CreateBucket.java
@@ -7,6 +7,7 @@
 import io.kestra.core.runners.RunContext;
 import io.kestra.plugin.aws.AbstractConnection;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import software.amazon.awssdk.services.s3.S3Client;
@@ -39,6 +40,7 @@ public class CreateBucket extends AbstractConnection implements AbstractS3, Runn
         description = "The S3 bucket name to create."
     )
     @PluginProperty(dynamic = true)
+    @NotNull
     private String bucket;
 
     @Schema(

diff --git a/src/main/java/io/kestra/plugin/aws/s3/Delete.java b/src/main/java/io/kestra/plugin/aws/s3/Delete.java
@@ -6,6 +6,7 @@
 import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.runners.RunContext;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import software.amazon.awssdk.services.s3.S3Client;
@@ -38,6 +39,7 @@ public class Delete extends AbstractS3Object implements RunnableTask<Delete.Outp
         title = "The key to delete."
     )
     @PluginProperty(dynamic = true)
+    @NotNull
     private String key;
 
     @Schema(

diff --git a/src/main/java/io/kestra/plugin/aws/s3/Download.java b/src/main/java/io/kestra/plugin/aws/s3/Download.java
@@ -6,6 +6,7 @@
 import io.kestra.core.models.tasks.RunnableTask;
 import io.kestra.core.runners.RunContext;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import org.apache.commons.lang3.tuple.Pair;
@@ -43,6 +44,7 @@ public class Download extends AbstractS3Object implements RunnableTask<Download.
         title = "The key of a file to download."
     )
     @PluginProperty(dynamic = true)
+    @NotNull
     private String key;
 
     @Schema(

diff --git a/src/main/java/io/kestra/plugin/aws/s3/Upload.java b/src/main/java/io/kestra/plugin/aws/s3/Upload.java
@@ -8,6 +8,7 @@
 import io.kestra.core.runners.RunContext;
 import io.kestra.core.serializers.JacksonMapper;
 import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotNull;
 import lombok.*;
 import lombok.experimental.SuperBuilder;
 import org.apache.commons.io.FilenameUtils;
@@ -57,13 +58,15 @@ public class Upload extends AbstractS3Object implements RunnableTask<Upload.Outp
         anyOf = {List.class, String.class}
     )
     @PluginProperty(dynamic = true)
+    @NotNull
     private Object from;
 
     @Schema(
         title = "The key where to upload the file.",
         description = "a full key (with filename) or the directory path if from is multiple files."
     )
     @PluginProperty(dynamic = true)
+    @NotNull
     private String key;
 
     @Schema(