f/aws_codepipeline add support for pipeline_type and variable

.changelog/34122.txt

@@ -0,0 +1,3 @@
+```release-note:enhancement
+resource/aws_codepipeline: Add `pipeline_type`, `variable` attribute
+```

internal/service/codepipeline/codepipeline.go

@@ -103,6 +103,12 @@
 					validation.StringMatch(regexache.MustCompile(`[0-9A-Za-z_.@-]+`), ""),
 				),
 			},
+			"pipeline_type": {
+				Type:         schema.TypeString,
+				Optional:     true,
+				Default:      codepipeline.PipelineTypeV1,
+				ValidateFunc: validation.StringInSlice(codepipeline.PipelineType_Values(), false),
+			},
 			"role_arn": {
 				Type:         schema.TypeString,
 				Required:     true,
@@ -208,6 +214,26 @@
 					},
 				},
 			},
+			"variable": {
+				Type:     schema.TypeList,
+				Optional: true,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"default_value": {
+							Type:     schema.TypeString,
+							Optional: true,
+						},
+						"description": {
+							Type:     schema.TypeString,
+							Optional: true,
+						},
+						"name": {
+							Type:     schema.TypeString,
+							Required: true,
+						},
+					},
+				},
+			},
 			names.AttrTags:    tftags.TagsSchema(),
 			names.AttrTagsAll: tftags.TagsSchemaComputed(),
 		},
@@ -285,6 +311,12 @@
 	d.Set("name", pipeline.Name)
 	d.Set("role_arn", pipeline.RoleArn)
 
+	d.Set("pipeline_type", pipeline.PipelineType)
+
+	if err := d.Set("variable", flattenVariableDeclarations(d, pipeline.Variables)); err != nil {
+		return sdkdiag.AppendErrorf(diags, "setting variable: %s", err)
+	}
+
 	return diags
 }
 
@@ -435,6 +467,10 @@
 		apiObject.Name = aws.String(v.(string))
 	}
 
+	if v, ok := d.GetOk("pipeline_type"); ok {
+		apiObject.PipelineType = aws.String(v.(string))
+	}
+
 	if v, ok := d.GetOk("role_arn"); ok {
 		apiObject.RoleArn = aws.String(v.(string))
 	}
@@ -443,6 +479,10 @@
 		apiObject.Stages = expandStageDeclarations(v.([]interface{}))
 	}
 
+	if v, ok := d.GetOk("variable"); ok && len(v.([]interface{})) > 0 {
+		apiObject.Variables = expandVariableDeclarations(v.([]interface{}))
+	}
+
 	return apiObject, nil
 }
 
@@ -696,6 +736,54 @@
 	return apiObjects
 }
 
+func expandVariableDeclaration(tfMap map[string]interface{}) *codepipeline.PipelineVariableDeclaration {
+	if tfMap == nil {
+		return nil
+	}
+
+	apiObject := &codepipeline.PipelineVariableDeclaration{}
+
+	if v, ok := tfMap["default_value"].(string); ok && v != "" {
+		apiObject.DefaultValue = aws.String(v)
+	}
+
+	if v, ok := tfMap["description"].(string); ok && v != "" {
+		apiObject.Description = aws.String(v)
+	}
+
+	if v, ok := tfMap["name"].(string); ok && v != "" {
+		apiObject.Name = aws.String(v)
+	}
+
+	return apiObject
+}
+
+func expandVariableDeclarations(tfList []interface{}) []*codepipeline.PipelineVariableDeclaration {
+	if len(tfList) == 0 {
+		return nil
+	}
+
+	var apiObjects []*codepipeline.PipelineVariableDeclaration
+
+	for _, tfMapRaw := range tfList {
+		tfMap, ok := tfMapRaw.(map[string]interface{})
+
+		if !ok {
+			continue
+		}
+
+		apiObject := expandVariableDeclaration(tfMap)
+
+		if apiObject == nil {
+			continue
+		}
+
+		apiObjects = append(apiObjects, apiObject)
+	}
+
+	return apiObjects
+}
+
 func flattenArtifactStore(apiObject *codepipeline.ArtifactStore) map[string]interface{} {
 	if apiObject == nil {
 		return nil
@@ -918,3 +1006,43 @@
 
 	return aws.StringValueSlice(tfList)
 }
+
+func flattenVariableDeclaration(d *schema.ResourceData, i int, apiObject *codepipeline.PipelineVariableDeclaration) map[string]interface{} {
+	if apiObject == nil {
+		return nil
+	}
+
+	tfMap := map[string]interface{}{}
+
+	if v := apiObject.DefaultValue; v != nil {
+		tfMap["default_value"] = aws.StringValue(v)
+	}
+
+	if v := apiObject.Description; v != nil {
+		tfMap["description"] = aws.StringValue(v)
+	}
+
+	if v := apiObject.Name; v != nil {
+		tfMap["name"] = aws.StringValue(v)
+	}
+
+	return tfMap
+}
+
+func flattenVariableDeclarations(d *schema.ResourceData, apiObjects []*codepipeline.PipelineVariableDeclaration) []interface{} {
+	if len(apiObjects) == 0 {
+		return nil
+	}
+
+	var tfList []interface{}
+
+	for i, apiObject := range apiObjects {
+		if apiObject == nil {
+			continue
+		}
+
+		tfList = append(tfList, flattenVariableDeclaration(d, i, apiObject))
+	}
+
+	return tfList
+}