Add a data source rg_list

decort/data_source_rg_list.go

@@ -0,0 +1,314 @@
+/*
+Copyright (c) 2019-2021 Digital Energy Cloud Solutions LLC. All Rights Reserved.
+Author: Sergey Shubin, <sergey.shubin@digitalenergy.online>, <svs1370@gmail.com>
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+/*
+This file is part of Terraform (by Hashicorp) provider for Digital Energy Cloud Orchestration
+Technology platfom.
+
+Visit https://github.com/rudecs/terraform-provider-decort for full source code package and updates.
+*/
+
+package decort
+
+import (
+	"github.com/google/uuid"
+	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
+)
+
+func flattenRgList(rgl ResgroupListResp) []map[string]interface{} {
+	res := make([]map[string]interface{}, 0)
+	for _, rg := range rgl {
+		temp := map[string]interface{}{
+			"account_id":        rg.AccountID,
+			"account_name":      rg.AccountName,
+			"acl":               flattenRgAcl(rg.ACLs),
+			"created_by":        rg.CreatedBy,
+			"created_time":      rg.CreatedTime,
+			"def_net_id":        rg.DefaultNetID,
+			"def_net_type":      rg.DefaultNetType,
+			"deleted_by":        rg.DeletedBy,
+			"deleted_time":      rg.DeletedTime,
+			"desc":              rg.Decsription,
+			"gid":               rg.GridID,
+			"guid":              rg.GUID,
+			"rg_id":             rg.ID,
+			"lock_status":       rg.LockStatus,
+			"milestones":        rg.Milestones,
+			"name":              rg.Name,
+			"register_computes": rg.RegisterComputes,
+			"resource_limits":   flattenRgResourceLimits(rg.ResourceLimits),
+			"secret":            rg.Secret,
+			"status":            rg.Status,
+			"updated_by":        rg.UpdatedBy,
+			"updated_time":      rg.UpdatedTime,
+			"vins":              rg.Vins,
+			"vms":               rg.Computes,
+		}
+		res = append(res, temp)
+	}
+	return res
+
+}
+
+func flattenRgAcl(rgAcls []AccountAclRecord) []map[string]interface{} {
+	res := make([]map[string]interface{}, 0)
+	for _, rgAcl := range rgAcls {
+		temp := map[string]interface{}{
+			"explicit":      rgAcl.IsExplicit,
+			"guid":          rgAcl.Guid,
+			"right":         rgAcl.Rights,
+			"status":        rgAcl.Status,
+			"type":          rgAcl.Type,
+			"user_group_id": rgAcl.UgroupID,
+		}
+		res = append(res, temp)
+	}
+	return res
+}
+
+func flattenRgResourceLimits(rl ResourceLimits) []map[string]interface{} {
+	res := make([]map[string]interface{}, 0)
+	temp := map[string]interface{}{
+		"cu_c":      rl.CUC,
+		"cu_d":      rl.CUD,
+		"cu_i":      rl.CUI,
+		"cu_m":      rl.CUM,
+		"cu_np":     rl.CUNP,
+		"gpu_units": rl.GpuUnits,
+	}
+	res = append(res, temp)
+
+	return res
+
+}
+
+func dataSourceRgListRead(d *schema.ResourceData, m interface{}) error {
+	rgList, err := utilityRgListCheckPresence(d, m)
+	if err != nil {
+		return err
+	}
+
+	id := uuid.New()
+	d.SetId(id.String())
+	d.Set("items", flattenRgList(rgList))
+
+	return nil
+}
+
+func dataSourceRgListSchemaMake() map[string]*schema.Schema {
+	res := map[string]*schema.Schema{
+		"includedeleted": {
+			Type:        schema.TypeBool,
+			Optional:    true,
+			Default:     false,
+			Description: "included deleted resource groups",
+		},
+		"page": {
+			Type:        schema.TypeInt,
+			Optional:    true,
+			Description: "Page number",
+		},
+		"size": {
+			Type:        schema.TypeInt,
+			Optional:    true,
+			Description: "Page size",
+		},
+		"items": {
+			Type:     schema.TypeList,
+			Computed: true,
+			Elem: &schema.Resource{
+				Schema: map[string]*schema.Schema{
+					"account_id": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"account_name": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"acl": {
+						Type:     schema.TypeList,
+						Computed: true,
+						Elem: &schema.Resource{
+							Schema: map[string]*schema.Schema{
+								"explicit": {
+									Type:     schema.TypeBool,
+									Computed: true,
+								},
+								"guid": {
+									Type:     schema.TypeString,
+									Computed: true,
+								},
+								"right": {
+									Type:     schema.TypeString,
+									Computed: true,
+								},
+								"status": {
+									Type:     schema.TypeString,
+									Computed: true,
+								},
+								"type": {
+									Type:     schema.TypeString,
+									Computed: true,
+								},
+								"user_group_id": {
+									Type:     schema.TypeString,
+									Computed: true,
+								},
+							},
+						},
+					},
+					"created_by": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"created_time": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"def_net_id": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"def_net_type": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"deleted_by": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"deleted_time": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"desc": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"gid": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"guid": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"rg_id": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"lock_status": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"milestones": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"name": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"register_computes": {
+						Type:     schema.TypeBool,
+						Computed: true,
+					},
+					"resource_limits": {
+						Type:     schema.TypeList,
+						Computed: true,
+						MaxItems: 1,
+						Elem: &schema.Resource{
+							Schema: map[string]*schema.Schema{
+								"cu_c": {
+									Type:     schema.TypeFloat,
+									Computed: true,
+								},
+								"cu_d": {
+									Type:     schema.TypeFloat,
+									Computed: true,
+								},
+								"cu_i": {
+									Type:     schema.TypeFloat,
+									Computed: true,
+								},
+								"cu_m": {
+									Type:     schema.TypeFloat,
+									Computed: true,
+								},
+								"cu_np": {
+									Type:     schema.TypeFloat,
+									Computed: true,
+								},
+								"gpu_units": {
+									Type:     schema.TypeFloat,
+									Computed: true,
+								},
+							},
+						},
+					},
+					"secret": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"status": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"updated_by": {
+						Type:     schema.TypeString,
+						Computed: true,
+					},
+					"updated_time": {
+						Type:     schema.TypeInt,
+						Computed: true,
+					},
+					"vins": {
+						Type:     schema.TypeList,
+						Computed: true,
+						Elem: &schema.Schema{
+							Type: schema.TypeInt,
+						},
+					},
+					"vms": {
+						Type:     schema.TypeList,
+						Computed: true,
+						Elem: &schema.Schema{
+							Type: schema.TypeInt,
+						},
+					},
+				},
+			},
+		},
+	}
+	return res
+}
+
+func dataSourceRgList() *schema.Resource {
+	return &schema.Resource{
+		SchemaVersion: 1,
+
+		Read: dataSourceRgListRead,
+
+		Timeouts: &schema.ResourceTimeout{
+			Read:    &Timeout30s,
+			Default: &Timeout60s,
+		},
+
+		Schema: dataSourceRgListSchemaMake(),
+	}
+}

decort/models_api.go

@@ -59,20 +59,35 @@ type AccountAclRecord struct {
 	UgroupID   string `json:"userGroupId"`
 }
 
+type ResourceLimits struct {
+	CUC      float64 `json:"CU_C"`
+	CUD      float64 `json:"CU_D"`
+	CUI      float64 `json:"CU_I"`
+	CUM      float64 `json:"CU_M"`
+	CUNP     float64 `json:"CU_NP"`
+	GpuUnits float64 `json:"gpu_units"`
+}
+
 type ResgroupRecord struct {
-	ACLs           []UserAclRecord  `json:"acl"`
+	ACLs             []AccountAclRecord `json:"acl"`
-	Owner          AccountAclRecord `json:"accountAcl"`
 	AccountID        int                `json:"accountId"`
 	AccountName      string             `json:"accountName"`
 	CreatedBy        string             `json:"createdBy"`
 	CreatedTime      uint64             `json:"createdTime"`
 	DefaultNetID     int                `json:"def_net_id"`
 	DefaultNetType   string             `json:"def_net_type"`
+	DeletedBy        string             `json:"deletedBy"`
+	DeletedTime      int                `json:"deletedTime"`
 	Decsription      string             `json:"desc"`
 	GridID           int                `json:"gid"`
+	GUID             int                `json:"guid"`
 	ID               uint               `json:"id"`
 	LockStatus       string             `json:"lockStatus"`
+	Milestones       int                `json:"milestones"`
 	Name             string             `json:"name"`
+	RegisterComputes bool               `json:"registerComputes"`
+	ResourceLimits   ResourceLimits     `json:"resourceLimits"`
+	Secret           string             `json:"secret"`
 	Status           string             `json:"status"`
 	UpdatedBy        string             `json:"updatedBy"`
 	UpdatedTime      uint64             `json:"updatedTime"`

decort/provider.go

@@ -138,6 +138,7 @@ func Provider() *schema.Provider {
 			"decort_sep_config":        dataSourceSepConfig(),
 			"decort_sep_pool":          dataSourceSepPool(),
 			"decort_disk_list":         dataSourceDiskList(),
+			"decort_rg_list":           dataSourceRgList(),
 			// "decort_pfw": dataSourcePfw(),
 		},
 

decort/utility_rg_list.go

@@ -0,0 +1,65 @@
+/*
+Copyright (c) 2019-2022 Digital Energy Cloud Solutions LLC. All Rights Reserved.
+Author: Stanislav Solovev, <spsolovev@digitalenergy.online>, <svs1370@gmail.com>
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+/*
+This file is part of Terraform (by Hashicorp) provider for Digital Energy Cloud Orchestration
+Technology platfom.
+
+Visit https://github.com/rudecs/terraform-provider-decort for full source code package and updates.
+*/
+
+package decort
+
+import (
+	"encoding/json"
+	"net/url"
+	"strconv"
+
+	log "github.com/sirupsen/logrus"
+
+	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
+)
+
+func utilityRgListCheckPresence(d *schema.ResourceData, m interface{}) (ResgroupListResp, error) {
+	controller := m.(*ControllerCfg)
+	urlValues := &url.Values{}
+
+	rgList := ResgroupListResp{}
+
+	if size, ok := d.GetOk("size"); ok {
+		urlValues.Add("size", strconv.Itoa(size.(int)))
+	}
+	if page, ok := d.GetOk("page"); ok {
+		urlValues.Add("page", strconv.Itoa(page.(int)))
+	}
+	if includedeleted, ok := d.GetOk("includedeleted"); ok {
+		urlValues.Add("includedeleted", strconv.FormatBool(includedeleted.(bool)))
+	}
+
+	log.Debugf("utilityRgListCheckPresence: load rg list")
+	rgListRaw, err := controller.decortAPICall("POST", ResgroupListAPI, urlValues)
+	if err != nil {
+		return nil, err
+	}
+
+	err = json.Unmarshal([]byte(rgListRaw), &rgList)
+	if err != nil {
+		return nil, err
+	}
+
+	return rgList, nil
+}

samples/README.md

@@ -19,6 +19,7 @@
   - sep_consumption
   - vgpu
   - disk_list
+  - rg_list
 - resources:
   - image
   - virtual_image

samples/data_rg_list/main.tf

@@ -0,0 +1,49 @@
+/*
+Пример использования
+Получение списка всех resource groups
+
+*/
+#Расскомментируйте этот код,
+#и внесите необходимые правки в версию и путь,
+#чтобы работать с установленным вручную (не через hashicorp provider registry) провайдером
+/*
+terraform {
+  required_providers {
+    decort = {
+      version = "1.1"
+      source  = "digitalenergy.online/decort/decort"
+    }
+  }
+}
+*/
+provider "decort" {
+  authenticator = "oauth2"
+  #controller_url = <DECORT_CONTROLLER_URL>
+  controller_url = "https://ds1.digitalenergy.online"
+  #oauth2_url = <DECORT_SSO_URL>
+  oauth2_url           = "https://sso.digitalenergy.online"
+  allow_unverified_ssl = true
+}
+
+data "decort_rg_list" "rl" {
+  #включение удаленных rg в результат поиска
+  #опциональный параметр
+  #тип - булев тип
+  #по-умолчанию - false
+  #includedeleted = true
+
+  #номер страницы для отображения
+  #опциональный параметр, тип - число
+  #если не задан - выводятся все доступные данные
+  #page = 2
+
+  #размер страницы
+  #опциональный параметр, тип - число
+  #если не задан - выводятся все доступные данные
+  #size = 3
+
+}
+
+output "test" {
+  value = data.decort_rg_list.rl
+}