feat: add VDB group update and tag management with acceptance tests

Author: sumedhbala-delphix

go.mod

@@ -5,7 +5,7 @@ go 1.22.0
 toolchain go1.22.6
 
 require (
-	github.com/delphix/dct-sdk-go/v25 v25.1.2
+	github.com/delphix/dct-sdk-go/v25 v25.2.0
 	github.com/hashicorp/terraform-plugin-sdk/v2 v2.33.0
 )
 

go.sum

@@ -21,6 +21,8 @@ github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/delphix/dct-sdk-go/v25 v25.1.2 h1:wiJui4cZB4xK9Znu9JdWb5N3rKqbnz1oXWaqLXjGHnE=
 github.com/delphix/dct-sdk-go/v25 v25.1.2/go.mod h1:Y//bIbAZP6SZhLLZAQMxEfeRXvsvKQwu/kSR8a5hfqc=
+github.com/delphix/dct-sdk-go/v25 v25.2.0 h1:djFGvJwDHE99vBFa5ZlixcV49niz7nRsuwfue8l/AQA=
+github.com/delphix/dct-sdk-go/v25 v25.2.0/go.mod h1:fCw+bOFPHiNcqUGvRpOEq4PINgcmw6KptstJy4v66Uo=
 github.com/emirpasic/gods v1.18.1 h1:FXtiHYKDGKCW2KzwZKx0iC0PQmdlorYgdFG9jPXJ1Bc=
 github.com/emirpasic/gods v1.18.1/go.mod h1:8tpGGwCnJ5H4r6BWwaV6OrWmMoPhUl5jm/FMNAnJvWQ=
 github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=

internal/provider/resource_vdb_group.go

@@ -35,18 +35,38 @@ func resourceVdbGroup() *schema.Resource {
 					Type: schema.TypeString,
 				},
 			},
+			"tags": {
+				Type:     schema.TypeList,
+				Optional: true,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"key": {
+							Type:     schema.TypeString,
+							Required: true,
+						},
+						"value": {
+							Type:     schema.TypeString,
+							Required: true,
+						},
+					},
+				},
+			},
 		},
 	}
 }
 
 func resourceVdbGroupCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
-
 	var diags diag.Diagnostics
 
 	client := meta.(*apiClient).client
 
 	vdbGroupCreateReq := *dctapi.NewCreateVDBGroupRequest(d.Get("name").(string))
 	vdbGroupCreateReq.SetVdbIds(toStringArray(d.Get("vdb_ids")))
+
+	if v, has_v := d.GetOk("tags"); has_v {
+		vdbGroupCreateReq.SetTags(toTagArray(v))
+	}
+
 	apiRes, httpRes, err := client.VDBGroupsAPI.CreateVdbGroup(ctx).CreateVDBGroupRequest(vdbGroupCreateReq).Execute()
 
 	if diags := apiErrorResponseHelper(ctx, apiRes, httpRes, err); diags != nil {
@@ -64,7 +84,6 @@ func resourceVdbGroupCreate(ctx context.Context, d *schema.ResourceData, meta in
 }
 
 func resourceVdbGroupRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
-
 	client := meta.(*apiClient).client
 
 	var diags diag.Diagnostics
@@ -80,12 +99,116 @@ func resourceVdbGroupRead(ctx context.Context, d *schema.ResourceData, meta inte
 
 	d.Set("name", apiRes.GetName())
 	d.Set("vdb_ids", apiRes.GetVdbIds())
+	d.Set("tags", flattenTags(apiRes.GetTags()))
 	return diags
 }
 
 func resourceVdbGroupUpdate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
+	client := meta.(*apiClient).client
+
+	vdbGroupId := d.Id()
+
+	if d.HasChange("name") || d.HasChange("vdb_ids") {
+		updateVdbGroupReq := *dctapi.NewUpdateVDBGroupParameters()
+		if d.HasChange("name") {
+			updateVdbGroupReq.SetName(d.Get("name").(string))
+		}
+		if d.HasChange("vdb_ids") {
+			updateVdbGroupReq.SetVdbIds(toStringArray(d.Get("vdb_ids")))
+		}
+
+		_, httpRes, err := client.VDBGroupsAPI.UpdateVdbGroupById(ctx, vdbGroupId).UpdateVDBGroupParameters(updateVdbGroupReq).Execute()
+		if diags := apiErrorResponseHelper(ctx, nil, httpRes, err); diags != nil {
+			return diags
+		}
+	}
+
+	if d.HasChange("tags") {
+		oldTags, newTags := d.GetChange("tags")
+		oldTagList := oldTags.([]interface{})
+		newTagList := newTags.([]interface{})
+
+		// Create a map of old tags for easy lookup
+		oldTagMap := make(map[string]map[string]bool)
+		for _, tag := range oldTagList {
+			tagMap := tag.(map[string]interface{})
+			key := tagMap["key"].(string)
+			value := tagMap["value"].(string)
+			if _, exists := oldTagMap[key]; !exists {
+				oldTagMap[key] = make(map[string]bool)
+			}
+			oldTagMap[key][value] = true
+		}
+
+		// Create a map of new tags for easy lookup
+		newTagMap := make(map[string]map[string]bool)
+		for _, tag := range newTagList {
+			tagMap := tag.(map[string]interface{})
+			key := tagMap["key"].(string)
+			value := tagMap["value"].(string)
+			if _, exists := newTagMap[key]; !exists {
+				newTagMap[key] = make(map[string]bool)
+			}
+			newTagMap[key][value] = true
+		}
+
+		// Delete removed tags
+		for key, oldValues := range oldTagMap {
+			newValues, exists := newTagMap[key]
+			if !exists {
+				// Key doesn't exist in new tags, delete all values for this key
+				deleteTag := *dctapi.NewDeleteTag()
+				deleteTag.SetKey(key)
+				httpRes, err := client.VDBGroupsAPI.DeleteVdbGroupTags(ctx, vdbGroupId).DeleteTag(deleteTag).Execute()
+				if diags := apiErrorResponseHelper(ctx, nil, httpRes, err); diags != nil {
+					return diags
+				}
+			} else {
+				// Key exists, delete only values that are not in new tags
+				for oldValue := range oldValues {
+					if !newValues[oldValue] {
+						deleteTag := *dctapi.NewDeleteTag()
+						deleteTag.SetKey(key)
+						deleteTag.SetValue(oldValue)
+						httpRes, err := client.VDBGroupsAPI.DeleteVdbGroupTags(ctx, vdbGroupId).DeleteTag(deleteTag).Execute()
+						if diags := apiErrorResponseHelper(ctx, nil, httpRes, err); diags != nil {
+							return diags
+						}
+					}
+				}
+			}
+		}
+
+		// Create new tags
+		var tags []dctapi.Tag
+		for key, newValues := range newTagMap {
+			oldValues, exists := oldTagMap[key]
+			if !exists {
+				// Key doesn't exist in old tags, create all values
+				for value := range newValues {
+					tag := *dctapi.NewTag(key, value)
+					tags = append(tags, tag)
+				}
+			} else {
+				// Key exists, create only new values
+				for value := range newValues {
+					if !oldValues[value] {
+						tag := *dctapi.NewTag(key, value)
+						tags = append(tags, tag)
+					}
+				}
+			}
+		}
+		if len(tags) > 0 {
+			tagsRequest := *dctapi.NewTagsRequest(tags)
+			_, httpRes, err := client.VDBGroupsAPI.CreateVdbGroupsTags(ctx, vdbGroupId).TagsRequest(tagsRequest).Execute()
+			if diags := apiErrorResponseHelper(ctx, nil, httpRes, err); diags != nil {
+				return diags
+			}
+		}
+	}
 
-	return diag.Errorf("not implemented")
+	return resourceVdbGroupRead(ctx, d, meta)
 }
 
 func resourceVdbGroupDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {