Add generic user provider and postgresql user provider

ovh/data_cloud_project_database_postgresql_user.go

@@ -0,0 +1,97 @@
+package ovh
+
+import (
+	"fmt"
+	"log"
+	"net/url"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+)
+
+func dataSourceCloudProjectDatabasePostgresqlUser() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceCloudProjectDatabasePostgresqlUserRead,
+		Schema: map[string]*schema.Schema{
+			"service_name": {
+				Type:        schema.TypeString,
+				Required:    true,
+				DefaultFunc: schema.EnvDefaultFunc("OVH_CLOUD_PROJECT_SERVICE", nil),
+			},
+			"cluster_id": {
+				Type:        schema.TypeString,
+				Description: "Cluster ID",
+				Required:    true,
+			},
+			"name": {
+				Type:        schema.TypeString,
+				Description: "Name of the user",
+				Required:    true,
+			},
+
+			//Computed
+			"created_at": {
+				Type:        schema.TypeString,
+				Description: "Date of the creation of the user",
+				Computed:    true,
+			},
+			"roles": {
+				Type:        schema.TypeList,
+				Description: "Roles the user belongs to",
+				Computed:    true,
+				Elem:        &schema.Schema{Type: schema.TypeString},
+			},
+			"status": {
+				Type:        schema.TypeString,
+				Description: "Current status of the user",
+				Computed:    true,
+			},
+		},
+	}
+}
+
+func dataSourceCloudProjectDatabasePostgresqlUserRead(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*Config)
+	serviceName := d.Get("service_name").(string)
+	clusterId := d.Get("cluster_id").(string)
+	name := d.Get("name").(string)
+
+	listEndpoint := fmt.Sprintf("/cloud/project/%s/database/postgresql/%s/user",
+		url.PathEscape(serviceName),
+		url.PathEscape(clusterId),
+	)
+
+	listRes := make([]string, 0)
+
+	log.Printf("[DEBUG] Will read users from cluster %s from project %s", clusterId, serviceName)
+	if err := config.OVHClient.Get(listEndpoint, &listRes); err != nil {
+		return fmt.Errorf("Error calling GET %s:\n\t %q", listEndpoint, err)
+	}
+
+	for _, id := range listRes {
+		endpoint := fmt.Sprintf("/cloud/project/%s/database/postgresql/%s/user/%s",
+			url.PathEscape(serviceName),
+			url.PathEscape(clusterId),
+			url.PathEscape(id),
+		)
+		res := &CloudProjectDatabasePostgresqlUserResponse{}
+
+		log.Printf("[DEBUG] Will read user %s from cluster %s from project %s", id, clusterId, serviceName)
+		if err := config.OVHClient.Get(endpoint, res); err != nil {
+			return fmt.Errorf("Error calling GET %s:\n\t %q", endpoint, err)
+		}
+
+		if res.Username == name {
+			for k, v := range res.ToMap() {
+				if k != "id" {
+					d.Set(k, v)
+				} else {
+					d.SetId(fmt.Sprint(v))
+				}
+			}
+			log.Printf("[DEBUG] Read user %+v", res)
+			return nil
+		}
+	}
+
+	return fmt.Errorf("User name %s not found for cluster %s from project %s", name, clusterId, serviceName)
+}

ovh/data_cloud_project_database_postgresql_user_test.go

@@ -0,0 +1,76 @@
+package ovh
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+const testAccCloudProjectDatabasePostgresqlUserDatasourceConfig_Basic = `
+resource "ovh_cloud_project_database" "db" {
+	service_name = "%s"
+	engine       = "postgresql"
+	version      = "%s"
+	plan         = "essential"
+	nodes {
+		region     = "%s"
+	}
+	flavor = "%s"
+}
+
+resource "ovh_cloud_project_database_postgresql_user" "user" {
+	service_name = ovh_cloud_project_database.db.service_name
+	cluster_id   = ovh_cloud_project_database.db.id
+	name		 = "%s"
+	roles = ["replication"]
+}
+
+data "ovh_cloud_project_database_postgresql_user" "user" {
+  service_name = ovh_cloud_project_database_postgresql_user.user.service_name
+  cluster_id   = ovh_cloud_project_database_postgresql_user.user.cluster_id
+  name         = ovh_cloud_project_database_postgresql_user.user.name
+}
+`
+
+func TestAccCloudProjectDatabasePostgresqlUserDataSource_basic(t *testing.T) {
+	serviceName := os.Getenv("OVH_CLOUD_PROJECT_SERVICE_TEST")
+	version := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_POSTGRESQL_VERSION_TEST")
+	if version == "" {
+		version = os.Getenv("OVH_CLOUD_PROJECT_DATABASE_VERSION_TEST")
+	}
+	region := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_REGION_TEST")
+	flavor := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_FLAVOR_TEST")
+	name := "johndoe"
+
+	config := fmt.Sprintf(
+		testAccCloudProjectDatabasePostgresqlUserDatasourceConfig_Basic,
+		serviceName,
+		version,
+		region,
+		flavor,
+		name,
+	)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:  func() { testAccPreCheckCloudDatabaseNoEngine(t) },
+		Providers: testAccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(
+						"data.ovh_cloud_project_database_postgresql_user.user", "created_at"),
+					resource.TestCheckResourceAttrSet(
+						"data.ovh_cloud_project_database_postgresql_user.user", "roles.#"),
+					resource.TestCheckResourceAttrSet(
+						"data.ovh_cloud_project_database_postgresql_user.user", "status"),
+					resource.TestCheckResourceAttr(
+						"data.ovh_cloud_project_database_postgresql_user.user", "name", name,
+					),
+				),
+			},
+		},
+	})
+}

ovh/data_cloud_project_database_user.go

@@ -0,0 +1,105 @@
+package ovh
+
+import (
+	"fmt"
+	"log"
+	"net/url"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+)
+
+func dataSourceCloudProjectDatabaseUser() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceCloudProjectDatabaseUserRead,
+		Schema: map[string]*schema.Schema{
+			"service_name": {
+				Type:        schema.TypeString,
+				Required:    true,
+				DefaultFunc: schema.EnvDefaultFunc("OVH_CLOUD_PROJECT_SERVICE", nil),
+			},
+			"engine": {
+				Type:        schema.TypeString,
+				Description: "Name of the engine of the service",
+				Required:    true,
+			},
+			"cluster_id": {
+				Type:        schema.TypeString,
+				Description: "Cluster ID",
+				Required:    true,
+			},
+			"name": {
+				Type:        schema.TypeString,
+				Description: "Name of the user",
+				Required:    true,
+			},
+
+			//Computed
+			"created_at": {
+				Type:        schema.TypeString,
+				Description: "Date of the creation of the user",
+				Computed:    true,
+			},
+			"status": {
+				Type:        schema.TypeString,
+				Description: "Current status of the user",
+				Computed:    true,
+			},
+		},
+	}
+}
+
+func dataSourceCloudProjectDatabaseUserRead(d *schema.ResourceData, meta interface{}) error {
+	config := meta.(*Config)
+	serviceName := d.Get("service_name").(string)
+	engine := d.Get("engine").(string)
+	clusterId := d.Get("cluster_id").(string)
+	name := d.Get("name").(string)
+
+	listEndpoint := fmt.Sprintf("/cloud/project/%s/database/%s/%s/user",
+		url.PathEscape(serviceName),
+		url.PathEscape(engine),
+		url.PathEscape(clusterId),
+	)
+
+	listRes := make([]string, 0)
+
+	log.Printf("[DEBUG] Will read users from cluster %s from project %s", clusterId, serviceName)
+	if err := config.OVHClient.Get(listEndpoint, &listRes); err != nil {
+		return fmt.Errorf("Error calling GET %s:\n\t %q", listEndpoint, err)
+	}
+
+	for _, id := range listRes {
+		endpoint := fmt.Sprintf("/cloud/project/%s/database/%s/%s/user/%s",
+			url.PathEscape(serviceName),
+			url.PathEscape(engine),
+			url.PathEscape(clusterId),
+			url.PathEscape(id),
+		)
+
+		err := mustGenericEngineUserEndpoint(engine)
+		if err != nil {
+			return fmt.Errorf("Calling Get %s :\n\t %q", endpoint, err)
+		}
+
+		res := &CloudProjectDatabaseUserResponse{}
+
+		log.Printf("[DEBUG] Will read user %s from cluster %s from project %s", id, clusterId, serviceName)
+		if err := config.OVHClient.Get(endpoint, res); err != nil {
+			return fmt.Errorf("Error calling GET %s:\n\t %q", endpoint, err)
+		}
+
+		if res.Username == name {
+			for k, v := range res.ToMap() {
+				if k != "id" {
+					d.Set(k, v)
+				} else {
+					d.SetId(fmt.Sprint(v))
+				}
+			}
+			log.Printf("[DEBUG] Read user %+v", res)
+			return nil
+		}
+	}
+
+	return fmt.Errorf("User name %s not found for cluster %s from project %s", name, clusterId, serviceName)
+}

ovh/data_cloud_project_database_user_test.go

@@ -0,0 +1,74 @@
+package ovh
+
+import (
+	"fmt"
+	"os"
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+const testAccCloudProjectDatabaseUserDatasourceConfig_Basic = `
+resource "ovh_cloud_project_database" "db" {
+	service_name = "%s"
+	engine       = "%s"
+	version      = "%s"
+	plan         = "essential"
+	nodes {
+		region     = "%s"
+	}
+	flavor = "%s"
+}
+
+resource "ovh_cloud_project_database_user" "user" {
+	service_name = ovh_cloud_project_database.db.service_name
+	engine		 = ovh_cloud_project_database.db.engine
+	cluster_id   = ovh_cloud_project_database.db.id
+	name		 = "%s"
+}
+
+data "ovh_cloud_project_database_user" "user" {
+  service_name = ovh_cloud_project_database_user.user.service_name
+  engine	   = ovh_cloud_project_database_user.user.engine
+  cluster_id   = ovh_cloud_project_database_user.user.cluster_id
+  name 	   = ovh_cloud_project_database_user.user.name
+}
+`
+
+func TestAccCloudProjectDatabaseUserDataSource_basic(t *testing.T) {
+	serviceName := os.Getenv("OVH_CLOUD_PROJECT_SERVICE_TEST")
+	engine := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_ENGINE_TEST")
+	version := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_VERSION_TEST")
+	region := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_REGION_TEST")
+	flavor := os.Getenv("OVH_CLOUD_PROJECT_DATABASE_FLAVOR_TEST")
+	name := "johndoe"
+
+	config := fmt.Sprintf(
+		testAccCloudProjectDatabaseUserDatasourceConfig_Basic,
+		serviceName,
+		engine,
+		version,
+		region,
+		flavor,
+		name,
+	)
+
+	resource.Test(t, resource.TestCase{
+		PreCheck:  func() { testAccPreCheckCloudDatabase(t) },
+		Providers: testAccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: config,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttrSet(
+						"data.ovh_cloud_project_database_user.user", "created_at"),
+					resource.TestCheckResourceAttrSet(
+						"data.ovh_cloud_project_database_user.user", "status"),
+					resource.TestCheckResourceAttr(
+						"data.ovh_cloud_project_database_user.user", "name", name,
+					),
+				),
+			},
+		},
+	})
+}