Support for OpenSearch SoftwareUpdateOptions (closes hashicorp#30103)

inish777 · Jun 27, 2023 · 9aab574 · 9aab574
1 parent 096459a
commit 9aab574
Show file tree

Hide file tree

Showing 3 changed files with 81 additions and 0 deletions.
diff --git a/internal/service/opensearch/domain.go b/internal/service/opensearch/domain.go
@@ -552,6 +552,21 @@ func ResourceDomain() *schema.Resource {
 					},
 				},
 			},
+			"software_update_options": {
+				Type:             schema.TypeList,
+				Optional:         true,
+				MaxItems:         1,
+				DiffSuppressFunc: verify.SuppressMissingOptionalConfigurationBlock,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"auto_software_update_enabled": {
+							Type:     schema.TypeBool,
+							Optional: true,
+							Default:  false,
+						},
+					},
+				},
+			},
 			names.AttrTags:    tftags.TagsSchema(),
 			names.AttrTagsAll: tftags.TagsSchemaComputed(),
 			"vpc_options": {
@@ -699,6 +714,24 @@ func resourceDomainCreate(ctx context.Context, d *schema.ResourceData, meta inte
 		}
 	}
 
+	if v, ok := d.GetOk("software_update_options"); ok {
+		options := v.([]interface{})
+
+		if len(options) == 1 {
+			if options[0] == nil {
+				return sdkdiag.AppendErrorf(diags, "At least one field is expected inside software_update_options")
+			}
+
+			o := options[0].(map[string]interface{})
+
+			softwareUpdateOptions := opensearchservice.SoftwareUpdateOptions{
+				AutoSoftwareUpdateEnabled: aws.Bool(o["auto_software_update_enabled"].(bool)),
+			}
+
+			input.SoftwareUpdateOptions = &softwareUpdateOptions
+		}
+	}
+
 	if v, ok := d.GetOk("vpc_options"); ok {
 		options := v.([]interface{})
 		if options[0] == nil {
@@ -892,6 +925,10 @@ func resourceDomainRead(ctx context.Context, d *schema.ResourceData, meta interf
 		return sdkdiag.AppendErrorf(diags, "setting snapshot_options: %s", err)
 	}
 
+	if err := d.Set("software_update_options", flattenSoftwareUpdateOptions(ds.SoftwareUpdateOptions)); err != nil {
+		return sdkdiag.AppendErrorf(diags, "setting software_update_options: %s", err)
+	}
+
 	if ds.VPCOptions != nil {
 		if err := d.Set("vpc_options", flattenVPCDerivedInfo(ds.VPCOptions)); err != nil {
 			return sdkdiag.AppendErrorf(diags, "setting vpc_options: %s", err)
@@ -1050,6 +1087,20 @@ func resourceDomainUpdate(ctx context.Context, d *schema.ResourceData, meta inte
 			}
 		}
 
+		if d.HasChange("software_update_options") {
+			options := d.Get("software_update_options").([]interface{})
+
+			if len(options) == 1 {
+				o := options[0].(map[string]interface{})
+
+				softwareUpdateOptions := opensearchservice.SoftwareUpdateOptions{
+					AutoSoftwareUpdateEnabled: aws.Bool(o["auto_software_update_enabled"].(bool)),
+				}
+
+				input.SoftwareUpdateOptions = &softwareUpdateOptions
+			}
+		}
+
 		if d.HasChange("vpc_options") {
 			options := d.Get("vpc_options").([]interface{})
 			s := options[0].(map[string]interface{})

diff --git a/internal/service/opensearch/domain_data_source.go b/internal/service/opensearch/domain_data_source.go
@@ -2,6 +2,7 @@ package opensearch
 
 import (
 	"context"
+	"github.com/hashicorp/terraform-provider-aws/internal/verify"
 
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/service/opensearchservice"
@@ -355,6 +356,21 @@ func DataSourceDomain() *schema.Resource {
 					},
 				},
 			},
+			"software_update_options": {
+				Type:             schema.TypeList,
+				Optional:         true,
+				MaxItems:         1,
+				DiffSuppressFunc: verify.SuppressMissingOptionalConfigurationBlock,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"auto_software_update_enabled": {
+							Type:     schema.TypeBool,
+							Optional: true,
+							Default:  false,
+						},
+					},
+				},
+			},
 			"tags": tftags.TagsSchemaComputed(),
 			"vpc_options": {
 				Type:     schema.TypeList,
@@ -462,6 +478,10 @@ func dataSourceDomainRead(ctx context.Context, d *schema.ResourceData, meta inte
 		return sdkdiag.AppendErrorf(diags, "setting snapshot_options: %s", err)
 	}
 
+	if err := d.Set("software_update_options", flattenSoftwareUpdateOptions(ds.SoftwareUpdateOptions)); err != nil {
+		return sdkdiag.AppendErrorf(diags, "setting software_update_options: %s", err)
+	}
+
 	if ds.VPCOptions != nil {
 		if err := d.Set("vpc_options", flattenVPCDerivedInfo(ds.VPCOptions)); err != nil {
 			return sdkdiag.AppendErrorf(diags, "setting vpc_options: %s", err)

diff --git a/internal/service/opensearch/flex.go b/internal/service/opensearch/flex.go
@@ -213,6 +213,16 @@ func flattenSnapshotOptions(snapshotOptions *opensearchservice.SnapshotOptions)
 	return []map[string]interface{}{m}
 }
 
+func flattenSoftwareUpdateOptions(softwareUpdateOptions *opensearchservice.SoftwareUpdateOptions) map[string]interface{} {
+	if softwareUpdateOptions == nil {
+		return map[string]interface{}{}
+	}
+
+	m := map[string]interface{}{}
+
+	return m
+}
+
 func flattenVPCDerivedInfo(o *opensearchservice.VPCDerivedInfo) []map[string]interface{} {
 	m := map[string]interface{}{}