40 lines
1.3 KiB
Go
40 lines
1.3 KiB
Go
package aws
|
|
|
|
import (
|
|
"github.com/cloudskiff/driftctl/pkg/helpers"
|
|
"github.com/cloudskiff/driftctl/pkg/resource"
|
|
)
|
|
|
|
const AwsSnsTopicSubscriptionResourceType = "aws_sns_topic_subscription"
|
|
|
|
func initSnsTopicSubscriptionMetaData(resourceSchemaRepository resource.SchemaRepositoryInterface) {
|
|
resourceSchemaRepository.UpdateSchema(AwsSnsTopicSubscriptionResourceType, map[string]func(attributeSchema *resource.AttributeSchema){
|
|
"delivery_policy": func(attributeSchema *resource.AttributeSchema) {
|
|
attributeSchema.JsonString = true
|
|
},
|
|
"filter_policy": func(attributeSchema *resource.AttributeSchema) {
|
|
attributeSchema.JsonString = true
|
|
},
|
|
})
|
|
|
|
resourceSchemaRepository.SetNormalizeFunc(AwsSnsTopicSubscriptionResourceType, func(res *resource.AbstractResource) {
|
|
val := res.Attrs
|
|
jsonString, err := helpers.NormalizeJsonString((*val)["delivery_policy"])
|
|
if err == nil {
|
|
_ = val.SafeSet([]string{"delivery_policy"}, jsonString)
|
|
}
|
|
|
|
jsonString, err = helpers.NormalizeJsonString((*val)["filter_policy"])
|
|
if err == nil {
|
|
_ = val.SafeSet([]string{"filter_policy"}, jsonString)
|
|
}
|
|
|
|
val.DeleteIfDefault("endpoint_auto_confirms")
|
|
|
|
v, exists := val.Get("confirmation_timeout_in_minutes")
|
|
if exists && v.(float64) == 1 {
|
|
val.SafeDelete([]string{"confirmation_timeout_in_minutes"})
|
|
}
|
|
})
|
|
}
|