enum_KafkaClusterClientAuthenticationType := [ "NONE", "IAM" ]
enum_KafkaClusterEncryptionInTransitType := [ "PLAINTEXT", "TLS" ]

valid {
    input.Body.capacity.autoScaling.maxWorkerCount == INTEGER
    input.Body.capacity.autoScaling.mcuCount == INTEGER
    input.Body.capacity.autoScaling.minWorkerCount == INTEGER
    input.Body.capacity.autoScaling.scaleInPolicy.cpuUtilizationPercentage == INTEGER
    input.Body.capacity.autoScaling.scaleOutPolicy.cpuUtilizationPercentage == INTEGER
    input.Body.capacity.provisionedCapacity.mcuCount == INTEGER
    input.Body.capacity.provisionedCapacity.workerCount == INTEGER
    input.Body.connectorConfiguration.STRING == STRING
    input.Body.connectorDescription == STRING
    input.Body.connectorName == STRING
    input.Body.kafkaCluster.apacheKafkaCluster.bootstrapServers == STRING
    input.Body.kafkaCluster.apacheKafkaCluster.vpc.securityGroups[_] == STRING
    input.Body.kafkaCluster.apacheKafkaCluster.vpc.subnets[_] == STRING
    input.Body.kafkaClusterClientAuthentication.authenticationType == enum_KafkaClusterClientAuthenticationType[_]
    input.Body.kafkaClusterEncryptionInTransit.encryptionType == enum_KafkaClusterEncryptionInTransitType[_]
    input.Body.kafkaConnectVersion == STRING
    input.Body.logDelivery.workerLogDelivery.cloudWatchLogs.enabled == BOOLEAN
    input.Body.logDelivery.workerLogDelivery.cloudWatchLogs.logGroup == STRING
    input.Body.logDelivery.workerLogDelivery.firehose.deliveryStream == STRING
    input.Body.logDelivery.workerLogDelivery.firehose.enabled == BOOLEAN
    input.Body.logDelivery.workerLogDelivery.s3.bucket == STRING
    input.Body.logDelivery.workerLogDelivery.s3.enabled == BOOLEAN
    input.Body.logDelivery.workerLogDelivery.s3.prefix == STRING
    input.Body.plugins[_].customPlugin.customPluginArn == STRING
    input.Body.plugins[_].customPlugin.revision == LONG
    input.Body.serviceExecutionRoleArn == STRING
    input.Body.workerConfiguration.revision == LONG
    input.Body.workerConfiguration.workerConfigurationArn == STRING
    input.Body.tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

enum_CustomPluginContentType := [ "JAR", "ZIP" ]

valid {
    input.Body.contentType == enum_CustomPluginContentType[_]
    input.Body.description == STRING
    input.Body.location.s3Location.bucketArn == STRING
    input.Body.location.s3Location.fileKey == STRING
    input.Body.location.s3Location.objectVersion == STRING
    input.Body.name == STRING
    input.Body.tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.description == STRING
    input.Body.name == STRING
    input.Body.propertiesFileContent == STRING
    input.Body.tags.STRING == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.connectorArn == STRING
    input.Qs.currentVersion == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.customPluginArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.workerConfigurationArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.connectorArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.connectorOperationArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.customPluginArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.workerConfigurationArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.connectorArn == STRING
    input.Qs.maxResults == INTEGER
    input.Qs.nextToken == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Qs.connectorNamePrefix == STRING
    input.Qs.maxResults == INTEGER
    input.Qs.nextToken == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Qs.maxResults == INTEGER
    input.Qs.nextToken == STRING
    input.Qs.namePrefix == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.resourceArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Qs.maxResults == INTEGER
    input.Qs.nextToken == STRING
    input.Qs.namePrefix == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.tags.STRING == STRING
    input.ReqMap.resourceArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.ReqMap.resourceArn == STRING
    input.Qs.tagKeys[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

valid {
    input.Body.capacity.autoScaling.maxWorkerCount == INTEGER
    input.Body.capacity.autoScaling.mcuCount == INTEGER
    input.Body.capacity.autoScaling.minWorkerCount == INTEGER
    input.Body.capacity.autoScaling.scaleInPolicy.cpuUtilizationPercentage == INTEGER
    input.Body.capacity.autoScaling.scaleOutPolicy.cpuUtilizationPercentage == INTEGER
    input.Body.capacity.provisionedCapacity.mcuCount == INTEGER
    input.Body.capacity.provisionedCapacity.workerCount == INTEGER
    input.Body.connectorConfiguration.STRING == STRING
    input.ReqMap.connectorArn == STRING
    input.Qs.currentVersion == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}