add test

cloud/rolebinding_test.go

@@ -0,0 +1,98 @@
+package cloud
+
+import (
+	"context"
+	"fmt"
+	"github.com/google/uuid"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/terraform"
+	"github.com/stretchr/testify/assert"
+	"k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"strings"
+	"testing"
+	"time"
+)
+
+func TestPredefinedBinding(t *testing.T) {
+	serviceAccount, err := uuid.NewRandom()
+	assert.NoError(t, err)
+	rolebindingName, err := uuid.NewRandom()
+	assert.NoError(t, err)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: testAccProviderFactories,
+		CheckDestroy: func(state *terraform.State) error {
+			time.Sleep(5 * time.Second)
+			for _, rs := range state.RootModule().Resources {
+				if rs.Type != "streamnative_rolebinding" {
+					continue
+				}
+				meta := testAccProvider.Meta()
+				clientSet, err := getClientSet(getFactoryFromMeta(meta))
+				if err != nil {
+					return err
+				}
+				organizationRolebinding := strings.Split(rs.Primary.ID, "/")
+				_, err = clientSet.CloudV1alpha1().
+					RoleBindings(organizationRolebinding[0]).
+					Get(context.Background(), organizationRolebinding[1], metav1.GetOptions{})
+				if err != nil {
+					if errors.IsNotFound(err) {
+						return nil
+					}
+					return err
+				}
+				return fmt.Errorf(`ERROR_RESOURCE_ROLEBINDING_STILL_EXISTS: "%s"`, rs.Primary.ID)
+			}
+			return nil
+		},
+		Steps: []resource.TestStep{
+			{
+				Config: fmt.Sprintf(`
+provider "streamnative" {
+}
+
+resource "streamnative_rolebinding" "rolebinding_demo" {
+  organization = "o-y8z75"
+  name         = "%s"
+  predefined_role_name = "metrics-viewer"
+  service_account_names = ["%s"]
+}
+
+data "streamnative_rolebinding" "rolebinding_demo" {
+  depends_on = [streamnative_rolebinding.rolebinding_demo]
+  organization = streamnative_rolebinding.rolebinding_demo.organization
+  name         = streamnative_rolebinding.rolebinding_demo.name
+}
+`, rolebindingName, serviceAccount),
+				Check: func(state *terraform.State) error {
+					rs, ok := state.RootModule().Resources["streamnative_rolebinding.rolebinding_demo"]
+					if !ok {
+						return fmt.Errorf(`ERROR_RESOURCE_SERVICE_ACCOUNT_NOT_FOUND: rolebinding_demo`)
+					}
+					if rs.Primary.ID == "" {
+						return fmt.Errorf(`ERROR_RESOURCE_SERVICE_ACCOUNT_ID_NOT_SET`)
+					}
+					meta := testAccProvider.Meta()
+					clientSet, err := getClientSet(getFactoryFromMeta(meta))
+					if err != nil {
+						return err
+					}
+					organizationCluster := strings.Split(rs.Primary.ID, "/")
+					rolebinding, err := clientSet.CloudV1alpha1().
+						RoleBindings(organizationCluster[0]).
+						Get(context.Background(), organizationCluster[1], metav1.GetOptions{})
+					if err != nil {
+						return err
+					}
+					if rolebinding.Status.Conditions[0].Type != "Ready" || rolebinding.Status.Conditions[0].Status != "True" {
+						return fmt.Errorf(`ERROR_RESOURCE_ROLEBINDING_NOT_READY: "%s"`, rs.Primary.ID)
+					}
+					return nil
+				},
+			},
+		},
+	})
+}

examples/rolebinding/main.tf

@@ -38,8 +38,8 @@ resource "streamnative_rolebinding" "rolebinding_demo" {
 
 data "streamnative_rolebinding" "rolebinding_1" {
   depends_on = [streamnative_rolebinding.rolebinding_demo]
-  organization = "o-y8z75"
-  name         = "test-rolebinding-demo"
+  organization = streamnative_rolebinding.rolebinding_demo.organization
+  name         = streamnative_rolebinding.rolebinding_demo.name
 }
 
 output "streamnative_rolebinding" {