Support Eventbridge Pipes parameters

go.mod

@@ -68,6 +68,7 @@ require (
 	github.com/mitchellh/go-testing-interface v1.14.1
 	github.com/pquerna/otp v1.4.0
 	github.com/shopspring/decimal v1.3.1
+	github.com/stretchr/testify v1.8.2
 	golang.org/x/crypto v0.8.0
 	golang.org/x/exp v0.0.0-20230206171751-46f607a40771
 	golang.org/x/tools v0.6.0
@@ -98,6 +99,7 @@ require (
 	github.com/bgentry/speakeasy v0.1.0 // indirect
 	github.com/boombuler/barcode v1.0.1-0.20190219062509-6c824513bacc // indirect
 	github.com/cloudflare/circl v1.3.2 // indirect
+	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/evanphx/json-patch v0.5.2 // indirect
 	github.com/fatih/color v1.14.1 // indirect
 	github.com/golang/protobuf v1.5.2 // indirect
@@ -122,6 +124,7 @@ require (
 	github.com/mitchellh/mapstructure v1.5.0 // indirect
 	github.com/mitchellh/reflectwalk v1.0.2 // indirect
 	github.com/oklog/run v1.1.0 // indirect
+	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/posener/complete v1.1.1 // indirect
 	github.com/rogpeppe/go-internal v1.9.0 // indirect
 	github.com/spf13/cast v1.3.1 // indirect

go.sum

@@ -329,14 +329,19 @@ github.com/spf13/cast v1.3.1 h1:nFm6S0SMdyzrzcmThSipiEubIDy8WEXKNZ0UOgiRpng=
 github.com/spf13/cast v1.3.1/go.mod h1:Qx5cxh0v+4UWYiBimWS+eyWzqEqokIECu5etghLkUJE=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.1.1/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
 github.com/stretchr/testify v1.6.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.2/go.mod h1:R6va5+xMeoiuVRoj+gSkQ7d3FALtqAAGI1FQKckRals=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/stretchr/testify v1.8.2 h1:+h33VjcLVPDHtOdpUCuF+7gSuG3yGIftsP1YvFihtJ8=
+github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
 github.com/vmihailenco/msgpack v3.3.3+incompatible/go.mod h1:fy3FlTQTDXWkZ7Bh6AcGMlsjHatGryHQYUTf1ShIgkk=
 github.com/vmihailenco/msgpack v4.0.4+incompatible h1:dSLoQfGFAo3F6OoNhwUmLwVgaUXK79GlxNBwueZn0xI=
 github.com/vmihailenco/msgpack v4.0.4+incompatible/go.mod h1:fy3FlTQTDXWkZ7Bh6AcGMlsjHatGryHQYUTf1ShIgkk=

internal/service/pipes/README.md

@@ -3,3 +3,4 @@
 * AWS Provider: [Contribution Guide](https://hashicorp.github.io/terraform-provider-aws/#contribute)
 * Service User Guide: [Amazon EventBridge Pipes](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html)
 * Service API Guide: [Welcome](https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/Welcome.html)
+

internal/service/pipes/enrichment_parameters.go

@@ -0,0 +1,185 @@
+package pipes
+
+import (
+	"github.com/aws/aws-sdk-go-v2/aws"
+	"github.com/aws/aws-sdk-go-v2/service/pipes/types"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/validation"
+	"github.com/hashicorp/terraform-provider-aws/internal/flex"
+)
+
+var enrichment_parameters_schema = &schema.Schema{
+	Type:     schema.TypeList,
+	Optional: true,
+	MaxItems: 1,
+	Elem: &schema.Resource{
+		Schema: map[string]*schema.Schema{
+			"input_template": {
+				Type:         schema.TypeString,
+				Optional:     true,
+				ValidateFunc: validation.StringLenBetween(0, 8192),
+			},
+			"http_parameters": {
+				Type:     schema.TypeList,
+				Optional: true,
+				MaxItems: 1,
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"header": {
+							Type:     schema.TypeList,
+							Optional: true,
+							Elem: &schema.Resource{
+								Schema: map[string]*schema.Schema{
+									"key": {
+										Type:         schema.TypeString,
+										Required:     true,
+										ValidateFunc: validation.StringLenBetween(0, 512),
+									},
+									"value": {
+										Type:         schema.TypeString,
+										Required:     true,
+										ValidateFunc: validation.StringLenBetween(0, 512),
+									},
+								},
+							},
+						},
+						"path_parameters": {
+							Type:     schema.TypeList,
+							Optional: true,
+							Elem: &schema.Schema{
+								Type: schema.TypeString,
+							},
+						},
+						"query_string": {
+							Type:     schema.TypeList,
+							Optional: true,
+							Elem: &schema.Resource{
+								Schema: map[string]*schema.Schema{
+									"key": {
+										Type:         schema.TypeString,
+										Required:     true,
+										ValidateFunc: validation.StringLenBetween(0, 512),
+									},
+									"value": {
+										Type:         schema.TypeString,
+										Required:     true,
+										ValidateFunc: validation.StringLenBetween(0, 512),
+									},
+								},
+							},
+						},
+					},
+				},
+			},
+		},
+	},
+}
+
+func expandEnrichmentParameters(config []interface{}) *types.PipeEnrichmentParameters {
+	if len(config) == 0 {
+		return nil
+	}
+
+	var parameters types.PipeEnrichmentParameters
+	for _, c := range config {
+		param := c.(map[string]interface{})
+		if val, ok := param["input_template"].(string); ok && val != "" {
+			parameters.InputTemplate = aws.String(val)
+		}
+		if val, ok := param["http_parameters"]; ok {
+			parameters.HttpParameters = expandEnrichmentHTTPParameters(val.([]interface{}))
+		}
+	}
+	return &parameters
+}
+
+func expandEnrichmentHTTPParameters(config []interface{}) *types.PipeEnrichmentHttpParameters {
+	if len(config) == 0 {
+		return nil
+	}
+
+	var parameters types.PipeEnrichmentHttpParameters
+	for _, c := range config {
+		param := c.(map[string]interface{})
+		if val, ok := param["path_parameters"]; ok {
+			parameters.PathParameterValues = flex.ExpandStringValueList(val.([]interface{}))
+		}
+
+		if val, ok := param["header"]; ok {
+			headers := map[string]string{}
+			if values, ok := val.([]interface{}); ok {
+				for _, v := range values {
+					valueParam := v.(map[string]interface{})
+
+					if key, ok := valueParam["key"].(string); ok && key != "" {
+						if value, ok := valueParam["value"].(string); ok && value != "" {
+							headers[key] = value
+						}
+					}
+				}
+			}
+			if len(headers) > 0 {
+				parameters.HeaderParameters = headers
+			}
+		}
+
+		if val, ok := param["query_string"]; ok {
+			queryStrings := map[string]string{}
+			if values, ok := val.([]interface{}); ok {
+				for _, v := range values {
+					valueParam := v.(map[string]interface{})
+
+					if key, ok := valueParam["key"].(string); ok && key != "" {
+						if value, ok := valueParam["value"].(string); ok && value != "" {
+							queryStrings[key] = value
+						}
+					}
+				}
+			}
+			if len(queryStrings) > 0 {
+				parameters.QueryStringParameters = queryStrings
+			}
+		}
+	}
+	return &parameters
+}
+
+func flattenEnrichmentParameters(enrichmentParameters *types.PipeEnrichmentParameters) []map[string]interface{} {
+	config := make(map[string]interface{})
+
+	if enrichmentParameters.InputTemplate != nil {
+		config["input_template"] = *enrichmentParameters.InputTemplate
+	}
+
+	if enrichmentParameters.HttpParameters != nil {
+		httpParameters := make(map[string]interface{})
+
+		var headerParameters []map[string]interface{}
+		for key, value := range enrichmentParameters.HttpParameters.HeaderParameters {
+			header := make(map[string]interface{})
+			header["key"] = key
+			header["value"] = value
+			headerParameters = append(headerParameters, header)
+		}
+		httpParameters["header"] = headerParameters
+
+		var queryStringParameters []map[string]interface{}
+		for key, value := range enrichmentParameters.HttpParameters.QueryStringParameters {
+			queryString := make(map[string]interface{})
+			queryString["key"] = key
+			queryString["value"] = value
+			queryStringParameters = append(queryStringParameters, queryString)
+		}
+		httpParameters["query_string"] = queryStringParameters
+		httpParameters["path_parameters"] = flex.FlattenStringValueList(enrichmentParameters.HttpParameters.PathParameterValues)
+
+		config["http_parameters"] = []map[string]interface{}{httpParameters}
+	}
+
+	if len(config) == 0 {
+		return nil
+	}
+
+	result := []map[string]interface{}{config}
+	return result
+}

internal/service/pipes/enrichment_parameters_test.go

@@ -0,0 +1,143 @@
+package pipes
+
+import (
+	"testing"
+
+	"github.com/aws/aws-sdk-go-v2/service/pipes/types"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/stretchr/testify/assert"
+)
+
+func Test_expandEnrichmentParameters(t *testing.T) {
+	tests := map[string]struct {
+		config   map[string]interface{}
+		expected *types.PipeEnrichmentParameters
+	}{
+		"input_template config": {
+			config: map[string]interface{}{
+				"input_template": "some template",
+			},
+			expected: &types.PipeEnrichmentParameters{
+				InputTemplate: aws.String("some template"),
+			},
+		},
+		"http_parameters config": {
+			config: map[string]interface{}{
+				"http_parameters": []interface{}{
+					map[string]interface{}{
+						"path_parameters": []interface{}{"a", "b"},
+						"header": []interface{}{
+							map[string]interface{}{
+								"key":   "key1",
+								"value": "value1",
+							},
+							map[string]interface{}{
+								"key":   "key2",
+								"value": "value2",
+							},
+						},
+						"query_string": []interface{}{
+							map[string]interface{}{
+								"key":   "key3",
+								"value": "value3",
+							},
+							map[string]interface{}{
+								"key":   "key4",
+								"value": "value4",
+							},
+						},
+					},
+				},
+			},
+			expected: &types.PipeEnrichmentParameters{
+				HttpParameters: &types.PipeEnrichmentHttpParameters{
+					PathParameterValues: []string{"a", "b"},
+					HeaderParameters: map[string]string{
+						"key1": "value1",
+						"key2": "value2",
+					},
+					QueryStringParameters: map[string]string{
+						"key3": "value3",
+						"key4": "value4",
+					},
+				},
+			},
+		},
+	}
+	for name, tt := range tests {
+		t.Run(name, func(t *testing.T) {
+			got := expandEnrichmentParameters([]interface{}{tt.config})
+
+			assert.Equal(t, tt.expected, got)
+		})
+	}
+}
+
+func Test_flattenEnrichmentParameters(t *testing.T) {
+	tests := map[string]struct {
+		config   *types.PipeEnrichmentParameters
+		expected []map[string]interface{}
+	}{
+		"input_template config": {
+			config: &types.PipeEnrichmentParameters{
+				InputTemplate: aws.String("some template"),
+			},
+			expected: []map[string]interface{}{
+				{
+					"input_template": "some template",
+				},
+			},
+		},
+		"http_parameters config": {
+			config: &types.PipeEnrichmentParameters{
+				HttpParameters: &types.PipeEnrichmentHttpParameters{
+					PathParameterValues: []string{"a", "b"},
+					HeaderParameters: map[string]string{
+						"key1": "value1",
+						"key2": "value2",
+					},
+					QueryStringParameters: map[string]string{
+						"key3": "value3",
+						"key4": "value4",
+					},
+				},
+			},
+			expected: []map[string]interface{}{
+				{
+					"http_parameters": []map[string]interface{}{
+						{
+							"path_parameters": []interface{}{"a", "b"},
+							"header": []map[string]interface{}{
+								{
+									"key":   "key1",
+									"value": "value1",
+								},
+								{
+									"key":   "key2",
+									"value": "value2",
+								},
+							},
+							"query_string": []map[string]interface{}{
+								{
+									"key":   "key3",
+									"value": "value3",
+								},
+								{
+									"key":   "key4",
+									"value": "value4",
+								},
+							},
+						},
+					},
+				},
+			},
+		},
+	}
+	for name, tt := range tests {
+		t.Run(name, func(t *testing.T) {
+			got := flattenEnrichmentParameters(tt.config)
+
+			assert.Equal(t, tt.expected, got)
+		})
+	}
+}