implement RoleCreate and update the related tests

Author: ThoSap

src/test/java/it/aboutbits/postgresql/_support/testdata/persisted/Given.java

@@ -2,6 +2,7 @@
 
 import io.fabric8.kubernetes.client.KubernetesClient;
 import it.aboutbits.postgresql._support.testdata.persisted.creator.ClusterConnectionCreate;
+import it.aboutbits.postgresql._support.testdata.persisted.creator.RoleCreate;
 import it.aboutbits.postgresql._support.testdata.persisted.creator.SecretRefCreate;
 import jakarta.enterprise.context.ApplicationScoped;
 import lombok.AccessLevel;
@@ -82,6 +83,14 @@ public ClusterConnectionCreate clusterConnection() {
                     dbConnectionDetails()
             );
         }
+
+        public RoleCreate role() {
+            return new RoleCreate(
+                    numberOfItems,
+                    given,
+                    kubernetesClient
+            );
+        }
     }
 
     public record DBConnectionDetails(

src/test/java/it/aboutbits/postgresql/_support/testdata/persisted/creator/ClusterConnectionCreate.java

@@ -19,7 +19,6 @@
 import java.util.concurrent.TimeUnit;
 
 @NullMarked
-@Getter
 @Setter
 @Accessors(fluent = true, chain = true)
 public class ClusterConnectionCreate extends TestDataCreator<ClusterConnection> {

src/test/java/it/aboutbits/postgresql/_support/testdata/persisted/creator/RoleCreate.java

@@ -0,0 +1,156 @@
+package it.aboutbits.postgresql._support.testdata.persisted.creator;
+
+import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
+import io.fabric8.kubernetes.client.KubernetesClient;
+import it.aboutbits.postgresql._support.testdata.base.TestDataCreator;
+import it.aboutbits.postgresql._support.testdata.persisted.Given;
+import it.aboutbits.postgresql.core.ClusterReference;
+import it.aboutbits.postgresql.core.SecretRef;
+import it.aboutbits.postgresql.crd.role.Role;
+import it.aboutbits.postgresql.crd.role.RoleSpec;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.experimental.Accessors;
+import org.jspecify.annotations.NullMarked;
+import org.jspecify.annotations.Nullable;
+
+import java.util.Objects;
+import java.util.concurrent.TimeUnit;
+
+@NullMarked
+@Setter
+@Accessors(fluent = true, chain = true)
+public class RoleCreate extends TestDataCreator<Role> {
+    private final Given given;
+
+    private final KubernetesClient kubernetesClient;
+
+    @Nullable
+    private String withNamespace;
+    @Setter(AccessLevel.NONE)
+    private boolean withoutNamespace = false;
+
+    @Nullable
+    private String withName;
+
+    @Nullable
+    private String withComment;
+
+    @Nullable
+    private String withClusterConnectionName;
+
+    @Nullable
+    private String withClusterConnectionNamespace;
+
+    @Nullable
+    private SecretRef withPasswordSecretRef;
+
+    private RoleSpec.@Nullable Flags withFlags;
+
+    public RoleCreate withLogin(boolean login) {
+        if (!login) {
+            withPasswordSecretRef = null;
+            return this;
+        }
+
+        if (withPasswordSecretRef != null) {
+            return this;
+        }
+
+        withPasswordSecretRef = given.one()
+                .secretRef()
+                .returnFirst();
+
+        return this;
+    }
+
+    public RoleCreate withoutNamespace() {
+        withoutNamespace = true;
+        return this;
+    }
+
+    public RoleCreate(
+            int numberOfItems,
+            Given given,
+            KubernetesClient kubernetesClient
+    ) {
+        super(numberOfItems);
+        this.given = given;
+        this.kubernetesClient = kubernetesClient;
+    }
+
+    @Override
+    protected Role create(int index) {
+        var namespace = getNamespace();
+        var name = getName();
+
+        var item = new Role();
+
+        item.setMetadata(new ObjectMetaBuilder()
+                .withName(name)
+                .withNamespace(namespace)
+                .build()
+        );
+
+        var spec = new RoleSpec();
+        spec.setName(name);
+        spec.setComment(withComment);
+
+        var clusterRef = new ClusterReference();
+        clusterRef.setName(getClusterConnectionName());
+        clusterRef.setNamespace(withClusterConnectionNamespace);
+        spec.setClusterRef(clusterRef);
+
+        spec.setPasswordSecretRef(withPasswordSecretRef);
+
+        if (withFlags != null) {
+            spec.setFlags(withFlags);
+        }
+
+        item.setSpec(spec);
+
+        kubernetesClient.resources(Role.class)
+                .inNamespace(namespace)
+                .resource(item)
+                .serverSideApply();
+
+        //noinspection ConstantConditions
+        return kubernetesClient.resources(Role.class)
+                .inNamespace(namespace)
+                .withName(name)
+                .waitUntilCondition(
+                        role -> role.getStatus() != null,
+                        10,
+                        TimeUnit.SECONDS
+                );
+    }
+
+    @Nullable
+    private String getNamespace() {
+        if (withoutNamespace) {
+            return null;
+        }
+
+        if (withNamespace != null) {
+            return withNamespace;
+        }
+
+        return kubernetesClient.getNamespace();
+    }
+
+    private String getName() {
+        if (withName != null) {
+            return withName;
+        }
+
+        return randomKubernetesNameSuffix("test-role");
+    }
+
+    private String getClusterConnectionName() {
+        return Objects.requireNonNullElse(
+                withClusterConnectionName,
+                "test-cluster-connection"
+        );
+    }
+}

src/test/java/it/aboutbits/postgresql/_support/testdata/persisted/creator/SecretRefCreate.java

@@ -4,6 +4,9 @@
 import io.fabric8.kubernetes.client.KubernetesClient;
 import it.aboutbits.postgresql._support.testdata.base.TestDataCreator;
 import it.aboutbits.postgresql.core.SecretRef;
+import lombok.AccessLevel;
+import lombok.Setter;
+import lombok.experimental.Accessors;
 import org.jspecify.annotations.NullMarked;
 import org.jspecify.annotations.Nullable;
 
@@ -12,22 +15,27 @@
 import static it.aboutbits.postgresql.core.KubernetesService.SECRET_TYPE_BASIC_AUTH;
 
 @NullMarked
+@Setter
+@Accessors(fluent = true, chain = true)
 public class SecretRefCreate extends TestDataCreator<SecretRef> {
     private final KubernetesClient kubernetesClient;
 
     @Nullable
     private String withNamespace;
+    @Setter(AccessLevel.NONE)
     private boolean withoutNamespace = false;
 
     @Nullable
     private String withName;
 
     @Nullable
     private String withUsername;
+    @Setter(AccessLevel.NONE)
     private boolean withoutUsername = false;
 
     @Nullable
     private String withPassword;
+    @Setter(AccessLevel.NONE)
     private boolean withoutPassword = false;
 
     public SecretRefCreate(
@@ -38,42 +46,18 @@ public SecretRefCreate(
         this.kubernetesClient = kubernetesClient;
     }
 
-    @SuppressWarnings("unused")
-    public SecretRefCreate withNamespace(String namespace) {
-        withNamespace = namespace;
-        return this;
-    }
-
     @SuppressWarnings("unused")
     public SecretRefCreate withoutNamespace() {
         withoutNamespace = true;
         return this;
     }
 
-    @SuppressWarnings("unused")
-    public SecretRefCreate withName(String name) {
-        withName = name;
-        return this;
-    }
-
-    @SuppressWarnings("unused")
-    public SecretRefCreate withUsername(String username) {
-        withUsername = username;
-        return this;
-    }
-
     @SuppressWarnings("unused")
     public SecretRefCreate withoutUsername() {
         withoutUsername = true;
         return this;
     }
 
-    @SuppressWarnings("unused")
-    public SecretRefCreate withPassword(String password) {
-        withPassword = password;
-        return this;
-    }
-
     @SuppressWarnings("unused")
     public SecretRefCreate withoutPassword() {
         withoutPassword = true;