// Code generated by generators/resource/main.go; DO NOT EDIT.

package lambda

import (
	"context"
	"regexp"

	"github.com/hashicorp/terraform-plugin-framework/tfsdk"
	"github.com/hashicorp/terraform-plugin-framework/types"
	. "github.com/hashicorp/terraform-provider-awscc/internal/generic"
	"github.com/hashicorp/terraform-provider-awscc/internal/registry"
	"github.com/hashicorp/terraform-provider-awscc/internal/validate"
)

func init() {
	registry.AddResourceTypeFactory("awscc_lambda_event_source_mapping", eventSourceMappingResourceType)
}

// eventSourceMappingResourceType returns the Terraform awscc_lambda_event_source_mapping resource type.
// This Terraform resource type corresponds to the CloudFormation AWS::Lambda::EventSourceMapping resource type.
func eventSourceMappingResourceType(ctx context.Context) (tfsdk.ResourceType, error) {
	attributes := map[string]tfsdk.Attribute{
		"batch_size": {
			// Property: BatchSize
			// CloudFormation resource type schema:
			// {
			//   "description": "The maximum number of items to retrieve in a single batch.",
			//   "maximum": 10000,
			//   "minimum": 1,
			//   "type": "integer"
			// }
			Description: "The maximum number of items to retrieve in a single batch.",
			Type:        types.Int64Type,
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.IntBetween(1, 10000),
			},
		},
		"bisect_batch_on_function_error": {
			// Property: BisectBatchOnFunctionError
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) If the function returns an error, split the batch in two and retry.",
			//   "type": "boolean"
			// }
			Description: "(Streams) If the function returns an error, split the batch in two and retry.",
			Type:        types.BoolType,
			Optional:    true,
		},
		"destination_config": {
			// Property: DestinationConfig
			// CloudFormation resource type schema:
			// {
			//   "additionalProperties": false,
			//   "description": "(Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.",
			//   "properties": {
			//     "OnFailure": {
			//       "additionalProperties": false,
			//       "description": "The destination configuration for failed invocations.",
			//       "properties": {
			//         "Destination": {
			//           "description": "The Amazon Resource Name (ARN) of the destination resource.",
			//           "maxLength": 1024,
			//           "minLength": 12,
			//           "pattern": "arn:(aws[a-zA-Z0-9-]*):([a-zA-Z0-9\\-])+:([a-z]{2}(-gov)?-[a-z]+-\\d{1})?:(\\d{12})?:(.*)",
			//           "type": "string"
			//         }
			//       },
			//       "type": "object"
			//     }
			//   },
			//   "type": "object"
			// }
			Description: "(Streams) An Amazon SQS queue or Amazon SNS topic destination for discarded records.",
			Attributes: tfsdk.SingleNestedAttributes(
				map[string]tfsdk.Attribute{
					"on_failure": {
						// Property: OnFailure
						Description: "The destination configuration for failed invocations.",
						Attributes: tfsdk.SingleNestedAttributes(
							map[string]tfsdk.Attribute{
								"destination": {
									// Property: Destination
									Description: "The Amazon Resource Name (ARN) of the destination resource.",
									Type:        types.StringType,
									Optional:    true,
									Validators: []tfsdk.AttributeValidator{
										validate.StringLenBetween(12, 1024),
										validate.StringMatch(regexp.MustCompile("arn:(aws[a-zA-Z0-9-]*):([a-zA-Z0-9\\-])+:([a-z]{2}(-gov)?-[a-z]+-\\d{1})?:(\\d{12})?:(.*)"), ""),
									},
								},
							},
						),
						Optional: true,
					},
				},
			),
			Optional: true,
		},
		"enabled": {
			// Property: Enabled
			// CloudFormation resource type schema:
			// {
			//   "description": "Disables the event source mapping to pause polling and invocation.",
			//   "type": "boolean"
			// }
			Description: "Disables the event source mapping to pause polling and invocation.",
			Type:        types.BoolType,
			Optional:    true,
		},
		"event_source_arn": {
			// Property: EventSourceArn
			// CloudFormation resource type schema:
			// {
			//   "description": "The Amazon Resource Name (ARN) of the event source.",
			//   "maxLength": 1024,
			//   "minLength": 12,
			//   "pattern": "arn:(aws[a-zA-Z0-9-]*):([a-zA-Z0-9\\-])+:([a-z]{2}(-gov)?-[a-z]+-\\d{1})?:(\\d{12})?:(.*)",
			//   "type": "string"
			// }
			Description: "The Amazon Resource Name (ARN) of the event source.",
			Type:        types.StringType,
			Optional:    true,
			Computed:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.StringLenBetween(12, 1024),
				validate.StringMatch(regexp.MustCompile("arn:(aws[a-zA-Z0-9-]*):([a-zA-Z0-9\\-])+:([a-z]{2}(-gov)?-[a-z]+-\\d{1})?:(\\d{12})?:(.*)"), ""),
			},
			PlanModifiers: []tfsdk.AttributePlanModifier{
				tfsdk.UseStateForUnknown(),
				tfsdk.RequiresReplace(),
			},
		},
		"filter_criteria": {
			// Property: FilterCriteria
			// CloudFormation resource type schema:
			// {
			//   "additionalProperties": false,
			//   "description": "The filter criteria to control event filtering.",
			//   "properties": {
			//     "Filters": {
			//       "description": "List of filters of this FilterCriteria",
			//       "items": {
			//         "additionalProperties": false,
			//         "description": "The filter object that defines parameters for ESM filtering.",
			//         "properties": {
			//           "Pattern": {
			//             "description": "The filter pattern that defines which events should be passed for invocations.",
			//             "maxLength": 4096,
			//             "minLength": 0,
			//             "pattern": ".*",
			//             "type": "string"
			//           }
			//         },
			//         "type": "object"
			//       },
			//       "maxItems": 20,
			//       "minItems": 1,
			//       "type": "array",
			//       "uniqueItems": true
			//     }
			//   },
			//   "type": "object"
			// }
			Description: "The filter criteria to control event filtering.",
			Attributes: tfsdk.SingleNestedAttributes(
				map[string]tfsdk.Attribute{
					"filters": {
						// Property: Filters
						Description: "List of filters of this FilterCriteria",
						Attributes: tfsdk.ListNestedAttributes(
							map[string]tfsdk.Attribute{
								"pattern": {
									// Property: Pattern
									Description: "The filter pattern that defines which events should be passed for invocations.",
									Type:        types.StringType,
									Optional:    true,
									Validators: []tfsdk.AttributeValidator{
										validate.StringLenBetween(0, 4096),
										validate.StringMatch(regexp.MustCompile(".*"), ""),
									},
								},
							},
							tfsdk.ListNestedAttributesOptions{},
						),
						Optional: true,
						Validators: []tfsdk.AttributeValidator{
							validate.ArrayLenBetween(1, 20),
							validate.UniqueItems(),
						},
					},
				},
			),
			Optional: true,
		},
		"function_name": {
			// Property: FunctionName
			// CloudFormation resource type schema:
			// {
			//   "description": "The name of the Lambda function.",
			//   "maxLength": 140,
			//   "minLength": 1,
			//   "pattern": "(arn:(aws[a-zA-Z-]*)?:lambda:)?([a-z]{2}(-gov)?-[a-z]+-\\d{1}:)?(\\d{12}:)?(function:)?([a-zA-Z0-9-_]+)(:(\\$LATEST|[a-zA-Z0-9-_]+))?",
			//   "type": "string"
			// }
			Description: "The name of the Lambda function.",
			Type:        types.StringType,
			Required:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.StringLenBetween(1, 140),
				validate.StringMatch(regexp.MustCompile("(arn:(aws[a-zA-Z-]*)?:lambda:)?([a-z]{2}(-gov)?-[a-z]+-\\d{1}:)?(\\d{12}:)?(function:)?([a-zA-Z0-9-_]+)(:(\\$LATEST|[a-zA-Z0-9-_]+))?"), ""),
			},
		},
		"function_response_types": {
			// Property: FunctionResponseTypes
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) A list of response types supported by the function.",
			//   "items": {
			//     "enum": [
			//       "ReportBatchItemFailures"
			//     ],
			//     "type": "string"
			//   },
			//   "maxLength": 1,
			//   "minLength": 0,
			//   "type": "array",
			//   "uniqueItems": true
			// }
			Description: "(Streams) A list of response types supported by the function.",
			Type:        types.ListType{ElemType: types.StringType},
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.UniqueItems(),
				validate.ArrayForEach(validate.StringInSlice([]string{
					"ReportBatchItemFailures",
				})),
			},
		},
		"id": {
			// Property: Id
			// CloudFormation resource type schema:
			// {
			//   "description": "Event Source Mapping Identifier UUID.",
			//   "maxLength": 36,
			//   "minLength": 36,
			//   "pattern": "[a-fA-F0-9]{8}-[a-fA-F0-9]{4}-[a-fA-F0-9]{4}-[a-fA-F0-9]{4}-[a-fA-F0-9]{12}",
			//   "type": "string"
			// }
			Description: "Event Source Mapping Identifier UUID.",
			Type:        types.StringType,
			Computed:    true,
			PlanModifiers: []tfsdk.AttributePlanModifier{
				tfsdk.UseStateForUnknown(),
			},
		},
		"maximum_batching_window_in_seconds": {
			// Property: MaximumBatchingWindowInSeconds
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) The maximum amount of time to gather records before invoking the function, in seconds.",
			//   "maximum": 300,
			//   "minimum": 0,
			//   "type": "integer"
			// }
			Description: "(Streams) The maximum amount of time to gather records before invoking the function, in seconds.",
			Type:        types.Int64Type,
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.IntBetween(0, 300),
			},
		},
		"maximum_record_age_in_seconds": {
			// Property: MaximumRecordAgeInSeconds
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) The maximum age of a record that Lambda sends to a function for processing.",
			//   "maximum": 604800,
			//   "minimum": -1,
			//   "type": "integer"
			// }
			Description: "(Streams) The maximum age of a record that Lambda sends to a function for processing.",
			Type:        types.Int64Type,
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.IntBetween(-1, 604800),
			},
		},
		"maximum_retry_attempts": {
			// Property: MaximumRetryAttempts
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) The maximum number of times to retry when the function returns an error.",
			//   "maximum": 10000,
			//   "minimum": -1,
			//   "type": "integer"
			// }
			Description: "(Streams) The maximum number of times to retry when the function returns an error.",
			Type:        types.Int64Type,
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.IntBetween(-1, 10000),
			},
		},
		"parallelization_factor": {
			// Property: ParallelizationFactor
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) The number of batches to process from each shard concurrently.",
			//   "maximum": 10,
			//   "minimum": 1,
			//   "type": "integer"
			// }
			Description: "(Streams) The number of batches to process from each shard concurrently.",
			Type:        types.Int64Type,
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.IntBetween(1, 10),
			},
		},
		"queues": {
			// Property: Queues
			// CloudFormation resource type schema:
			// {
			//   "description": "(ActiveMQ) A list of ActiveMQ queues.",
			//   "items": {
			//     "maxLength": 1000,
			//     "minLength": 1,
			//     "pattern": "[\\s\\S]*",
			//     "type": "string"
			//   },
			//   "maxItems": 1,
			//   "minItems": 1,
			//   "type": "array",
			//   "uniqueItems": true
			// }
			Description: "(ActiveMQ) A list of ActiveMQ queues.",
			Type:        types.ListType{ElemType: types.StringType},
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.ArrayLenBetween(1, 1),
				validate.UniqueItems(),
				validate.ArrayForEach(validate.StringLenBetween(1, 1000)),
				validate.ArrayForEach(validate.StringMatch(regexp.MustCompile("[\\s\\S]*"), "")),
			},
		},
		"self_managed_event_source": {
			// Property: SelfManagedEventSource
			// CloudFormation resource type schema:
			// {
			//   "additionalProperties": false,
			//   "description": "Self-managed event source endpoints.",
			//   "properties": {
			//     "Endpoints": {
			//       "additionalProperties": false,
			//       "description": "The endpoints for a self-managed event source.",
			//       "properties": {
			//         "KafkaBootstrapServers": {
			//           "description": "A list of Kafka server endpoints.",
			//           "items": {
			//             "description": "The URL of a Kafka server.",
			//             "maxLength": 300,
			//             "minLength": 1,
			//             "pattern": "^(([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\\-]*[a-zA-Z0-9])\\.)*([A-Za-z0-9]|[A-Za-z0-9][A-Za-z0-9\\-]*[A-Za-z0-9]):[0-9]{1,5}",
			//             "type": "string"
			//           },
			//           "maxItems": 10,
			//           "minItems": 1,
			//           "type": "array",
			//           "uniqueItems": true
			//         }
			//       },
			//       "type": "object"
			//     }
			//   },
			//   "type": "object"
			// }
			Description: "Self-managed event source endpoints.",
			Attributes: tfsdk.SingleNestedAttributes(
				map[string]tfsdk.Attribute{
					"endpoints": {
						// Property: Endpoints
						Description: "The endpoints for a self-managed event source.",
						Attributes: tfsdk.SingleNestedAttributes(
							map[string]tfsdk.Attribute{
								"kafka_bootstrap_servers": {
									// Property: KafkaBootstrapServers
									Description: "A list of Kafka server endpoints.",
									Type:        types.ListType{ElemType: types.StringType},
									Optional:    true,
									Validators: []tfsdk.AttributeValidator{
										validate.ArrayLenBetween(1, 10),
										validate.UniqueItems(),
										validate.ArrayForEach(validate.StringLenBetween(1, 300)),
										validate.ArrayForEach(validate.StringMatch(regexp.MustCompile("^(([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\\-]*[a-zA-Z0-9])\\.)*([A-Za-z0-9]|[A-Za-z0-9][A-Za-z0-9\\-]*[A-Za-z0-9]):[0-9]{1,5}"), "")),
									},
								},
							},
						),
						Optional: true,
					},
				},
			),
			Optional: true,
			Computed: true,
			PlanModifiers: []tfsdk.AttributePlanModifier{
				tfsdk.UseStateForUnknown(),
				tfsdk.RequiresReplace(),
			},
		},
		"source_access_configurations": {
			// Property: SourceAccessConfigurations
			// CloudFormation resource type schema:
			// {
			//   "description": "A list of SourceAccessConfiguration.",
			//   "items": {
			//     "additionalProperties": false,
			//     "description": "The configuration used by AWS Lambda to access event source",
			//     "properties": {
			//       "Type": {
			//         "description": "The type of source access configuration.",
			//         "enum": [
			//           "BASIC_AUTH",
			//           "VPC_SUBNET",
			//           "VPC_SECURITY_GROUP",
			//           "SASL_SCRAM_512_AUTH",
			//           "SASL_SCRAM_256_AUTH",
			//           "VIRTUAL_HOST",
			//           "CLIENT_CERTIFICATE_TLS_AUTH",
			//           "SERVER_ROOT_CA_CERTIFICATE"
			//         ],
			//         "type": "string"
			//       },
			//       "URI": {
			//         "description": "The URI for the source access configuration resource.",
			//         "maxLength": 200,
			//         "minLength": 1,
			//         "pattern": "[a-zA-Z0-9-\\/*:_+=.@-]*",
			//         "type": "string"
			//       }
			//     },
			//     "type": "object"
			//   },
			//   "maxItems": 22,
			//   "minItems": 1,
			//   "type": "array",
			//   "uniqueItems": true
			// }
			Description: "A list of SourceAccessConfiguration.",
			Attributes: tfsdk.ListNestedAttributes(
				map[string]tfsdk.Attribute{
					"type": {
						// Property: Type
						Description: "The type of source access configuration.",
						Type:        types.StringType,
						Optional:    true,
						Validators: []tfsdk.AttributeValidator{
							validate.StringInSlice([]string{
								"BASIC_AUTH",
								"VPC_SUBNET",
								"VPC_SECURITY_GROUP",
								"SASL_SCRAM_512_AUTH",
								"SASL_SCRAM_256_AUTH",
								"VIRTUAL_HOST",
								"CLIENT_CERTIFICATE_TLS_AUTH",
								"SERVER_ROOT_CA_CERTIFICATE",
							}),
						},
					},
					"uri": {
						// Property: URI
						Description: "The URI for the source access configuration resource.",
						Type:        types.StringType,
						Optional:    true,
						Validators: []tfsdk.AttributeValidator{
							validate.StringLenBetween(1, 200),
							validate.StringMatch(regexp.MustCompile("[a-zA-Z0-9-\\/*:_+=.@-]*"), ""),
						},
					},
				},
				tfsdk.ListNestedAttributesOptions{},
			),
			Optional: true,
			Validators: []tfsdk.AttributeValidator{
				validate.ArrayLenBetween(1, 22),
				validate.UniqueItems(),
			},
		},
		"starting_position": {
			// Property: StartingPosition
			// CloudFormation resource type schema:
			// {
			//   "description": "The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.",
			//   "maxLength": 12,
			//   "minLength": 6,
			//   "pattern": "(LATEST|TRIM_HORIZON|AT_TIMESTAMP)+",
			//   "type": "string"
			// }
			Description: "The position in a stream from which to start reading. Required for Amazon Kinesis and Amazon DynamoDB Streams sources.",
			Type:        types.StringType,
			Optional:    true,
			Computed:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.StringLenBetween(6, 12),
				validate.StringMatch(regexp.MustCompile("(LATEST|TRIM_HORIZON|AT_TIMESTAMP)+"), ""),
			},
			PlanModifiers: []tfsdk.AttributePlanModifier{
				tfsdk.UseStateForUnknown(),
				tfsdk.RequiresReplace(),
			},
		},
		"starting_position_timestamp": {
			// Property: StartingPositionTimestamp
			// CloudFormation resource type schema:
			// {
			//   "description": "With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.",
			//   "type": "number"
			// }
			Description: "With StartingPosition set to AT_TIMESTAMP, the time from which to start reading, in Unix time seconds.",
			Type:        types.Float64Type,
			Optional:    true,
			Computed:    true,
			PlanModifiers: []tfsdk.AttributePlanModifier{
				tfsdk.UseStateForUnknown(),
				tfsdk.RequiresReplace(),
			},
		},
		"topics": {
			// Property: Topics
			// CloudFormation resource type schema:
			// {
			//   "description": "(Kafka) A list of Kafka topics.",
			//   "items": {
			//     "maxLength": 249,
			//     "minLength": 1,
			//     "pattern": "^[^.]([a-zA-Z0-9\\-_.]+)",
			//     "type": "string"
			//   },
			//   "maxItems": 1,
			//   "minItems": 1,
			//   "type": "array",
			//   "uniqueItems": true
			// }
			Description: "(Kafka) A list of Kafka topics.",
			Type:        types.ListType{ElemType: types.StringType},
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.ArrayLenBetween(1, 1),
				validate.UniqueItems(),
				validate.ArrayForEach(validate.StringLenBetween(1, 249)),
				validate.ArrayForEach(validate.StringMatch(regexp.MustCompile("^[^.]([a-zA-Z0-9\\-_.]+)"), "")),
			},
		},
		"tumbling_window_in_seconds": {
			// Property: TumblingWindowInSeconds
			// CloudFormation resource type schema:
			// {
			//   "description": "(Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.",
			//   "maximum": 900,
			//   "minimum": 0,
			//   "type": "integer"
			// }
			Description: "(Streams) Tumbling window (non-overlapping time window) duration to perform aggregations.",
			Type:        types.Int64Type,
			Optional:    true,
			Validators: []tfsdk.AttributeValidator{
				validate.IntBetween(0, 900),
			},
		},
	}

	schema := tfsdk.Schema{
		Description: "Resource Type definition for AWS::Lambda::EventSourceMapping",
		Version:     1,
		Attributes:  attributes,
	}

	var opts ResourceTypeOptions

	opts = opts.WithCloudFormationTypeName("AWS::Lambda::EventSourceMapping").WithTerraformTypeName("awscc_lambda_event_source_mapping")
	opts = opts.WithTerraformSchema(schema)
	opts = opts.WithSyntheticIDAttribute(false)
	opts = opts.WithAttributeNameMap(map[string]string{
		"batch_size":                         "BatchSize",
		"bisect_batch_on_function_error":     "BisectBatchOnFunctionError",
		"destination":                        "Destination",
		"destination_config":                 "DestinationConfig",
		"enabled":                            "Enabled",
		"endpoints":                          "Endpoints",
		"event_source_arn":                   "EventSourceArn",
		"filter_criteria":                    "FilterCriteria",
		"filters":                            "Filters",
		"function_name":                      "FunctionName",
		"function_response_types":            "FunctionResponseTypes",
		"id":                                 "Id",
		"kafka_bootstrap_servers":            "KafkaBootstrapServers",
		"maximum_batching_window_in_seconds": "MaximumBatchingWindowInSeconds",
		"maximum_record_age_in_seconds":      "MaximumRecordAgeInSeconds",
		"maximum_retry_attempts":             "MaximumRetryAttempts",
		"on_failure":                         "OnFailure",
		"parallelization_factor":             "ParallelizationFactor",
		"pattern":                            "Pattern",
		"queues":                             "Queues",
		"self_managed_event_source":          "SelfManagedEventSource",
		"source_access_configurations":       "SourceAccessConfigurations",
		"starting_position":                  "StartingPosition",
		"starting_position_timestamp":        "StartingPositionTimestamp",
		"topics":                             "Topics",
		"tumbling_window_in_seconds":         "TumblingWindowInSeconds",
		"type":                               "Type",
		"uri":                                "URI",
	})

	opts = opts.WithCreateTimeoutInMinutes(0).WithDeleteTimeoutInMinutes(0)

	opts = opts.WithUpdateTimeoutInMinutes(0)

	resourceType, err := NewResourceType(ctx, opts...)

	if err != nil {
		return nil, err
	}

	return resourceType, nil
}