feat(redis): add data source (#1245)

Co-authored-by: Rémy Léone <[email protected]>

Author: Codelax

docs/data-sources/redis_cluster.md

@@ -0,0 +1,36 @@
+---
+layout: "scaleway"
+page_title: "Scaleway: scaleway_redis_instance"
+description: |-
+Gets information about a Redis cluster.
+---
+
+# scaleway_redis_cluster
+
+Gets information about a Redis cluster.
+
+## Example Usage
+
+```hcl
+# Get info by name
+data "scaleway_redis_cluster" "my_cluster" {
+  name = "foobar"
+}
+
+# Get info by cluster ID
+data "scaleway_redis_cluster" "my_cluster" {
+  cluster_id = "11111111-1111-1111-1111-111111111111"
+}
+```
+
+## Argument Reference
+
+- `name` - (Optional) The name of the Redis cluster.
+  Only one of the `name` and `cluster_id` should be specified.
+
+- `cluster_id` - (Optional) The Redis cluster ID.
+  Only one of the `name` and `cluster_id` should be specified.
+
+- `zone` - (Default to [provider](../index.md) `region`) The [zone](../guides/regions_and_zones.md#zones) in which the server exists.
+
+- `project_id` - (Default to [provider](../index.md) `project_id`)

scaleway/data_source_redis_cluster.go

@@ -0,0 +1,82 @@
+package scaleway
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	redis "github.com/scaleway/scaleway-sdk-go/api/redis/v1alpha1"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+)
+
+func dataSourceScalewayRedisCluster() *schema.Resource {
+	// Generate datasource schema from resource
+	dsSchema := datasourceSchemaFromResourceSchema(resourceScalewayRedisCluster().Schema)
+	// Set 'Optional' schema elements
+	addOptionalFieldsToSchema(dsSchema, "name", "zone")
+
+	dsSchema["name"].ConflictsWith = []string{"cluster_id"}
+	dsSchema["cluster_id"] = &schema.Schema{
+		Type:          schema.TypeString,
+		Optional:      true,
+		Description:   "The ID of the Redis cluster",
+		ConflictsWith: []string{"name"},
+		ValidateFunc:  validationUUIDorUUIDWithLocality(),
+	}
+
+	return &schema.Resource{
+		ReadContext: dataSourceScalewayRedisClusterRead,
+		Schema:      dsSchema,
+	}
+}
+
+func dataSourceScalewayRedisClusterRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	api, zone, err := redisAPIWithZone(d, meta)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	clusterID, ok := d.GetOk("cluster_id")
+	if !ok {
+		res, err := api.ListClusters(&redis.ListClustersRequest{
+			Zone:      zone,
+			Name:      expandStringPtr(d.Get("name")),
+			ProjectID: expandStringPtr(d.Get("project_id")),
+		}, scw.WithContext(ctx))
+		if err != nil {
+			return diag.FromErr(err)
+		}
+		for _, cluster := range res.Clusters {
+			if cluster.Name == d.Get("name").(string) {
+				if clusterID != "" {
+					return diag.FromErr(fmt.Errorf("more than 1 cluster found with the same name %s", d.Get("name")))
+				}
+				clusterID = cluster.ID
+			}
+		}
+		if clusterID == "" {
+			return diag.FromErr(fmt.Errorf("no clusters found with the name %s", d.Get("name")))
+		}
+	}
+
+	zonedID := datasourceNewZonedID(clusterID, zone)
+	d.SetId(zonedID)
+	err = d.Set("cluster_id", zonedID)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	// Check if cluster exist as Read will return nil if resource does not exist
+	// clusterID may be zoned if using name in data source
+	getReq := &redis.GetClusterRequest{
+		Zone:      zone,
+		ClusterID: expandID(clusterID.(string)),
+	}
+	_, err = api.GetCluster(getReq, scw.WithContext(ctx))
+	if err != nil {
+		return diag.FromErr(fmt.Errorf("no clusters found with the id %s", clusterID))
+	}
+
+	return resourceScalewayRedisClusterRead(ctx, d, meta)
+}

scaleway/data_source_redis_cluster_test.go

@@ -0,0 +1,47 @@
+package scaleway
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+func TestAccScalewayDataSourceRedisCluster_Basic(t *testing.T) {
+	tt := NewTestTools(t)
+	defer tt.Cleanup()
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: tt.ProviderFactories,
+		CheckDestroy:      testAccCheckScalewayRedisClusterDestroy(tt),
+		Steps: []resource.TestStep{
+			{
+				Config: `
+					resource "scaleway_redis_cluster" "test" {
+    					name = "test_redis_datasource_terraform"
+    					version = "6.2.6"
+    					node_type = "MDB-BETA-M"
+    					user_name = "my_initial_user"
+    					password = "thiZ_is_v&ry_s3cret"
+					}
+
+					data "scaleway_redis_cluster" "test" {
+						name = scaleway_redis_cluster.test.name
+					}
+
+					data "scaleway_redis_cluster" "test2" {
+						cluster_id = scaleway_redis_cluster.test.id
+					}
+				`,
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckScalewayRedisExists(tt, "scaleway_redis_cluster.test"),
+
+					resource.TestCheckResourceAttr("data.scaleway_redis_cluster.test", "name", "test_redis_datasource_terraform"),
+					resource.TestCheckResourceAttrSet("data.scaleway_redis_cluster.test", "id"),
+
+					resource.TestCheckResourceAttr("data.scaleway_redis_cluster.test2", "name", "test_redis_datasource_terraform"),
+					resource.TestCheckResourceAttrSet("data.scaleway_redis_cluster.test2", "id"),
+				),
+			},
+		},
+	})
+}

scaleway/provider.go

@@ -133,6 +133,7 @@ func Provider(config *ProviderConfig) plugin.ProviderFunc {
 				"scaleway_rdb_instance":                dataSourceScalewayRDBInstance(),
 				"scaleway_rdb_database":                dataSourceScalewayRDBDatabase(),
 				"scaleway_rdb_privilege":               dataSourceScalewayRDBPrivilege(),
+				"scaleway_redis_cluster":               dataSourceScalewayRedisCluster(),
 				"scaleway_registry_namespace":          dataSourceScalewayRegistryNamespace(),
 				"scaleway_registry_image":              dataSourceScalewayRegistryImage(),
 				"scaleway_vpc_public_gateway":          dataSourceScalewayVPCPublicGateway(),

scaleway/resource_redis_cluster.go

@@ -62,6 +62,7 @@ func resourceScalewayRedisCluster() *schema.Resource {
 			"cluster_size": {
 				Type:        schema.TypeInt,
 				Optional:    true,
+				Computed:    true,
 				Description: "Number of nodes for the cluster.",
 			},
 			"tls_enabled": {
@@ -130,6 +131,7 @@ func resourceScalewayRedisClusterCreate(ctx context.Context, d *schema.ResourceD
 
 	return resourceScalewayRedisClusterRead(ctx, d, meta)
 }
+
 func resourceScalewayRedisClusterRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
 	redisAPI, zone, ID, err := redisAPIWithZoneAndID(meta, d.Id())
 	if err != nil {