feat(rdb): add support for data source rdb instance (#569)

Author: remyleone

scaleway/data_source_rdb_instance.go

@@ -0,0 +1,65 @@
+package scaleway
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	"github.com/scaleway/scaleway-sdk-go/api/rdb/v1"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+)
+
+func dataSourceScalewayRDBInstance() *schema.Resource {
+	// Generate datasource schema from resource
+	dsSchema := datasourceSchemaFromResourceSchema(resourceScalewayRdbInstanceBeta().Schema)
+	// Set 'Optional' schema elements
+	addOptionalFieldsToSchema(dsSchema, "name")
+
+	dsSchema["name"].ConflictsWith = []string{"instance_id"}
+	dsSchema["instance_id"] = &schema.Schema{
+		Type:          schema.TypeString,
+		Optional:      true,
+		Description:   "The ID of the RDB instance",
+		ConflictsWith: []string{"name"},
+		ValidateFunc:  validationUUIDorUUIDWithLocality(),
+	}
+
+	return &schema.Resource{
+		ReadContext: dataSourceScalewayRDBInstanceRead,
+		Schema:      dsSchema,
+	}
+}
+
+func dataSourceScalewayRDBInstanceRead(ctx context.Context, d *schema.ResourceData, m interface{}) diag.Diagnostics {
+	api, region, err := rdbAPIWithRegion(d, m)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+
+	instanceID, ok := d.GetOk("instance_id")
+	if !ok { // Get instance by region and name.
+		res, err := api.ListInstances(&rdb.ListInstancesRequest{
+			Region: region,
+			Name:   scw.StringPtr(d.Get("name").(string)),
+		}, scw.WithContext(ctx))
+		if err != nil {
+			return diag.FromErr(err)
+		}
+		if len(res.Instances) == 0 {
+			return diag.FromErr(fmt.Errorf("no instances found with the name %s", d.Get("name")))
+		}
+		if len(res.Instances) > 1 {
+			return diag.FromErr(fmt.Errorf("%d instances found with the same name %s", len(res.Instances), d.Get("name")))
+		}
+		instanceID = res.Instances[0].ID
+	}
+
+	regionalID := datasourceNewRegionalizedID(instanceID, region)
+	d.SetId(regionalID)
+	err = d.Set("instance_id", regionalID)
+	if err != nil {
+		return diag.FromErr(err)
+	}
+	return resourceScalewayRdbInstanceBetaRead(ctx, d, m)
+}

scaleway/data_source_rdb_instance_test.go

@@ -0,0 +1,53 @@
+package scaleway
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+func TestAccScalewayDataSourceRDBInstance_Basic(t *testing.T) {
+	tt := NewTestTools(t)
+	defer tt.Cleanup()
+	resource.ParallelTest(t, resource.TestCase{
+		PreCheck:          func() { testAccPreCheck(t) },
+		ProviderFactories: tt.ProviderFactories,
+		CheckDestroy:      testAccCheckScalewayRdbInstanceBetaDestroy(tt),
+		Steps: []resource.TestStep{
+			{
+				Config: `
+					resource "scaleway_rdb_instance_beta" "test" {
+						name = "test-terraform"
+						engine = "PostgreSQL-11"
+						node_type = "db-dev-s"
+					}`,
+			},
+			{
+				Config: `
+					resource "scaleway_rdb_instance_beta" "test" {
+						name = "test-terraform"
+						engine = "PostgreSQL-11"
+						node_type = "db-dev-s"
+					}
+
+					data "scaleway_rdb_instance" "test" {
+						name = scaleway_rdb_instance_beta.test.name
+					}
+
+					data "scaleway_rdb_instance" "test2" {
+						instance_id = scaleway_rdb_instance_beta.test.id
+					}
+				`,
+				Check: resource.ComposeTestCheckFunc(
+					testAccCheckScalewayRdbBetaExists(tt, "scaleway_rdb_instance_beta.test"),
+
+					resource.TestCheckResourceAttr("scaleway_rdb_instance_beta.test", "name", "test-terraform"),
+					resource.TestCheckResourceAttrSet("data.scaleway_rdb_instance.test", "id"),
+
+					resource.TestCheckResourceAttr("data.scaleway_rdb_instance.test2", "name", "test-terraform"),
+					resource.TestCheckResourceAttrSet("data.scaleway_rdb_instance.test2", "id"),
+				),
+			},
+		},
+	})
+}

scaleway/provider.go

@@ -96,6 +96,7 @@ func Provider(config *ProviderConfig) plugin.ProviderFunc {
 				"scaleway_instance_volume":         dataSourceScalewayInstanceVolume(),
 				"scaleway_baremetal_offer":         dataSourceScalewayBaremetalOffer(),
 				"scaleway_lb_ip_beta":              dataSourceScalewayLbIPBeta(),
+				"scaleway_rdb_instance":            dataSourceScalewayRDBInstance(),
 				"scaleway_marketplace_image_beta":  dataSourceScalewayMarketplaceImageBeta(),
 				"scaleway_registry_namespace_beta": dataSourceScalewayRegistryNamespaceBeta(),
 				"scaleway_registry_image_beta":     dataSourceScalewayRegistryImageBeta(),