2 lines
156 KiB
JavaScript
2 lines
156 KiB
JavaScript
"use strict";Object.defineProperty(exports,"__esModule",{value:!0}),exports.CfnPipe=void 0;var jsiiDeprecationWarnings=()=>{var tmp=require("../../.warnings.jsii.js");return jsiiDeprecationWarnings=()=>tmp,tmp};const JSII_RTTI_SYMBOL_1=Symbol.for("jsii.rtti");var cdk=()=>{var tmp=require("../../core/lib");return cdk=()=>tmp,tmp},cfn_parse=()=>{var tmp=require("../../core/lib/helpers-internal");return cfn_parse=()=>tmp,tmp},cdk_errors=()=>{var tmp=require("../../core/lib/errors");return cdk_errors=()=>tmp,tmp};class CfnPipe extends cdk().CfnResource{static[JSII_RTTI_SYMBOL_1]={fqn:"aws-cdk-lib.aws_pipes.CfnPipe",version:"2.252.0"};static CFN_RESOURCE_TYPE_NAME="AWS::Pipes::Pipe";static _fromCloudFormation(scope,id,resourceAttributes,options){resourceAttributes=resourceAttributes||{};const resourceProperties=options.parser.parseValue(resourceAttributes.Properties),propsResult=CfnPipePropsFromCloudFormation(resourceProperties);if(cdk().isResolvableObject(propsResult.value))throw new(cdk_errors()).ValidationError(cfn_parse().lit`UnexpectedIResolvable`,"Unexpected IResolvable",scope);const ret=new CfnPipe(scope,id,propsResult.value);for(const[propKey,propVal]of Object.entries(propsResult.extraProperties))ret.addPropertyOverride(propKey,propVal);return options.parser.handleAttributes(ret,resourceAttributes,id),ret}static isCfnPipe(x){return cdk().CfnResource.isCfnResource(x)&&x.cfnResourceType===CfnPipe.CFN_RESOURCE_TYPE_NAME}static arnForPipe(resource){try{jsiiDeprecationWarnings().aws_cdk_lib_interfaces_aws_pipes_IPipeRef(resource)}catch(error){throw process.env.JSII_DEBUG!=="1"&&error.name==="DeprecationError"&&Error.captureStackTrace(error,this.arnForPipe),error}return resource.pipeRef.pipeArn}_description;_desiredState;_enrichment;_enrichmentParameters;_kmsKeyIdentifier;_logConfiguration;_name;_roleArn;_source;_sourceParameters;tags;_tagsRaw;_target;_targetParameters;cfnPropertyNames={description:"Description",desiredState:"DesiredState",enrichment:"Enrichment",enrichmentParameters:"EnrichmentParameters",kmsKeyIdentifier:"KmsKeyIdentifier",logConfiguration:"LogConfiguration",name:"Name",roleArn:"RoleArn",source:"Source",sourceParameters:"SourceParameters",tags:"Tags",target:"Target",targetParameters:"TargetParameters"};constructor(scope,id,props){super(scope,id,{type:CfnPipe.CFN_RESOURCE_TYPE_NAME,properties:props});try{jsiiDeprecationWarnings().aws_cdk_lib_aws_pipes_CfnPipeProps(props)}catch(error){throw process.env.JSII_DEBUG!=="1"&&error.name==="DeprecationError"&&Error.captureStackTrace(error,CfnPipe),error}cdk().requireProperty(props,"roleArn",this),cdk().requireProperty(props,"source",this),cdk().requireProperty(props,"target",this),this._description=props.description,this._desiredState=props.desiredState,this._enrichment=cdk().getRefProperty(props.enrichment?.functionRef,"functionArn")??cdk().ensureStringOrUndefined(props.enrichment,"enrichment","lambda.IFunctionRef | string"),this._enrichmentParameters=props.enrichmentParameters,this._kmsKeyIdentifier=props.kmsKeyIdentifier,this._logConfiguration=props.logConfiguration,this._name=props.name,this._roleArn=cdk().getRefProperty(props.roleArn?.roleRef,"roleArn")??cdk().ensureStringOrUndefined(props.roleArn,"roleArn","iam.IRoleRef | string"),this._source=cdk().getRefProperty(props.source?.queueRef,"queueArn")??cdk().getRefProperty(props.source?.streamRef,"streamArn")??cdk().ensureStringOrUndefined(props.source,"source","sqs.IQueueRef | kinesis.IStreamRef | string"),this._sourceParameters=props.sourceParameters,this.tags=new(cdk()).TagManager(cdk().TagType.MAP,"AWS::Pipes::Pipe",props.tags,{tagPropertyName:"tags"}),this._tagsRaw=props.tags,this._target=cdk().getRefProperty(props.target?.logGroupRef,"logGroupArn")??cdk().getRefProperty(props.target?.functionRef,"functionArn")??cdk().getRefProperty(props.target?.stateMachineRef,"stateMachineArn")??cdk().getRefProperty(props.target?.eventBusRef,"eventBusArn")??cdk().getRefProperty(props.target?.queueRef,"queueArn")??cdk().getRefProperty(props.target?.topicRef,"topicArn")??cdk().ensureStringOrUndefined(props.target,"target","logs.ILogGroupRef | lambda.IFunctionRef | stepfunctions.IStateMachineRef | events.IEventBusRef | sqs.IQueueRef | sns.ITopicRef | string"),this._targetParameters=props.targetParameters}get pipeRef(){return{pipeName:this.ref,pipeArn:this.attrArn}}get description(){return this._description}set description(value){cdk().traceProperty(this.node,"Description"),this._description=value}get desiredState(){return this._desiredState}set desiredState(value){cdk().traceProperty(this.node,"DesiredState"),this._desiredState=value}get enrichment(){return this._enrichment}set enrichment(value){cdk().traceProperty(this.node,"Enrichment"),this._enrichment=value}get enrichmentParameters(){return this._enrichmentParameters}set enrichmentParameters(value){cdk().traceProperty(this.node,"EnrichmentParameters"),this._enrichmentParameters=value}get kmsKeyIdentifier(){return this._kmsKeyIdentifier}set kmsKeyIdentifier(value){cdk().traceProperty(this.node,"KmsKeyIdentifier"),this._kmsKeyIdentifier=value}get logConfiguration(){return this._logConfiguration}set logConfiguration(value){cdk().traceProperty(this.node,"LogConfiguration"),this._logConfiguration=value}get name(){return this._name}set name(value){cdk().traceProperty(this.node,"Name"),this._name=value}get roleArn(){return this._roleArn}set roleArn(value){cdk().traceProperty(this.node,"RoleArn"),this._roleArn=value}get source(){return this._source}set source(value){cdk().traceProperty(this.node,"Source"),this._source=value}get sourceParameters(){return this._sourceParameters}set sourceParameters(value){cdk().traceProperty(this.node,"SourceParameters"),this._sourceParameters=value}get tagsRaw(){return this._tagsRaw}set tagsRaw(value){cdk().traceProperty(this.node,"Tags"),this._tagsRaw=value}get target(){return this._target}set target(value){cdk().traceProperty(this.node,"Target"),this._target=value}get targetParameters(){return this._targetParameters}set targetParameters(value){cdk().traceProperty(this.node,"TargetParameters"),this._targetParameters=value}get attrArn(){return cdk().Token.asString(this.getAtt("Arn",cdk().ResolutionTypeHint.STRING))}get attrCreationTime(){return cdk().Token.asString(this.getAtt("CreationTime",cdk().ResolutionTypeHint.STRING))}get attrCurrentState(){return cdk().Token.asString(this.getAtt("CurrentState",cdk().ResolutionTypeHint.STRING))}get attrLastModifiedTime(){return cdk().Token.asString(this.getAtt("LastModifiedTime",cdk().ResolutionTypeHint.STRING))}get attrStateReason(){return cdk().Token.asString(this.getAtt("StateReason",cdk().ResolutionTypeHint.STRING))}get cfnProperties(){return{description:this._description,desiredState:this._desiredState,enrichment:this._enrichment,enrichmentParameters:this._enrichmentParameters,kmsKeyIdentifier:this._kmsKeyIdentifier,logConfiguration:this._logConfiguration,name:this._name,roleArn:this._roleArn,source:this._source,sourceParameters:this._sourceParameters,tags:this.tags.renderTags(),target:this._target,targetParameters:this._targetParameters}}inspect(inspector){try{jsiiDeprecationWarnings().aws_cdk_lib_TreeInspector(inspector)}catch(error){throw process.env.JSII_DEBUG!=="1"&&error.name==="DeprecationError"&&Error.captureStackTrace(error,this.inspect),error}inspector.addAttribute("aws:cdk:cloudformation:type",CfnPipe.CFN_RESOURCE_TYPE_NAME),inspector.addAttribute("aws:cdk:cloudformation:logicalId",this._synthesizeLogicalId()),inspector.addAttribute("aws:cdk:cloudformation:props",this.cfnProperties)}renderProperties(props){return convertCfnPipePropsToCloudFormation(props)}}exports.CfnPipe=CfnPipe;function CfnPipePipeTargetStateMachineParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("invocationType",cdk().validateString)(properties.invocationType)),errors.wrap('supplied properties not correct for "PipeTargetStateMachineParametersProperty"')}function convertCfnPipePipeTargetStateMachineParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetStateMachineParametersPropertyValidator(properties).assertSuccess(),{InvocationType:cdk().stringToCloudFormation(properties.invocationType)}):properties}function CfnPipePipeTargetStateMachineParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("invocationType","InvocationType",properties.InvocationType!=null?cfn_parse().FromCloudFormation.getString(properties.InvocationType):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetHttpParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("headerParameters",cdk().hashValidator(cdk().validateString))(properties.headerParameters)),errors.collect(cdk().propertyValidator("pathParameterValues",cdk().listValidator(cdk().validateString))(properties.pathParameterValues)),errors.collect(cdk().propertyValidator("queryStringParameters",cdk().hashValidator(cdk().validateString))(properties.queryStringParameters)),errors.wrap('supplied properties not correct for "PipeTargetHttpParametersProperty"')}function convertCfnPipePipeTargetHttpParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetHttpParametersPropertyValidator(properties).assertSuccess(),{HeaderParameters:cdk().hashMapper(cdk().stringToCloudFormation)(properties.headerParameters),PathParameterValues:cdk().listMapper(cdk().stringToCloudFormation)(properties.pathParameterValues),QueryStringParameters:cdk().hashMapper(cdk().stringToCloudFormation)(properties.queryStringParameters)}):properties}function CfnPipePipeTargetHttpParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("headerParameters","HeaderParameters",properties.HeaderParameters!=null?cfn_parse().FromCloudFormation.getMap(cfn_parse().FromCloudFormation.getString)(properties.HeaderParameters):void 0),ret.addPropertyResult("pathParameterValues","PathParameterValues",properties.PathParameterValues!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.PathParameterValues):void 0),ret.addPropertyResult("queryStringParameters","QueryStringParameters",properties.QueryStringParameters!=null?cfn_parse().FromCloudFormation.getMap(cfn_parse().FromCloudFormation.getString)(properties.QueryStringParameters):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetSqsQueueParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("messageDeduplicationId",cdk().validateString)(properties.messageDeduplicationId)),errors.collect(cdk().propertyValidator("messageGroupId",cdk().validateString)(properties.messageGroupId)),errors.wrap('supplied properties not correct for "PipeTargetSqsQueueParametersProperty"')}function convertCfnPipePipeTargetSqsQueueParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetSqsQueueParametersPropertyValidator(properties).assertSuccess(),{MessageDeduplicationId:cdk().stringToCloudFormation(properties.messageDeduplicationId),MessageGroupId:cdk().stringToCloudFormation(properties.messageGroupId)}):properties}function CfnPipePipeTargetSqsQueueParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("messageDeduplicationId","MessageDeduplicationId",properties.MessageDeduplicationId!=null?cfn_parse().FromCloudFormation.getString(properties.MessageDeduplicationId):void 0),ret.addPropertyResult("messageGroupId","MessageGroupId",properties.MessageGroupId!=null?cfn_parse().FromCloudFormation.getString(properties.MessageGroupId):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetCloudWatchLogsParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("logStreamName",cdk().validateString)(properties.logStreamName)),errors.collect(cdk().propertyValidator("timestamp",cdk().validateString)(properties.timestamp)),errors.wrap('supplied properties not correct for "PipeTargetCloudWatchLogsParametersProperty"')}function convertCfnPipePipeTargetCloudWatchLogsParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetCloudWatchLogsParametersPropertyValidator(properties).assertSuccess(),{LogStreamName:cdk().stringToCloudFormation(properties.logStreamName),Timestamp:cdk().stringToCloudFormation(properties.timestamp)}):properties}function CfnPipePipeTargetCloudWatchLogsParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("logStreamName","LogStreamName",properties.LogStreamName!=null?cfn_parse().FromCloudFormation.getString(properties.LogStreamName):void 0),ret.addPropertyResult("timestamp","Timestamp",properties.Timestamp!=null?cfn_parse().FromCloudFormation.getString(properties.Timestamp):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetKinesisStreamParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("partitionKey",cdk().requiredValidator)(properties.partitionKey)),errors.collect(cdk().propertyValidator("partitionKey",cdk().validateString)(properties.partitionKey)),errors.wrap('supplied properties not correct for "PipeTargetKinesisStreamParametersProperty"')}function convertCfnPipePipeTargetKinesisStreamParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetKinesisStreamParametersPropertyValidator(properties).assertSuccess(),{PartitionKey:cdk().stringToCloudFormation(properties.partitionKey)}):properties}function CfnPipePipeTargetKinesisStreamParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("partitionKey","PartitionKey",properties.PartitionKey!=null?cfn_parse().FromCloudFormation.getString(properties.PartitionKey):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeSageMakerPipelineParameterPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("name",cdk().requiredValidator)(properties.name)),errors.collect(cdk().propertyValidator("name",cdk().validateString)(properties.name)),errors.collect(cdk().propertyValidator("value",cdk().requiredValidator)(properties.value)),errors.collect(cdk().propertyValidator("value",cdk().validateString)(properties.value)),errors.wrap('supplied properties not correct for "SageMakerPipelineParameterProperty"')}function convertCfnPipeSageMakerPipelineParameterPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeSageMakerPipelineParameterPropertyValidator(properties).assertSuccess(),{Name:cdk().stringToCloudFormation(properties.name),Value:cdk().stringToCloudFormation(properties.value)}):properties}function CfnPipeSageMakerPipelineParameterPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("name","Name",properties.Name!=null?cfn_parse().FromCloudFormation.getString(properties.Name):void 0),ret.addPropertyResult("value","Value",properties.Value!=null?cfn_parse().FromCloudFormation.getString(properties.Value):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetSageMakerPipelineParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("pipelineParameterList",cdk().listValidator(CfnPipeSageMakerPipelineParameterPropertyValidator))(properties.pipelineParameterList)),errors.wrap('supplied properties not correct for "PipeTargetSageMakerPipelineParametersProperty"')}function convertCfnPipePipeTargetSageMakerPipelineParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetSageMakerPipelineParametersPropertyValidator(properties).assertSuccess(),{PipelineParameterList:cdk().listMapper(convertCfnPipeSageMakerPipelineParameterPropertyToCloudFormation)(properties.pipelineParameterList)}):properties}function CfnPipePipeTargetSageMakerPipelineParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("pipelineParameterList","PipelineParameterList",properties.PipelineParameterList!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeSageMakerPipelineParameterPropertyFromCloudFormation)(properties.PipelineParameterList):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetEventBridgeEventBusParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("detailType",cdk().validateString)(properties.detailType)),errors.collect(cdk().propertyValidator("endpointId",cdk().validateString)(properties.endpointId)),errors.collect(cdk().propertyValidator("resources",cdk().listValidator(cdk().validateString))(properties.resources)),errors.collect(cdk().propertyValidator("source",cdk().validateString)(properties.source)),errors.collect(cdk().propertyValidator("time",cdk().validateString)(properties.time)),errors.wrap('supplied properties not correct for "PipeTargetEventBridgeEventBusParametersProperty"')}function convertCfnPipePipeTargetEventBridgeEventBusParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetEventBridgeEventBusParametersPropertyValidator(properties).assertSuccess(),{DetailType:cdk().stringToCloudFormation(properties.detailType),EndpointId:cdk().stringToCloudFormation(properties.endpointId),Resources:cdk().listMapper(cdk().stringToCloudFormation)(properties.resources),Source:cdk().stringToCloudFormation(properties.source),Time:cdk().stringToCloudFormation(properties.time)}):properties}function CfnPipePipeTargetEventBridgeEventBusParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("detailType","DetailType",properties.DetailType!=null?cfn_parse().FromCloudFormation.getString(properties.DetailType):void 0),ret.addPropertyResult("endpointId","EndpointId",properties.EndpointId!=null?cfn_parse().FromCloudFormation.getString(properties.EndpointId):void 0),ret.addPropertyResult("resources","Resources",properties.Resources!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.Resources):void 0),ret.addPropertyResult("source","Source",properties.Source!=null?cfn_parse().FromCloudFormation.getString(properties.Source):void 0),ret.addPropertyResult("time","Time",properties.Time!=null?cfn_parse().FromCloudFormation.getString(properties.Time):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetLambdaFunctionParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("invocationType",cdk().validateString)(properties.invocationType)),errors.wrap('supplied properties not correct for "PipeTargetLambdaFunctionParametersProperty"')}function convertCfnPipePipeTargetLambdaFunctionParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetLambdaFunctionParametersPropertyValidator(properties).assertSuccess(),{InvocationType:cdk().stringToCloudFormation(properties.invocationType)}):properties}function CfnPipePipeTargetLambdaFunctionParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("invocationType","InvocationType",properties.InvocationType!=null?cfn_parse().FromCloudFormation.getString(properties.InvocationType):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePlacementConstraintPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("expression",cdk().validateString)(properties.expression)),errors.collect(cdk().propertyValidator("type",cdk().validateString)(properties.type)),errors.wrap('supplied properties not correct for "PlacementConstraintProperty"')}function convertCfnPipePlacementConstraintPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePlacementConstraintPropertyValidator(properties).assertSuccess(),{Expression:cdk().stringToCloudFormation(properties.expression),Type:cdk().stringToCloudFormation(properties.type)}):properties}function CfnPipePlacementConstraintPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("expression","Expression",properties.Expression!=null?cfn_parse().FromCloudFormation.getString(properties.Expression):void 0),ret.addPropertyResult("type","Type",properties.Type!=null?cfn_parse().FromCloudFormation.getString(properties.Type):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePlacementStrategyPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("field",cdk().validateString)(properties.field)),errors.collect(cdk().propertyValidator("type",cdk().validateString)(properties.type)),errors.wrap('supplied properties not correct for "PlacementStrategyProperty"')}function convertCfnPipePlacementStrategyPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePlacementStrategyPropertyValidator(properties).assertSuccess(),{Field:cdk().stringToCloudFormation(properties.field),Type:cdk().stringToCloudFormation(properties.type)}):properties}function CfnPipePlacementStrategyPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("field","Field",properties.Field!=null?cfn_parse().FromCloudFormation.getString(properties.Field):void 0),ret.addPropertyResult("type","Type",properties.Type!=null?cfn_parse().FromCloudFormation.getString(properties.Type):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeCapacityProviderStrategyItemPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("base",cdk().validateNumber)(properties.base)),errors.collect(cdk().propertyValidator("capacityProvider",cdk().requiredValidator)(properties.capacityProvider)),errors.collect(cdk().propertyValidator("capacityProvider",cdk().validateString)(properties.capacityProvider)),errors.collect(cdk().propertyValidator("weight",cdk().validateNumber)(properties.weight)),errors.wrap('supplied properties not correct for "CapacityProviderStrategyItemProperty"')}function convertCfnPipeCapacityProviderStrategyItemPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeCapacityProviderStrategyItemPropertyValidator(properties).assertSuccess(),{Base:cdk().numberToCloudFormation(properties.base),CapacityProvider:cdk().stringToCloudFormation(properties.capacityProvider),Weight:cdk().numberToCloudFormation(properties.weight)}):properties}function CfnPipeCapacityProviderStrategyItemPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("base","Base",properties.Base!=null?cfn_parse().FromCloudFormation.getNumber(properties.Base):void 0),ret.addPropertyResult("capacityProvider","CapacityProvider",properties.CapacityProvider!=null?cfn_parse().FromCloudFormation.getString(properties.CapacityProvider):void 0),ret.addPropertyResult("weight","Weight",properties.Weight!=null?cfn_parse().FromCloudFormation.getNumber(properties.Weight):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsInferenceAcceleratorOverridePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("deviceName",cdk().validateString)(properties.deviceName)),errors.collect(cdk().propertyValidator("deviceType",cdk().validateString)(properties.deviceType)),errors.wrap('supplied properties not correct for "EcsInferenceAcceleratorOverrideProperty"')}function convertCfnPipeEcsInferenceAcceleratorOverridePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsInferenceAcceleratorOverridePropertyValidator(properties).assertSuccess(),{DeviceName:cdk().stringToCloudFormation(properties.deviceName),DeviceType:cdk().stringToCloudFormation(properties.deviceType)}):properties}function CfnPipeEcsInferenceAcceleratorOverridePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("deviceName","DeviceName",properties.DeviceName!=null?cfn_parse().FromCloudFormation.getString(properties.DeviceName):void 0),ret.addPropertyResult("deviceType","DeviceType",properties.DeviceType!=null?cfn_parse().FromCloudFormation.getString(properties.DeviceType):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsEphemeralStoragePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("sizeInGiB",cdk().requiredValidator)(properties.sizeInGiB)),errors.collect(cdk().propertyValidator("sizeInGiB",cdk().validateNumber)(properties.sizeInGiB)),errors.wrap('supplied properties not correct for "EcsEphemeralStorageProperty"')}function convertCfnPipeEcsEphemeralStoragePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsEphemeralStoragePropertyValidator(properties).assertSuccess(),{SizeInGiB:cdk().numberToCloudFormation(properties.sizeInGiB)}):properties}function CfnPipeEcsEphemeralStoragePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("sizeInGiB","SizeInGiB",properties.SizeInGiB!=null?cfn_parse().FromCloudFormation.getNumber(properties.SizeInGiB):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsEnvironmentVariablePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("name",cdk().validateString)(properties.name)),errors.collect(cdk().propertyValidator("value",cdk().validateString)(properties.value)),errors.wrap('supplied properties not correct for "EcsEnvironmentVariableProperty"')}function convertCfnPipeEcsEnvironmentVariablePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsEnvironmentVariablePropertyValidator(properties).assertSuccess(),{Name:cdk().stringToCloudFormation(properties.name),Value:cdk().stringToCloudFormation(properties.value)}):properties}function CfnPipeEcsEnvironmentVariablePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("name","Name",properties.Name!=null?cfn_parse().FromCloudFormation.getString(properties.Name):void 0),ret.addPropertyResult("value","Value",properties.Value!=null?cfn_parse().FromCloudFormation.getString(properties.Value):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsResourceRequirementPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("type",cdk().requiredValidator)(properties.type)),errors.collect(cdk().propertyValidator("type",cdk().validateString)(properties.type)),errors.collect(cdk().propertyValidator("value",cdk().requiredValidator)(properties.value)),errors.collect(cdk().propertyValidator("value",cdk().validateString)(properties.value)),errors.wrap('supplied properties not correct for "EcsResourceRequirementProperty"')}function convertCfnPipeEcsResourceRequirementPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsResourceRequirementPropertyValidator(properties).assertSuccess(),{Type:cdk().stringToCloudFormation(properties.type),Value:cdk().stringToCloudFormation(properties.value)}):properties}function CfnPipeEcsResourceRequirementPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("type","Type",properties.Type!=null?cfn_parse().FromCloudFormation.getString(properties.Type):void 0),ret.addPropertyResult("value","Value",properties.Value!=null?cfn_parse().FromCloudFormation.getString(properties.Value):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsEnvironmentFilePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("type",cdk().requiredValidator)(properties.type)),errors.collect(cdk().propertyValidator("type",cdk().validateString)(properties.type)),errors.collect(cdk().propertyValidator("value",cdk().requiredValidator)(properties.value)),errors.collect(cdk().propertyValidator("value",cdk().validateString)(properties.value)),errors.wrap('supplied properties not correct for "EcsEnvironmentFileProperty"')}function convertCfnPipeEcsEnvironmentFilePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsEnvironmentFilePropertyValidator(properties).assertSuccess(),{Type:cdk().stringToCloudFormation(properties.type),Value:cdk().stringToCloudFormation(properties.value)}):properties}function CfnPipeEcsEnvironmentFilePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("type","Type",properties.Type!=null?cfn_parse().FromCloudFormation.getString(properties.Type):void 0),ret.addPropertyResult("value","Value",properties.Value!=null?cfn_parse().FromCloudFormation.getString(properties.Value):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsContainerOverridePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("command",cdk().listValidator(cdk().validateString))(properties.command)),errors.collect(cdk().propertyValidator("cpu",cdk().validateNumber)(properties.cpu)),errors.collect(cdk().propertyValidator("environment",cdk().listValidator(CfnPipeEcsEnvironmentVariablePropertyValidator))(properties.environment)),errors.collect(cdk().propertyValidator("environmentFiles",cdk().listValidator(CfnPipeEcsEnvironmentFilePropertyValidator))(properties.environmentFiles)),errors.collect(cdk().propertyValidator("memory",cdk().validateNumber)(properties.memory)),errors.collect(cdk().propertyValidator("memoryReservation",cdk().validateNumber)(properties.memoryReservation)),errors.collect(cdk().propertyValidator("name",cdk().validateString)(properties.name)),errors.collect(cdk().propertyValidator("resourceRequirements",cdk().listValidator(CfnPipeEcsResourceRequirementPropertyValidator))(properties.resourceRequirements)),errors.wrap('supplied properties not correct for "EcsContainerOverrideProperty"')}function convertCfnPipeEcsContainerOverridePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsContainerOverridePropertyValidator(properties).assertSuccess(),{Command:cdk().listMapper(cdk().stringToCloudFormation)(properties.command),Cpu:cdk().numberToCloudFormation(properties.cpu),Environment:cdk().listMapper(convertCfnPipeEcsEnvironmentVariablePropertyToCloudFormation)(properties.environment),EnvironmentFiles:cdk().listMapper(convertCfnPipeEcsEnvironmentFilePropertyToCloudFormation)(properties.environmentFiles),Memory:cdk().numberToCloudFormation(properties.memory),MemoryReservation:cdk().numberToCloudFormation(properties.memoryReservation),Name:cdk().stringToCloudFormation(properties.name),ResourceRequirements:cdk().listMapper(convertCfnPipeEcsResourceRequirementPropertyToCloudFormation)(properties.resourceRequirements)}):properties}function CfnPipeEcsContainerOverridePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("command","Command",properties.Command!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.Command):void 0),ret.addPropertyResult("cpu","Cpu",properties.Cpu!=null?cfn_parse().FromCloudFormation.getNumber(properties.Cpu):void 0),ret.addPropertyResult("environment","Environment",properties.Environment!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeEcsEnvironmentVariablePropertyFromCloudFormation)(properties.Environment):void 0),ret.addPropertyResult("environmentFiles","EnvironmentFiles",properties.EnvironmentFiles!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeEcsEnvironmentFilePropertyFromCloudFormation)(properties.EnvironmentFiles):void 0),ret.addPropertyResult("memory","Memory",properties.Memory!=null?cfn_parse().FromCloudFormation.getNumber(properties.Memory):void 0),ret.addPropertyResult("memoryReservation","MemoryReservation",properties.MemoryReservation!=null?cfn_parse().FromCloudFormation.getNumber(properties.MemoryReservation):void 0),ret.addPropertyResult("name","Name",properties.Name!=null?cfn_parse().FromCloudFormation.getString(properties.Name):void 0),ret.addPropertyResult("resourceRequirements","ResourceRequirements",properties.ResourceRequirements!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeEcsResourceRequirementPropertyFromCloudFormation)(properties.ResourceRequirements):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeEcsTaskOverridePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("containerOverrides",cdk().listValidator(CfnPipeEcsContainerOverridePropertyValidator))(properties.containerOverrides)),errors.collect(cdk().propertyValidator("cpu",cdk().validateString)(properties.cpu)),errors.collect(cdk().propertyValidator("ephemeralStorage",CfnPipeEcsEphemeralStoragePropertyValidator)(properties.ephemeralStorage)),errors.collect(cdk().propertyValidator("executionRoleArn",cdk().validateString)(properties.executionRoleArn)),errors.collect(cdk().propertyValidator("inferenceAcceleratorOverrides",cdk().listValidator(CfnPipeEcsInferenceAcceleratorOverridePropertyValidator))(properties.inferenceAcceleratorOverrides)),errors.collect(cdk().propertyValidator("memory",cdk().validateString)(properties.memory)),errors.collect(cdk().propertyValidator("taskRoleArn",cdk().validateString)(properties.taskRoleArn)),errors.wrap('supplied properties not correct for "EcsTaskOverrideProperty"')}function convertCfnPipeEcsTaskOverridePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeEcsTaskOverridePropertyValidator(properties).assertSuccess(),{ContainerOverrides:cdk().listMapper(convertCfnPipeEcsContainerOverridePropertyToCloudFormation)(properties.containerOverrides),Cpu:cdk().stringToCloudFormation(properties.cpu),EphemeralStorage:convertCfnPipeEcsEphemeralStoragePropertyToCloudFormation(properties.ephemeralStorage),ExecutionRoleArn:cdk().stringToCloudFormation(properties.executionRoleArn),InferenceAcceleratorOverrides:cdk().listMapper(convertCfnPipeEcsInferenceAcceleratorOverridePropertyToCloudFormation)(properties.inferenceAcceleratorOverrides),Memory:cdk().stringToCloudFormation(properties.memory),TaskRoleArn:cdk().stringToCloudFormation(properties.taskRoleArn)}):properties}function CfnPipeEcsTaskOverridePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("containerOverrides","ContainerOverrides",properties.ContainerOverrides!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeEcsContainerOverridePropertyFromCloudFormation)(properties.ContainerOverrides):void 0),ret.addPropertyResult("cpu","Cpu",properties.Cpu!=null?cfn_parse().FromCloudFormation.getString(properties.Cpu):void 0),ret.addPropertyResult("ephemeralStorage","EphemeralStorage",properties.EphemeralStorage!=null?CfnPipeEcsEphemeralStoragePropertyFromCloudFormation(properties.EphemeralStorage):void 0),ret.addPropertyResult("executionRoleArn","ExecutionRoleArn",properties.ExecutionRoleArn!=null?cfn_parse().FromCloudFormation.getString(properties.ExecutionRoleArn):void 0),ret.addPropertyResult("inferenceAcceleratorOverrides","InferenceAcceleratorOverrides",properties.InferenceAcceleratorOverrides!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeEcsInferenceAcceleratorOverridePropertyFromCloudFormation)(properties.InferenceAcceleratorOverrides):void 0),ret.addPropertyResult("memory","Memory",properties.Memory!=null?cfn_parse().FromCloudFormation.getString(properties.Memory):void 0),ret.addPropertyResult("taskRoleArn","TaskRoleArn",properties.TaskRoleArn!=null?cfn_parse().FromCloudFormation.getString(properties.TaskRoleArn):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeAwsVpcConfigurationPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("assignPublicIp",cdk().validateString)(properties.assignPublicIp)),errors.collect(cdk().propertyValidator("securityGroups",cdk().listValidator(cdk().validateString))(properties.securityGroups)),errors.collect(cdk().propertyValidator("subnets",cdk().requiredValidator)(properties.subnets)),errors.collect(cdk().propertyValidator("subnets",cdk().listValidator(cdk().validateString))(properties.subnets)),errors.wrap('supplied properties not correct for "AwsVpcConfigurationProperty"')}function convertCfnPipeAwsVpcConfigurationPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeAwsVpcConfigurationPropertyValidator(properties).assertSuccess(),{AssignPublicIp:cdk().stringToCloudFormation(properties.assignPublicIp),SecurityGroups:cdk().listMapper(cdk().stringToCloudFormation)(properties.securityGroups),Subnets:cdk().listMapper(cdk().stringToCloudFormation)(properties.subnets)}):properties}function CfnPipeAwsVpcConfigurationPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("assignPublicIp","AssignPublicIp",properties.AssignPublicIp!=null?cfn_parse().FromCloudFormation.getString(properties.AssignPublicIp):void 0),ret.addPropertyResult("securityGroups","SecurityGroups",properties.SecurityGroups!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.SecurityGroups):void 0),ret.addPropertyResult("subnets","Subnets",properties.Subnets!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.Subnets):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeNetworkConfigurationPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("awsvpcConfiguration",CfnPipeAwsVpcConfigurationPropertyValidator)(properties.awsvpcConfiguration)),errors.wrap('supplied properties not correct for "NetworkConfigurationProperty"')}function convertCfnPipeNetworkConfigurationPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeNetworkConfigurationPropertyValidator(properties).assertSuccess(),{AwsvpcConfiguration:convertCfnPipeAwsVpcConfigurationPropertyToCloudFormation(properties.awsvpcConfiguration)}):properties}function CfnPipeNetworkConfigurationPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("awsvpcConfiguration","AwsvpcConfiguration",properties.AwsvpcConfiguration!=null?CfnPipeAwsVpcConfigurationPropertyFromCloudFormation(properties.AwsvpcConfiguration):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetEcsTaskParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("capacityProviderStrategy",cdk().listValidator(CfnPipeCapacityProviderStrategyItemPropertyValidator))(properties.capacityProviderStrategy)),errors.collect(cdk().propertyValidator("enableEcsManagedTags",cdk().validateBoolean)(properties.enableEcsManagedTags)),errors.collect(cdk().propertyValidator("enableExecuteCommand",cdk().validateBoolean)(properties.enableExecuteCommand)),errors.collect(cdk().propertyValidator("group",cdk().validateString)(properties.group)),errors.collect(cdk().propertyValidator("launchType",cdk().validateString)(properties.launchType)),errors.collect(cdk().propertyValidator("networkConfiguration",CfnPipeNetworkConfigurationPropertyValidator)(properties.networkConfiguration)),errors.collect(cdk().propertyValidator("overrides",CfnPipeEcsTaskOverridePropertyValidator)(properties.overrides)),errors.collect(cdk().propertyValidator("placementConstraints",cdk().listValidator(CfnPipePlacementConstraintPropertyValidator))(properties.placementConstraints)),errors.collect(cdk().propertyValidator("placementStrategy",cdk().listValidator(CfnPipePlacementStrategyPropertyValidator))(properties.placementStrategy)),errors.collect(cdk().propertyValidator("platformVersion",cdk().validateString)(properties.platformVersion)),errors.collect(cdk().propertyValidator("propagateTags",cdk().validateString)(properties.propagateTags)),errors.collect(cdk().propertyValidator("referenceId",cdk().validateString)(properties.referenceId)),errors.collect(cdk().propertyValidator("tags",cdk().listValidator(cdk().validateCfnTag))(properties.tags)),errors.collect(cdk().propertyValidator("taskCount",cdk().validateNumber)(properties.taskCount)),errors.collect(cdk().propertyValidator("taskDefinitionArn",cdk().requiredValidator)(properties.taskDefinitionArn)),errors.collect(cdk().propertyValidator("taskDefinitionArn",cdk().validateString)(properties.taskDefinitionArn)),errors.wrap('supplied properties not correct for "PipeTargetEcsTaskParametersProperty"')}function convertCfnPipePipeTargetEcsTaskParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetEcsTaskParametersPropertyValidator(properties).assertSuccess(),{CapacityProviderStrategy:cdk().listMapper(convertCfnPipeCapacityProviderStrategyItemPropertyToCloudFormation)(properties.capacityProviderStrategy),EnableECSManagedTags:cdk().booleanToCloudFormation(properties.enableEcsManagedTags),EnableExecuteCommand:cdk().booleanToCloudFormation(properties.enableExecuteCommand),Group:cdk().stringToCloudFormation(properties.group),LaunchType:cdk().stringToCloudFormation(properties.launchType),NetworkConfiguration:convertCfnPipeNetworkConfigurationPropertyToCloudFormation(properties.networkConfiguration),Overrides:convertCfnPipeEcsTaskOverridePropertyToCloudFormation(properties.overrides),PlacementConstraints:cdk().listMapper(convertCfnPipePlacementConstraintPropertyToCloudFormation)(properties.placementConstraints),PlacementStrategy:cdk().listMapper(convertCfnPipePlacementStrategyPropertyToCloudFormation)(properties.placementStrategy),PlatformVersion:cdk().stringToCloudFormation(properties.platformVersion),PropagateTags:cdk().stringToCloudFormation(properties.propagateTags),ReferenceId:cdk().stringToCloudFormation(properties.referenceId),Tags:cdk().listMapper(cdk().cfnTagToCloudFormation)(properties.tags),TaskCount:cdk().numberToCloudFormation(properties.taskCount),TaskDefinitionArn:cdk().stringToCloudFormation(properties.taskDefinitionArn)}):properties}function CfnPipePipeTargetEcsTaskParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("capacityProviderStrategy","CapacityProviderStrategy",properties.CapacityProviderStrategy!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeCapacityProviderStrategyItemPropertyFromCloudFormation)(properties.CapacityProviderStrategy):void 0),ret.addPropertyResult("enableEcsManagedTags","EnableECSManagedTags",properties.EnableECSManagedTags!=null?cfn_parse().FromCloudFormation.getBoolean(properties.EnableECSManagedTags):void 0),ret.addPropertyResult("enableExecuteCommand","EnableExecuteCommand",properties.EnableExecuteCommand!=null?cfn_parse().FromCloudFormation.getBoolean(properties.EnableExecuteCommand):void 0),ret.addPropertyResult("group","Group",properties.Group!=null?cfn_parse().FromCloudFormation.getString(properties.Group):void 0),ret.addPropertyResult("launchType","LaunchType",properties.LaunchType!=null?cfn_parse().FromCloudFormation.getString(properties.LaunchType):void 0),ret.addPropertyResult("networkConfiguration","NetworkConfiguration",properties.NetworkConfiguration!=null?CfnPipeNetworkConfigurationPropertyFromCloudFormation(properties.NetworkConfiguration):void 0),ret.addPropertyResult("overrides","Overrides",properties.Overrides!=null?CfnPipeEcsTaskOverridePropertyFromCloudFormation(properties.Overrides):void 0),ret.addPropertyResult("placementConstraints","PlacementConstraints",properties.PlacementConstraints!=null?cfn_parse().FromCloudFormation.getArray(CfnPipePlacementConstraintPropertyFromCloudFormation)(properties.PlacementConstraints):void 0),ret.addPropertyResult("placementStrategy","PlacementStrategy",properties.PlacementStrategy!=null?cfn_parse().FromCloudFormation.getArray(CfnPipePlacementStrategyPropertyFromCloudFormation)(properties.PlacementStrategy):void 0),ret.addPropertyResult("platformVersion","PlatformVersion",properties.PlatformVersion!=null?cfn_parse().FromCloudFormation.getString(properties.PlatformVersion):void 0),ret.addPropertyResult("propagateTags","PropagateTags",properties.PropagateTags!=null?cfn_parse().FromCloudFormation.getString(properties.PropagateTags):void 0),ret.addPropertyResult("referenceId","ReferenceId",properties.ReferenceId!=null?cfn_parse().FromCloudFormation.getString(properties.ReferenceId):void 0),ret.addPropertyResult("tags","Tags",properties.Tags!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getCfnTag)(properties.Tags):void 0),ret.addPropertyResult("taskCount","TaskCount",properties.TaskCount!=null?cfn_parse().FromCloudFormation.getNumber(properties.TaskCount):void 0),ret.addPropertyResult("taskDefinitionArn","TaskDefinitionArn",properties.TaskDefinitionArn!=null?cfn_parse().FromCloudFormation.getString(properties.TaskDefinitionArn):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeBatchJobDependencyPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("jobId",cdk().validateString)(properties.jobId)),errors.collect(cdk().propertyValidator("type",cdk().validateString)(properties.type)),errors.wrap('supplied properties not correct for "BatchJobDependencyProperty"')}function convertCfnPipeBatchJobDependencyPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeBatchJobDependencyPropertyValidator(properties).assertSuccess(),{JobId:cdk().stringToCloudFormation(properties.jobId),Type:cdk().stringToCloudFormation(properties.type)}):properties}function CfnPipeBatchJobDependencyPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("jobId","JobId",properties.JobId!=null?cfn_parse().FromCloudFormation.getString(properties.JobId):void 0),ret.addPropertyResult("type","Type",properties.Type!=null?cfn_parse().FromCloudFormation.getString(properties.Type):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeBatchArrayPropertiesPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("size",cdk().validateNumber)(properties.size)),errors.wrap('supplied properties not correct for "BatchArrayPropertiesProperty"')}function convertCfnPipeBatchArrayPropertiesPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeBatchArrayPropertiesPropertyValidator(properties).assertSuccess(),{Size:cdk().numberToCloudFormation(properties.size)}):properties}function CfnPipeBatchArrayPropertiesPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("size","Size",properties.Size!=null?cfn_parse().FromCloudFormation.getNumber(properties.Size):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeBatchRetryStrategyPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("attempts",cdk().validateNumber)(properties.attempts)),errors.wrap('supplied properties not correct for "BatchRetryStrategyProperty"')}function convertCfnPipeBatchRetryStrategyPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeBatchRetryStrategyPropertyValidator(properties).assertSuccess(),{Attempts:cdk().numberToCloudFormation(properties.attempts)}):properties}function CfnPipeBatchRetryStrategyPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("attempts","Attempts",properties.Attempts!=null?cfn_parse().FromCloudFormation.getNumber(properties.Attempts):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeBatchEnvironmentVariablePropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("name",cdk().validateString)(properties.name)),errors.collect(cdk().propertyValidator("value",cdk().validateString)(properties.value)),errors.wrap('supplied properties not correct for "BatchEnvironmentVariableProperty"')}function convertCfnPipeBatchEnvironmentVariablePropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeBatchEnvironmentVariablePropertyValidator(properties).assertSuccess(),{Name:cdk().stringToCloudFormation(properties.name),Value:cdk().stringToCloudFormation(properties.value)}):properties}function CfnPipeBatchEnvironmentVariablePropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("name","Name",properties.Name!=null?cfn_parse().FromCloudFormation.getString(properties.Name):void 0),ret.addPropertyResult("value","Value",properties.Value!=null?cfn_parse().FromCloudFormation.getString(properties.Value):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeBatchResourceRequirementPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("type",cdk().requiredValidator)(properties.type)),errors.collect(cdk().propertyValidator("type",cdk().validateString)(properties.type)),errors.collect(cdk().propertyValidator("value",cdk().requiredValidator)(properties.value)),errors.collect(cdk().propertyValidator("value",cdk().validateString)(properties.value)),errors.wrap('supplied properties not correct for "BatchResourceRequirementProperty"')}function convertCfnPipeBatchResourceRequirementPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeBatchResourceRequirementPropertyValidator(properties).assertSuccess(),{Type:cdk().stringToCloudFormation(properties.type),Value:cdk().stringToCloudFormation(properties.value)}):properties}function CfnPipeBatchResourceRequirementPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("type","Type",properties.Type!=null?cfn_parse().FromCloudFormation.getString(properties.Type):void 0),ret.addPropertyResult("value","Value",properties.Value!=null?cfn_parse().FromCloudFormation.getString(properties.Value):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeBatchContainerOverridesPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("command",cdk().listValidator(cdk().validateString))(properties.command)),errors.collect(cdk().propertyValidator("environment",cdk().listValidator(CfnPipeBatchEnvironmentVariablePropertyValidator))(properties.environment)),errors.collect(cdk().propertyValidator("instanceType",cdk().validateString)(properties.instanceType)),errors.collect(cdk().propertyValidator("resourceRequirements",cdk().listValidator(CfnPipeBatchResourceRequirementPropertyValidator))(properties.resourceRequirements)),errors.wrap('supplied properties not correct for "BatchContainerOverridesProperty"')}function convertCfnPipeBatchContainerOverridesPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeBatchContainerOverridesPropertyValidator(properties).assertSuccess(),{Command:cdk().listMapper(cdk().stringToCloudFormation)(properties.command),Environment:cdk().listMapper(convertCfnPipeBatchEnvironmentVariablePropertyToCloudFormation)(properties.environment),InstanceType:cdk().stringToCloudFormation(properties.instanceType),ResourceRequirements:cdk().listMapper(convertCfnPipeBatchResourceRequirementPropertyToCloudFormation)(properties.resourceRequirements)}):properties}function CfnPipeBatchContainerOverridesPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("command","Command",properties.Command!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.Command):void 0),ret.addPropertyResult("environment","Environment",properties.Environment!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeBatchEnvironmentVariablePropertyFromCloudFormation)(properties.Environment):void 0),ret.addPropertyResult("instanceType","InstanceType",properties.InstanceType!=null?cfn_parse().FromCloudFormation.getString(properties.InstanceType):void 0),ret.addPropertyResult("resourceRequirements","ResourceRequirements",properties.ResourceRequirements!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeBatchResourceRequirementPropertyFromCloudFormation)(properties.ResourceRequirements):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetBatchJobParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("arrayProperties",CfnPipeBatchArrayPropertiesPropertyValidator)(properties.arrayProperties)),errors.collect(cdk().propertyValidator("containerOverrides",CfnPipeBatchContainerOverridesPropertyValidator)(properties.containerOverrides)),errors.collect(cdk().propertyValidator("dependsOn",cdk().listValidator(CfnPipeBatchJobDependencyPropertyValidator))(properties.dependsOn)),errors.collect(cdk().propertyValidator("jobDefinition",cdk().requiredValidator)(properties.jobDefinition)),errors.collect(cdk().propertyValidator("jobDefinition",cdk().validateString)(properties.jobDefinition)),errors.collect(cdk().propertyValidator("jobName",cdk().requiredValidator)(properties.jobName)),errors.collect(cdk().propertyValidator("jobName",cdk().validateString)(properties.jobName)),errors.collect(cdk().propertyValidator("parameters",cdk().hashValidator(cdk().validateString))(properties.parameters)),errors.collect(cdk().propertyValidator("retryStrategy",CfnPipeBatchRetryStrategyPropertyValidator)(properties.retryStrategy)),errors.wrap('supplied properties not correct for "PipeTargetBatchJobParametersProperty"')}function convertCfnPipePipeTargetBatchJobParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetBatchJobParametersPropertyValidator(properties).assertSuccess(),{ArrayProperties:convertCfnPipeBatchArrayPropertiesPropertyToCloudFormation(properties.arrayProperties),ContainerOverrides:convertCfnPipeBatchContainerOverridesPropertyToCloudFormation(properties.containerOverrides),DependsOn:cdk().listMapper(convertCfnPipeBatchJobDependencyPropertyToCloudFormation)(properties.dependsOn),JobDefinition:cdk().stringToCloudFormation(properties.jobDefinition),JobName:cdk().stringToCloudFormation(properties.jobName),Parameters:cdk().hashMapper(cdk().stringToCloudFormation)(properties.parameters),RetryStrategy:convertCfnPipeBatchRetryStrategyPropertyToCloudFormation(properties.retryStrategy)}):properties}function CfnPipePipeTargetBatchJobParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("arrayProperties","ArrayProperties",properties.ArrayProperties!=null?CfnPipeBatchArrayPropertiesPropertyFromCloudFormation(properties.ArrayProperties):void 0),ret.addPropertyResult("containerOverrides","ContainerOverrides",properties.ContainerOverrides!=null?CfnPipeBatchContainerOverridesPropertyFromCloudFormation(properties.ContainerOverrides):void 0),ret.addPropertyResult("dependsOn","DependsOn",properties.DependsOn!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeBatchJobDependencyPropertyFromCloudFormation)(properties.DependsOn):void 0),ret.addPropertyResult("jobDefinition","JobDefinition",properties.JobDefinition!=null?cfn_parse().FromCloudFormation.getString(properties.JobDefinition):void 0),ret.addPropertyResult("jobName","JobName",properties.JobName!=null?cfn_parse().FromCloudFormation.getString(properties.JobName):void 0),ret.addPropertyResult("parameters","Parameters",properties.Parameters!=null?cfn_parse().FromCloudFormation.getMap(cfn_parse().FromCloudFormation.getString)(properties.Parameters):void 0),ret.addPropertyResult("retryStrategy","RetryStrategy",properties.RetryStrategy!=null?CfnPipeBatchRetryStrategyPropertyFromCloudFormation(properties.RetryStrategy):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetRedshiftDataParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("database",cdk().requiredValidator)(properties.database)),errors.collect(cdk().propertyValidator("database",cdk().validateString)(properties.database)),errors.collect(cdk().propertyValidator("dbUser",cdk().validateString)(properties.dbUser)),errors.collect(cdk().propertyValidator("secretManagerArn",cdk().validateString)(properties.secretManagerArn)),errors.collect(cdk().propertyValidator("sqls",cdk().requiredValidator)(properties.sqls)),errors.collect(cdk().propertyValidator("sqls",cdk().listValidator(cdk().validateString))(properties.sqls)),errors.collect(cdk().propertyValidator("statementName",cdk().validateString)(properties.statementName)),errors.collect(cdk().propertyValidator("withEvent",cdk().validateBoolean)(properties.withEvent)),errors.wrap('supplied properties not correct for "PipeTargetRedshiftDataParametersProperty"')}function convertCfnPipePipeTargetRedshiftDataParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetRedshiftDataParametersPropertyValidator(properties).assertSuccess(),{Database:cdk().stringToCloudFormation(properties.database),DbUser:cdk().stringToCloudFormation(properties.dbUser),SecretManagerArn:cdk().stringToCloudFormation(properties.secretManagerArn),Sqls:cdk().listMapper(cdk().stringToCloudFormation)(properties.sqls),StatementName:cdk().stringToCloudFormation(properties.statementName),WithEvent:cdk().booleanToCloudFormation(properties.withEvent)}):properties}function CfnPipePipeTargetRedshiftDataParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("database","Database",properties.Database!=null?cfn_parse().FromCloudFormation.getString(properties.Database):void 0),ret.addPropertyResult("dbUser","DbUser",properties.DbUser!=null?cfn_parse().FromCloudFormation.getString(properties.DbUser):void 0),ret.addPropertyResult("secretManagerArn","SecretManagerArn",properties.SecretManagerArn!=null?cfn_parse().FromCloudFormation.getString(properties.SecretManagerArn):void 0),ret.addPropertyResult("sqls","Sqls",properties.Sqls!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.Sqls):void 0),ret.addPropertyResult("statementName","StatementName",properties.StatementName!=null?cfn_parse().FromCloudFormation.getString(properties.StatementName):void 0),ret.addPropertyResult("withEvent","WithEvent",properties.WithEvent!=null?cfn_parse().FromCloudFormation.getBoolean(properties.WithEvent):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeDimensionMappingPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("dimensionName",cdk().requiredValidator)(properties.dimensionName)),errors.collect(cdk().propertyValidator("dimensionName",cdk().validateString)(properties.dimensionName)),errors.collect(cdk().propertyValidator("dimensionValue",cdk().requiredValidator)(properties.dimensionValue)),errors.collect(cdk().propertyValidator("dimensionValue",cdk().validateString)(properties.dimensionValue)),errors.collect(cdk().propertyValidator("dimensionValueType",cdk().requiredValidator)(properties.dimensionValueType)),errors.collect(cdk().propertyValidator("dimensionValueType",cdk().validateString)(properties.dimensionValueType)),errors.wrap('supplied properties not correct for "DimensionMappingProperty"')}function convertCfnPipeDimensionMappingPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeDimensionMappingPropertyValidator(properties).assertSuccess(),{DimensionName:cdk().stringToCloudFormation(properties.dimensionName),DimensionValue:cdk().stringToCloudFormation(properties.dimensionValue),DimensionValueType:cdk().stringToCloudFormation(properties.dimensionValueType)}):properties}function CfnPipeDimensionMappingPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("dimensionName","DimensionName",properties.DimensionName!=null?cfn_parse().FromCloudFormation.getString(properties.DimensionName):void 0),ret.addPropertyResult("dimensionValue","DimensionValue",properties.DimensionValue!=null?cfn_parse().FromCloudFormation.getString(properties.DimensionValue):void 0),ret.addPropertyResult("dimensionValueType","DimensionValueType",properties.DimensionValueType!=null?cfn_parse().FromCloudFormation.getString(properties.DimensionValueType):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeSingleMeasureMappingPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("measureName",cdk().requiredValidator)(properties.measureName)),errors.collect(cdk().propertyValidator("measureName",cdk().validateString)(properties.measureName)),errors.collect(cdk().propertyValidator("measureValue",cdk().requiredValidator)(properties.measureValue)),errors.collect(cdk().propertyValidator("measureValue",cdk().validateString)(properties.measureValue)),errors.collect(cdk().propertyValidator("measureValueType",cdk().requiredValidator)(properties.measureValueType)),errors.collect(cdk().propertyValidator("measureValueType",cdk().validateString)(properties.measureValueType)),errors.wrap('supplied properties not correct for "SingleMeasureMappingProperty"')}function convertCfnPipeSingleMeasureMappingPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeSingleMeasureMappingPropertyValidator(properties).assertSuccess(),{MeasureName:cdk().stringToCloudFormation(properties.measureName),MeasureValue:cdk().stringToCloudFormation(properties.measureValue),MeasureValueType:cdk().stringToCloudFormation(properties.measureValueType)}):properties}function CfnPipeSingleMeasureMappingPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("measureName","MeasureName",properties.MeasureName!=null?cfn_parse().FromCloudFormation.getString(properties.MeasureName):void 0),ret.addPropertyResult("measureValue","MeasureValue",properties.MeasureValue!=null?cfn_parse().FromCloudFormation.getString(properties.MeasureValue):void 0),ret.addPropertyResult("measureValueType","MeasureValueType",properties.MeasureValueType!=null?cfn_parse().FromCloudFormation.getString(properties.MeasureValueType):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeMultiMeasureAttributeMappingPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("measureValue",cdk().requiredValidator)(properties.measureValue)),errors.collect(cdk().propertyValidator("measureValue",cdk().validateString)(properties.measureValue)),errors.collect(cdk().propertyValidator("measureValueType",cdk().requiredValidator)(properties.measureValueType)),errors.collect(cdk().propertyValidator("measureValueType",cdk().validateString)(properties.measureValueType)),errors.collect(cdk().propertyValidator("multiMeasureAttributeName",cdk().requiredValidator)(properties.multiMeasureAttributeName)),errors.collect(cdk().propertyValidator("multiMeasureAttributeName",cdk().validateString)(properties.multiMeasureAttributeName)),errors.wrap('supplied properties not correct for "MultiMeasureAttributeMappingProperty"')}function convertCfnPipeMultiMeasureAttributeMappingPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeMultiMeasureAttributeMappingPropertyValidator(properties).assertSuccess(),{MeasureValue:cdk().stringToCloudFormation(properties.measureValue),MeasureValueType:cdk().stringToCloudFormation(properties.measureValueType),MultiMeasureAttributeName:cdk().stringToCloudFormation(properties.multiMeasureAttributeName)}):properties}function CfnPipeMultiMeasureAttributeMappingPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("measureValue","MeasureValue",properties.MeasureValue!=null?cfn_parse().FromCloudFormation.getString(properties.MeasureValue):void 0),ret.addPropertyResult("measureValueType","MeasureValueType",properties.MeasureValueType!=null?cfn_parse().FromCloudFormation.getString(properties.MeasureValueType):void 0),ret.addPropertyResult("multiMeasureAttributeName","MultiMeasureAttributeName",properties.MultiMeasureAttributeName!=null?cfn_parse().FromCloudFormation.getString(properties.MultiMeasureAttributeName):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeMultiMeasureMappingPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("multiMeasureAttributeMappings",cdk().requiredValidator)(properties.multiMeasureAttributeMappings)),errors.collect(cdk().propertyValidator("multiMeasureAttributeMappings",cdk().listValidator(CfnPipeMultiMeasureAttributeMappingPropertyValidator))(properties.multiMeasureAttributeMappings)),errors.collect(cdk().propertyValidator("multiMeasureName",cdk().requiredValidator)(properties.multiMeasureName)),errors.collect(cdk().propertyValidator("multiMeasureName",cdk().validateString)(properties.multiMeasureName)),errors.wrap('supplied properties not correct for "MultiMeasureMappingProperty"')}function convertCfnPipeMultiMeasureMappingPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeMultiMeasureMappingPropertyValidator(properties).assertSuccess(),{MultiMeasureAttributeMappings:cdk().listMapper(convertCfnPipeMultiMeasureAttributeMappingPropertyToCloudFormation)(properties.multiMeasureAttributeMappings),MultiMeasureName:cdk().stringToCloudFormation(properties.multiMeasureName)}):properties}function CfnPipeMultiMeasureMappingPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("multiMeasureAttributeMappings","MultiMeasureAttributeMappings",properties.MultiMeasureAttributeMappings!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeMultiMeasureAttributeMappingPropertyFromCloudFormation)(properties.MultiMeasureAttributeMappings):void 0),ret.addPropertyResult("multiMeasureName","MultiMeasureName",properties.MultiMeasureName!=null?cfn_parse().FromCloudFormation.getString(properties.MultiMeasureName):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetTimestreamParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("dimensionMappings",cdk().requiredValidator)(properties.dimensionMappings)),errors.collect(cdk().propertyValidator("dimensionMappings",cdk().listValidator(CfnPipeDimensionMappingPropertyValidator))(properties.dimensionMappings)),errors.collect(cdk().propertyValidator("epochTimeUnit",cdk().validateString)(properties.epochTimeUnit)),errors.collect(cdk().propertyValidator("multiMeasureMappings",cdk().listValidator(CfnPipeMultiMeasureMappingPropertyValidator))(properties.multiMeasureMappings)),errors.collect(cdk().propertyValidator("singleMeasureMappings",cdk().listValidator(CfnPipeSingleMeasureMappingPropertyValidator))(properties.singleMeasureMappings)),errors.collect(cdk().propertyValidator("timeFieldType",cdk().validateString)(properties.timeFieldType)),errors.collect(cdk().propertyValidator("timeValue",cdk().requiredValidator)(properties.timeValue)),errors.collect(cdk().propertyValidator("timeValue",cdk().validateString)(properties.timeValue)),errors.collect(cdk().propertyValidator("timestampFormat",cdk().validateString)(properties.timestampFormat)),errors.collect(cdk().propertyValidator("versionValue",cdk().requiredValidator)(properties.versionValue)),errors.collect(cdk().propertyValidator("versionValue",cdk().validateString)(properties.versionValue)),errors.wrap('supplied properties not correct for "PipeTargetTimestreamParametersProperty"')}function convertCfnPipePipeTargetTimestreamParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetTimestreamParametersPropertyValidator(properties).assertSuccess(),{DimensionMappings:cdk().listMapper(convertCfnPipeDimensionMappingPropertyToCloudFormation)(properties.dimensionMappings),EpochTimeUnit:cdk().stringToCloudFormation(properties.epochTimeUnit),MultiMeasureMappings:cdk().listMapper(convertCfnPipeMultiMeasureMappingPropertyToCloudFormation)(properties.multiMeasureMappings),SingleMeasureMappings:cdk().listMapper(convertCfnPipeSingleMeasureMappingPropertyToCloudFormation)(properties.singleMeasureMappings),TimeFieldType:cdk().stringToCloudFormation(properties.timeFieldType),TimeValue:cdk().stringToCloudFormation(properties.timeValue),TimestampFormat:cdk().stringToCloudFormation(properties.timestampFormat),VersionValue:cdk().stringToCloudFormation(properties.versionValue)}):properties}function CfnPipePipeTargetTimestreamParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("dimensionMappings","DimensionMappings",properties.DimensionMappings!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeDimensionMappingPropertyFromCloudFormation)(properties.DimensionMappings):void 0),ret.addPropertyResult("epochTimeUnit","EpochTimeUnit",properties.EpochTimeUnit!=null?cfn_parse().FromCloudFormation.getString(properties.EpochTimeUnit):void 0),ret.addPropertyResult("multiMeasureMappings","MultiMeasureMappings",properties.MultiMeasureMappings!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeMultiMeasureMappingPropertyFromCloudFormation)(properties.MultiMeasureMappings):void 0),ret.addPropertyResult("singleMeasureMappings","SingleMeasureMappings",properties.SingleMeasureMappings!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeSingleMeasureMappingPropertyFromCloudFormation)(properties.SingleMeasureMappings):void 0),ret.addPropertyResult("timeFieldType","TimeFieldType",properties.TimeFieldType!=null?cfn_parse().FromCloudFormation.getString(properties.TimeFieldType):void 0),ret.addPropertyResult("timestampFormat","TimestampFormat",properties.TimestampFormat!=null?cfn_parse().FromCloudFormation.getString(properties.TimestampFormat):void 0),ret.addPropertyResult("timeValue","TimeValue",properties.TimeValue!=null?cfn_parse().FromCloudFormation.getString(properties.TimeValue):void 0),ret.addPropertyResult("versionValue","VersionValue",properties.VersionValue!=null?cfn_parse().FromCloudFormation.getString(properties.VersionValue):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeTargetParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchJobParameters",CfnPipePipeTargetBatchJobParametersPropertyValidator)(properties.batchJobParameters)),errors.collect(cdk().propertyValidator("cloudWatchLogsParameters",CfnPipePipeTargetCloudWatchLogsParametersPropertyValidator)(properties.cloudWatchLogsParameters)),errors.collect(cdk().propertyValidator("ecsTaskParameters",CfnPipePipeTargetEcsTaskParametersPropertyValidator)(properties.ecsTaskParameters)),errors.collect(cdk().propertyValidator("eventBridgeEventBusParameters",CfnPipePipeTargetEventBridgeEventBusParametersPropertyValidator)(properties.eventBridgeEventBusParameters)),errors.collect(cdk().propertyValidator("httpParameters",CfnPipePipeTargetHttpParametersPropertyValidator)(properties.httpParameters)),errors.collect(cdk().propertyValidator("inputTemplate",cdk().validateString)(properties.inputTemplate)),errors.collect(cdk().propertyValidator("kinesisStreamParameters",CfnPipePipeTargetKinesisStreamParametersPropertyValidator)(properties.kinesisStreamParameters)),errors.collect(cdk().propertyValidator("lambdaFunctionParameters",CfnPipePipeTargetLambdaFunctionParametersPropertyValidator)(properties.lambdaFunctionParameters)),errors.collect(cdk().propertyValidator("redshiftDataParameters",CfnPipePipeTargetRedshiftDataParametersPropertyValidator)(properties.redshiftDataParameters)),errors.collect(cdk().propertyValidator("sageMakerPipelineParameters",CfnPipePipeTargetSageMakerPipelineParametersPropertyValidator)(properties.sageMakerPipelineParameters)),errors.collect(cdk().propertyValidator("sqsQueueParameters",CfnPipePipeTargetSqsQueueParametersPropertyValidator)(properties.sqsQueueParameters)),errors.collect(cdk().propertyValidator("stepFunctionStateMachineParameters",CfnPipePipeTargetStateMachineParametersPropertyValidator)(properties.stepFunctionStateMachineParameters)),errors.collect(cdk().propertyValidator("timestreamParameters",CfnPipePipeTargetTimestreamParametersPropertyValidator)(properties.timestreamParameters)),errors.wrap('supplied properties not correct for "PipeTargetParametersProperty"')}function convertCfnPipePipeTargetParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeTargetParametersPropertyValidator(properties).assertSuccess(),{BatchJobParameters:convertCfnPipePipeTargetBatchJobParametersPropertyToCloudFormation(properties.batchJobParameters),CloudWatchLogsParameters:convertCfnPipePipeTargetCloudWatchLogsParametersPropertyToCloudFormation(properties.cloudWatchLogsParameters),EcsTaskParameters:convertCfnPipePipeTargetEcsTaskParametersPropertyToCloudFormation(properties.ecsTaskParameters),EventBridgeEventBusParameters:convertCfnPipePipeTargetEventBridgeEventBusParametersPropertyToCloudFormation(properties.eventBridgeEventBusParameters),HttpParameters:convertCfnPipePipeTargetHttpParametersPropertyToCloudFormation(properties.httpParameters),InputTemplate:cdk().stringToCloudFormation(properties.inputTemplate),KinesisStreamParameters:convertCfnPipePipeTargetKinesisStreamParametersPropertyToCloudFormation(properties.kinesisStreamParameters),LambdaFunctionParameters:convertCfnPipePipeTargetLambdaFunctionParametersPropertyToCloudFormation(properties.lambdaFunctionParameters),RedshiftDataParameters:convertCfnPipePipeTargetRedshiftDataParametersPropertyToCloudFormation(properties.redshiftDataParameters),SageMakerPipelineParameters:convertCfnPipePipeTargetSageMakerPipelineParametersPropertyToCloudFormation(properties.sageMakerPipelineParameters),SqsQueueParameters:convertCfnPipePipeTargetSqsQueueParametersPropertyToCloudFormation(properties.sqsQueueParameters),StepFunctionStateMachineParameters:convertCfnPipePipeTargetStateMachineParametersPropertyToCloudFormation(properties.stepFunctionStateMachineParameters),TimestreamParameters:convertCfnPipePipeTargetTimestreamParametersPropertyToCloudFormation(properties.timestreamParameters)}):properties}function CfnPipePipeTargetParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchJobParameters","BatchJobParameters",properties.BatchJobParameters!=null?CfnPipePipeTargetBatchJobParametersPropertyFromCloudFormation(properties.BatchJobParameters):void 0),ret.addPropertyResult("cloudWatchLogsParameters","CloudWatchLogsParameters",properties.CloudWatchLogsParameters!=null?CfnPipePipeTargetCloudWatchLogsParametersPropertyFromCloudFormation(properties.CloudWatchLogsParameters):void 0),ret.addPropertyResult("ecsTaskParameters","EcsTaskParameters",properties.EcsTaskParameters!=null?CfnPipePipeTargetEcsTaskParametersPropertyFromCloudFormation(properties.EcsTaskParameters):void 0),ret.addPropertyResult("eventBridgeEventBusParameters","EventBridgeEventBusParameters",properties.EventBridgeEventBusParameters!=null?CfnPipePipeTargetEventBridgeEventBusParametersPropertyFromCloudFormation(properties.EventBridgeEventBusParameters):void 0),ret.addPropertyResult("httpParameters","HttpParameters",properties.HttpParameters!=null?CfnPipePipeTargetHttpParametersPropertyFromCloudFormation(properties.HttpParameters):void 0),ret.addPropertyResult("inputTemplate","InputTemplate",properties.InputTemplate!=null?cfn_parse().FromCloudFormation.getString(properties.InputTemplate):void 0),ret.addPropertyResult("kinesisStreamParameters","KinesisStreamParameters",properties.KinesisStreamParameters!=null?CfnPipePipeTargetKinesisStreamParametersPropertyFromCloudFormation(properties.KinesisStreamParameters):void 0),ret.addPropertyResult("lambdaFunctionParameters","LambdaFunctionParameters",properties.LambdaFunctionParameters!=null?CfnPipePipeTargetLambdaFunctionParametersPropertyFromCloudFormation(properties.LambdaFunctionParameters):void 0),ret.addPropertyResult("redshiftDataParameters","RedshiftDataParameters",properties.RedshiftDataParameters!=null?CfnPipePipeTargetRedshiftDataParametersPropertyFromCloudFormation(properties.RedshiftDataParameters):void 0),ret.addPropertyResult("sageMakerPipelineParameters","SageMakerPipelineParameters",properties.SageMakerPipelineParameters!=null?CfnPipePipeTargetSageMakerPipelineParametersPropertyFromCloudFormation(properties.SageMakerPipelineParameters):void 0),ret.addPropertyResult("sqsQueueParameters","SqsQueueParameters",properties.SqsQueueParameters!=null?CfnPipePipeTargetSqsQueueParametersPropertyFromCloudFormation(properties.SqsQueueParameters):void 0),ret.addPropertyResult("stepFunctionStateMachineParameters","StepFunctionStateMachineParameters",properties.StepFunctionStateMachineParameters!=null?CfnPipePipeTargetStateMachineParametersPropertyFromCloudFormation(properties.StepFunctionStateMachineParameters):void 0),ret.addPropertyResult("timestreamParameters","TimestreamParameters",properties.TimestreamParameters!=null?CfnPipePipeTargetTimestreamParametersPropertyFromCloudFormation(properties.TimestreamParameters):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeEnrichmentHttpParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("headerParameters",cdk().hashValidator(cdk().validateString))(properties.headerParameters)),errors.collect(cdk().propertyValidator("pathParameterValues",cdk().listValidator(cdk().validateString))(properties.pathParameterValues)),errors.collect(cdk().propertyValidator("queryStringParameters",cdk().hashValidator(cdk().validateString))(properties.queryStringParameters)),errors.wrap('supplied properties not correct for "PipeEnrichmentHttpParametersProperty"')}function convertCfnPipePipeEnrichmentHttpParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeEnrichmentHttpParametersPropertyValidator(properties).assertSuccess(),{HeaderParameters:cdk().hashMapper(cdk().stringToCloudFormation)(properties.headerParameters),PathParameterValues:cdk().listMapper(cdk().stringToCloudFormation)(properties.pathParameterValues),QueryStringParameters:cdk().hashMapper(cdk().stringToCloudFormation)(properties.queryStringParameters)}):properties}function CfnPipePipeEnrichmentHttpParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("headerParameters","HeaderParameters",properties.HeaderParameters!=null?cfn_parse().FromCloudFormation.getMap(cfn_parse().FromCloudFormation.getString)(properties.HeaderParameters):void 0),ret.addPropertyResult("pathParameterValues","PathParameterValues",properties.PathParameterValues!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.PathParameterValues):void 0),ret.addPropertyResult("queryStringParameters","QueryStringParameters",properties.QueryStringParameters!=null?cfn_parse().FromCloudFormation.getMap(cfn_parse().FromCloudFormation.getString)(properties.QueryStringParameters):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeEnrichmentParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("httpParameters",CfnPipePipeEnrichmentHttpParametersPropertyValidator)(properties.httpParameters)),errors.collect(cdk().propertyValidator("inputTemplate",cdk().validateString)(properties.inputTemplate)),errors.wrap('supplied properties not correct for "PipeEnrichmentParametersProperty"')}function convertCfnPipePipeEnrichmentParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeEnrichmentParametersPropertyValidator(properties).assertSuccess(),{HttpParameters:convertCfnPipePipeEnrichmentHttpParametersPropertyToCloudFormation(properties.httpParameters),InputTemplate:cdk().stringToCloudFormation(properties.inputTemplate)}):properties}function CfnPipePipeEnrichmentParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("httpParameters","HttpParameters",properties.HttpParameters!=null?CfnPipePipeEnrichmentHttpParametersPropertyFromCloudFormation(properties.HttpParameters):void 0),ret.addPropertyResult("inputTemplate","InputTemplate",properties.InputTemplate!=null?cfn_parse().FromCloudFormation.getString(properties.InputTemplate):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeMSKAccessCredentialsPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("clientCertificateTlsAuth",cdk().validateString)(properties.clientCertificateTlsAuth)),errors.collect(cdk().propertyValidator("saslScram512Auth",cdk().validateString)(properties.saslScram512Auth)),errors.wrap('supplied properties not correct for "MSKAccessCredentialsProperty"')}function convertCfnPipeMSKAccessCredentialsPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeMSKAccessCredentialsPropertyValidator(properties).assertSuccess(),{ClientCertificateTlsAuth:cdk().stringToCloudFormation(properties.clientCertificateTlsAuth),SaslScram512Auth:cdk().stringToCloudFormation(properties.saslScram512Auth)}):properties}function CfnPipeMSKAccessCredentialsPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("clientCertificateTlsAuth","ClientCertificateTlsAuth",properties.ClientCertificateTlsAuth!=null?cfn_parse().FromCloudFormation.getString(properties.ClientCertificateTlsAuth):void 0),ret.addPropertyResult("saslScram512Auth","SaslScram512Auth",properties.SaslScram512Auth!=null?cfn_parse().FromCloudFormation.getString(properties.SaslScram512Auth):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceManagedStreamingKafkaParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("consumerGroupId",cdk().validateString)(properties.consumerGroupId)),errors.collect(cdk().propertyValidator("credentials",CfnPipeMSKAccessCredentialsPropertyValidator)(properties.credentials)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.collect(cdk().propertyValidator("startingPosition",cdk().validateString)(properties.startingPosition)),errors.collect(cdk().propertyValidator("topicName",cdk().requiredValidator)(properties.topicName)),errors.collect(cdk().propertyValidator("topicName",cdk().validateString)(properties.topicName)),errors.wrap('supplied properties not correct for "PipeSourceManagedStreamingKafkaParametersProperty"')}function convertCfnPipePipeSourceManagedStreamingKafkaParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceManagedStreamingKafkaParametersPropertyValidator(properties).assertSuccess(),{BatchSize:cdk().numberToCloudFormation(properties.batchSize),ConsumerGroupID:cdk().stringToCloudFormation(properties.consumerGroupId),Credentials:convertCfnPipeMSKAccessCredentialsPropertyToCloudFormation(properties.credentials),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds),StartingPosition:cdk().stringToCloudFormation(properties.startingPosition),TopicName:cdk().stringToCloudFormation(properties.topicName)}):properties}function CfnPipePipeSourceManagedStreamingKafkaParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("consumerGroupId","ConsumerGroupID",properties.ConsumerGroupID!=null?cfn_parse().FromCloudFormation.getString(properties.ConsumerGroupID):void 0),ret.addPropertyResult("credentials","Credentials",properties.Credentials!=null?CfnPipeMSKAccessCredentialsPropertyFromCloudFormation(properties.Credentials):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addPropertyResult("startingPosition","StartingPosition",properties.StartingPosition!=null?cfn_parse().FromCloudFormation.getString(properties.StartingPosition):void 0),ret.addPropertyResult("topicName","TopicName",properties.TopicName!=null?cfn_parse().FromCloudFormation.getString(properties.TopicName):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeDeadLetterConfigPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("arn",cdk().validateString)(properties.arn)),errors.wrap('supplied properties not correct for "DeadLetterConfigProperty"')}function convertCfnPipeDeadLetterConfigPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeDeadLetterConfigPropertyValidator(properties).assertSuccess(),{Arn:cdk().stringToCloudFormation(properties.arn)}):properties}function CfnPipeDeadLetterConfigPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("arn","Arn",properties.Arn!=null?cfn_parse().FromCloudFormation.getString(properties.Arn):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceDynamoDBStreamParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("deadLetterConfig",CfnPipeDeadLetterConfigPropertyValidator)(properties.deadLetterConfig)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.collect(cdk().propertyValidator("maximumRecordAgeInSeconds",cdk().validateNumber)(properties.maximumRecordAgeInSeconds)),errors.collect(cdk().propertyValidator("maximumRetryAttempts",cdk().validateNumber)(properties.maximumRetryAttempts)),errors.collect(cdk().propertyValidator("onPartialBatchItemFailure",cdk().validateString)(properties.onPartialBatchItemFailure)),errors.collect(cdk().propertyValidator("parallelizationFactor",cdk().validateNumber)(properties.parallelizationFactor)),errors.collect(cdk().propertyValidator("startingPosition",cdk().requiredValidator)(properties.startingPosition)),errors.collect(cdk().propertyValidator("startingPosition",cdk().validateString)(properties.startingPosition)),errors.wrap('supplied properties not correct for "PipeSourceDynamoDBStreamParametersProperty"')}function convertCfnPipePipeSourceDynamoDBStreamParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceDynamoDBStreamParametersPropertyValidator(properties).assertSuccess(),{BatchSize:cdk().numberToCloudFormation(properties.batchSize),DeadLetterConfig:convertCfnPipeDeadLetterConfigPropertyToCloudFormation(properties.deadLetterConfig),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds),MaximumRecordAgeInSeconds:cdk().numberToCloudFormation(properties.maximumRecordAgeInSeconds),MaximumRetryAttempts:cdk().numberToCloudFormation(properties.maximumRetryAttempts),OnPartialBatchItemFailure:cdk().stringToCloudFormation(properties.onPartialBatchItemFailure),ParallelizationFactor:cdk().numberToCloudFormation(properties.parallelizationFactor),StartingPosition:cdk().stringToCloudFormation(properties.startingPosition)}):properties}function CfnPipePipeSourceDynamoDBStreamParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("deadLetterConfig","DeadLetterConfig",properties.DeadLetterConfig!=null?CfnPipeDeadLetterConfigPropertyFromCloudFormation(properties.DeadLetterConfig):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addPropertyResult("maximumRecordAgeInSeconds","MaximumRecordAgeInSeconds",properties.MaximumRecordAgeInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumRecordAgeInSeconds):void 0),ret.addPropertyResult("maximumRetryAttempts","MaximumRetryAttempts",properties.MaximumRetryAttempts!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumRetryAttempts):void 0),ret.addPropertyResult("onPartialBatchItemFailure","OnPartialBatchItemFailure",properties.OnPartialBatchItemFailure!=null?cfn_parse().FromCloudFormation.getString(properties.OnPartialBatchItemFailure):void 0),ret.addPropertyResult("parallelizationFactor","ParallelizationFactor",properties.ParallelizationFactor!=null?cfn_parse().FromCloudFormation.getNumber(properties.ParallelizationFactor):void 0),ret.addPropertyResult("startingPosition","StartingPosition",properties.StartingPosition!=null?cfn_parse().FromCloudFormation.getString(properties.StartingPosition):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("securityGroup",cdk().listValidator(cdk().validateString))(properties.securityGroup)),errors.collect(cdk().propertyValidator("subnets",cdk().listValidator(cdk().validateString))(properties.subnets)),errors.wrap('supplied properties not correct for "SelfManagedKafkaAccessConfigurationVpcProperty"')}function convertCfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyValidator(properties).assertSuccess(),{SecurityGroup:cdk().listMapper(cdk().stringToCloudFormation)(properties.securityGroup),Subnets:cdk().listMapper(cdk().stringToCloudFormation)(properties.subnets)}):properties}function CfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("securityGroup","SecurityGroup",properties.SecurityGroup!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.SecurityGroup):void 0),ret.addPropertyResult("subnets","Subnets",properties.Subnets!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.Subnets):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("basicAuth",cdk().validateString)(properties.basicAuth)),errors.collect(cdk().propertyValidator("clientCertificateTlsAuth",cdk().validateString)(properties.clientCertificateTlsAuth)),errors.collect(cdk().propertyValidator("saslScram256Auth",cdk().validateString)(properties.saslScram256Auth)),errors.collect(cdk().propertyValidator("saslScram512Auth",cdk().validateString)(properties.saslScram512Auth)),errors.wrap('supplied properties not correct for "SelfManagedKafkaAccessConfigurationCredentialsProperty"')}function convertCfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyValidator(properties).assertSuccess(),{BasicAuth:cdk().stringToCloudFormation(properties.basicAuth),ClientCertificateTlsAuth:cdk().stringToCloudFormation(properties.clientCertificateTlsAuth),SaslScram256Auth:cdk().stringToCloudFormation(properties.saslScram256Auth),SaslScram512Auth:cdk().stringToCloudFormation(properties.saslScram512Auth)}):properties}function CfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("basicAuth","BasicAuth",properties.BasicAuth!=null?cfn_parse().FromCloudFormation.getString(properties.BasicAuth):void 0),ret.addPropertyResult("clientCertificateTlsAuth","ClientCertificateTlsAuth",properties.ClientCertificateTlsAuth!=null?cfn_parse().FromCloudFormation.getString(properties.ClientCertificateTlsAuth):void 0),ret.addPropertyResult("saslScram256Auth","SaslScram256Auth",properties.SaslScram256Auth!=null?cfn_parse().FromCloudFormation.getString(properties.SaslScram256Auth):void 0),ret.addPropertyResult("saslScram512Auth","SaslScram512Auth",properties.SaslScram512Auth!=null?cfn_parse().FromCloudFormation.getString(properties.SaslScram512Auth):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceSelfManagedKafkaParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("additionalBootstrapServers",cdk().listValidator(cdk().validateString))(properties.additionalBootstrapServers)),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("consumerGroupId",cdk().validateString)(properties.consumerGroupId)),errors.collect(cdk().propertyValidator("credentials",CfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyValidator)(properties.credentials)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.collect(cdk().propertyValidator("serverRootCaCertificate",cdk().validateString)(properties.serverRootCaCertificate)),errors.collect(cdk().propertyValidator("startingPosition",cdk().validateString)(properties.startingPosition)),errors.collect(cdk().propertyValidator("topicName",cdk().requiredValidator)(properties.topicName)),errors.collect(cdk().propertyValidator("topicName",cdk().validateString)(properties.topicName)),errors.collect(cdk().propertyValidator("vpc",CfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyValidator)(properties.vpc)),errors.wrap('supplied properties not correct for "PipeSourceSelfManagedKafkaParametersProperty"')}function convertCfnPipePipeSourceSelfManagedKafkaParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceSelfManagedKafkaParametersPropertyValidator(properties).assertSuccess(),{AdditionalBootstrapServers:cdk().listMapper(cdk().stringToCloudFormation)(properties.additionalBootstrapServers),BatchSize:cdk().numberToCloudFormation(properties.batchSize),ConsumerGroupID:cdk().stringToCloudFormation(properties.consumerGroupId),Credentials:convertCfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyToCloudFormation(properties.credentials),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds),ServerRootCaCertificate:cdk().stringToCloudFormation(properties.serverRootCaCertificate),StartingPosition:cdk().stringToCloudFormation(properties.startingPosition),TopicName:cdk().stringToCloudFormation(properties.topicName),Vpc:convertCfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyToCloudFormation(properties.vpc)}):properties}function CfnPipePipeSourceSelfManagedKafkaParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("additionalBootstrapServers","AdditionalBootstrapServers",properties.AdditionalBootstrapServers!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.AdditionalBootstrapServers):void 0),ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("consumerGroupId","ConsumerGroupID",properties.ConsumerGroupID!=null?cfn_parse().FromCloudFormation.getString(properties.ConsumerGroupID):void 0),ret.addPropertyResult("credentials","Credentials",properties.Credentials!=null?CfnPipeSelfManagedKafkaAccessConfigurationCredentialsPropertyFromCloudFormation(properties.Credentials):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addPropertyResult("serverRootCaCertificate","ServerRootCaCertificate",properties.ServerRootCaCertificate!=null?cfn_parse().FromCloudFormation.getString(properties.ServerRootCaCertificate):void 0),ret.addPropertyResult("startingPosition","StartingPosition",properties.StartingPosition!=null?cfn_parse().FromCloudFormation.getString(properties.StartingPosition):void 0),ret.addPropertyResult("topicName","TopicName",properties.TopicName!=null?cfn_parse().FromCloudFormation.getString(properties.TopicName):void 0),ret.addPropertyResult("vpc","Vpc",properties.Vpc!=null?CfnPipeSelfManagedKafkaAccessConfigurationVpcPropertyFromCloudFormation(properties.Vpc):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeMQBrokerAccessCredentialsPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("basicAuth",cdk().requiredValidator)(properties.basicAuth)),errors.collect(cdk().propertyValidator("basicAuth",cdk().validateString)(properties.basicAuth)),errors.wrap('supplied properties not correct for "MQBrokerAccessCredentialsProperty"')}function convertCfnPipeMQBrokerAccessCredentialsPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeMQBrokerAccessCredentialsPropertyValidator(properties).assertSuccess(),{BasicAuth:cdk().stringToCloudFormation(properties.basicAuth)}):properties}function CfnPipeMQBrokerAccessCredentialsPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("basicAuth","BasicAuth",properties.BasicAuth!=null?cfn_parse().FromCloudFormation.getString(properties.BasicAuth):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceRabbitMQBrokerParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("credentials",cdk().requiredValidator)(properties.credentials)),errors.collect(cdk().propertyValidator("credentials",CfnPipeMQBrokerAccessCredentialsPropertyValidator)(properties.credentials)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.collect(cdk().propertyValidator("queueName",cdk().requiredValidator)(properties.queueName)),errors.collect(cdk().propertyValidator("queueName",cdk().validateString)(properties.queueName)),errors.collect(cdk().propertyValidator("virtualHost",cdk().validateString)(properties.virtualHost)),errors.wrap('supplied properties not correct for "PipeSourceRabbitMQBrokerParametersProperty"')}function convertCfnPipePipeSourceRabbitMQBrokerParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceRabbitMQBrokerParametersPropertyValidator(properties).assertSuccess(),{BatchSize:cdk().numberToCloudFormation(properties.batchSize),Credentials:convertCfnPipeMQBrokerAccessCredentialsPropertyToCloudFormation(properties.credentials),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds),QueueName:cdk().stringToCloudFormation(properties.queueName),VirtualHost:cdk().stringToCloudFormation(properties.virtualHost)}):properties}function CfnPipePipeSourceRabbitMQBrokerParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("credentials","Credentials",properties.Credentials!=null?CfnPipeMQBrokerAccessCredentialsPropertyFromCloudFormation(properties.Credentials):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addPropertyResult("queueName","QueueName",properties.QueueName!=null?cfn_parse().FromCloudFormation.getString(properties.QueueName):void 0),ret.addPropertyResult("virtualHost","VirtualHost",properties.VirtualHost!=null?cfn_parse().FromCloudFormation.getString(properties.VirtualHost):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceSqsQueueParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.wrap('supplied properties not correct for "PipeSourceSqsQueueParametersProperty"')}function convertCfnPipePipeSourceSqsQueueParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceSqsQueueParametersPropertyValidator(properties).assertSuccess(),{BatchSize:cdk().numberToCloudFormation(properties.batchSize),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds)}):properties}function CfnPipePipeSourceSqsQueueParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceKinesisStreamParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("deadLetterConfig",CfnPipeDeadLetterConfigPropertyValidator)(properties.deadLetterConfig)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.collect(cdk().propertyValidator("maximumRecordAgeInSeconds",cdk().validateNumber)(properties.maximumRecordAgeInSeconds)),errors.collect(cdk().propertyValidator("maximumRetryAttempts",cdk().validateNumber)(properties.maximumRetryAttempts)),errors.collect(cdk().propertyValidator("onPartialBatchItemFailure",cdk().validateString)(properties.onPartialBatchItemFailure)),errors.collect(cdk().propertyValidator("parallelizationFactor",cdk().validateNumber)(properties.parallelizationFactor)),errors.collect(cdk().propertyValidator("startingPosition",cdk().requiredValidator)(properties.startingPosition)),errors.collect(cdk().propertyValidator("startingPosition",cdk().validateString)(properties.startingPosition)),errors.collect(cdk().propertyValidator("startingPositionTimestamp",cdk().validateString)(properties.startingPositionTimestamp)),errors.wrap('supplied properties not correct for "PipeSourceKinesisStreamParametersProperty"')}function convertCfnPipePipeSourceKinesisStreamParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceKinesisStreamParametersPropertyValidator(properties).assertSuccess(),{BatchSize:cdk().numberToCloudFormation(properties.batchSize),DeadLetterConfig:convertCfnPipeDeadLetterConfigPropertyToCloudFormation(properties.deadLetterConfig),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds),MaximumRecordAgeInSeconds:cdk().numberToCloudFormation(properties.maximumRecordAgeInSeconds),MaximumRetryAttempts:cdk().numberToCloudFormation(properties.maximumRetryAttempts),OnPartialBatchItemFailure:cdk().stringToCloudFormation(properties.onPartialBatchItemFailure),ParallelizationFactor:cdk().numberToCloudFormation(properties.parallelizationFactor),StartingPosition:cdk().stringToCloudFormation(properties.startingPosition),StartingPositionTimestamp:cdk().stringToCloudFormation(properties.startingPositionTimestamp)}):properties}function CfnPipePipeSourceKinesisStreamParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("deadLetterConfig","DeadLetterConfig",properties.DeadLetterConfig!=null?CfnPipeDeadLetterConfigPropertyFromCloudFormation(properties.DeadLetterConfig):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addPropertyResult("maximumRecordAgeInSeconds","MaximumRecordAgeInSeconds",properties.MaximumRecordAgeInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumRecordAgeInSeconds):void 0),ret.addPropertyResult("maximumRetryAttempts","MaximumRetryAttempts",properties.MaximumRetryAttempts!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumRetryAttempts):void 0),ret.addPropertyResult("onPartialBatchItemFailure","OnPartialBatchItemFailure",properties.OnPartialBatchItemFailure!=null?cfn_parse().FromCloudFormation.getString(properties.OnPartialBatchItemFailure):void 0),ret.addPropertyResult("parallelizationFactor","ParallelizationFactor",properties.ParallelizationFactor!=null?cfn_parse().FromCloudFormation.getNumber(properties.ParallelizationFactor):void 0),ret.addPropertyResult("startingPosition","StartingPosition",properties.StartingPosition!=null?cfn_parse().FromCloudFormation.getString(properties.StartingPosition):void 0),ret.addPropertyResult("startingPositionTimestamp","StartingPositionTimestamp",properties.StartingPositionTimestamp!=null?cfn_parse().FromCloudFormation.getString(properties.StartingPositionTimestamp):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeFilterPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("pattern",cdk().validateString)(properties.pattern)),errors.wrap('supplied properties not correct for "FilterProperty"')}function convertCfnPipeFilterPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeFilterPropertyValidator(properties).assertSuccess(),{Pattern:cdk().stringToCloudFormation(properties.pattern)}):properties}function CfnPipeFilterPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("pattern","Pattern",properties.Pattern!=null?cfn_parse().FromCloudFormation.getString(properties.Pattern):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeFilterCriteriaPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("filters",cdk().listValidator(CfnPipeFilterPropertyValidator))(properties.filters)),errors.wrap('supplied properties not correct for "FilterCriteriaProperty"')}function convertCfnPipeFilterCriteriaPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeFilterCriteriaPropertyValidator(properties).assertSuccess(),{Filters:cdk().listMapper(convertCfnPipeFilterPropertyToCloudFormation)(properties.filters)}):properties}function CfnPipeFilterCriteriaPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("filters","Filters",properties.Filters!=null?cfn_parse().FromCloudFormation.getArray(CfnPipeFilterPropertyFromCloudFormation)(properties.Filters):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceActiveMQBrokerParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("batchSize",cdk().validateNumber)(properties.batchSize)),errors.collect(cdk().propertyValidator("credentials",cdk().requiredValidator)(properties.credentials)),errors.collect(cdk().propertyValidator("credentials",CfnPipeMQBrokerAccessCredentialsPropertyValidator)(properties.credentials)),errors.collect(cdk().propertyValidator("maximumBatchingWindowInSeconds",cdk().validateNumber)(properties.maximumBatchingWindowInSeconds)),errors.collect(cdk().propertyValidator("queueName",cdk().requiredValidator)(properties.queueName)),errors.collect(cdk().propertyValidator("queueName",cdk().validateString)(properties.queueName)),errors.wrap('supplied properties not correct for "PipeSourceActiveMQBrokerParametersProperty"')}function convertCfnPipePipeSourceActiveMQBrokerParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceActiveMQBrokerParametersPropertyValidator(properties).assertSuccess(),{BatchSize:cdk().numberToCloudFormation(properties.batchSize),Credentials:convertCfnPipeMQBrokerAccessCredentialsPropertyToCloudFormation(properties.credentials),MaximumBatchingWindowInSeconds:cdk().numberToCloudFormation(properties.maximumBatchingWindowInSeconds),QueueName:cdk().stringToCloudFormation(properties.queueName)}):properties}function CfnPipePipeSourceActiveMQBrokerParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("batchSize","BatchSize",properties.BatchSize!=null?cfn_parse().FromCloudFormation.getNumber(properties.BatchSize):void 0),ret.addPropertyResult("credentials","Credentials",properties.Credentials!=null?CfnPipeMQBrokerAccessCredentialsPropertyFromCloudFormation(properties.Credentials):void 0),ret.addPropertyResult("maximumBatchingWindowInSeconds","MaximumBatchingWindowInSeconds",properties.MaximumBatchingWindowInSeconds!=null?cfn_parse().FromCloudFormation.getNumber(properties.MaximumBatchingWindowInSeconds):void 0),ret.addPropertyResult("queueName","QueueName",properties.QueueName!=null?cfn_parse().FromCloudFormation.getString(properties.QueueName):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeSourceParametersPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("activeMqBrokerParameters",CfnPipePipeSourceActiveMQBrokerParametersPropertyValidator)(properties.activeMqBrokerParameters)),errors.collect(cdk().propertyValidator("dynamoDbStreamParameters",CfnPipePipeSourceDynamoDBStreamParametersPropertyValidator)(properties.dynamoDbStreamParameters)),errors.collect(cdk().propertyValidator("filterCriteria",CfnPipeFilterCriteriaPropertyValidator)(properties.filterCriteria)),errors.collect(cdk().propertyValidator("kinesisStreamParameters",CfnPipePipeSourceKinesisStreamParametersPropertyValidator)(properties.kinesisStreamParameters)),errors.collect(cdk().propertyValidator("managedStreamingKafkaParameters",CfnPipePipeSourceManagedStreamingKafkaParametersPropertyValidator)(properties.managedStreamingKafkaParameters)),errors.collect(cdk().propertyValidator("rabbitMqBrokerParameters",CfnPipePipeSourceRabbitMQBrokerParametersPropertyValidator)(properties.rabbitMqBrokerParameters)),errors.collect(cdk().propertyValidator("selfManagedKafkaParameters",CfnPipePipeSourceSelfManagedKafkaParametersPropertyValidator)(properties.selfManagedKafkaParameters)),errors.collect(cdk().propertyValidator("sqsQueueParameters",CfnPipePipeSourceSqsQueueParametersPropertyValidator)(properties.sqsQueueParameters)),errors.wrap('supplied properties not correct for "PipeSourceParametersProperty"')}function convertCfnPipePipeSourceParametersPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeSourceParametersPropertyValidator(properties).assertSuccess(),{ActiveMQBrokerParameters:convertCfnPipePipeSourceActiveMQBrokerParametersPropertyToCloudFormation(properties.activeMqBrokerParameters),DynamoDBStreamParameters:convertCfnPipePipeSourceDynamoDBStreamParametersPropertyToCloudFormation(properties.dynamoDbStreamParameters),FilterCriteria:convertCfnPipeFilterCriteriaPropertyToCloudFormation(properties.filterCriteria),KinesisStreamParameters:convertCfnPipePipeSourceKinesisStreamParametersPropertyToCloudFormation(properties.kinesisStreamParameters),ManagedStreamingKafkaParameters:convertCfnPipePipeSourceManagedStreamingKafkaParametersPropertyToCloudFormation(properties.managedStreamingKafkaParameters),RabbitMQBrokerParameters:convertCfnPipePipeSourceRabbitMQBrokerParametersPropertyToCloudFormation(properties.rabbitMqBrokerParameters),SelfManagedKafkaParameters:convertCfnPipePipeSourceSelfManagedKafkaParametersPropertyToCloudFormation(properties.selfManagedKafkaParameters),SqsQueueParameters:convertCfnPipePipeSourceSqsQueueParametersPropertyToCloudFormation(properties.sqsQueueParameters)}):properties}function CfnPipePipeSourceParametersPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("activeMqBrokerParameters","ActiveMQBrokerParameters",properties.ActiveMQBrokerParameters!=null?CfnPipePipeSourceActiveMQBrokerParametersPropertyFromCloudFormation(properties.ActiveMQBrokerParameters):void 0),ret.addPropertyResult("dynamoDbStreamParameters","DynamoDBStreamParameters",properties.DynamoDBStreamParameters!=null?CfnPipePipeSourceDynamoDBStreamParametersPropertyFromCloudFormation(properties.DynamoDBStreamParameters):void 0),ret.addPropertyResult("filterCriteria","FilterCriteria",properties.FilterCriteria!=null?CfnPipeFilterCriteriaPropertyFromCloudFormation(properties.FilterCriteria):void 0),ret.addPropertyResult("kinesisStreamParameters","KinesisStreamParameters",properties.KinesisStreamParameters!=null?CfnPipePipeSourceKinesisStreamParametersPropertyFromCloudFormation(properties.KinesisStreamParameters):void 0),ret.addPropertyResult("managedStreamingKafkaParameters","ManagedStreamingKafkaParameters",properties.ManagedStreamingKafkaParameters!=null?CfnPipePipeSourceManagedStreamingKafkaParametersPropertyFromCloudFormation(properties.ManagedStreamingKafkaParameters):void 0),ret.addPropertyResult("rabbitMqBrokerParameters","RabbitMQBrokerParameters",properties.RabbitMQBrokerParameters!=null?CfnPipePipeSourceRabbitMQBrokerParametersPropertyFromCloudFormation(properties.RabbitMQBrokerParameters):void 0),ret.addPropertyResult("selfManagedKafkaParameters","SelfManagedKafkaParameters",properties.SelfManagedKafkaParameters!=null?CfnPipePipeSourceSelfManagedKafkaParametersPropertyFromCloudFormation(properties.SelfManagedKafkaParameters):void 0),ret.addPropertyResult("sqsQueueParameters","SqsQueueParameters",properties.SqsQueueParameters!=null?CfnPipePipeSourceSqsQueueParametersPropertyFromCloudFormation(properties.SqsQueueParameters):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeS3LogDestinationPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("bucketName",cdk().validateString)(properties.bucketName)),errors.collect(cdk().propertyValidator("bucketOwner",cdk().validateString)(properties.bucketOwner)),errors.collect(cdk().propertyValidator("outputFormat",cdk().validateString)(properties.outputFormat)),errors.collect(cdk().propertyValidator("prefix",cdk().validateString)(properties.prefix)),errors.wrap('supplied properties not correct for "S3LogDestinationProperty"')}function convertCfnPipeS3LogDestinationPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeS3LogDestinationPropertyValidator(properties).assertSuccess(),{BucketName:cdk().stringToCloudFormation(properties.bucketName),BucketOwner:cdk().stringToCloudFormation(properties.bucketOwner),OutputFormat:cdk().stringToCloudFormation(properties.outputFormat),Prefix:cdk().stringToCloudFormation(properties.prefix)}):properties}function CfnPipeS3LogDestinationPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("bucketName","BucketName",properties.BucketName!=null?cfn_parse().FromCloudFormation.getString(properties.BucketName):void 0),ret.addPropertyResult("bucketOwner","BucketOwner",properties.BucketOwner!=null?cfn_parse().FromCloudFormation.getString(properties.BucketOwner):void 0),ret.addPropertyResult("outputFormat","OutputFormat",properties.OutputFormat!=null?cfn_parse().FromCloudFormation.getString(properties.OutputFormat):void 0),ret.addPropertyResult("prefix","Prefix",properties.Prefix!=null?cfn_parse().FromCloudFormation.getString(properties.Prefix):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeFirehoseLogDestinationPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("deliveryStreamArn",cdk().validateString)(properties.deliveryStreamArn)),errors.wrap('supplied properties not correct for "FirehoseLogDestinationProperty"')}function convertCfnPipeFirehoseLogDestinationPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeFirehoseLogDestinationPropertyValidator(properties).assertSuccess(),{DeliveryStreamArn:cdk().stringToCloudFormation(properties.deliveryStreamArn)}):properties}function CfnPipeFirehoseLogDestinationPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("deliveryStreamArn","DeliveryStreamArn",properties.DeliveryStreamArn!=null?cfn_parse().FromCloudFormation.getString(properties.DeliveryStreamArn):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipeCloudwatchLogsLogDestinationPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("logGroupArn",cdk().validateString)(properties.logGroupArn)),errors.wrap('supplied properties not correct for "CloudwatchLogsLogDestinationProperty"')}function convertCfnPipeCloudwatchLogsLogDestinationPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipeCloudwatchLogsLogDestinationPropertyValidator(properties).assertSuccess(),{LogGroupArn:cdk().stringToCloudFormation(properties.logGroupArn)}):properties}function CfnPipeCloudwatchLogsLogDestinationPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("logGroupArn","LogGroupArn",properties.LogGroupArn!=null?cfn_parse().FromCloudFormation.getString(properties.LogGroupArn):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePipeLogConfigurationPropertyValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("cloudwatchLogsLogDestination",CfnPipeCloudwatchLogsLogDestinationPropertyValidator)(properties.cloudwatchLogsLogDestination)),errors.collect(cdk().propertyValidator("firehoseLogDestination",CfnPipeFirehoseLogDestinationPropertyValidator)(properties.firehoseLogDestination)),errors.collect(cdk().propertyValidator("includeExecutionData",cdk().listValidator(cdk().validateString))(properties.includeExecutionData)),errors.collect(cdk().propertyValidator("level",cdk().validateString)(properties.level)),errors.collect(cdk().propertyValidator("s3LogDestination",CfnPipeS3LogDestinationPropertyValidator)(properties.s3LogDestination)),errors.wrap('supplied properties not correct for "PipeLogConfigurationProperty"')}function convertCfnPipePipeLogConfigurationPropertyToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePipeLogConfigurationPropertyValidator(properties).assertSuccess(),{CloudwatchLogsLogDestination:convertCfnPipeCloudwatchLogsLogDestinationPropertyToCloudFormation(properties.cloudwatchLogsLogDestination),FirehoseLogDestination:convertCfnPipeFirehoseLogDestinationPropertyToCloudFormation(properties.firehoseLogDestination),IncludeExecutionData:cdk().listMapper(cdk().stringToCloudFormation)(properties.includeExecutionData),Level:cdk().stringToCloudFormation(properties.level),S3LogDestination:convertCfnPipeS3LogDestinationPropertyToCloudFormation(properties.s3LogDestination)}):properties}function CfnPipePipeLogConfigurationPropertyFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("cloudwatchLogsLogDestination","CloudwatchLogsLogDestination",properties.CloudwatchLogsLogDestination!=null?CfnPipeCloudwatchLogsLogDestinationPropertyFromCloudFormation(properties.CloudwatchLogsLogDestination):void 0),ret.addPropertyResult("firehoseLogDestination","FirehoseLogDestination",properties.FirehoseLogDestination!=null?CfnPipeFirehoseLogDestinationPropertyFromCloudFormation(properties.FirehoseLogDestination):void 0),ret.addPropertyResult("includeExecutionData","IncludeExecutionData",properties.IncludeExecutionData!=null?cfn_parse().FromCloudFormation.getArray(cfn_parse().FromCloudFormation.getString)(properties.IncludeExecutionData):void 0),ret.addPropertyResult("level","Level",properties.Level!=null?cfn_parse().FromCloudFormation.getString(properties.Level):void 0),ret.addPropertyResult("s3LogDestination","S3LogDestination",properties.S3LogDestination!=null?CfnPipeS3LogDestinationPropertyFromCloudFormation(properties.S3LogDestination):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}function CfnPipePropsValidator(properties){if(!cdk().canInspect(properties))return cdk().VALIDATION_SUCCESS;const errors=new(cdk()).ValidationResults;return properties&&typeof properties=="object"&&!Array.isArray(properties)||errors.collect(new(cdk()).ValidationResult("Expected an object, but received: "+JSON.stringify(properties))),errors.collect(cdk().propertyValidator("description",cdk().validateString)(properties.description)),errors.collect(cdk().propertyValidator("desiredState",cdk().validateString)(properties.desiredState)),errors.collect(cdk().propertyValidator("enrichment",cdk().validateString)(properties.enrichment)),errors.collect(cdk().propertyValidator("enrichmentParameters",CfnPipePipeEnrichmentParametersPropertyValidator)(properties.enrichmentParameters)),errors.collect(cdk().propertyValidator("kmsKeyIdentifier",cdk().validateString)(properties.kmsKeyIdentifier)),errors.collect(cdk().propertyValidator("logConfiguration",CfnPipePipeLogConfigurationPropertyValidator)(properties.logConfiguration)),errors.collect(cdk().propertyValidator("name",cdk().validateString)(properties.name)),errors.collect(cdk().propertyValidator("roleArn",cdk().requiredValidator)(properties.roleArn)),errors.collect(cdk().propertyValidator("roleArn",cdk().validateString)(properties.roleArn)),errors.collect(cdk().propertyValidator("source",cdk().requiredValidator)(properties.source)),errors.collect(cdk().propertyValidator("source",cdk().validateString)(properties.source)),errors.collect(cdk().propertyValidator("sourceParameters",CfnPipePipeSourceParametersPropertyValidator)(properties.sourceParameters)),errors.collect(cdk().propertyValidator("tags",cdk().hashValidator(cdk().validateString))(properties.tags)),errors.collect(cdk().propertyValidator("target",cdk().requiredValidator)(properties.target)),errors.collect(cdk().propertyValidator("target",cdk().validateString)(properties.target)),errors.collect(cdk().propertyValidator("targetParameters",CfnPipePipeTargetParametersPropertyValidator)(properties.targetParameters)),errors.wrap('supplied properties not correct for "CfnPipeProps"')}function convertCfnPipePropsToCloudFormation(properties){return cdk().canInspect(properties)?(CfnPipePropsValidator(properties).assertSuccess(),{Description:cdk().stringToCloudFormation(properties.description),DesiredState:cdk().stringToCloudFormation(properties.desiredState),Enrichment:cdk().stringToCloudFormation(properties.enrichment),EnrichmentParameters:convertCfnPipePipeEnrichmentParametersPropertyToCloudFormation(properties.enrichmentParameters),KmsKeyIdentifier:cdk().stringToCloudFormation(properties.kmsKeyIdentifier),LogConfiguration:convertCfnPipePipeLogConfigurationPropertyToCloudFormation(properties.logConfiguration),Name:cdk().stringToCloudFormation(properties.name),RoleArn:cdk().stringToCloudFormation(properties.roleArn),Source:cdk().stringToCloudFormation(properties.source),SourceParameters:convertCfnPipePipeSourceParametersPropertyToCloudFormation(properties.sourceParameters),Tags:cdk().hashMapper(cdk().stringToCloudFormation)(properties.tags),Target:cdk().stringToCloudFormation(properties.target),TargetParameters:convertCfnPipePipeTargetParametersPropertyToCloudFormation(properties.targetParameters)}):properties}function CfnPipePropsFromCloudFormation(properties){if(cdk().isResolvableObject(properties))return new(cfn_parse()).FromCloudFormationResult(properties);if(properties=properties??{},!(properties&&typeof properties=="object"&&!Array.isArray(properties)))return new(cfn_parse()).FromCloudFormationResult(properties);const ret=new(cfn_parse()).FromCloudFormationPropertyObject;return ret.addPropertyResult("description","Description",properties.Description!=null?cfn_parse().FromCloudFormation.getString(properties.Description):void 0),ret.addPropertyResult("desiredState","DesiredState",properties.DesiredState!=null?cfn_parse().FromCloudFormation.getString(properties.DesiredState):void 0),ret.addPropertyResult("enrichment","Enrichment",properties.Enrichment!=null?cfn_parse().FromCloudFormation.getString(properties.Enrichment):void 0),ret.addPropertyResult("enrichmentParameters","EnrichmentParameters",properties.EnrichmentParameters!=null?CfnPipePipeEnrichmentParametersPropertyFromCloudFormation(properties.EnrichmentParameters):void 0),ret.addPropertyResult("kmsKeyIdentifier","KmsKeyIdentifier",properties.KmsKeyIdentifier!=null?cfn_parse().FromCloudFormation.getString(properties.KmsKeyIdentifier):void 0),ret.addPropertyResult("logConfiguration","LogConfiguration",properties.LogConfiguration!=null?CfnPipePipeLogConfigurationPropertyFromCloudFormation(properties.LogConfiguration):void 0),ret.addPropertyResult("name","Name",properties.Name!=null?cfn_parse().FromCloudFormation.getString(properties.Name):void 0),ret.addPropertyResult("roleArn","RoleArn",properties.RoleArn!=null?cfn_parse().FromCloudFormation.getString(properties.RoleArn):void 0),ret.addPropertyResult("source","Source",properties.Source!=null?cfn_parse().FromCloudFormation.getString(properties.Source):void 0),ret.addPropertyResult("sourceParameters","SourceParameters",properties.SourceParameters!=null?CfnPipePipeSourceParametersPropertyFromCloudFormation(properties.SourceParameters):void 0),ret.addPropertyResult("tags","Tags",properties.Tags!=null?cfn_parse().FromCloudFormation.getMap(cfn_parse().FromCloudFormation.getString)(properties.Tags):void 0),ret.addPropertyResult("target","Target",properties.Target!=null?cfn_parse().FromCloudFormation.getString(properties.Target):void 0),ret.addPropertyResult("targetParameters","TargetParameters",properties.TargetParameters!=null?CfnPipePipeTargetParametersPropertyFromCloudFormation(properties.TargetParameters):void 0),ret.addUnrecognizedPropertiesAsExtra(properties),ret}
|