datasource_digitalocean_database_cluster.go

package digitalocean

import (
	"context"
	"fmt"

	"github.com/digitalocean/godo"
	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
	"github.com/hashicorp/terraform-plugin-sdk/helper/validation"
)

func dataSourceDigitalOceanDatabaseCluster() *schema.Resource {
	return &schema.Resource{
		Read: dataSourceDigitalOceanDatabaseClusterRead,
		Schema: map[string]*schema.Schema{
			"name": {
				Type:         schema.TypeString,
				Required:     true,
				ForceNew:     true,
				ValidateFunc: validation.NoZeroValues,
			},

			"engine": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"version": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"size": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"region": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"node_count": {
				Type:     schema.TypeInt,
				Computed: true,
			},

			"maintenance_window": {
				Type:     schema.TypeList,
				Computed: true,
				MinItems: 1,
				Elem: &schema.Resource{
					Schema: map[string]*schema.Schema{
						"day": {
							Type:     schema.TypeString,
							Computed: true,
						},
						"hour": {
							Type:     schema.TypeString,
							Computed: true,
						},
					},
				},
			},

			"host": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"private_host": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"port": {
				Type:     schema.TypeInt,
				Computed: true,
			},

			"password": {
				Type:      schema.TypeString,
				Computed:  true,
				Sensitive: true,
			},

			"uri": {
				Type:      schema.TypeString,
				Computed:  true,
				Sensitive: true,
			},

			"private_uri": {
				Type:      schema.TypeString,
				Computed:  true,
				Sensitive: true,
			},

			"database": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"user": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"urn": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"private_network_uuid": {
				Type:     schema.TypeString,
				Computed: true,
			},

			"tags": tagsSchema(),
		},
	}
}

func dataSourceDigitalOceanDatabaseClusterRead(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*CombinedConfig).godoClient()

	name := d.Get("name").(string)

	opts := &godo.ListOptions{
		Page:    1,
		PerPage: 200,
	}

	var databaseList []godo.Database

	for {
		databases, resp, err := client.Databases.List(context.Background(), opts)
		if err != nil {
			return fmt.Errorf("Error retrieving DatabaseClusters: %s", err)
		}

		for _, d := range databases {
			databaseList = append(databaseList, d)
		}

		if resp.Links == nil || resp.Links.IsLastPage() {
			break
		}

		page, err := resp.Links.CurrentPage()
		if err != nil {
			return fmt.Errorf("Error retrieving DatabaseClusters: %s", err)
		}

		opts.Page = page + 1
	}

	if len(databaseList) == 0 {
		return fmt.Errorf("Unable to find any database clusters")
	}

	for _, db := range databaseList {
		if db.Name == name {
			d.SetId(db.ID)

			d.Set("name", db.Name)
			d.Set("engine", db.EngineSlug)
			d.Set("version", db.VersionSlug)
			d.Set("size", db.SizeSlug)
			d.Set("region", db.RegionSlug)
			d.Set("node_count", db.NumNodes)
			d.Set("tags", db.Tags)

			if _, ok := d.GetOk("maintenance_window"); ok {
				if err := d.Set("maintenance_window", flattenMaintWindowOpts(*db.MaintenanceWindow)); err != nil {
					return fmt.Errorf("[DEBUG] Error setting maintenance_window - error: %#v", err)
				}
			}

			d.Set("host", db.Connection.Host)
			d.Set("private_host", db.PrivateConnection.Host)
			d.Set("port", db.Connection.Port)
			d.Set("uri", db.Connection.URI)
			d.Set("private_uri", db.PrivateConnection.URI)
			d.Set("database", db.Connection.Database)
			d.Set("user", db.Connection.User)
			d.Set("password", db.Connection.Password)
			d.Set("urn", db.URN())
			d.Set("private_network_uuid", db.PrivateNetworkUUID)

			break
		}
	}

	return nil
}