add KmsMasterKeyId col to sns resource

client/mocks/builders_test.go

@@ -636,6 +636,7 @@ func buildSnsTopics(t *testing.T, ctrl *gomock.Controller) client.Services {
 				"FifoTopic":                 "false",
 				"ContentBasedDeduplication": "true",
 				"DisplayName":               "cloudquery",
+				"KmsMasterKeyId":            "test/key",
 				"Owner":                     "owner",
 				"Policy":                    `{"stuff": 3}`,
 				"DeliveryPolicy":            `{"stuff": 3}`,

docs/tables/aws_sns_topics.md

@@ -16,4 +16,5 @@ AWS SNS topic
 |effective_delivery_policy|jsonb|The JSON serialization of the effective delivery policy, taking system defaults into account.|
 |fifo_topic|boolean|When this is set to true, a FIFO topic is created.|
 |content_based_deduplication|boolean|Enables content-based deduplication for FIFO topics.|
+|kms_master_key_id|text|The ID of an AWS managed customer master key (CMK) for Amazon SNS or a custom CMK|
 |arn|text|The topic's ARN.|

resources/migrations/7_v0.6.5.down.sql → resources/migrations/7_v0.7.0.down.sql

@@ -15,3 +15,5 @@ ALTER TABLE IF EXISTS "aws_directconnect_gateway_associations" RENAME COLUMN "ga
 ALTER TABLE IF EXISTS "aws_directconnect_gateway_attachments" DROP COLUMN "gateway_id";
 
 ALTER TABLE IF EXISTS "aws_elbv2_listeners" DROP COLUMN "load_balancer_cq_id";
+
+ALTER TABLE IF EXISTS "aws_sns_topics" DROP COLUMN kms_master_key_id;

resources/migrations/7_v0.6.5.up.sql → resources/migrations/7_v0.7.0.up.sql

@@ -1,6 +1,5 @@
 ALTER TABLE IF EXISTS "aws_iam_password_policies" ADD COLUMN policy_exists boolean;
 
-
 ALTER TABLE IF EXISTS "aws_directconnect_gateways" RENAME COLUMN "direct_connect_gateway_state" TO "state";
 
 ALTER TABLE IF EXISTS "aws_directconnect_gateways" RENAME COLUMN "direct_connect_gateway_name" TO "name";
@@ -13,5 +12,6 @@ ALTER TABLE IF EXISTS "aws_directconnect_gateway_associations" RENAME COLUMN "di
 
 ALTER TABLE IF EXISTS "aws_directconnect_gateway_attachments" ADD COLUMN "gateway_id" text;
 
-
 ALTER TABLE IF EXISTS "aws_elbv2_listeners" ADD COLUMN "load_balancer_cq_id" uuid;
+
+ALTER TABLE IF EXISTS "aws_sns_topics" ADD COLUMN kms_master_key_id text;

resources/sns_topics.go

@@ -85,6 +85,11 @@ func SnsTopics() *schema.Table {
 				Description: "Enables content-based deduplication for FIFO topics.",
 				Type:        schema.TypeBool,
 			},
+			{
+				Name:        "kms_master_key_id",
+				Description: "The ID of an AWS managed customer master key (CMK) for Amazon SNS or a custom CMK",
+				Type:        schema.TypeString,
+			},
 			{
 				Name:        "arn",
 				Description: "The topic's ARN.",
@@ -172,6 +177,11 @@ func resolveTopicAttributes(ctx context.Context, meta schema.ClientMeta, resourc
 			return err
 		}
 	}
+	if p, ok := output.Attributes["KmsMasterKeyId"]; ok && p != "" {
+		if err := resource.Set("kms_master_key_id", p); err != nil {
+			return err
+		}
+	}
 
 	return nil
 }