data_source_ibm_is_volume_profiles.go

// Copyright IBM Corp. 2017, 2021 All Rights Reserved.
// Licensed under the Mozilla Public License v2.0

package vpc

import (
	"fmt"
	"time"

	"github.com/IBM-Cloud/terraform-provider-ibm/ibm/flex"
	"github.com/IBM/vpc-go-sdk/vpcv1"
	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
)

const (
	isVolumeProfiles = "profiles"
)

func DataSourceIBMISVolumeProfiles() *schema.Resource {
	return &schema.Resource{
		Read: dataSourceIBMISVolumeProfilesRead,

		Schema: map[string]*schema.Schema{

			isVolumeProfiles: {
				Type:        schema.TypeList,
				Description: "List of Volume profile maps",
				Computed:    true,
				Elem: &schema.Resource{
					Schema: map[string]*schema.Schema{
						"name": {
							Type:     schema.TypeString,
							Computed: true,
						},
						"family": {
							Type:     schema.TypeString,
							Computed: true,
						},
					},
				},
			},
		},
	}
}

func dataSourceIBMISVolumeProfilesRead(d *schema.ResourceData, meta interface{}) error {

	err := volumeProfilesList(d, meta)
	if err != nil {
		return err
	}
	return nil
}

func volumeProfilesList(d *schema.ResourceData, meta interface{}) error {
	sess, err := vpcClient(meta)
	if err != nil {
		return err
	}

	start := ""
	allrecs := []vpcv1.VolumeProfile{}
	for {
		listVolumeProfilesOptions := &vpcv1.ListVolumeProfilesOptions{}
		if start != "" {
			listVolumeProfilesOptions.Start = &start
		}
		availableProfiles, response, err := sess.ListVolumeProfiles(listVolumeProfilesOptions)
		if err != nil {
			return fmt.Errorf("[ERROR] Error Fetching Volume Profiles %s\n%s", err, response)
		}
		start = flex.GetNext(availableProfiles.Next)
		allrecs = append(allrecs, availableProfiles.Profiles...)
		if start == "" {
			break
		}
	}

	// listVolumeProfilesOptions := &vpcv1.ListVolumeProfilesOptions{}
	// availableProfiles, response, err := sess.ListVolumeProfiles(listVolumeProfilesOptions)
	// if err != nil {
	// 	return fmt.Errorf("[ERROR] Error Fetching Volume Profiles %s\n%s", err, response)
	// }
	profilesInfo := make([]map[string]interface{}, 0)
	for _, profile := range allrecs {

		l := map[string]interface{}{
			"name":   *profile.Name,
			"family": *profile.Family,
		}
		profilesInfo = append(profilesInfo, l)
	}
	d.SetId(dataSourceIBMISVolumeProfilesID(d))
	d.Set(isVolumeProfiles, profilesInfo)
	return nil
}

// dataSourceIBMISVolumeProfilesID returns a reasonable ID for a Volume Profile list.
func dataSourceIBMISVolumeProfilesID(d *schema.ResourceData) string {
	return time.Now().UTC().String()
}